diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-02-14 09:46:36 -0800 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-02-14 09:46:36 -0800 |
| commit | 96c1ae84719e934231e0a81c89917d1190be5e39 (patch) | |
| tree | e2157e651de64141a810a9603cdedfdafe2eacad /weed/util/http_util.go | |
| parent | cf5064d7025c6b74ac721b8914a76d5f1d155836 (diff) | |
| download | seaweedfs-96c1ae84719e934231e0a81c89917d1190be5e39.tar.xz seaweedfs-96c1ae84719e934231e0a81c89917d1190be5e39.zip | |
refactoring the close http response
Diffstat (limited to 'weed/util/http_util.go')
| -rw-r--r-- | weed/util/http_util.go | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/weed/util/http_util.go b/weed/util/http_util.go index 38202f4de..f819d8497 100644 --- a/weed/util/http_util.go +++ b/weed/util/http_util.go @@ -88,7 +88,7 @@ func Head(url string) (http.Header, error) { if err != nil { return nil, err } - defer closeResp(r) + defer CloseResponse(r) if r.StatusCode >= 400 { return nil, fmt.Errorf("%s: %s", url, r.Status) } @@ -130,7 +130,7 @@ func GetBufferStream(url string, values url.Values, allocatedBytes []byte, eachB if err != nil { return err } - defer closeResp(r) + defer CloseResponse(r) if r.StatusCode != 200 { return fmt.Errorf("%s: %s", url, r.Status) } @@ -153,7 +153,7 @@ func GetUrlStream(url string, values url.Values, readFn func(io.Reader) error) e if err != nil { return err } - defer closeResp(r) + defer CloseResponse(r) if r.StatusCode != 200 { return fmt.Errorf("%s: %s", url, r.Status) } @@ -262,7 +262,7 @@ func ReadUrlAsStream(fileUrl string, offset int64, size int, fn func(data []byte if err != nil { return 0, err } - defer closeResp(r) + defer CloseResponse(r) if r.StatusCode >= 400 { return 0, fmt.Errorf("%s: %s", fileUrl, r.Status) } @@ -308,7 +308,7 @@ func ReadUrlAsReaderCloser(fileUrl string, rangeHeader string) (io.ReadCloser, e return r.Body, nil } -func closeResp(resp *http.Response) { +func CloseResponse(resp *http.Response) { io.Copy(ioutil.Discard, resp.Body) resp.Body.Close() } |
