diff options
| author | chrislu <chris.lu@gmail.com> | 2022-08-26 10:23:42 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2022-08-26 10:23:42 -0700 |
| commit | f5156cf3a8d08622574865532ef5139537384b40 (patch) | |
| tree | 80d2ae4103942ed5e74743b80c6af4e889a52c28 | |
| parent | e90ab4ac604a7bdc02a25bc8dde5b6dde52272a3 (diff) | |
| download | seaweedfs-f5156cf3a8d08622574865532ef5139537384b40.tar.xz seaweedfs-f5156cf3a8d08622574865532ef5139537384b40.zip | |
rename varaible
| -rw-r--r-- | weed/wdclient/masterclient.go | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/weed/wdclient/masterclient.go b/weed/wdclient/masterclient.go index 6e91c31eb..d330e9ec6 100644 --- a/weed/wdclient/masterclient.go +++ b/weed/wdclient/masterclient.go @@ -29,8 +29,8 @@ type MasterClient struct { vidMap vidMapCacheSize int - OnPeerUpdate func(update *master_pb.ClusterNodeUpdate, startFrom time.Time) - OnPeerUpdateAccessLock sync.RWMutex + OnPeerUpdate func(update *master_pb.ClusterNodeUpdate, startFrom time.Time) + OnPeerUpdateLock sync.RWMutex } func NewMasterClient(grpcDialOption grpc.DialOption, filerGroup string, clientType string, clientHost pb.ServerAddress, clientDataCenter string, rack string, masters map[string]pb.ServerAddress) *MasterClient { @@ -47,9 +47,9 @@ func NewMasterClient(grpcDialOption grpc.DialOption, filerGroup string, clientTy } func (mc *MasterClient) SetOnPeerUpdateFn(onPeerUpdate func(update *master_pb.ClusterNodeUpdate, startFrom time.Time)) { - mc.OnPeerUpdateAccessLock.Lock() + mc.OnPeerUpdateLock.Lock() mc.OnPeerUpdate = onPeerUpdate - mc.OnPeerUpdateAccessLock.Unlock() + mc.OnPeerUpdateLock.Unlock() } func (mc *MasterClient) GetLookupFileIdFunction() LookupFileIdFunctionType { @@ -227,7 +227,7 @@ func (mc *MasterClient) tryConnectToMaster(master pb.ServerAddress) (nextHintedL if resp.ClusterNodeUpdate != nil { update := resp.ClusterNodeUpdate - mc.OnPeerUpdateAccessLock.RLock() + mc.OnPeerUpdateLock.RLock() if mc.OnPeerUpdate != nil { if update.FilerGroup == mc.FilerGroup { if update.IsAdd { @@ -239,7 +239,7 @@ func (mc *MasterClient) tryConnectToMaster(master pb.ServerAddress) (nextHintedL mc.OnPeerUpdate(update, time.Now()) } } - mc.OnPeerUpdateAccessLock.RUnlock() + mc.OnPeerUpdateLock.RUnlock() } } }) |