aboutsummaryrefslogtreecommitdiff
path: root/weed/shell/command_volume_fix_replication.go
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2020-11-10 12:26:05 -0800
committerChris Lu <chris.lu@gmail.com>2020-11-10 12:26:05 -0800
commitde3bdd0651cb2b83319d78cbb0f9da86cd950bfb (patch)
tree5ca4716934da6570b9ddf4c85436e54ab6a89cea /weed/shell/command_volume_fix_replication.go
parent1dd3a6ac36034587724ec57197620863110517cc (diff)
downloadseaweedfs-de3bdd0651cb2b83319d78cbb0f9da86cd950bfb.tar.xz
seaweedfs-de3bdd0651cb2b83319d78cbb0f9da86cd950bfb.zip
delete old volume replica
related to https://github.com/chrislusf/seaweedfs/issues/1607 old is: * older compaction revision * older modified time * smaller volume size
Diffstat (limited to 'weed/shell/command_volume_fix_replication.go')
-rw-r--r--weed/shell/command_volume_fix_replication.go26
1 files changed, 14 insertions, 12 deletions
diff --git a/weed/shell/command_volume_fix_replication.go b/weed/shell/command_volume_fix_replication.go
index 471b24a2a..9b9abd8eb 100644
--- a/weed/shell/command_volume_fix_replication.go
+++ b/weed/shell/command_volume_fix_replication.go
@@ -369,18 +369,20 @@ func countReplicas(replicas []*VolumeReplica) (diffDc, diffRack, diffNode map[st
func pickOneReplicaToDelete(replicas []*VolumeReplica, replicaPlacement *super_block.ReplicaPlacement) *VolumeReplica {
- allSame := true
- oldest := replicas[0]
- for _, replica := range replicas {
- if replica.info.ModifiedAtSecond < oldest.info.ModifiedAtSecond {
- oldest = replica
- allSame = false
+ sort.Slice(replicas, func(i, j int) bool {
+ a, b := replicas[i], replicas[j]
+ if a.info.CompactRevision != b.info.CompactRevision {
+ return a.info.CompactRevision < b.info.CompactRevision
}
- }
- if !allSame {
- return oldest
- }
+ if a.info.ModifiedAtSecond != b.info.ModifiedAtSecond {
+ return a.info.ModifiedAtSecond < b.info.ModifiedAtSecond
+ }
+ if a.info.Size != b.info.Size {
+ return a.info.Size < b.info.Size
+ }
+ return false
+ })
+
+ return replicas[0]
- // TODO what if all the replicas have the same timestamp?
- return oldest
}