diff options
| -rw-r--r-- | weed/topology/topology_vacuum.go | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/weed/topology/topology_vacuum.go b/weed/topology/topology_vacuum.go index ba7c328c5..dd20e8cb2 100644 --- a/weed/topology/topology_vacuum.go +++ b/weed/topology/topology_vacuum.go @@ -55,7 +55,8 @@ func batchVacuumVolumeCompact(vl *VolumeLayout, vid storage.VolumeId, locationli isVacuumSuccess := true for _ = range locationlist.list { select { - case _ = <-ch: + case canCommit := <-ch: + isVacuumSuccess = isVacuumSuccess && canCommit case <-time.After(30 * time.Minute): isVacuumSuccess = false break |