lsm/seaweedfs
1
0
Fork 0
mirror of https://github.com/seaweedfs/seaweedfs.git synced 2025-09-23 04:43:38 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

[master] update LastLeaderChangeTime for hashicorp raft (#6292)

Browse Source
This commit is contained in:
Konstantin Lebedev
2024-11-26 21:02:45 +05:00
committed by GitHub
parent d43fa07f06
commit fec88e64eb
2 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
weed/server/master_server.go
View File

@@ -191,7 +191,6 @@ func (ms *MasterServer) SetRaftServer(raftServer *RaftServer) {
} else if raftServer.RaftHashicorp != nil { } else if raftServer.RaftHashicorp != nil {
ms.Topo.HashicorpRaft = raftServer.RaftHashicorp ms.Topo.HashicorpRaft = raftServer.RaftHashicorp
raftServerName = ms.Topo.HashicorpRaft.String() raftServerName = ms.Topo.HashicorpRaft.String()
// TODO fix this for hashicorp raft
ms.Topo.LastLeaderChangeTime = time.Now() ms.Topo.LastLeaderChangeTime = time.Now()
} }
ms.Topo.RaftServerAccessLock.Unlock() ms.Topo.RaftServerAccessLock.Unlock()

1
weed/server/raft_hashicorp.go
View File

@@ -78,6 +78,7 @@ func (s *RaftServer) monitorLeaderLoop(updatePeers bool) {
} }
glog.V(0).Infof("is leader %+v change event: %+v => %+v", isLeader, prevLeader, leader) glog.V(0).Infof("is leader %+v change event: %+v => %+v", isLeader, prevLeader, leader)
prevLeader = leader prevLeader = leader
s.topo.LastLeaderChangeTime = time.Now()
} }
} }
} }