aboutsummaryrefslogtreecommitdiff
path: root/weed/filesys/file.go
diff options
context:
space:
mode:
authorchrislu <chris.lu@gmail.com>2022-01-10 00:52:16 -0800
committerchrislu <chris.lu@gmail.com>2022-01-10 00:52:16 -0800
commitcbc055dc2b1cfdea16ae557780a9476b566899fe (patch)
treee45b8381abad4b03e6ab5a966f25728b8805daf4 /weed/filesys/file.go
parent19555385f7b99bce0e1f562f3cd4a4f440dd3d8e (diff)
downloadseaweedfs-cbc055dc2b1cfdea16ae557780a9476b566899fe.tar.xz
seaweedfs-cbc055dc2b1cfdea16ae557780a9476b566899fe.zip
mount: file fsync
fix https://github.com/chrislusf/seaweedfs/issues/2561
Diffstat (limited to 'weed/filesys/file.go')
-rw-r--r--weed/filesys/file.go5
1 files changed, 3 insertions, 2 deletions
diff --git a/weed/filesys/file.go b/weed/filesys/file.go
index c7652843c..244ed38ea 100644
--- a/weed/filesys/file.go
+++ b/weed/filesys/file.go
@@ -248,11 +248,12 @@ func (file *File) Listxattr(ctx context.Context, req *fuse.ListxattrRequest, res
}
func (file *File) Fsync(ctx context.Context, req *fuse.FsyncRequest) error {
- // fsync works at OS level
+
// write the file chunks to the filerGrpcAddress
glog.V(4).Infof("%s/%s fsync file %+v", file.dir.FullPath(), file.Name, req)
- return nil
+ return file.wfs.Fsync(file, req.Header)
+
}
func (file *File) Forget() {