lsm/seaweedfs
1
0
Fork 0
mirror of https://github.com/seaweedfs/seaweedfs.git synced 2025-08-01 17:18:31 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Merge pull request #306 from hankya/master

Browse Source 
master: redirect handler accept collection parameter
This commit is contained in:
Chris Lu 2016-05-23 10:13:01 -07:00
commit dfde029430
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
go/weed/weed_server/master_server_handlers_admin.go
View File

@ -121,7 +121,8 @@ func (ms *MasterServer) redirectHandler(w http.ResponseWriter, r *http.Request)
debug("parsing error:", err, r.URL.Path) debug("parsing error:", err, r.URL.Path)
return return
} }
machines := ms.Topo.Lookup("", volumeId) collection := r.FormValue("collection")
machines := ms.Topo.Lookup(collection, volumeId)
if machines != nil && len(machines) > 0 { if machines != nil && len(machines) > 0 {
var url string var url string
if r.URL.RawQuery != "" { if r.URL.RawQuery != "" {
@ -131,7 +132,7 @@ func (ms *MasterServer) redirectHandler(w http.ResponseWriter, r *http.Request)
} }
http.Redirect(w, r, url, http.StatusMovedPermanently) http.Redirect(w, r, url, http.StatusMovedPermanently)
} else { } else {
writeJsonError(w, r, http.StatusNotFound, fmt.Errorf("volume id %d not found", volumeId)) writeJsonError(w, r, http.StatusNotFound, fmt.Errorf("volume id %d or collection %s not found", volumeId, collection))
} }
} }