diff options
| author | Chris Lu <chris.lu@gmail.com> | 2017-08-29 23:11:08 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2017-08-29 23:11:20 -0700 |
| commit | f7c22f0159b79d4f6d0a63df9597cfb1e9e6155d (patch) | |
| tree | 3a6042124c7cbad2bfda7a2e42d17c3be8174ee4 | |
| parent | b3f714612d289588c0772cf5fb1b8d2b9c874061 (diff) | |
| download | seaweedfs-f7c22f0159b79d4f6d0a63df9597cfb1e9e6155d.tar.xz seaweedfs-f7c22f0159b79d4f6d0a63df9597cfb1e9e6155d.zip | |
fix bug when collecting vacuum errors
| -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 |