Sfoglia il codice sorgente

Close s3 request body on error if any

DarthSim 2 anni fa
parent
commit
d2cca005d3
1 ha cambiato i file con 4 aggiunte e 0 eliminazioni
  1. 4 0
      transport/s3/s3.go

+ 4 - 0
transport/s3/s3.go

@@ -64,6 +64,10 @@ func (t transport) RoundTrip(req *http.Request) (resp *http.Response, err error)
 	s3req, _ := t.svc.GetObjectRequest(input)
 
 	if err := s3req.Send(); err != nil {
+		if s3req.HTTPResponse != nil && s3req.HTTPResponse.Body != nil {
+			s3req.HTTPResponse.Body.Close()
+		}
+
 		if s3err, ok := err.(awserr.RequestFailure); !ok || s3err.StatusCode() < 100 || s3err.StatusCode() == 301 {
 			return nil, err
 		} else {