aboutsummaryrefslogtreecommitdiff
path: root/weed/filesys/wfs.go
diff options
context:
space:
mode:
Diffstat (limited to 'weed/filesys/wfs.go')
-rw-r--r--weed/filesys/wfs.go10
1 files changed, 8 insertions, 2 deletions
diff --git a/weed/filesys/wfs.go b/weed/filesys/wfs.go
index 56b69a8ac..2f885d0af 100644
--- a/weed/filesys/wfs.go
+++ b/weed/filesys/wfs.go
@@ -9,10 +9,12 @@ import (
"bazil.org/fuse"
"github.com/chrislusf/seaweedfs/weed/glog"
"github.com/chrislusf/seaweedfs/weed/util"
+ "strings"
)
type WFS struct {
filerGrpcAddress string
+ filerMountRootPath string
listDirectoryEntriesCache *ccache.Cache
collection string
replication string
@@ -26,9 +28,13 @@ type WFS struct {
pathToHandleLock sync.Mutex
}
-func NewSeaweedFileSystem(filerGrpcAddress string, collection string, replication string, ttlSec int32, chunkSizeLimitMB int, dataCenter string) *WFS {
+func NewSeaweedFileSystem(filerGrpcAddress string, filerMountRootPath string, collection string, replication string, ttlSec int32, chunkSizeLimitMB int, dataCenter string) *WFS {
+ if filerMountRootPath != "/" && strings.HasSuffix(filerMountRootPath, "/") {
+ filerMountRootPath = filerMountRootPath[0:len(filerMountRootPath)-1]
+ }
return &WFS{
filerGrpcAddress: filerGrpcAddress,
+ filerMountRootPath: filerMountRootPath,
listDirectoryEntriesCache: ccache.New(ccache.Configure().MaxSize(6000).ItemsToPrune(100)),
collection: collection,
replication: replication,
@@ -40,7 +46,7 @@ func NewSeaweedFileSystem(filerGrpcAddress string, collection string, replicatio
}
func (wfs *WFS) Root() (fs.Node, error) {
- return &Dir{Path: "/", wfs: wfs}, nil
+ return &Dir{Path: wfs.filerMountRootPath, wfs: wfs}, nil
}
func (wfs *WFS) withFilerClient(fn func(filer_pb.SeaweedFilerClient) error) error {