From b154af8be4caa53b104fbac3ec6d9a2b53ee6af2 Mon Sep 17 00:00:00 2001 From: Haiyan Meng Date: Wed, 8 Jan 2020 10:32:12 -0800 Subject: [PATCH] Check the error of closing response body --- api/internal/crawl/crawler/github/crawler.go | 21 ++++++++++++++------ 1 file changed, 15 insertions(+), 6 deletions(-) diff --git a/api/internal/crawl/crawler/github/crawler.go b/api/internal/crawl/crawler/github/crawler.go index 6467294da..0ad438169 100644 --- a/api/internal/crawl/crawler/github/crawler.go +++ b/api/internal/crawl/crawler/github/crawler.go @@ -124,7 +124,7 @@ func (gc githubCrawler) FetchDocument(_ context.Context, d *doc.Document) error } if err == nil && resp.StatusCode == http.StatusOK { d.IsSame = httpclient.FromCache(resp.Header) - defer resp.Body.Close() + defer CloseResponseBody(resp) data, err := ioutil.ReadAll(resp.Body) if err != nil { return err @@ -311,7 +311,10 @@ func (gcl GhClient) GetFileData(k GhFileSpec) ([]byte, error) { return nil, fmt.Errorf("%+v: could not read '%s' metadata: %v", k, url, err) } - resp.Body.Close() + + if err := resp.Body.Close(); err != nil { + return nil, err + } type githubContentRawURL struct { DownloadURL string `json:"download_url,omitempty"` @@ -330,18 +333,24 @@ func (gcl GhClient) GetFileData(k GhFileSpec) ([]byte, error) { k, rawURL.DownloadURL, err) } - defer resp.Body.Close() + defer CloseResponseBody(resp) data, err = ioutil.ReadAll(resp.Body) return data, err } +func CloseResponseBody(resp *http.Response) { + if err := resp.Body.Close(); err != nil { + log.Printf("failed to close response body: %v", err) + } +} + func (gcl GhClient) GetDefaultBranch(url string) (string, error) { resp, err := gcl.GetReposData(url) if err != nil { return "", fmt.Errorf( "'%s' could not get default_branch: %v", url, err) } - defer resp.Body.Close() + defer CloseResponseBody(resp) data, err := ioutil.ReadAll(resp.Body) if err != nil { return "", fmt.Errorf( @@ -393,7 +402,7 @@ func (gcl GhClient) GetFileCreationTime( } } - defer resp.Body.Close() + defer CloseResponseBody(resp) data, err := ioutil.ReadAll(resp.Body) if err != nil { return defaultTime, fmt.Errorf( @@ -516,7 +525,7 @@ func (gcl GhClient) parseGithubResponse(getRequest string) GhResponseInfo { } var data []byte - defer resp.Body.Close() + defer CloseResponseBody(resp) data, requestInfo.Error = ioutil.ReadAll(resp.Body) if requestInfo.Error != nil { return requestInfo