aboutsummaryrefslogtreecommitdiff
path: root/weed/server/volume_server_handlers_admin.go
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2018-10-15 00:40:46 -0700
committerChris Lu <chris.lu@gmail.com>2018-10-15 00:40:46 -0700
commitb423bb9e2def089f57406ce8476c08f3de8436e9 (patch)
treecfca3252fd667a57f39af5f16190db7576c1ad95 /weed/server/volume_server_handlers_admin.go
parent333709657cb9360d112ce681e2275abd22961087 (diff)
downloadseaweedfs-b423bb9e2def089f57406ce8476c08f3de8436e9.tar.xz
seaweedfs-b423bb9e2def089f57406ce8476c08f3de8436e9.zip
migrate assign volume to grpc API on volume server
Diffstat (limited to 'weed/server/volume_server_handlers_admin.go')
-rw-r--r--weed/server/volume_server_handlers_admin.go31
1 files changed, 1 insertions, 30 deletions
diff --git a/weed/server/volume_server_handlers_admin.go b/weed/server/volume_server_handlers_admin.go
index 4e985f787..091e121cb 100644
--- a/weed/server/volume_server_handlers_admin.go
+++ b/weed/server/volume_server_handlers_admin.go
@@ -4,10 +4,7 @@ import (
"fmt"
"net/http"
"path/filepath"
- "strconv"
-
- "github.com/chrislusf/seaweedfs/weed/glog"
- "github.com/chrislusf/seaweedfs/weed/stats"
+ "github.com/chrislusf/seaweedfs/weed/stats"
"github.com/chrislusf/seaweedfs/weed/storage"
"github.com/chrislusf/seaweedfs/weed/util"
)
@@ -19,32 +16,6 @@ func (vs *VolumeServer) statusHandler(w http.ResponseWriter, r *http.Request) {
writeJsonQuiet(w, r, http.StatusOK, m)
}
-func (vs *VolumeServer) assignVolumeHandler(w http.ResponseWriter, r *http.Request) {
- var err error
- preallocate := int64(0)
- if r.FormValue("preallocate") != "" {
- preallocate, err = strconv.ParseInt(r.FormValue("preallocate"), 10, 64)
- if err != nil {
- glog.V(0).Infof("ignoring invalid int64 value for preallocate = %v", r.FormValue("preallocate"))
- }
- }
- err = vs.store.AddVolume(
- r.FormValue("volume"),
- r.FormValue("collection"),
- vs.needleMapKind,
- r.FormValue("replication"),
- r.FormValue("ttl"),
- preallocate,
- )
- if err == nil {
- writeJsonQuiet(w, r, http.StatusAccepted, map[string]string{"error": ""})
- } else {
- writeJsonError(w, r, http.StatusNotAcceptable, err)
- }
- glog.V(2).Infof("assign volume = %s, collection = %s , replication = %s, error = %v",
- r.FormValue("volume"), r.FormValue("collection"), r.FormValue("replication"), err)
-}
-
func (vs *VolumeServer) statsDiskHandler(w http.ResponseWriter, r *http.Request) {
m := make(map[string]interface{})
m["Version"] = util.VERSION