aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2018-09-12 01:00:51 -0700
committerChris Lu <chris.lu@gmail.com>2018-09-12 01:00:51 -0700
commitf628953c330936d68bad0ce86df07adb8b2f70af (patch)
tree2e2e41f0418a81b46c6e3293058a9dc38c317d7e
parentf6d8525d1d8c1faf9a0826472bfcef0592ba3a93 (diff)
downloadseaweedfs-f628953c330936d68bad0ce86df07adb8b2f70af.tar.xz
seaweedfs-f628953c330936d68bad0ce86df07adb8b2f70af.zip
cleanup tmp upload directories
-rw-r--r--weed/s3api/filer_multipart.go5
1 files changed, 5 insertions, 0 deletions
diff --git a/weed/s3api/filer_multipart.go b/weed/s3api/filer_multipart.go
index a688b917a..73be496d9 100644
--- a/weed/s3api/filer_multipart.go
+++ b/weed/s3api/filer_multipart.go
@@ -102,6 +102,10 @@ func (s3a *S3ApiServer) completeMultipartUpload(input *s3.CompleteMultipartUploa
},
}
+ if err = s3a.rm(s3a.genUploadsFolder(*input.Bucket), *input.UploadId, true, false, true); err != nil {
+ glog.V(1).Infof("completeMultipartUpload cleanup %s upload %s: %v", *input.Bucket, *input.UploadId, err)
+ }
+
return
}
@@ -155,6 +159,7 @@ func (s3a *S3ApiServer) listMultipartUploads(input *s3.ListMultipartUploadsInput
})
}
}
+
return
}