|
@ -55,7 +55,8 @@ func batchVacuumVolumeCompact(vl *VolumeLayout, vid storage.VolumeId, locationli |
|
|
isVacuumSuccess := true |
|
|
isVacuumSuccess := true |
|
|
for _ = range locationlist.list { |
|
|
for _ = range locationlist.list { |
|
|
select { |
|
|
select { |
|
|
case _ = <-ch: |
|
|
|
|
|
|
|
|
case canCommit := <-ch: |
|
|
|
|
|
isVacuumSuccess = isVacuumSuccess && canCommit |
|
|
case <-time.After(30 * time.Minute): |
|
|
case <-time.After(30 * time.Minute): |
|
|
isVacuumSuccess = false |
|
|
isVacuumSuccess = false |
|
|
break |
|
|
break |
|
|