Merge pull request #2 from robin1900/master

fix leader change event dispatch issue
seaweedfs · Jul 8, 2020 · b5feda1 · b5feda1
2 parents 8079638 + 649c754
commit b5feda1
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/server.go b/server.go
@@ -988,7 +988,12 @@ func (s *server) processAppendEntriesRequest(req *AppendEntriesRequest) (*Append
 
 		// discover new leader when candidate
 		// save leader name when follower
+		prevLeader := s.leader
 		s.leader = req.LeaderName
+		if prevLeader != s.leader {
+			s.DispatchEvent(newEvent(LeaderChangeEventType, s.leader, prevLeader))
+		}
+
 	} else {
 		// Update term and leader.
 		s.updateCurrentTerm(req.Term, req.LeaderName)