aboutsummaryrefslogtreecommitdiff
path: root/weed/filesys/filehandle.go
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2021-04-20 19:56:51 -0700
committerChris Lu <chris.lu@gmail.com>2021-04-20 19:56:55 -0700
commit11c405fc854d17db98929771c1270300a5293929 (patch)
tree65e499fff74e470deaa665889157629b27b84c6a /weed/filesys/filehandle.go
parent72e9d9673ebc04b46d2182706f91db62d2a7d2d5 (diff)
downloadseaweedfs-11c405fc854d17db98929771c1270300a5293929.tar.xz
seaweedfs-11c405fc854d17db98929771c1270300a5293929.zip
ensure file handles are released
Diffstat (limited to 'weed/filesys/filehandle.go')
-rw-r--r--weed/filesys/filehandle.go14
1 files changed, 7 insertions, 7 deletions
diff --git a/weed/filesys/filehandle.go b/weed/filesys/filehandle.go
index 3f4ee69f4..27ffab6e1 100644
--- a/weed/filesys/filehandle.go
+++ b/weed/filesys/filehandle.go
@@ -200,13 +200,7 @@ func (fh *FileHandle) Release(ctx context.Context, req *fuse.ReleaseRequest) err
fh.f.isOpen--
- if fh.f.isOpen < 0 {
- glog.V(0).Infof("Release reset %s open count %d => %d", fh.f.Name, fh.f.isOpen, 0)
- fh.f.isOpen = 0
- return nil
- }
-
- if fh.f.isOpen == 0 {
+ if fh.f.isOpen <= 0 {
fh.f.entry = nil
fh.entryViewCache = nil
fh.reader = nil
@@ -214,6 +208,12 @@ func (fh *FileHandle) Release(ctx context.Context, req *fuse.ReleaseRequest) err
fh.f.wfs.ReleaseHandle(fh.f.fullpath(), fuse.HandleID(fh.handle))
}
+ if fh.f.isOpen < 0 {
+ glog.V(0).Infof("Release reset %s open count %d => %d", fh.f.Name, fh.f.isOpen, 0)
+ fh.f.isOpen = 0
+ return nil
+ }
+
return nil
}