diff options
author | Arne H Juul <arnej@yahooinc.com> | 2022-06-07 12:39:52 +0000 |
---|---|---|
committer | gjoranv <gv@verizonmedia.com> | 2022-06-08 11:45:31 +0200 |
commit | 8822bf13ddb2ad2c226a8d812efbe08c54d092a2 (patch) | |
tree | 225e34caf3a6a9c8ee223967003190a0289c0185 /storage | |
parent | 86deaa8e3085dd377755684c943c5c88cb7009e2 (diff) |
cleanup unused second pass stats
Diffstat (limited to 'storage')
-rw-r--r-- | storage/src/vespa/storageapi/mbusprot/protocolserialization5_0.cpp | 10 | ||||
-rw-r--r-- | storage/src/vespa/storageapi/mbusprot/protocolserialization7.cpp | 4 |
2 files changed, 4 insertions, 10 deletions
diff --git a/storage/src/vespa/storageapi/mbusprot/protocolserialization5_0.cpp b/storage/src/vespa/storageapi/mbusprot/protocolserialization5_0.cpp index fa400b565b2..e49eb8842ff 100644 --- a/storage/src/vespa/storageapi/mbusprot/protocolserialization5_0.cpp +++ b/storage/src/vespa/storageapi/mbusprot/protocolserialization5_0.cpp @@ -538,9 +538,8 @@ ProtocolSerialization5_0::onEncode(GBBuf& buf, const api::CreateVisitorReply& ms buf.putLong(msg.getVisitorStatistics().getBytesVisited()); buf.putLong(msg.getVisitorStatistics().getDocumentsReturned()); buf.putLong(msg.getVisitorStatistics().getBytesReturned()); - // TODO remove second pass concept on Vespa 8 - buf.putLong(msg.getVisitorStatistics().getSecondPassDocumentsReturned()); - buf.putLong(msg.getVisitorStatistics().getSecondPassBytesReturned()); + buf.putLong(0); + buf.putLong(0); } api::StorageReply::UP @@ -555,9 +554,8 @@ ProtocolSerialization5_0::onDecodeCreateVisitorReply(const SCmd& cmd, BBuf& buf) vs.setBytesVisited(SH::getLong(buf)); vs.setDocumentsReturned(SH::getLong(buf)); vs.setBytesReturned(SH::getLong(buf)); - // TODO remove second pass concept on Vespa 8 - vs.setSecondPassDocumentsReturned(SH::getLong(buf)); - vs.setSecondPassBytesReturned(SH::getLong(buf)); + SH::getLong(buf); + SH::getLong(buf); msg->setVisitorStatistics(vs); return msg; diff --git a/storage/src/vespa/storageapi/mbusprot/protocolserialization7.cpp b/storage/src/vespa/storageapi/mbusprot/protocolserialization7.cpp index 91b5999e34c..dee766b4b2d 100644 --- a/storage/src/vespa/storageapi/mbusprot/protocolserialization7.cpp +++ b/storage/src/vespa/storageapi/mbusprot/protocolserialization7.cpp @@ -1240,8 +1240,6 @@ void ProtocolSerialization7::onEncode(GBBuf& buf, const api::CreateVisitorReply& proto_stats->set_bytes_visited(stats.getBytesVisited()); proto_stats->set_documents_returned(stats.getDocumentsReturned()); proto_stats->set_bytes_returned(stats.getBytesReturned()); - proto_stats->set_second_pass_documents_returned(stats.getSecondPassDocumentsReturned()); // TODO remove on Vespa 8 - proto_stats->set_second_pass_bytes_returned(stats.getSecondPassBytesReturned()); // TODO remove on Vespa 8 }); } @@ -1287,8 +1285,6 @@ api::StorageReply::UP ProtocolSerialization7::onDecodeCreateVisitorReply(const S vs.setBytesVisited(proto_stats.bytes_visited()); vs.setDocumentsReturned(proto_stats.documents_returned()); vs.setBytesReturned(proto_stats.bytes_returned()); - vs.setSecondPassDocumentsReturned(proto_stats.second_pass_documents_returned()); // TODO remove on Vespa 8 - vs.setSecondPassBytesReturned(proto_stats.second_pass_bytes_returned()); // TODO remove on Vespa 8 reply->setVisitorStatistics(vs); return reply; }); |