summaryrefslogtreecommitdiffstats
path: root/searchlib
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2021-06-26 20:51:09 +0000
committerHenning Baldersheim <balder@yahoo-inc.com>2021-06-26 21:02:56 +0000
commit2b4569480234c579e7b278414ab1ef06729209c6 (patch)
treeff92f2fc0e6d5b40b3cce9aad4c8cd61a5494104 /searchlib
parent281d6ed48cf5412bbe02d25ad252bfcd6c94ebe4 (diff)
GC unused 'partitionid' and various other members of MonitorReply that are long gone.
Diffstat (limited to 'searchlib')
-rw-r--r--searchlib/src/tests/engine/proto_converter/proto_converter_test.cpp13
-rw-r--r--searchlib/src/tests/engine/proto_rpc_adapter/proto_rpc_adapter_test.cpp2
-rw-r--r--searchlib/src/vespa/searchlib/engine/monitorapi.h4
-rw-r--r--searchlib/src/vespa/searchlib/engine/monitorreply.cpp10
-rw-r--r--searchlib/src/vespa/searchlib/engine/monitorreply.h14
-rw-r--r--searchlib/src/vespa/searchlib/engine/monitorrequest.cpp5
-rw-r--r--searchlib/src/vespa/searchlib/engine/monitorrequest.h8
-rw-r--r--searchlib/src/vespa/searchlib/engine/proto_converter.cpp4
-rw-r--r--searchlib/src/vespa/searchlib/engine/proto_rpc_adapter.cpp2
9 files changed, 9 insertions, 53 deletions
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<MonitorReply> ping(std::unique_ptr<MonitorRequest> req, MonitorClient &) override {
(void) req;
assert(req);
auto reply = std::make_unique<MonitorReply>();
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<MonitorReply> 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<MonitorReply> ping(std::unique_ptr<MonitorRequest> 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 <memory>
+#include <cstdint>
namespace search::engine {
struct MonitorReply
{
- typedef std::unique_ptr<MonitorReply> 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 <memory>
-
namespace search::engine {
struct MonitorRequest
{
- typedef std::shared_ptr<MonitorRequest> SP;
- typedef std::unique_ptr<MonitorRequest> 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<MonitorReply> reply) override {
ProtoMonitorReply msg;
ProtoConverter::monitor_reply_to_proto(*reply, msg);
encode_message(msg, *req.GetReturn());