mirrors/scylladb
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

gossip: Run real_mark_alive under seastar::async context

Browse Source 
Now on_dead is now under seastar::async context.
This commit is contained in:
Asias He
2015-08-07 11:12:34 +08:00
parent d15c8289a2
commit 5f7628da12
1 changed files with 15 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
gms/gossiper.cc
View File

@@ -998,13 +998,21 @@ void gossiper::real_mark_alive(inet_address addr, endpoint_state local_state) {
void gossiper::mark_dead(inet_address addr, endpoint_state& local_state) {
logger.trace("marking as down {}", addr);
local_state.mark_dead();
_live_endpoints.erase(addr);
_unreachable_endpoints[addr] = now();
logger.info("inet_address {} is now DOWN", addr);
for (auto& subscriber : _subscribers) {
subscriber->on_dead(addr, local_state);
logger.trace("Notified {}", subscriber);
}
seastar::async([this, addr, local_state] {
_live_endpoints.erase(addr);
_unreachable_endpoints[addr] = now();
logger.info("inet_address {} is now DOWN", addr);
for (auto& subscriber : _subscribers) {
subscriber->on_dead(addr, local_state);
logger.trace("Notified {}", subscriber);
}
}).then_wrapped([addr] (auto&& f) {
try {
f.get();
} catch (...) {
logger.error("Fail to mark_dead={}: {}", addr, std::current_exception());
}
});
}
// Runs inside seastar::async context