diff options
| author | chrislu <chris.lu@gmail.com> | 2022-07-08 10:29:24 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2022-07-08 10:29:24 -0700 |
| commit | 48382676d2765ae4facfc60e89b897247c711ef5 (patch) | |
| tree | 11a3f3b8108123c4f18e55e879b8df1d945502f6 | |
| parent | b9518e06f5bd9640264a53a43a0a1cb951a04a12 (diff) | |
| download | seaweedfs-48382676d2765ae4facfc60e89b897247c711ef5.tar.xz seaweedfs-48382676d2765ae4facfc60e89b897247c711ef5.zip | |
fix filtering by volume id
| -rw-r--r-- | weed/topology/topology_vacuum.go | 9 |
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) } } } |
