diff options
| author | Chris Lu <chris.lu@gmail.com> | 2018-10-15 01:19:15 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2018-10-15 01:19:15 -0700 |
| commit | fda771c83fd2702dc791244065b5886e5a3b9df2 (patch) | |
| tree | e566188618dc37cbc451fa57fb5046e7f5676798 /weed/server/volume_server_handlers_sync.go | |
| parent | b423bb9e2def089f57406ce8476c08f3de8436e9 (diff) | |
| download | seaweedfs-fda771c83fd2702dc791244065b5886e5a3b9df2.tar.xz seaweedfs-fda771c83fd2702dc791244065b5886e5a3b9df2.zip | |
migrate volume sync status to grpc API on volume server
Diffstat (limited to 'weed/server/volume_server_handlers_sync.go')
| -rw-r--r-- | weed/server/volume_server_handlers_sync.go | 16 |
1 files changed, 0 insertions, 16 deletions
diff --git a/weed/server/volume_server_handlers_sync.go b/weed/server/volume_server_handlers_sync.go index 1ceec4ddd..9fe22d02b 100644 --- a/weed/server/volume_server_handlers_sync.go +++ b/weed/server/volume_server_handlers_sync.go @@ -4,27 +4,11 @@ import ( "fmt" "net/http" - "github.com/chrislusf/seaweedfs/weed/glog" "github.com/chrislusf/seaweedfs/weed/storage" "github.com/chrislusf/seaweedfs/weed/storage/types" "github.com/chrislusf/seaweedfs/weed/util" ) -func (vs *VolumeServer) getVolumeSyncStatusHandler(w http.ResponseWriter, r *http.Request) { - v, err := vs.getVolume("volume", r) - if v == nil { - writeJsonError(w, r, http.StatusBadRequest, err) - return - } - syncStat := v.GetVolumeSyncStatus() - if syncStat.Error != "" { - writeJsonError(w, r, http.StatusInternalServerError, fmt.Errorf("Get Volume %d status error: %s", v.Id, syncStat.Error)) - glog.V(2).Infoln("getVolumeSyncStatusHandler volume =", r.FormValue("volume"), ", error =", err) - } else { - writeJsonQuiet(w, r, http.StatusOK, syncStat) - } -} - func (vs *VolumeServer) getVolumeIndexContentHandler(w http.ResponseWriter, r *http.Request) { v, err := vs.getVolume("volume", r) if v == nil { |