summaryrefslogtreecommitdiffstats
path: root/storage
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2024-02-03 19:18:50 +0000
committerHenning Baldersheim <balder@yahoo-inc.com>2024-02-03 19:39:10 +0000
commit3b590870d88f329c9219759d46924571ce3db66d (patch)
tree392c5bc7ed64999a4e4be421a332103083731982 /storage
parent359bc341f0a85993a231c16f0e7b8c508ea55dc8 (diff)
GC unused distributor_auto_ownership_transfer_on_whole_group_down
Diffstat (limited to 'storage')
-rw-r--r--storage/src/tests/bucketdb/bucketmanagertest.cpp4
-rw-r--r--storage/src/tests/common/global_bucket_space_distribution_converter_test.cpp4
-rw-r--r--storage/src/tests/distributor/top_level_bucket_db_updater_test.cpp12
-rw-r--r--storage/src/vespa/storage/common/global_bucket_space_distribution_converter.cpp1
-rw-r--r--storage/src/vespa/storage/distributor/pending_bucket_space_db_transition.cpp3
5 files changed, 2 insertions, 22 deletions
diff --git a/storage/src/tests/bucketdb/bucketmanagertest.cpp b/storage/src/tests/bucketdb/bucketmanagertest.cpp
index 45d8fab7061..6173a43e25e 100644
--- a/storage/src/tests/bucketdb/bucketmanagertest.cpp
+++ b/storage/src/tests/bucketdb/bucketmanagertest.cpp
@@ -689,7 +689,7 @@ public:
static std::unique_ptr<lib::Distribution> default_grouped_distribution() {
return std::make_unique<lib::Distribution>(
- GlobalBucketSpaceDistributionConverter::string_to_config(vespalib::string(
+ lib::Distribution::ConfigWrapper(GlobalBucketSpaceDistributionConverter::string_to_config(vespalib::string(
R"(redundancy 2
group[3]
group[0].name "invalid"
@@ -708,7 +708,7 @@ group[2].nodes[3]
group[2].nodes[0].index 3
group[2].nodes[1].index 4
group[2].nodes[2].index 5
-)")));
+)"))));
}
static std::shared_ptr<lib::Distribution> derived_global_grouped_distribution() {
diff --git a/storage/src/tests/common/global_bucket_space_distribution_converter_test.cpp b/storage/src/tests/common/global_bucket_space_distribution_converter_test.cpp
index 61f62d86544..774f90821fa 100644
--- a/storage/src/tests/common/global_bucket_space_distribution_converter_test.cpp
+++ b/storage/src/tests/common/global_bucket_space_distribution_converter_test.cpp
@@ -37,7 +37,6 @@ initial_redundancy 0
ensure_primary_persisted true
ready_copies 3
active_per_leaf_group true
-distributor_auto_ownership_transfer_on_whole_group_down true
group[0].index "invalid"
group[0].name "invalid"
group[0].capacity 1
@@ -91,7 +90,6 @@ initial_redundancy 0
ensure_primary_persisted true
ready_copies 6
active_per_leaf_group true
-distributor_auto_ownership_transfer_on_whole_group_down true
group[0].index "invalid"
group[0].name "invalid"
group[0].capacity 1
@@ -161,7 +159,6 @@ initial_redundancy 0
ensure_primary_persisted true
ready_copies 4
active_per_leaf_group true
-distributor_auto_ownership_transfer_on_whole_group_down true
group[0].index "invalid"
group[0].name "invalid"
group[0].capacity 1
@@ -231,7 +228,6 @@ initial_redundancy 0
ensure_primary_persisted true
ready_copies 3
active_per_leaf_group true
-distributor_auto_ownership_transfer_on_whole_group_down true
group[0].index "invalid"
group[0].name "invalid"
group[0].capacity 1
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 d21ecc814a5..51c0a75e45d 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
@@ -1580,18 +1580,6 @@ TEST_F(TopLevelBucketDBUpdaterTest, pending_cluster_state_with_group_down) {
"distributor:6 .2.s:d storage:6"));
}
-TEST_F(TopLevelBucketDBUpdaterTest, pending_cluster_state_with_group_down_and_no_handover) {
- std::string config = dist_config_6_nodes_across_4_groups();
- config += "distributor_auto_ownership_transfer_on_whole_group_down false\n";
- set_distribution(config);
-
- // Group is down, but config says to not do anything about it.
- EXPECT_EQ(get_node_list({0, 1, 2, 3, 4, 5}, _bucket_spaces.size() - 1),
- get_sent_nodes("distributor:6 storage:6",
- "distributor:6 .2.s:d .3.s:d storage:6"));
-}
-
-
namespace {
void
diff --git a/storage/src/vespa/storage/common/global_bucket_space_distribution_converter.cpp b/storage/src/vespa/storage/common/global_bucket_space_distribution_converter.cpp
index f34c1f2d92a..1d632c14cd5 100644
--- a/storage/src/vespa/storage/common/global_bucket_space_distribution_converter.cpp
+++ b/storage/src/vespa/storage/common/global_bucket_space_distribution_converter.cpp
@@ -22,7 +22,6 @@ struct Group {
};
void set_distribution_invariant_config_fields(DistributionConfigBuilder& builder) {
- builder.distributorAutoOwnershipTransferOnWholeGroupDown = true;
builder.activePerLeafGroup = true;
// TODO consider how to best support n-of-m replication for global docs
builder.ensurePrimaryPersisted = true;
diff --git a/storage/src/vespa/storage/distributor/pending_bucket_space_db_transition.cpp b/storage/src/vespa/storage/distributor/pending_bucket_space_db_transition.cpp
index aac16f8b618..19d66f629c5 100644
--- a/storage/src/vespa/storage/distributor/pending_bucket_space_db_transition.cpp
+++ b/storage/src/vespa/storage/distributor/pending_bucket_space_db_transition.cpp
@@ -303,9 +303,6 @@ PendingBucketSpaceDbTransition::nodeNeedsOwnershipTransferFromGroupDown(
const lib::ClusterState& state) const
{
const auto &dist(_bucket_space_state.get_distribution());
- if (!dist.distributorAutoOwnershipTransferOnWholeGroupDown()) {
- return false; // Not doing anything for downed groups.
- }
const lib::Group* group(dist.getNodeGraph().getGroupForNode(nodeIndex));
// If there is no group information associated with the node (because the
// group has changed or the node has been removed from config), we must