aboutsummaryrefslogtreecommitdiff
path: root/weed/server/master_server_handlers_admin.go
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2018-10-14 23:12:43 -0700
committerChris Lu <chris.lu@gmail.com>2018-10-14 23:12:43 -0700
commitb1daede91bca63bf2ca3019f622e763d35969e4f (patch)
tree2078fd7bc116e12f0eeb2c3015c3568b90163b57 /weed/server/master_server_handlers_admin.go
parent91ac2e0dd920c0f629f4076202267afbac74a62c (diff)
downloadseaweedfs-b1daede91bca63bf2ca3019f622e763d35969e4f.tar.xz
seaweedfs-b1daede91bca63bf2ca3019f622e763d35969e4f.zip
move volume vacuum to gRpc
Diffstat (limited to 'weed/server/master_server_handlers_admin.go')
-rw-r--r--weed/server/master_server_handlers_admin.go12
1 files changed, 9 insertions, 3 deletions
diff --git a/weed/server/master_server_handlers_admin.go b/weed/server/master_server_handlers_admin.go
index 71362d52b..4f1d94594 100644
--- a/weed/server/master_server_handlers_admin.go
+++ b/weed/server/master_server_handlers_admin.go
@@ -37,9 +37,15 @@ func (ms *MasterServer) dirStatusHandler(w http.ResponseWriter, r *http.Request)
}
func (ms *MasterServer) volumeVacuumHandler(w http.ResponseWriter, r *http.Request) {
- gcThreshold := r.FormValue("garbageThreshold")
- if gcThreshold == "" {
- gcThreshold = ms.garbageThreshold
+ gcString := r.FormValue("garbageThreshold")
+ gcThreshold := ms.garbageThreshold
+ if gcString != "" {
+ var err error
+ gcThreshold, err = strconv.ParseFloat(gcString, 32)
+ if err != nil {
+ glog.V(0).Infof("garbageThreshold %s is not a valid float number: %v", gcString, err)
+ return
+ }
}
glog.Infoln("garbageThreshold =", gcThreshold)
ms.Topo.Vacuum(gcThreshold, ms.preallocate)