diff options
| author | Konstantin Lebedev <9497591+kmlebedev@users.noreply.github.com> | 2022-08-26 22:18:49 +0500 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-08-26 10:18:49 -0700 |
| commit | e90ab4ac604a7bdc02a25bc8dde5b6dde52272a3 (patch) | |
| tree | 8ed31b01c041d341306b99741f5caeda870df11f /weed/server/master_server.go | |
| parent | 4f7a1f67cdecf36ae590d35eca0f8e8510fce715 (diff) | |
| download | seaweedfs-e90ab4ac604a7bdc02a25bc8dde5b6dde52272a3.tar.xz seaweedfs-e90ab4ac604a7bdc02a25bc8dde5b6dde52272a3.zip | |
avoid race conditions for OnPeerUpdate (#3525)
https://github.com/seaweedfs/seaweedfs/issues/3524
Diffstat (limited to 'weed/server/master_server.go')
| -rw-r--r-- | weed/server/master_server.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/server/master_server.go b/weed/server/master_server.go index ecbfd64af..758f212ad 100644 --- a/weed/server/master_server.go +++ b/weed/server/master_server.go @@ -116,7 +116,7 @@ func NewMasterServer(r *mux.Router, option *MasterOption, peers map[string]pb.Se } ms.boundedLeaderChan = make(chan int, 16) - ms.MasterClient.OnPeerUpdate = ms.OnPeerUpdate + ms.MasterClient.SetOnPeerUpdateFn(ms.OnPeerUpdate) seq := ms.createSequencer(option) if nil == seq { |