RaftCore implementation fix

This commit is contained in:
Pavel Kirienko
2015-05-24 16:32:52 +03:00
parent 546be2b89b
commit e5f3a96476
@@ -247,6 +247,11 @@ private:
setActiveMode(false); // Haha
}
if (append_entries_client_.hasPendingCalls())
{
append_entries_client_.cancelAllCalls(); // Refer to the response callback to learn why
}
if (active_mode_ || (next_server_index_ > 0))
{
const NodeID node_id = cluster_.getRemoteServerNodeIDAtIndex(next_server_index_);