aboutsummaryrefslogtreecommitdiff
path: root/weed/server/master_grpc_server.go
diff options
context:
space:
mode:
authorKonstantin Lebedev <9497591+kmlebedev@users.noreply.github.com>2022-10-08 01:26:29 +0500
committerGitHub <noreply@github.com>2022-10-07 13:26:29 -0700
commit5db25a8f2ad235c40c2b19306a6a49b5c4715331 (patch)
treea1e37ce03659f24845b3c331aa103ad2fb5f46ab /weed/server/master_grpc_server.go
parentf8d3ff466d8d2360c39132910710f5a33cf2b2be (diff)
downloadseaweedfs-5db25a8f2ad235c40c2b19306a6a49b5c4715331.tar.xz
seaweedfs-5db25a8f2ad235c40c2b19306a6a49b5c4715331.zip
metric shows who is currently blocking the cluster or not (#3799)
* master_admin_lock Shows whether cluster is locked now or not https://github.com/seaweedfs/seaweedfs/issues/3452 * fix metric MasterAdminLock
Diffstat (limited to 'weed/server/master_grpc_server.go')
-rw-r--r--weed/server/master_grpc_server.go2
1 files changed, 2 insertions, 0 deletions
diff --git a/weed/server/master_grpc_server.go b/weed/server/master_grpc_server.go
index 7caaf01b2..93569ce0d 100644
--- a/weed/server/master_grpc_server.go
+++ b/weed/server/master_grpc_server.go
@@ -307,6 +307,8 @@ func (ms *MasterServer) KeepConnected(stream master_pb.Seaweed_KeepConnectedServ
case <-ticker.C:
if !ms.Topo.IsLeader() {
stats.MasterRaftIsleader.Set(0)
+ stats.MasterAdminLock.Reset()
+ stats.MasterReplicaPlacementMismatch.Reset()
return ms.informNewLeader(stream)
} else {
stats.MasterRaftIsleader.Set(1)