diff options
| author | Chris Lu <chrislusf@users.noreply.github.com> | 2019-11-19 20:43:05 -0800 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2019-11-19 20:43:05 -0800 |
| commit | 4f3adcb5ab97d6e7316d6dc5154c59bdfac41d1d (patch) | |
| tree | 4d220c504f327ae715db95074639b35da223473a | |
| parent | 9711a6ffaabdac8516317a5539316e9a2bb83faf (diff) | |
| parent | 5656d43264feea1f39b97d4dba14ce28759fa49f (diff) | |
| download | seaweedfs-4f3adcb5ab97d6e7316d6dc5154c59bdfac41d1d.tar.xz seaweedfs-4f3adcb5ab97d6e7316d6dc5154c59bdfac41d1d.zip | |
Merge pull request #1129 from divinerapier/master
can not break out of from for-select block
| -rw-r--r-- | weed/topology/topology_vacuum.go | 10 |
1 files changed, 4 insertions, 6 deletions
diff --git a/weed/topology/topology_vacuum.go b/weed/topology/topology_vacuum.go index 37a6a30b9..ff32f1874 100644 --- a/weed/topology/topology_vacuum.go +++ b/weed/topology/topology_vacuum.go @@ -35,13 +35,12 @@ func batchVacuumVolumeCheck(grpcDialOption grpc.DialOption, vl *VolumeLayout, vi }(index, dn.Url(), vid) } isCheckSuccess := true - for _ = range locationlist.list { + for range locationlist.list { select { case canVacuum := <-ch: isCheckSuccess = isCheckSuccess && canVacuum case <-time.After(30 * time.Minute): - isCheckSuccess = false - break + return false } } return isCheckSuccess @@ -71,13 +70,12 @@ func batchVacuumVolumeCompact(grpcDialOption grpc.DialOption, vl *VolumeLayout, }(index, dn.Url(), vid) } isVacuumSuccess := true - for _ = range locationlist.list { + for range locationlist.list { select { case canCommit := <-ch: isVacuumSuccess = isVacuumSuccess && canCommit case <-time.After(30 * time.Minute): - isVacuumSuccess = false - break + return false } } return isVacuumSuccess |
