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

filer: retryable when error is not found

Browse Source
This commit is contained in:
chrislu 2022-08-19 03:36:15 -07:00
parent 58dd880322
commit aac45f3e89
2 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
weed/server/volume_server_handlers_read.go
View File

@ -143,7 +143,11 @@ func (vs *VolumeServer) GetOrHeadHandler(w http.ResponseWriter, r *http.Request)
// glog.V(4).Infoln("read bytes", count, "error", err) // glog.V(4).Infoln("read bytes", count, "error", err)
if err != nil || count < 0 { if err != nil || count < 0 {
glog.V(3).Infof("read %s isNormalVolume %v error: %v", r.URL.Path, hasVolume, err) glog.V(3).Infof("read %s isNormalVolume %v error: %v", r.URL.Path, hasVolume, err)
w.WriteHeader(http.StatusNotFound) if err == storage.ErrorNotFound || err == storage.ErrorDeleted {
w.WriteHeader(http.StatusNotFound)
} else {
w.WriteHeader(http.StatusInternalServerError)
}
return return
} }
if n.Cookie != cookie { if n.Cookie != cookie {

2
weed/util/http_util.go
View File

@ -309,7 +309,7 @@ func ReadUrlAsStream(fileUrl string, cipherKey []byte, isContentGzipped bool, is
} }
defer CloseResponse(r) defer CloseResponse(r)
if r.StatusCode >= 400 { if r.StatusCode >= 400 {
retryable = r.StatusCode >= 500 retryable = r.StatusCode == http.StatusNotFound || r.StatusCode >= 500
return retryable, fmt.Errorf("%s: %s", fileUrl, r.Status) return retryable, fmt.Errorf("%s: %s", fileUrl, r.Status)
} }