diff options
| author | chrislu <chris.lu@gmail.com> | 2025-10-30 21:19:04 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2025-10-30 21:19:04 -0700 |
| commit | d1031e71903d676e8fbdb0040f5e527ca6871a93 (patch) | |
| tree | e0db29cc856cbfc6b604c347440426dd20530a09 | |
| parent | 8b9a48c1b5e87a607692cc229d9ecbf2cade675d (diff) | |
| download | seaweedfs-origin/pr-7412.tar.xz seaweedfs-origin/pr-7412.zip | |
consistentorigin/pr-7412
| -rw-r--r-- | weed/wdclient/masterclient.go | 8 |
1 files changed, 2 insertions, 6 deletions
diff --git a/weed/wdclient/masterclient.go b/weed/wdclient/masterclient.go index d6cb2c285..a8ff5c9c7 100644 --- a/weed/wdclient/masterclient.go +++ b/weed/wdclient/masterclient.go @@ -127,9 +127,7 @@ func (mc *MasterClient) LookupVolumeIdsWithFallback(ctx context.Context, volumeI vidStringToUint := make(map[string]uint32, len(volumeIds)) // Get stable pointer to vidMap with minimal lock hold time - mc.vidMapLock.RLock() - vm := mc.vidMap - mc.vidMapLock.RUnlock() + vm := mc.getStableVidMap() for _, vidString := range volumeIds { vid, err := strconv.ParseUint(vidString, 10, 32) @@ -161,9 +159,7 @@ func (mc *MasterClient) LookupVolumeIdsWithFallback(ctx context.Context, volumeI batchResult := make(map[string][]Location) // Get stable pointer with minimal lock hold time - mc.vidMapLock.RLock() - vm := mc.vidMap - mc.vidMapLock.RUnlock() + vm := mc.getStableVidMap() for _, vidString := range needsLookup { vid := vidStringToUint[vidString] // Use pre-parsed value |