summaryrefslogtreecommitdiffstats
path: root/messagebus
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2017-09-15 16:17:03 +0200
committerHenning Baldersheim <balder@yahoo-inc.com>2017-09-15 16:17:03 +0200
commit95fb3d2771728609787cd2733613d019a5e45c5b (patch)
tree0602415f46c19cb7a2ce186af8b9f5c29d5a2915 /messagebus
parent77e08073393ee63d19d1866a9acd54a8b9b2a9ec (diff)
body has moved to last 3 parameters.
Diffstat (limited to 'messagebus')
-rw-r--r--messagebus/src/vespa/messagebus/network/rpcsendv2.cpp16
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;