lsm/seaweedfs
1
0
Fork 0
mirror of https://github.com/seaweedfs/seaweedfs.git synced 2025-09-21 06:47:56 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

print out the url

Browse Source
This commit is contained in:
Chris Lu
2021-03-11 18:39:45 -08:00
parent 7f887c78d2
commit cca66c7fbe
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
weed/shell/command_s3_clean_uploads.go
View File

@@ -78,9 +78,10 @@ func (c *commandS3CleanUploads) cleanupUploads(commandEnv *CommandEnv, writer io
} }
for _, staleUpload:= range staleUploads { for _, staleUpload:= range staleUploads {
fmt.Fprintf(writer, "purge %s/%s\n", uploadsDir, staleUpload) deleteUrl := fmt.Sprintf("http://%s:%d%s/%s?recursive=true&ignoreRecursiveError=true",commandEnv.option.FilerHost, commandEnv.option.FilerPort,uploadsDir, staleUpload)
fmt.Fprintf(writer, "purge %s\n", deleteUrl)
err = util.Delete(fmt.Sprintf("http://%s:%d%s/%s?recursive=true&ignoreRecursiveError=true",commandEnv.option.FilerHost, commandEnv.option.FilerPort,uploadsDir, staleUpload), "") err = util.Delete(deleteUrl, "")
if err != nil { if err != nil {
return fmt.Errorf("purge %s/%s: %v", uploadsDir, staleUpload, err) return fmt.Errorf("purge %s/%s: %v", uploadsDir, staleUpload, err)
} }