aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorChris Lu <chrislusf@users.noreply.github.com>2019-11-19 20:43:05 -0800
committerGitHub <noreply@github.com>2019-11-19 20:43:05 -0800
commit4f3adcb5ab97d6e7316d6dc5154c59bdfac41d1d (patch)
tree4d220c504f327ae715db95074639b35da223473a
parent9711a6ffaabdac8516317a5539316e9a2bb83faf (diff)
parent5656d43264feea1f39b97d4dba14ce28759fa49f (diff)
downloadseaweedfs-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.go10
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