aboutsummaryrefslogtreecommitdiff
path: root/weed/server/master_grpc_server_raft.go
diff options
context:
space:
mode:
authorchrislu <chris.lu@gmail.com>2022-10-09 18:58:14 -0700
committerchrislu <chris.lu@gmail.com>2022-10-09 18:58:14 -0700
commit1e27d36576afd1d2525e1146b7994cd3d7ef51c5 (patch)
tree81a9ef90764dd4c50d9adafe3d547d12fab0ea6d /weed/server/master_grpc_server_raft.go
parentf9383aa726771b9bd9027cf5e9d62fcaecad9cee (diff)
parentb7de4a967e14f4d7419378e1daf590d3ef8c3c82 (diff)
downloadseaweedfs-1e27d36576afd1d2525e1146b7994cd3d7ef51c5.tar.xz
seaweedfs-1e27d36576afd1d2525e1146b7994cd3d7ef51c5.zip
Merge branch 'master' of https://github.com/seaweedfs/seaweedfs
Diffstat (limited to 'weed/server/master_grpc_server_raft.go')
-rw-r--r--weed/server/master_grpc_server_raft.go2
1 files changed, 2 insertions, 0 deletions
diff --git a/weed/server/master_grpc_server_raft.go b/weed/server/master_grpc_server_raft.go
index 7f8ad70df..e6454704e 100644
--- a/weed/server/master_grpc_server_raft.go
+++ b/weed/server/master_grpc_server_raft.go
@@ -20,6 +20,7 @@ func (ms *MasterServer) RaftListClusterServers(ctx context.Context, req *master_
}
servers := ms.Topo.HashicorpRaft.GetConfiguration().Configuration().Servers
+ _, leaderId := ms.Topo.HashicorpRaft.LeaderWithID()
ms.Topo.RaftServerAccessLock.RUnlock()
for _, server := range servers {
@@ -27,6 +28,7 @@ func (ms *MasterServer) RaftListClusterServers(ctx context.Context, req *master_
Id: string(server.ID),
Address: string(server.Address),
Suffrage: server.Suffrage.String(),
+ IsLeader: server.ID == leaderId,
})
}
return resp, nil