diff options
Diffstat (limited to 'weed/filesys')
| -rw-r--r-- | weed/filesys/dirty_page.go | 1 | ||||
| -rw-r--r-- | weed/filesys/wfs.go | 4 |
2 files changed, 4 insertions, 1 deletions
diff --git a/weed/filesys/dirty_page.go b/weed/filesys/dirty_page.go index 172262c98..6a7b557c2 100644 --- a/weed/filesys/dirty_page.go +++ b/weed/filesys/dirty_page.go @@ -122,6 +122,7 @@ func (pages *ContinuousDirtyPages) saveToStorage(ctx context.Context, buf []byte Replication: pages.f.wfs.replication, Collection: pages.f.wfs.collection, TtlSec: pages.f.wfs.ttlSec, + DataCenter: pages.f.wfs.dataCenter, } resp, err := client.AssignVolume(ctx, request) diff --git a/weed/filesys/wfs.go b/weed/filesys/wfs.go index d7e133483..56b69a8ac 100644 --- a/weed/filesys/wfs.go +++ b/weed/filesys/wfs.go @@ -18,6 +18,7 @@ type WFS struct { replication string ttlSec int32 chunkSizeLimit int64 + dataCenter string // contains all open handles handles []*FileHandle @@ -25,7 +26,7 @@ type WFS struct { pathToHandleLock sync.Mutex } -func NewSeaweedFileSystem(filerGrpcAddress string, collection string, replication string, ttlSec int32, chunkSizeLimitMB int) *WFS { +func NewSeaweedFileSystem(filerGrpcAddress string, collection string, replication string, ttlSec int32, chunkSizeLimitMB int, dataCenter string) *WFS { return &WFS{ filerGrpcAddress: filerGrpcAddress, listDirectoryEntriesCache: ccache.New(ccache.Configure().MaxSize(6000).ItemsToPrune(100)), @@ -33,6 +34,7 @@ func NewSeaweedFileSystem(filerGrpcAddress string, collection string, replicatio replication: replication, ttlSec: ttlSec, chunkSizeLimit: int64(chunkSizeLimitMB) * 1024 * 1024, + dataCenter: dataCenter, pathToHandleIndex: make(map[string]int), } } |