summaryrefslogtreecommitdiffstats
path: root/storage/src/tests/bucketdb/bucketmanagertest.cpp
diff options
context:
space:
mode:
authorTor Brede Vekterli <vekterli@yahooinc.com>2022-09-22 12:13:09 +0000
committerTor Brede Vekterli <vekterli@yahooinc.com>2022-09-22 12:18:51 +0000
commit0c5994afd6a0f983461de278838d8ff329e33a93 (patch)
tree3d5b41f058a4ef6f6386f1d39c8313bbab46a5e0 /storage/src/tests/bucketdb/bucketmanagertest.cpp
parent1fe8e71e45ee65013c88fd55453eed2e8c9bf2f8 (diff)
Simplify state version checks by requiring exact version match
The existing state unification logic was likely to help ensure that various distributor availability-states were treated as if they were simply Up, but the distributor has not been able to even _be_ in other available states than Up for many years. So it's effectively pointless. Remove unification entirely and instead require both the distributor and content node to be mutually in sync with the exact cluster state version.
Diffstat (limited to 'storage/src/tests/bucketdb/bucketmanagertest.cpp')
-rw-r--r--storage/src/tests/bucketdb/bucketmanagertest.cpp6
1 files changed, 5 insertions, 1 deletions
diff --git a/storage/src/tests/bucketdb/bucketmanagertest.cpp b/storage/src/tests/bucketdb/bucketmanagertest.cpp
index 6404dba7935..dc33bfd04e2 100644
--- a/storage/src/tests/bucketdb/bucketmanagertest.cpp
+++ b/storage/src/tests/bucketdb/bucketmanagertest.cpp
@@ -631,6 +631,10 @@ public:
return std::make_shared<api::RequestBucketInfoCommand>(makeBucketSpace(), 0, *_state);
}
+ auto createFullFetchCommand(const lib::ClusterState& explicit_state) const {
+ return std::make_shared<api::RequestBucketInfoCommand>(makeBucketSpace(), 0, explicit_state);
+ }
+
auto createFullFetchCommandWithHash(vespalib::stringref hash) const {
return std::make_shared<api::RequestBucketInfoCommand>(makeBucketSpace(), 0, *_state, hash);
}
@@ -1271,7 +1275,7 @@ TEST_F(BucketManagerTest, bounce_request_on_state_change_barrier_not_reached) {
_top->waitForMessage(api::MessageType::SETSYSTEMSTATE_REPLY, MESSAGE_WAIT_TIME);
(void)_top->getRepliesOnce();
- _top->sendDown(f.createFullFetchCommand());
+ _top->sendDown(f.createFullFetchCommand(new_state));
replies = f.awaitAndGetReplies(1);
{
auto& reply = dynamic_cast<api::RequestBucketInfoReply&>(*replies[0]);