diff options
Diffstat (limited to 'weed/filesys')
| -rw-r--r-- | weed/filesys/dir.go | 11 | ||||
| -rw-r--r-- | weed/filesys/dirty_page.go | 4 | ||||
| -rw-r--r-- | weed/filesys/wfs.go | 8 |
3 files changed, 14 insertions, 9 deletions
diff --git a/weed/filesys/dir.go b/weed/filesys/dir.go index e53c4cfaf..b90e428ab 100644 --- a/weed/filesys/dir.go +++ b/weed/filesys/dir.go @@ -123,11 +123,12 @@ func (dir *Dir) Create(ctx context.Context, req *fuse.CreateRequest, dir.NodeMap[req.Name] = file file.isOpen = true return file, &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 } diff --git a/weed/filesys/dirty_page.go b/weed/filesys/dirty_page.go index bfb73f3b0..da442d6c6 100644 --- a/weed/filesys/dirty_page.go +++ b/weed/filesys/dirty_page.go @@ -108,8 +108,8 @@ func (pages *ContinuousDirtyPages) saveToStorage(ctx context.Context) (*filer_pb request := &filer_pb.AssignVolumeRequest{ Count: 1, - Replication: "000", - Collection: "", + Replication: pages.f.wfs.replication, + Collection: pages.f.wfs.collection, } resp, err := client.AssignVolume(ctx, request) diff --git a/weed/filesys/wfs.go b/weed/filesys/wfs.go index 1b843e2d7..b9cb0210b 100644 --- a/weed/filesys/wfs.go +++ b/weed/filesys/wfs.go @@ -11,12 +11,16 @@ import ( type WFS struct { filer string listDirectoryEntriesCache *ccache.Cache + collection string + replication string } -func NewSeaweedFileSystem(filer string) *WFS { +func NewSeaweedFileSystem(filer string, collection string, replication string) *WFS { return &WFS{ - filer: filer, + filer: filer, listDirectoryEntriesCache: ccache.New(ccache.Configure().MaxSize(6000).ItemsToPrune(100)), + collection: collection, + replication: replication, } } |