diff options
author | Geir Storli <geirst@verizonmedia.com> | 2021-09-20 14:18:27 +0000 |
---|---|---|
committer | Geir Storli <geirst@verizonmedia.com> | 2021-09-20 14:57:02 +0000 |
commit | a89b2ce68a2ef3ba421517f8e96f9bbb24840958 (patch) | |
tree | 82ac0df4e7ab5c6839e24436ac04c5b903ebfc62 /storage/src/tests/distributor/top_level_bucket_db_updater_test.cpp | |
parent | a26d83aab1acbe84ce31a7f886374e33202ec0d0 (diff) |
Use BucketSpaceStateMap to track cluster state and distribution in the top-level distributor.
This replaces the previous hack (needed in legacy mode) that used
DistributorBucketSpaceRepo to achieve the same.
Diffstat (limited to 'storage/src/tests/distributor/top_level_bucket_db_updater_test.cpp')
-rw-r--r-- | storage/src/tests/distributor/top_level_bucket_db_updater_test.cpp | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/storage/src/tests/distributor/top_level_bucket_db_updater_test.cpp b/storage/src/tests/distributor/top_level_bucket_db_updater_test.cpp index d57ce228908..fe8a607c9ae 100644 --- a/storage/src/tests/distributor/top_level_bucket_db_updater_test.cpp +++ b/storage/src/tests/distributor/top_level_bucket_db_updater_test.cpp @@ -364,7 +364,7 @@ public: OutdatedNodesMap outdated_nodes_map; state = PendingClusterState::createForClusterStateChange( clock, cluster_info, sender, - owner.top_level_bucket_space_repo(), + owner.bucket_space_states(), cmd, outdated_nodes_map, api::Timestamp(1)); } @@ -374,7 +374,7 @@ public: { auto cluster_info = owner.create_cluster_info(old_cluster_state); state = PendingClusterState::createForDistributionChange( - clock, cluster_info, sender, owner.top_level_bucket_space_repo(), api::Timestamp(1)); + clock, cluster_info, sender, owner.bucket_space_states(), api::Timestamp(1)); } }; @@ -1389,7 +1389,7 @@ TopLevelBucketDBUpdaterTest::get_sent_nodes_distribution_changed(const std::stri auto cluster_info = create_cluster_info(old_cluster_state); std::unique_ptr<PendingClusterState> state( PendingClusterState::createForDistributionChange( - clock, cluster_info, sender, top_level_bucket_space_repo(), api::Timestamp(1))); + clock, cluster_info, sender, bucket_space_states(), api::Timestamp(1))); sort_sent_messages_by_index(sender); @@ -1514,7 +1514,7 @@ TEST_F(TopLevelBucketDBUpdaterTest, pending_cluster_state_receive) { OutdatedNodesMap outdated_nodes_map; std::unique_ptr<PendingClusterState> state( PendingClusterState::createForClusterStateChange( - clock, cluster_info, sender, top_level_bucket_space_repo(), + clock, cluster_info, sender, bucket_space_states(), cmd, outdated_nodes_map, api::Timestamp(1))); ASSERT_EQ(message_count(3), sender.commands().size()); @@ -1670,7 +1670,7 @@ TopLevelBucketDBUpdaterTest::merge_bucket_lists( auto cluster_info = create_cluster_info("cluster:d"); auto state = PendingClusterState::createForClusterStateChange( - clock, cluster_info, sender, top_level_bucket_space_repo(), + clock, cluster_info, sender, bucket_space_states(), cmd, outdated_nodes_map, before_time); parse_input_data(existing_data, before_time, *state, include_bucket_info); @@ -1690,7 +1690,7 @@ TopLevelBucketDBUpdaterTest::merge_bucket_lists( auto cluster_info = create_cluster_info(old_state.toString()); auto state = PendingClusterState::createForClusterStateChange( - clock, cluster_info, sender, top_level_bucket_space_repo(), + clock, cluster_info, sender, bucket_space_states(), cmd, outdated_nodes_map, after_time); parse_input_data(new_data, after_time, *state, include_bucket_info); |