mirrors/scylladb
1
0
Fork 0
mirror of https://github.com/scylladb/scylladb.git synced 2026-04-23 01:50:35 +00:00
Code Issues Packages Projects Releases Wiki Activity

gossip: Add error handling for GOSSIP_SHUTDOWN and GOSSIP_DIGEST_ACK verb

Browse Source
This commit is contained in:
Asias He
2015-08-12 15:26:31 +08:00
parent 74e2f0156a
commit 5831dcba28
1 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
gms/gossiper.cc
View File

@@ -211,7 +211,9 @@ void gossiper::init_messaging_service_handler() {
gossiper.set_last_processed_message_at();
// TODO: Implement processing of incoming SHUTDOWN message
get_local_failure_detector().force_conviction(from);
}).discard_result();
}).handle_exception([] (auto ep) {
logger.error("Fail to handle GOSSIP_SHUTDOWN: {}", ep);
});
return messaging_service::no_wait();
});
ms().register_gossip_digest_syn([] (gossip_digest_syn syn_msg) {
@@ -228,7 +230,9 @@ void gossiper::init_messaging_service_handler() {
/* Notify the Failure Detector */
gossiper.notify_failure_detector(remote_ep_state_map);
return gossiper.apply_state_locally(remote_ep_state_map);
}).discard_result();
}).handle_exception([] (auto ep) {
logger.error("Fail to handle GOSSIP_DIGEST_ACK: {}", ep);
});
return messaging_service::no_wait();
});
}