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/filer/filer.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/filer/filer.go')
| -rw-r--r-- | weed/filer/filer.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/filer/filer.go b/weed/filer/filer.go index 993175112..fe5fe289a 100644 --- a/weed/filer/filer.go +++ b/weed/filer/filer.go @@ -96,7 +96,7 @@ func (f *Filer) MaybeBootstrapFromPeers(self pb.ServerAddress, existingNodes []* func (f *Filer) AggregateFromPeers(self pb.ServerAddress, existingNodes []*master_pb.ClusterNodeUpdate, startFrom time.Time) { f.MetaAggregator = NewMetaAggregator(f, self, f.GrpcDialOption) - f.MasterClient.OnPeerUpdate = f.MetaAggregator.OnPeerUpdate + f.MasterClient.SetOnPeerUpdateFn(f.MetaAggregator.OnPeerUpdate) for _, peerUpdate := range existingNodes { f.MetaAggregator.OnPeerUpdate(peerUpdate, startFrom) |