aboutsummaryrefslogtreecommitdiff
path: root/weed/util/http_util.go
diff options
context:
space:
mode:
authorLars Lehtonen <lars.lehtonen@gmail.com>2023-09-01 13:10:45 -0700
committerGitHub <noreply@github.com>2023-09-01 13:10:45 -0700
commite6385e5e8b3b18f962df6c0dc6065c2ffc2452b6 (patch)
treedb33f177b45f56387608441f05cd75bf33b39ffb /weed/util/http_util.go
parentf139a56cb95ddf9823226bc2d9fbdad31cb69511 (diff)
downloadseaweedfs-e6385e5e8b3b18f962df6c0dc6065c2ffc2452b6.tar.xz
seaweedfs-e6385e5e8b3b18f962df6c0dc6065c2ffc2452b6.zip
weed/util: fix dropped errors (#4803)
Diffstat (limited to 'weed/util/http_util.go')
-rw-r--r--weed/util/http_util.go12
1 files changed, 12 insertions, 0 deletions
diff --git a/weed/util/http_util.go b/weed/util/http_util.go
index bb1a32ede..ef4b29158 100644
--- a/weed/util/http_util.go
+++ b/weed/util/http_util.go
@@ -54,6 +54,9 @@ func Post(url string, values url.Values) ([]byte, error) {
func Get(url string) ([]byte, bool, error) {
request, err := http.NewRequest("GET", url, nil)
+ if err != nil {
+ return nil, true, err
+ }
request.Header.Add("Accept-Encoding", "gzip")
response, err := client.Do(request)
@@ -66,6 +69,9 @@ func Get(url string) ([]byte, bool, error) {
switch response.Header.Get("Content-Encoding") {
case "gzip":
reader, err = gzip.NewReader(response.Body)
+ if err != nil {
+ return nil, true, err
+ }
defer reader.Close()
default:
reader = response.Body
@@ -253,6 +259,9 @@ func ReadUrl(fileUrl string, cipherKey []byte, isContentCompressed bool, isFullC
switch contentEncoding {
case "gzip":
reader, err = gzip.NewReader(r.Body)
+ if err != nil {
+ return 0, err
+ }
defer reader.Close()
default:
reader = r.Body
@@ -400,6 +409,9 @@ func ReadUrlAsReaderCloser(fileUrl string, jwt string, rangeHeader string) (*htt
switch contentEncoding {
case "gzip":
reader, err = gzip.NewReader(r.Body)
+ if err != nil {
+ return nil, nil, err
+ }
default:
reader = r.Body
}