aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorsteve.wei <coderushing@gmail.com>2024-04-08 22:30:04 +0800
committerGitHub <noreply@github.com>2024-04-08 07:30:04 -0700
commit67ead9b18f0e7f23f690c7f04e521be9e4d88270 (patch)
treeb6cc3d0867ea055814e988e817334196de28fb73
parent5c8e6014baabe84cde25eea00ea75d0be5f0aa8f (diff)
downloadseaweedfs-67ead9b18f0e7f23f690c7f04e521be9e4d88270.tar.xz
seaweedfs-67ead9b18f0e7f23f690c7f04e521be9e4d88270.zip
fix(volume.fix.replication): adjust volume count, not free volume count (#5479)
-rw-r--r--weed/shell/command_volume_fix_replication.go8
1 files changed, 4 insertions, 4 deletions
diff --git a/weed/shell/command_volume_fix_replication.go b/weed/shell/command_volume_fix_replication.go
index 9b6a64e6f..b724f16f9 100644
--- a/weed/shell/command_volume_fix_replication.go
+++ b/weed/shell/command_volume_fix_replication.go
@@ -315,8 +315,8 @@ func (c *commandVolumeFixReplication) fixOneUnderReplicatedVolume(commandEnv *Co
fmt.Fprintf(writer, "replicating volume %d %s from %s to dataNode %s ...\n", replica.info.Id, replicaPlacement, replica.location.dataNode.Id, dst.dataNode.Id)
if !takeAction {
- // adjust free volume count
- dst.dataNode.DiskInfos[replica.info.DiskType].FreeVolumeCount--
+ // adjust volume count
+ dst.dataNode.DiskInfos[replica.info.DiskType].VolumeCount++
break
}
@@ -349,8 +349,8 @@ func (c *commandVolumeFixReplication) fixOneUnderReplicatedVolume(commandEnv *Co
return err
}
- // adjust free volume count
- dst.dataNode.DiskInfos[replica.info.DiskType].FreeVolumeCount--
+ // adjust volume count
+ dst.dataNode.DiskInfos[replica.info.DiskType].VolumeCount++
break
}
}