diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-03-25 02:21:15 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-03-25 02:21:15 -0700 |
| commit | 6d87a0c5f588e814917c7f28e175ac1b9c0f2023 (patch) | |
| tree | 74e7625f8b566e6f77833f79721ad1f69181168a /weed/operation/delete_content.go | |
| parent | 5ebc95b69bad1014980c5165d7cb382ace296880 (diff) | |
| download | seaweedfs-6d87a0c5f588e814917c7f28e175ac1b9c0f2023.tar.xz seaweedfs-6d87a0c5f588e814917c7f28e175ac1b9c0f2023.zip | |
batch delete orphan data by file keys
Diffstat (limited to 'weed/operation/delete_content.go')
| -rw-r--r-- | weed/operation/delete_content.go | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/weed/operation/delete_content.go b/weed/operation/delete_content.go index d4a72f375..9868a411d 100644 --- a/weed/operation/delete_content.go +++ b/weed/operation/delete_content.go @@ -101,7 +101,7 @@ func DeleteFilesWithLookupVolumeId(grpcDialOption grpc.DialOption, fileIds []str go func(server string, fidList []string) { defer wg.Done() - if deleteResults, deleteErr := DeleteFilesAtOneVolumeServer(server, grpcDialOption, fidList); deleteErr != nil { + if deleteResults, deleteErr := DeleteFilesAtOneVolumeServer(server, grpcDialOption, fidList, true); deleteErr != nil { err = deleteErr } else if deleteResults != nil { resultChan <- deleteResults @@ -120,12 +120,13 @@ func DeleteFilesWithLookupVolumeId(grpcDialOption grpc.DialOption, fileIds []str } // DeleteFilesAtOneVolumeServer deletes a list of files that is on one volume server via gRpc -func DeleteFilesAtOneVolumeServer(volumeServer string, grpcDialOption grpc.DialOption, fileIds []string) (ret []*volume_server_pb.DeleteResult, err error) { +func DeleteFilesAtOneVolumeServer(volumeServer string, grpcDialOption grpc.DialOption, fileIds []string, includeCookie bool) (ret []*volume_server_pb.DeleteResult, err error) { err = WithVolumeServerClient(volumeServer, grpcDialOption, func(volumeServerClient volume_server_pb.VolumeServerClient) error { req := &volume_server_pb.BatchDeleteRequest{ - FileIds: fileIds, + FileIds: fileIds, + SkipCookieCheck: !includeCookie, } resp, err := volumeServerClient.BatchDelete(context.Background(), req) |