diff options
| author | skycope <wings.wyang@gmail.com> | 2024-04-23 21:33:50 +0800 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2024-04-23 06:33:50 -0700 |
| commit | 6e4b9181f5742b5a71c49ffb8f8e22ed0754ef5f (patch) | |
| tree | 849a181e3ffb5f6e6cd910cd159ac6698c6a2adc /weed/shell/command_volume_balance.go | |
| parent | cc2885b4f235c0de7ad2314b732cf4c52b531daf (diff) | |
| download | seaweedfs-6e4b9181f5742b5a71c49ffb8f8e22ed0754ef5f.tar.xz seaweedfs-6e4b9181f5742b5a71c49ffb8f8e22ed0754ef5f.zip | |
fix "volume.fix.replication" move many replications only to one volumeServer (#5522)
Diffstat (limited to 'weed/shell/command_volume_balance.go')
| -rw-r--r-- | weed/shell/command_volume_balance.go | 6 |
1 files changed, 2 insertions, 4 deletions
diff --git a/weed/shell/command_volume_balance.go b/weed/shell/command_volume_balance.go index cb201e064..e9a483f41 100644 --- a/weed/shell/command_volume_balance.go +++ b/weed/shell/command_volume_balance.go @@ -402,14 +402,12 @@ func adjustAfterMove(v *master_pb.VolumeInformationMessage, volumeReplicas map[u replica.location = &loc for diskType, diskInfo := range fullNode.info.DiskInfos { if diskType == v.DiskType { - diskInfo.VolumeCount-- - diskInfo.FreeVolumeCount++ + addVolumeCount(diskInfo, -1) } } for diskType, diskInfo := range emptyNode.info.DiskInfos { if diskType == v.DiskType { - diskInfo.VolumeCount++ - diskInfo.FreeVolumeCount-- + addVolumeCount(diskInfo, 1) } } return |
