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

gossip: Implement GossipDigestAck2VerbHandler

Browse Source
This commit is contained in:
Asias He
2015-04-13 09:35:56 +08:00
parent 1ad7af3bca
commit 7ee239e7e7
1 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
gms/gossiper.cc
View File

@@ -37,9 +37,12 @@ void gossiper::init_messaging_service_handler() {
gms::gossip_digest_ack ack(std::move(digests), std::move(eps));
return make_ready_future<gossip_digest_ack>(ack);
});
ms().register_handler_oneway(messaging_verb::GOSSIP_DIGEST_ACK2, [] (gossip_digest_ack2 msg) {
ms().register_handler_oneway(messaging_verb::GOSSIP_DIGEST_ACK2, [this] (gossip_digest_ack2 msg) {
print("gossiper: Server got ack2 msg = %s\n", msg);
// TODO: Implement processing of incoming ACK2 message
auto& remote_ep_state_map = msg.get_endpoint_state_map();
/* Notify the Failure Detector */
this->notify_failure_detector(remote_ep_state_map);
this->apply_state_locally(remote_ep_state_map);
return messaging_service::no_wait();
});
}