diff options
| author | Chris Lu <chris.lu@gmail.com> | 2018-10-15 00:40:46 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2018-10-15 00:40:46 -0700 |
| commit | b423bb9e2def089f57406ce8476c08f3de8436e9 (patch) | |
| tree | cfca3252fd667a57f39af5f16190db7576c1ad95 /weed/server/volume_server_handlers_admin.go | |
| parent | 333709657cb9360d112ce681e2275abd22961087 (diff) | |
| download | seaweedfs-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.go | 31 |
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 |
