lsm/seaweedfs
1
0
Fork 0
mirror of https://github.com/seaweedfs/seaweedfs.git synced 2025-10-21 22:57:24 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

shell: add volume.vacuum command

Browse Source
This commit is contained in:
Chris Lu
2020-11-28 23:18:02 -08:00
parent 96c48bc8a8
commit 965413c21b
5 changed files with 451 additions and 218 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
weed/topology/topology_vacuum.go
View File

@@ -144,12 +144,12 @@ func batchVacuumVolumeCleanup(grpcDialOption grpc.DialOption, vl *VolumeLayout,
}
}
func (t *Topology) Vacuum(grpcDialOption grpc.DialOption, garbageThreshold float64, preallocate int64) int {
func (t *Topology) Vacuum(grpcDialOption grpc.DialOption, garbageThreshold float64, preallocate int64) {
// if there is vacuum going on, return immediately
swapped := atomic.CompareAndSwapInt64(&t.vacuumLockCounter, 0, 1)
if !swapped {
return 0
return
}
defer atomic.StoreInt64(&t.vacuumLockCounter, 0)
@@ -165,7 +165,6 @@ func (t *Topology) Vacuum(grpcDialOption grpc.DialOption, garbageThreshold float
}
}
}
return 0
}
func vacuumOneVolumeLayout(grpcDialOption grpc.DialOption, volumeLayout *VolumeLayout, c *Collection, garbageThreshold float64, preallocate int64) {