mirrors/scylladb
1
0
Fork 0
mirror of https://github.com/scylladb/scylladb.git synced 2026-05-12 19:02:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

gms: gossiper: use named gate

Browse Source 
Signed-off-by: Benny Halevy <bhalevy@scylladb.com>
This commit is contained in:
Benny Halevy
2025-03-16 18:19:21 +02:00
parent bc69bc3de7
commit cecfb6dfd7
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
gms/gossiper.cc
View File

@@ -2063,7 +2063,7 @@ future<> gossiper::start_gossiping(gms::generation_type generation_nbr, applicat
if (!_background_msg.is_closed()) {
co_await _background_msg.close();
}
_background_msg = seastar::gate();
_background_msg = seastar::named_gate("gossiper");
/* Ensure all shards have enabled gossip before starting the failure detector loop */
co_await container().invoke_on_all([] (gms::gossiper& g) {
g._enabled = true;

2
gms/gossiper.hh
View File

@@ -116,7 +116,7 @@ private:
bool _enabled = false;
semaphore _callback_running{1};
semaphore _apply_state_locally_semaphore{100};
seastar::gate _background_msg;
seastar::named_gate _background_msg;
std::unordered_map<locator::host_id, syn_msg_pending> _syn_handlers;
std::unordered_map<locator::host_id, ack_msg_pending> _ack_handlers;
// Map ip address and generation number