aboutsummaryrefslogtreecommitdiff
path: root/weed/server/common.go
diff options
context:
space:
mode:
authorLHHDZ <changlin.shi@ly.com>2022-06-20 13:42:18 +0800
committerGitHub <noreply@github.com>2022-06-20 13:42:18 +0800
commit8db9f13bc69be974fbd18c4b0aacd071ea1acaa9 (patch)
treee84927ea360a7ede80d13fe7aada59356c0475ce /weed/server/common.go
parent9e036df3566e842710ea2b0ed3ad28f5af2a1885 (diff)
parent1baa7ead59a0a040d1165e3579cf79f90c20dd65 (diff)
downloadseaweedfs-8db9f13bc69be974fbd18c4b0aacd071ea1acaa9.tar.xz
seaweedfs-8db9f13bc69be974fbd18c4b0aacd071ea1acaa9.zip
Merge branch 'master' into circuit_breaker
Diffstat (limited to 'weed/server/common.go')
-rw-r--r--weed/server/common.go4
1 files changed, 4 insertions, 0 deletions
diff --git a/weed/server/common.go b/weed/server/common.go
index 39a8637ac..f02ec67ac 100644
--- a/weed/server/common.go
+++ b/weed/server/common.go
@@ -284,6 +284,7 @@ func processRangeRequest(r *http.Request, w http.ResponseWriter, totalSize int64
if rangeReq == "" {
w.Header().Set("Content-Length", strconv.FormatInt(totalSize, 10))
if err := writeFn(bufferedWriter, 0, totalSize); err != nil {
+ glog.Errorf("processRangeRequest headers: %+v err: %v", w.Header(), err)
http.Error(w, err.Error(), http.StatusInternalServerError)
return
}
@@ -294,6 +295,7 @@ func processRangeRequest(r *http.Request, w http.ResponseWriter, totalSize int64
//mostly copy from src/pkg/net/http/fs.go
ranges, err := parseRange(rangeReq, totalSize)
if err != nil {
+ glog.Errorf("processRangeRequest headers: %+v err: %v", w.Header(), err)
http.Error(w, err.Error(), http.StatusRequestedRangeNotSatisfiable)
return
}
@@ -326,6 +328,7 @@ func processRangeRequest(r *http.Request, w http.ResponseWriter, totalSize int64
w.WriteHeader(http.StatusPartialContent)
err = writeFn(bufferedWriter, ra.start, ra.length)
if err != nil {
+ glog.Errorf("processRangeRequest headers: %+v err: %v", w.Header(), err)
http.Error(w, err.Error(), http.StatusInternalServerError)
return
}
@@ -365,6 +368,7 @@ func processRangeRequest(r *http.Request, w http.ResponseWriter, totalSize int64
}
w.WriteHeader(http.StatusPartialContent)
if _, err := io.CopyN(bufferedWriter, sendContent, sendSize); err != nil {
+ glog.Errorf("processRangeRequest err: %v", err)
http.Error(w, "Internal Error", http.StatusInternalServerError)
return
}