diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2017-09-15 16:17:03 +0200 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2017-09-15 16:17:03 +0200 |
commit | 95fb3d2771728609787cd2733613d019a5e45c5b (patch) | |
tree | 0602415f46c19cb7a2ce186af8b9f5c29d5a2915 /messagebus | |
parent | 77e08073393ee63d19d1866a9acd54a8b9b2a9ec (diff) |
body has moved to last 3 parameters.
Diffstat (limited to 'messagebus')
-rw-r--r-- | messagebus/src/vespa/messagebus/network/rpcsendv2.cpp | 16 |
1 files changed, 8 insertions, 8 deletions
diff --git a/messagebus/src/vespa/messagebus/network/rpcsendv2.cpp b/messagebus/src/vespa/messagebus/network/rpcsendv2.cpp index b1e94a5a811..1228e08f3b4 100644 --- a/messagebus/src/vespa/messagebus/network/rpcsendv2.cpp +++ b/messagebus/src/vespa/messagebus/network/rpcsendv2.cpp @@ -142,10 +142,10 @@ public: ParamsV2(const FRT_Values &arg) : _slime() { - uint8_t encoding = arg[0]._intval8; - uint32_t uncompressedSize = arg[1]._intval32; - DataBuffer uncompressed(arg[2]._data._buf, arg[2]._data._len); - ConstBufferRef blob(arg[2]._data._buf, arg[2]._data._len); + uint8_t encoding = arg[3]._intval8; + uint32_t uncompressedSize = arg[4]._intval32; + DataBuffer uncompressed(arg[5]._data._buf, arg[5]._data._len); + ConstBufferRef blob(arg[5]._data._buf, arg[5]._data._len); decompress(CompressionConfig::toType(encoding), uncompressedSize, blob, uncompressed, true); assert(uncompressedSize == uncompressed.getDataLen()); BinaryFormat::decode(Memory(uncompressed.getData(), uncompressed.getDataLen()), _slime); @@ -188,10 +188,10 @@ std::unique_ptr<Reply> RPCSendV2::createReply(const FRT_Values & ret, const string & serviceName, Error & error, vespalib::TraceNode & rootTrace) const { - uint8_t encoding = ret[0]._intval8; - uint32_t uncompressedSize = ret[1]._intval32; - DataBuffer uncompressed(ret[2]._data._buf, ret[2]._data._len); - ConstBufferRef blob(ret[2]._data._buf, ret[2]._data._len); + uint8_t encoding = ret[3]._intval8; + uint32_t uncompressedSize = ret[4]._intval32; + DataBuffer uncompressed(ret[5]._data._buf, ret[5]._data._len); + ConstBufferRef blob(ret[5]._data._buf, ret[5]._data._len); decompress(CompressionConfig::toType(encoding), uncompressedSize, blob, uncompressed, true); assert(uncompressedSize == uncompressed.getDataLen()); Slime slime; |