aboutsummaryrefslogtreecommitdiff
path: root/weed/shell/command_volume_fix_replication.go
diff options
context:
space:
mode:
authorchrislu <chris.lu@gmail.com>2022-06-03 08:45:29 -0700
committerchrislu <chris.lu@gmail.com>2022-06-03 08:45:29 -0700
commitf97acdd4891b7b318f3fb67b1d8c2b11c809b158 (patch)
treea1a33b24ca6f263faede58f88684edc5d225e222 /weed/shell/command_volume_fix_replication.go
parent6793bc853c8b54823157bda6af4385411f8f6aea (diff)
downloadseaweedfs-f97acdd4891b7b318f3fb67b1d8c2b11c809b158.tar.xz
seaweedfs-f97acdd4891b7b318f3fb67b1d8c2b11c809b158.zip
volume.fix.replication fix retry logic
fix https://github.com/chrislusf/seaweedfs/issues/3136
Diffstat (limited to 'weed/shell/command_volume_fix_replication.go')
-rw-r--r--weed/shell/command_volume_fix_replication.go2
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/shell/command_volume_fix_replication.go b/weed/shell/command_volume_fix_replication.go
index 2afcd9cba..4d986d252 100644
--- a/weed/shell/command_volume_fix_replication.go
+++ b/weed/shell/command_volume_fix_replication.go
@@ -151,7 +151,7 @@ func (c *commandVolumeFixReplication) Do(args []string, commandEnv *CommandEnv,
return err
}
volumeIdLocationCount = len(volumeLocIds[0].Locations)
- if *retryCount > i {
+ if *retryCount <= i {
return fmt.Errorf("replicas volume %s mismatch in topology", volumeId)
}
i += 1