diff options
| author | chrislu <chris.lu@gmail.com> | 2024-06-15 09:41:08 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2024-06-15 09:41:08 -0700 |
| commit | 843e778875072ab5b239ef4badd31229f7f85cee (patch) | |
| tree | 92ea17358f223eb4f6607057f53f43008016d01f | |
| parent | 677cfb8ad1b9c9e0206ae63d568928f9a052a21d (diff) | |
| download | seaweedfs-843e778875072ab5b239ef4badd31229f7f85cee.tar.xz seaweedfs-843e778875072ab5b239ef4badd31229f7f85cee.zip | |
refactor
| -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()) |