From 966cfd6e8e6974611816aef1147f9bde638afaf7 Mon Sep 17 00:00:00 2001 From: Xiang Li Date: Tue, 2 Sep 2014 21:55:42 -0700 Subject: [PATCH] raft: fix elapsed reset --- raft/raft.go | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/raft/raft.go b/raft/raft.go index 1202e1b18..cea3de8b3 100644 --- a/raft/raft.go +++ b/raft/raft.go @@ -444,7 +444,6 @@ func stepCandidate(r *raft, m pb.Message) { case msgProp: panic("no leader") case msgApp: - r.elapsed = 0 r.becomeFollower(r.Term, m.From) r.handleAppendEntries(m) case msgSnap: @@ -480,8 +479,8 @@ func stepFollower(r *raft, m pb.Message) { r.elapsed = 0 r.handleSnapshot(m) case msgVote: - // TODO(xiang): maybe reset elapsed? if (r.Vote == none || r.Vote == m.From) && r.raftLog.isUpToDate(m.Index, m.LogTerm) { + r.elapsed = 0 r.Vote = m.From r.send(pb.Message{To: m.From, Type: msgVoteResp, Index: r.raftLog.lastIndex()}) } else {