aboutsummaryrefslogtreecommitdiff
path: root/weed/filesys
diff options
context:
space:
mode:
Diffstat (limited to 'weed/filesys')
-rw-r--r--weed/filesys/file.go20
1 files changed, 16 insertions, 4 deletions
diff --git a/weed/filesys/file.go b/weed/filesys/file.go
index 4b711ecee..8a5b619ac 100644
--- a/weed/filesys/file.go
+++ b/weed/filesys/file.go
@@ -117,12 +117,12 @@ func (file *File) Setattr(ctx context.Context, req *fuse.SetattrRequest, resp *f
}
if file.isOpen > 0 {
file.wfs.handlesLock.Lock()
- fileHandle := file.wfs.handles[file.Id()]
+ fh := file.wfs.handles[file.Id()]
file.wfs.handlesLock.Unlock()
- if fileHandle != nil {
- fileHandle.Lock()
- defer fileHandle.Unlock()
+ if fh != nil {
+ fh.Lock()
+ defer fh.Unlock()
}
}
@@ -207,6 +207,11 @@ func (file *File) Setxattr(ctx context.Context, req *fuse.SetxattrRequest) error
if err := setxattr(entry, req); err != nil {
return err
}
+ file.dirtyMetadata = true
+
+ if file.isOpen > 0 {
+ return nil
+ }
return file.saveEntry(entry)
@@ -224,6 +229,11 @@ func (file *File) Removexattr(ctx context.Context, req *fuse.RemovexattrRequest)
if err := removexattr(entry, req); err != nil {
return err
}
+ file.dirtyMetadata = true
+
+ if file.isOpen > 0 {
+ return nil
+ }
return file.saveEntry(entry)
@@ -351,6 +361,8 @@ func (file *File) saveEntry(entry *filer_pb.Entry) error {
file.wfs.metaCache.InsertEntry(context.Background(), filer.FromPbEntry(request.Directory, request.Entry))
+ file.dirtyMetadata = false
+
return nil
})
}