mirror of
https://github.com/seaweedfs/seaweedfs.git
synced 2024-01-19 02:48:24 +00:00
fix
This commit is contained in:
parent
5d86b50782
commit
b5c29e25aa
|
@ -135,7 +135,7 @@ func PostHandler(w http.ResponseWriter, r *http.Request) {
|
||||||
ret := store.Write(volumeId, needle)
|
ret := store.Write(volumeId, needle)
|
||||||
if ret > 0 || !store.HasVolume(volumeId) { //send to other replica locations
|
if ret > 0 || !store.HasVolume(volumeId) { //send to other replica locations
|
||||||
if r.FormValue("type") != "standard" {
|
if r.FormValue("type") != "standard" {
|
||||||
if lookupResult, lookupErr := operation.Lookup(*server, volumeId); lookupErr == nil {
|
if lookupResult, lookupErr := operation.Lookup(*masterNode, volumeId); lookupErr == nil {
|
||||||
sendFunc := func(background bool) {
|
sendFunc := func(background bool) {
|
||||||
postContentFunc := func(location operation.Location) bool {
|
postContentFunc := func(location operation.Location) bool {
|
||||||
operation.Upload("http://"+location.Url+r.URL.Path+"?type=standard", filename, bytes.NewReader(needle.Data))
|
operation.Upload("http://"+location.Url+r.URL.Path+"?type=standard", filename, bytes.NewReader(needle.Data))
|
||||||
|
|
Loading…
Reference in a new issue