aboutsummaryrefslogtreecommitdiffstats
path: root/storage
diff options
context:
space:
mode:
authorArne H Juul <arnej@yahooinc.com>2022-06-07 12:39:52 +0000
committergjoranv <gv@verizonmedia.com>2022-06-08 11:45:31 +0200
commit8822bf13ddb2ad2c226a8d812efbe08c54d092a2 (patch)
tree225e34caf3a6a9c8ee223967003190a0289c0185 /storage
parent86deaa8e3085dd377755684c943c5c88cb7009e2 (diff)
cleanup unused second pass stats
Diffstat (limited to 'storage')
-rw-r--r--storage/src/vespa/storageapi/mbusprot/protocolserialization5_0.cpp10
-rw-r--r--storage/src/vespa/storageapi/mbusprot/protocolserialization7.cpp4
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;
});