add event dispatch when status follower unchanged but leader changes

seaweedfs · Jul 8, 2020 · 649c754 · 649c754
1 parent b8f3fb6
commit 649c754
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)