diff options
| author | chrislu <chris.lu@gmail.com> | 2022-08-31 00:09:23 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2022-08-31 00:09:23 -0700 |
| commit | a54f30b6c615570fe95323990f9dedca84a29c57 (patch) | |
| tree | 8a6901ef2a6b76de513daa686290bb8274367705 /weed/s3api | |
| parent | 7eb121d5ae1412aec7001533e76cf1070e74b5ef (diff) | |
| download | seaweedfs-a54f30b6c615570fe95323990f9dedca84a29c57.tar.xz seaweedfs-a54f30b6c615570fe95323990f9dedca84a29c57.zip | |
s3: close response body with copying object
Diffstat (limited to 'weed/s3api')
| -rw-r--r-- | weed/s3api/s3api_object_copy_handlers.go | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/weed/s3api/s3api_object_copy_handlers.go b/weed/s3api/s3api_object_copy_handlers.go index a5e8f128c..0e6c5ab89 100644 --- a/weed/s3api/s3api_object_copy_handlers.go +++ b/weed/s3api/s3api_object_copy_handlers.go @@ -174,11 +174,12 @@ func (s3a *S3ApiServer) CopyObjectPartHandler(w http.ResponseWriter, r *http.Req srcUrl := fmt.Sprintf("http://%s%s/%s%s", s3a.option.Filer.ToHttpAddress(), s3a.option.BucketsPath, srcBucket, urlPathEscape(srcObject)) - dataReader, err := util.ReadUrlAsReaderCloser(srcUrl, s3a.maybeGetFilerJwtAuthorizationToken(false), rangeHeader) + resp, dataReader, err := util.ReadUrlAsReaderCloser(srcUrl, s3a.maybeGetFilerJwtAuthorizationToken(false), rangeHeader) if err != nil { s3err.WriteErrorResponse(w, r, s3err.ErrInvalidCopySource) return } + defer util.CloseResponse(resp) defer dataReader.Close() glog.V(2).Infof("copy from %s to %s", srcUrl, dstUrl) |