From 2b4569480234c579e7b278414ab1ef06729209c6 Mon Sep 17 00:00:00 2001 From: Henning Baldersheim Date: Sat, 26 Jun 2021 20:51:09 +0000 Subject: GC unused 'partitionid' and various other members of MonitorReply that are long gone. --- .../tests/engine/proto_converter/proto_converter_test.cpp | 13 ------------- .../engine/proto_rpc_adapter/proto_rpc_adapter_test.cpp | 2 +- searchlib/src/vespa/searchlib/engine/monitorapi.h | 4 ++-- searchlib/src/vespa/searchlib/engine/monitorreply.cpp | 10 +--------- searchlib/src/vespa/searchlib/engine/monitorreply.h | 14 ++------------ searchlib/src/vespa/searchlib/engine/monitorrequest.cpp | 5 +---- searchlib/src/vespa/searchlib/engine/monitorrequest.h | 8 -------- searchlib/src/vespa/searchlib/engine/proto_converter.cpp | 4 +--- searchlib/src/vespa/searchlib/engine/proto_rpc_adapter.cpp | 2 +- 9 files changed, 9 insertions(+), 53 deletions(-) (limited to 'searchlib') diff --git a/searchlib/src/tests/engine/proto_converter/proto_converter_test.cpp b/searchlib/src/tests/engine/proto_converter/proto_converter_test.cpp index 16e4f93b6fb..9cf8c73765c 100644 --- a/searchlib/src/tests/engine/proto_converter/proto_converter_test.cpp +++ b/searchlib/src/tests/engine/proto_converter/proto_converter_test.cpp @@ -492,19 +492,6 @@ TEST_F(DocsumReplyTest, require_that_missing_root_slime_gives_empty_payload) { //----------------------------------------------------------------------------- -struct MonitorRequestTest : ::testing::Test { - Converter::ProtoMonitorRequest proto; - MonitorRequest request; - void convert() { Converter::monitor_request_from_proto(proto, request); } -}; - -TEST_F(MonitorRequestTest, require_that_active_docs_are_always_requested) { - convert(); - EXPECT_TRUE(request.reportActiveDocs); -} - -//----------------------------------------------------------------------------- - struct MonitorReplyTest : ::testing::Test { MonitorReply reply; Converter::ProtoMonitorReply proto; diff --git a/searchlib/src/tests/engine/proto_rpc_adapter/proto_rpc_adapter_test.cpp b/searchlib/src/tests/engine/proto_rpc_adapter/proto_rpc_adapter_test.cpp index 1cd91329912..304e33900a6 100644 --- a/searchlib/src/tests/engine/proto_rpc_adapter/proto_rpc_adapter_test.cpp +++ b/searchlib/src/tests/engine/proto_rpc_adapter/proto_rpc_adapter_test.cpp @@ -62,7 +62,7 @@ struct MyDocsumServer : DocsumServer { }; struct MyMonitorServer : MonitorServer { - MonitorReply::UP ping(MonitorRequest::UP req, MonitorClient &) override { + std::unique_ptr ping(std::unique_ptr req, MonitorClient &) override { (void) req; assert(req); auto reply = std::make_unique(); diff --git a/searchlib/src/vespa/searchlib/engine/monitorapi.h b/searchlib/src/vespa/searchlib/engine/monitorapi.h index ece52da74da..2f467f12e5c 100644 --- a/searchlib/src/vespa/searchlib/engine/monitorapi.h +++ b/searchlib/src/vespa/searchlib/engine/monitorapi.h @@ -20,7 +20,7 @@ public: * * @param reply the monitor reply **/ - virtual void pingDone(MonitorReply::UP reply) = 0; + virtual void pingDone(std::unique_ptr reply) = 0; /** * Empty, needed for subclassing @@ -52,7 +52,7 @@ public: * @param request object containing request parameters * @param client the client to be notified of async completion **/ - virtual MonitorReply::UP ping(MonitorRequest::UP request, MonitorClient &client) = 0; + virtual std::unique_ptr ping(std::unique_ptr request, MonitorClient &client) = 0; /** * Empty, needed for subclassing diff --git a/searchlib/src/vespa/searchlib/engine/monitorreply.cpp b/searchlib/src/vespa/searchlib/engine/monitorreply.cpp index 3414603a893..5d9c381515d 100644 --- a/searchlib/src/vespa/searchlib/engine/monitorreply.cpp +++ b/searchlib/src/vespa/searchlib/engine/monitorreply.cpp @@ -5,17 +5,9 @@ namespace search::engine { MonitorReply::MonitorReply() - : mld(), - activeDocsRequested(false), - partid(), + : activeDocs(0), distribution_key(-1), timestamp(), - totalNodes(), - activeNodes(), - totalParts(), - activeParts(), - activeDocs(0), - flags(), is_blocking_writes(false) { } diff --git a/searchlib/src/vespa/searchlib/engine/monitorreply.h b/searchlib/src/vespa/searchlib/engine/monitorreply.h index f66a30fdd89..0010735ef43 100644 --- a/searchlib/src/vespa/searchlib/engine/monitorreply.h +++ b/searchlib/src/vespa/searchlib/engine/monitorreply.h @@ -2,25 +2,15 @@ #pragma once -#include +#include namespace search::engine { struct MonitorReply { - typedef std::unique_ptr UP; - - bool mld; - bool activeDocsRequested; - uint32_t partid; + uint64_t activeDocs; int32_t distribution_key; uint32_t timestamp; - uint32_t totalNodes; // mld - uint32_t activeNodes; // mld - uint32_t totalParts; // mld - uint32_t activeParts; // mld - uint64_t activeDocs; - uint32_t flags; bool is_blocking_writes; MonitorReply(); diff --git a/searchlib/src/vespa/searchlib/engine/monitorrequest.cpp b/searchlib/src/vespa/searchlib/engine/monitorrequest.cpp index 1e5c2868cef..efc4faaa402 100644 --- a/searchlib/src/vespa/searchlib/engine/monitorrequest.cpp +++ b/searchlib/src/vespa/searchlib/engine/monitorrequest.cpp @@ -4,10 +4,7 @@ namespace search::engine { -MonitorRequest::MonitorRequest() - : reportActiveDocs(false), flags(0) -{ -} +MonitorRequest::MonitorRequest() = default; } diff --git a/searchlib/src/vespa/searchlib/engine/monitorrequest.h b/searchlib/src/vespa/searchlib/engine/monitorrequest.h index ac07e42a68a..d99221e24ae 100644 --- a/searchlib/src/vespa/searchlib/engine/monitorrequest.h +++ b/searchlib/src/vespa/searchlib/engine/monitorrequest.h @@ -2,18 +2,10 @@ #pragma once -#include - namespace search::engine { struct MonitorRequest { - typedef std::shared_ptr SP; - typedef std::unique_ptr UP; - - bool reportActiveDocs; - uint32_t flags; - MonitorRequest(); }; diff --git a/searchlib/src/vespa/searchlib/engine/proto_converter.cpp b/searchlib/src/vespa/searchlib/engine/proto_converter.cpp index 53756bfcac6..9ad058c20ad 100644 --- a/searchlib/src/vespa/searchlib/engine/proto_converter.cpp +++ b/searchlib/src/vespa/searchlib/engine/proto_converter.cpp @@ -171,10 +171,8 @@ ProtoConverter::docsum_reply_to_proto(const DocsumReply &reply, ProtoDocsumReply //----------------------------------------------------------------------------- void -ProtoConverter::monitor_request_from_proto(const ProtoMonitorRequest &proto, MonitorRequest &request) +ProtoConverter::monitor_request_from_proto(const ProtoMonitorRequest &, MonitorRequest &) { - (void) proto; - request.reportActiveDocs = true; } void diff --git a/searchlib/src/vespa/searchlib/engine/proto_rpc_adapter.cpp b/searchlib/src/vespa/searchlib/engine/proto_rpc_adapter.cpp index 4634c192a51..b1bc8ec37b4 100644 --- a/searchlib/src/vespa/searchlib/engine/proto_rpc_adapter.cpp +++ b/searchlib/src/vespa/searchlib/engine/proto_rpc_adapter.cpp @@ -174,7 +174,7 @@ struct GetDocsumsCompletionHandler : DocsumClient { struct PingCompletionHandler : MonitorClient { FRT_RPCRequest &req; PingCompletionHandler(FRT_RPCRequest &req_in) : req(req_in) {} - void pingDone(MonitorReply::UP reply) override { + void pingDone(std::unique_ptr reply) override { ProtoMonitorReply msg; ProtoConverter::monitor_reply_to_proto(*reply, msg); encode_message(msg, *req.GetReturn()); -- cgit v1.2.3