Unverified Commit 36be2723 authored by Ozan Tezcan's avatar Ozan Tezcan Committed by GitHub
Browse files

Set leader_id to NONE when node becomes follower (#57)

parent 85d154b7
...@@ -488,6 +488,7 @@ void raft_become_follower(raft_server_t* me_) ...@@ -488,6 +488,7 @@ void raft_become_follower(raft_server_t* me_)
raft_set_state(me_, RAFT_STATE_FOLLOWER); raft_set_state(me_, RAFT_STATE_FOLLOWER);
raft_randomize_election_timeout(me_); raft_randomize_election_timeout(me_);
me->timeout_elapsed = 0; me->timeout_elapsed = 0;
me->leader_id = RAFT_NODE_ID_NONE;
} }
static int msgid_cmp(const void *a, const void *b) static int msgid_cmp(const void *a, const void *b)
...@@ -648,7 +649,7 @@ int raft_recv_appendentries_response(raft_server_t* me_, ...@@ -648,7 +649,7 @@ int raft_recv_appendentries_response(raft_server_t* me_,
if (0 != e) if (0 != e)
return e; return e;
raft_become_follower(me_); raft_become_follower(me_);
me->leader_id = RAFT_NODE_ID_NONE;
return 0; return 0;
} }
else if (me->current_term != r->term) else if (me->current_term != r->term)
...@@ -932,7 +933,6 @@ int raft_recv_requestvote(raft_server_t* me_, ...@@ -932,7 +933,6 @@ int raft_recv_requestvote(raft_server_t* me_,
goto done; goto done;
} }
raft_become_follower(me_); raft_become_follower(me_);
me->leader_id = RAFT_NODE_ID_NONE;
} }
if (me->current_term > vr->term) { if (me->current_term > vr->term) {
...@@ -1011,7 +1011,7 @@ int raft_recv_requestvote_response(raft_server_t* me_, ...@@ -1011,7 +1011,7 @@ int raft_recv_requestvote_response(raft_server_t* me_,
if (0 != e) if (0 != e)
return e; return e;
raft_become_follower(me_); raft_become_follower(me_);
me->leader_id = RAFT_NODE_ID_NONE;
return 0; return 0;
} }
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment