Merge pull request #2415 from xiaost/fix-leaderid-error

raft: fix leaderID error when state changed
influxdata · Apr 24, 2015 · 5894f65 · 5894f65
2 parents 2d2c806 + e521ac9
commit 5894f65
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/raft/log.go b/raft/log.go
@@ -1035,6 +1035,9 @@ func (l *Log) candidateLoop(closing <-chan struct{}) State {
 		case <-l.terms:
 			return Follower
 		case <-elected:
+			l.lock()
+			l.leaderID = l.id
+			l.unlock()
 			return Leader
 		case ch := <-l.Clock.AfterElectionTimeout():
 			close(ch)