diff options
author | Geir Storli <geirst@verizonmedia.com> | 2020-04-14 14:10:03 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2020-04-14 14:10:03 +0200 |
commit | 188d45faa1dd8c44762bc45ff000a1a1df82e455 (patch) | |
tree | 950c9fc513d113f2d133a1757d110640641802cf /searchlib | |
parent | 1291885d369234bc8b14d702fdc89c410f05c49f (diff) | |
parent | 42b0ff922cbed35e2c7f588d473e8cb3bb680a88 (diff) |
Merge pull request #12899 from vespa-engine/geirst/populate-is-blocking-writes-in-ping-reply
Propagate is_blocking_writes flag in monitor ping reply from proton.
Diffstat (limited to 'searchlib')
4 files changed, 14 insertions, 1 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 3e129457d46..16e4f93b6fb 100644 --- a/searchlib/src/tests/engine/proto_converter/proto_converter_test.cpp +++ b/searchlib/src/tests/engine/proto_converter/proto_converter_test.cpp @@ -535,6 +535,16 @@ TEST_F(MonitorReplyTest, require_that_distribution_key_is_converted) { EXPECT_EQ(proto.distribution_key(), 7); } +TEST_F(MonitorReplyTest, require_that_is_blocking_writes_is_converted) { + reply.is_blocking_writes = false; + convert(); + EXPECT_FALSE(proto.is_blocking_writes()); + + reply.is_blocking_writes = true; + convert(); + EXPECT_TRUE(proto.is_blocking_writes()); +} + //----------------------------------------------------------------------------- GTEST_MAIN_RUN_ALL_TESTS() diff --git a/searchlib/src/vespa/searchlib/engine/monitorreply.cpp b/searchlib/src/vespa/searchlib/engine/monitorreply.cpp index c0f7fa0d42a..3414603a893 100644 --- a/searchlib/src/vespa/searchlib/engine/monitorreply.cpp +++ b/searchlib/src/vespa/searchlib/engine/monitorreply.cpp @@ -15,7 +15,8 @@ MonitorReply::MonitorReply() totalParts(), activeParts(), activeDocs(0), - flags() + flags(), + is_blocking_writes(false) { } } diff --git a/searchlib/src/vespa/searchlib/engine/monitorreply.h b/searchlib/src/vespa/searchlib/engine/monitorreply.h index 7d1f0ce1cef..f66a30fdd89 100644 --- a/searchlib/src/vespa/searchlib/engine/monitorreply.h +++ b/searchlib/src/vespa/searchlib/engine/monitorreply.h @@ -21,6 +21,7 @@ struct MonitorReply uint32_t activeParts; // mld uint64_t activeDocs; uint32_t flags; + bool is_blocking_writes; MonitorReply(); }; diff --git a/searchlib/src/vespa/searchlib/engine/proto_converter.cpp b/searchlib/src/vespa/searchlib/engine/proto_converter.cpp index e5846734a8d..2876fa99434 100644 --- a/searchlib/src/vespa/searchlib/engine/proto_converter.cpp +++ b/searchlib/src/vespa/searchlib/engine/proto_converter.cpp @@ -170,6 +170,7 @@ ProtoConverter::monitor_reply_to_proto(const MonitorReply &reply, ProtoMonitorRe proto.set_online(reply.timestamp != 0); proto.set_active_docs(reply.activeDocs); proto.set_distribution_key(reply.distribution_key); + proto.set_is_blocking_writes(reply.is_blocking_writes); } //----------------------------------------------------------------------------- |