aboutsummaryrefslogtreecommitdiff
path: root/weed/shell/command_volume_balance.go
diff options
context:
space:
mode:
authorskycope <wings.wyang@gmail.com>2024-04-23 21:33:50 +0800
committerGitHub <noreply@github.com>2024-04-23 06:33:50 -0700
commit6e4b9181f5742b5a71c49ffb8f8e22ed0754ef5f (patch)
tree849a181e3ffb5f6e6cd910cd159ac6698c6a2adc /weed/shell/command_volume_balance.go
parentcc2885b4f235c0de7ad2314b732cf4c52b531daf (diff)
downloadseaweedfs-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.go6
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