aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorchrislu <chris.lu@gmail.com>2022-07-08 10:29:24 -0700
committerchrislu <chris.lu@gmail.com>2022-07-08 10:29:24 -0700
commit48382676d2765ae4facfc60e89b897247c711ef5 (patch)
tree11a3f3b8108123c4f18e55e879b8df1d945502f6
parentb9518e06f5bd9640264a53a43a0a1cb951a04a12 (diff)
downloadseaweedfs-48382676d2765ae4facfc60e89b897247c711ef5.tar.xz
seaweedfs-48382676d2765ae4facfc60e89b897247c711ef5.zip
fix filtering by volume id
-rw-r--r--weed/topology/topology_vacuum.go9
1 files changed, 6 insertions, 3 deletions
diff --git a/weed/topology/topology_vacuum.go b/weed/topology/topology_vacuum.go
index e53aa2853..3850b8916 100644
--- a/weed/topology/topology_vacuum.go
+++ b/weed/topology/topology_vacuum.go
@@ -185,10 +185,13 @@ func (t *Topology) Vacuum(grpcDialOption grpc.DialOption, garbageThreshold float
for _, vl := range c.storageType2VolumeLayout.Items() {
if vl != nil {
volumeLayout := vl.(*VolumeLayout)
- if volumeId > 0 && volumeLayout.Lookup(needle.VolumeId(volumeId)) == nil {
- continue
+ if volumeId > 0 {
+ if volumeLayout.Lookup(needle.VolumeId(volumeId)) != nil {
+ t.vacuumOneVolumeLayout(grpcDialOption, volumeLayout, c, garbageThreshold, preallocate)
+ }
+ } else {
+ t.vacuumOneVolumeLayout(grpcDialOption, volumeLayout, c, garbageThreshold, preallocate)
}
- t.vacuumOneVolumeLayout(grpcDialOption, volumeLayout, c, garbageThreshold, preallocate)
}
}
}