mirror of
https://github.com/seaweedfs/seaweedfs.git
synced 2025-09-24 17:43:37 +08:00
better clean up upload directory
This commit is contained in:
@@ -55,10 +55,11 @@ func (s3a *S3ApiServer) rm(parentDirectoryPath, entryName string, isDeleteData,
|
|||||||
|
|
||||||
func doDeleteEntry(client filer_pb.SeaweedFilerClient, parentDirectoryPath string, entryName string, isDeleteData bool, isRecursive bool) error {
|
func doDeleteEntry(client filer_pb.SeaweedFilerClient, parentDirectoryPath string, entryName string, isDeleteData bool, isRecursive bool) error {
|
||||||
request := &filer_pb.DeleteEntryRequest{
|
request := &filer_pb.DeleteEntryRequest{
|
||||||
Directory: parentDirectoryPath,
|
Directory: parentDirectoryPath,
|
||||||
Name: entryName,
|
Name: entryName,
|
||||||
IsDeleteData: isDeleteData,
|
IsDeleteData: isDeleteData,
|
||||||
IsRecursive: isRecursive,
|
IsRecursive: isRecursive,
|
||||||
|
IgnoreRecursiveError: true,
|
||||||
}
|
}
|
||||||
|
|
||||||
glog.V(1).Infof("delete entry %v/%v: %v", parentDirectoryPath, entryName, request)
|
glog.V(1).Infof("delete entry %v/%v: %v", parentDirectoryPath, entryName, request)
|
||||||
|
Reference in New Issue
Block a user