aboutsummaryrefslogtreecommitdiff
path: root/weed/filesys/file.go
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2018-05-28 12:30:17 -0700
committerChris Lu <chris.lu@gmail.com>2018-05-28 12:30:17 -0700
commitd0b238d2db81093b7f02141d4f70b446fcd0b2cd (patch)
tree06ec63dbba299d85758c7197ed6dc155bcdda7dc /weed/filesys/file.go
parent07e0d13d2d13f53a6540e836189741186aaf060e (diff)
downloadseaweedfs-d0b238d2db81093b7f02141d4f70b446fcd0b2cd.tar.xz
seaweedfs-d0b238d2db81093b7f02141d4f70b446fcd0b2cd.zip
cache local writes before flushing to volume server
Diffstat (limited to 'weed/filesys/file.go')
-rw-r--r--weed/filesys/file.go11
1 files changed, 6 insertions, 5 deletions
diff --git a/weed/filesys/file.go b/weed/filesys/file.go
index 7ea14cc49..255fe4af0 100644
--- a/weed/filesys/file.go
+++ b/weed/filesys/file.go
@@ -84,11 +84,12 @@ func (file *File) Open(ctx context.Context, req *fuse.OpenRequest, resp *fuse.Op
file.isOpen = true
return &FileHandle{
- f: file,
- RequestId: req.Header.ID,
- NodeId: req.Header.Node,
- Uid: req.Uid,
- Gid: req.Gid,
+ f: file,
+ dirtyPages: &ContinuousDirtyPages{f: file},
+ RequestId: req.Header.ID,
+ NodeId: req.Header.Node,
+ Uid: req.Uid,
+ Gid: req.Gid,
}, nil
}