aboutsummaryrefslogtreecommitdiff
path: root/weed/filesys/dir.go
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2021-06-15 12:45:20 -0700
committerChris Lu <chris.lu@gmail.com>2021-06-15 12:45:23 -0700
commit055374a50bc3cfe78be6d73514182decb8531666 (patch)
treec8a8e3d89f8aeab739816c897e4cda452c6fe0d7 /weed/filesys/dir.go
parentcd59573dd3cdb797783091bae1c6d4464e3c423c (diff)
downloadseaweedfs-055374a50bc3cfe78be6d73514182decb8531666.tar.xz
seaweedfs-055374a50bc3cfe78be6d73514182decb8531666.zip
FUSE: skip flushing if file is deleted
related to https://github.com/chrislusf/seaweedfs/issues/2110
Diffstat (limited to 'weed/filesys/dir.go')
-rw-r--r--weed/filesys/dir.go5
1 files changed, 4 insertions, 1 deletions
diff --git a/weed/filesys/dir.go b/weed/filesys/dir.go
index 904999c43..1af868d58 100644
--- a/weed/filesys/dir.go
+++ b/weed/filesys/dir.go
@@ -443,7 +443,10 @@ func (dir *Dir) removeOneFile(req *fuse.RemoveRequest) error {
dir.wfs.handlesLock.Lock()
defer dir.wfs.handlesLock.Unlock()
inodeId := filePath.AsInode()
- delete(dir.wfs.handles, inodeId)
+ if fh, ok := dir.wfs.handles[inodeId]; ok {
+ delete(dir.wfs.handles, inodeId)
+ fh.isDeleted = true
+ }
return nil