aboutsummaryrefslogtreecommitdiff
path: root/weed/server/master_server.go
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2018-06-12 01:54:09 -0700
committerChris Lu <chris.lu@gmail.com>2018-06-12 01:54:09 -0700
commit03f50180f3f6bfca5ae61fab0fa1c3b1db939e05 (patch)
tree35a236730feafdc8d651d67f996593ac6ffe3ffe /weed/server/master_server.go
parent69b4f9383086f71a04a28d358d1ccca1cc149ff2 (diff)
downloadseaweedfs-03f50180f3f6bfca5ae61fab0fa1c3b1db939e05.tar.xz
seaweedfs-03f50180f3f6bfca5ae61fab0fa1c3b1db939e05.zip
simplifying the leader election by raft
fixing https://github.com/chrislusf/seaweedfs/issues/629
Diffstat (limited to 'weed/server/master_server.go')
-rw-r--r--weed/server/master_server.go1
1 files changed, 1 insertions, 0 deletions
diff --git a/weed/server/master_server.go b/weed/server/master_server.go
index 9fd07072f..efa0ae104 100644
--- a/weed/server/master_server.go
+++ b/weed/server/master_server.go
@@ -88,6 +88,7 @@ func NewMasterServer(r *mux.Router, port int, metaFolder string,
func (ms *MasterServer) SetRaftServer(raftServer *RaftServer) {
ms.Topo.RaftServer = raftServer.raftServer
ms.Topo.RaftServer.AddEventListener(raft.LeaderChangeEventType, func(e raft.Event) {
+ glog.V(0).Infof("event: %+v", e)
if ms.Topo.RaftServer.Leader() != "" {
glog.V(0).Infoln("[", ms.Topo.RaftServer.Name(), "]", ms.Topo.RaftServer.Leader(), "becomes leader.")
}