bahman/scylla
1
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

topology coordinator: drop expiring entries in gossiper address map on error injections since raft one is no longer used

Browse Source
This commit is contained in:
Gleb Natapov
2024-11-26 11:53:48 +02:00
parent fca1f90cc7
commit cbb6148a36
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
service/storage_service.cc
View File

@@ -1272,7 +1272,7 @@ public:
" for the response from the topology coordinator");
if (utils::get_local_injector().enter("pre_server_start_drop_expiring")) {
_ss._group0->modifiable_address_map().force_drop_expiring_entries();
_ss._gossiper.get_mutable_address_map().force_drop_expiring_entries();
}
_ss._join_node_request_done.set_value();
@@ -6842,7 +6842,7 @@ future<join_node_response_result> storage_service::join_node_response_handler(jo
}
if (utils::get_local_injector().enter("join_node_response_drop_expiring")) {
_group0->modifiable_address_map().force_drop_expiring_entries();
_gossiper.get_mutable_address_map().force_drop_expiring_entries();
}
try {

2
service/topology_coordinator.cc
View File

@@ -2226,7 +2226,7 @@ class topology_coordinator : public endpoint_lifecycle_subscriber {
auto validation_result = validate_joining_node(node);
if (utils::get_local_injector().enter("handle_node_transition_drop_expiring")) {
_group0.modifiable_address_map().force_drop_expiring_entries();
_gossiper.get_mutable_address_map().force_drop_expiring_entries();
}
// When the validation succeeded, it's important that all nodes in the