From 843e778875072ab5b239ef4badd31229f7f85cee Mon Sep 17 00:00:00 2001 From: chrislu Date: Sat, 15 Jun 2024 09:41:08 -0700 Subject: [PATCH] refactor --- weed/filer/filer_deletion.go | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) 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())