mirror of
https://github.com/seaweedfs/seaweedfs.git
synced 2024-01-19 02:48:24 +00:00
volume: handle repeated writes response
This commit is contained in:
parent
22400c6633
commit
f9b3750ad1
|
@ -188,12 +188,17 @@ func upload_content(uploadUrl string, fillBufferFunction func(w io.Writer) error
|
|||
return nil, post_err
|
||||
}
|
||||
defer resp.Body.Close()
|
||||
|
||||
var ret UploadResult
|
||||
etag := getEtag(resp)
|
||||
if resp.StatusCode == http.StatusNoContent {
|
||||
ret.ETag = etag
|
||||
return &ret, nil
|
||||
}
|
||||
resp_body, ra_err := ioutil.ReadAll(resp.Body)
|
||||
if ra_err != nil {
|
||||
return nil, ra_err
|
||||
}
|
||||
var ret UploadResult
|
||||
unmarshal_err := json.Unmarshal(resp_body, &ret)
|
||||
if unmarshal_err != nil {
|
||||
glog.V(0).Infoln("failing to read upload response", uploadUrl, string(resp_body))
|
||||
|
|
Loading…
Reference in a new issue