diff options
| -rw-r--r-- | weed/filer/filer_deletion.go | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/weed/filer/filer_deletion.go b/weed/filer/filer_deletion.go index 9ea89de2d..d27e54954 100644 --- a/weed/filer/filer_deletion.go +++ b/weed/filer/filer_deletion.go @@ -114,10 +114,14 @@ func (f *Filer) DirectDeleteChunks(chunks []*filer_pb.FileChunk) { } func (f *Filer) DeleteUncommittedChunks(chunks []*filer_pb.FileChunk) { - f.DeleteChunks(chunks) + f.doDeleteChunks(chunks) } func (f *Filer) DeleteChunks(chunks []*filer_pb.FileChunk) { + f.doDeleteChunks(chunks) +} + +func (f *Filer) doDeleteChunks(chunks []*filer_pb.FileChunk) { for _, chunk := range chunks { if !chunk.IsChunkManifest { f.fileIdDeletionQueue.EnQueue(chunk.GetFileIdString()) |