diff options
| author | Konstantin Lebedev <9497591+kmlebedev@users.noreply.github.com> | 2022-07-20 18:40:35 +0500 |
|---|---|---|
| committer | Konstantin Lebedev <9497591+kmlebedev@users.noreply.github.com> | 2022-07-20 18:40:50 +0500 |
| commit | 7875470e74022e2b4262e51a349c4e3c15459a33 (patch) | |
| tree | c6ba26ddafd3c32f15c95b1afed40a8bcdea0c91 | |
| parent | c5189c343baa0d7b36349bbca669f8bba12d491b (diff) | |
| download | seaweedfs-7875470e74022e2b4262e51a349c4e3c15459a33.tar.xz seaweedfs-7875470e74022e2b4262e51a349c4e3c15459a33.zip | |
onPeerUpdateGoroutineCount use int32
| -rw-r--r-- | weed/server/master_server.go | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/weed/server/master_server.go b/weed/server/master_server.go index 7f9bff389..98fb6aab1 100644 --- a/weed/server/master_server.go +++ b/weed/server/master_server.go @@ -67,7 +67,7 @@ type MasterServer struct { boundedLeaderChan chan int onPeerUpdateDoneCn chan string - onPeerUpdateGoroutineCount uint32 + onPeerUpdateGoroutineCount int32 // notifying clients clientChansLock sync.RWMutex @@ -367,16 +367,16 @@ func (ms *MasterServer) OnPeerUpdate(update *master_pb.ClusterNodeUpdate, startF hashicorpRaft.ServerAddress(peerAddress.ToGrpcAddress()), 0, 0) } } - if atomic.LoadUint32(&ms.onPeerUpdateGoroutineCount) > 0 { + if atomic.LoadInt32(&ms.onPeerUpdateGoroutineCount) > 0 { ms.onPeerUpdateDoneCn <- peerName } } else if isLeader { go func(peerName string) { raftServerRemovalTimeAfter := time.After(RaftServerRemovalTime) raftServerPingTicker := time.NewTicker(5 * time.Minute) - atomic.AddUint32(&ms.onPeerUpdateGoroutineCount, 1) + atomic.AddInt32(&ms.onPeerUpdateGoroutineCount, 1) defer func() { - atomic.AddUint32(&ms.onPeerUpdateGoroutineCount, -1) + atomic.AddInt32(&ms.onPeerUpdateGoroutineCount, -1) }() for { select { |