can attr root directory

weed/mount/inode_to_path.go

@@ -0,0 +1,61 @@
+package mount
+
+import (
+	"github.com/chrislusf/seaweedfs/weed/glog"
+	"github.com/chrislusf/seaweedfs/weed/util"
+	"sync"
+)
+
+type InodeToPath struct {
+	sync.RWMutex
+	nextInodeId uint64
+	inode2path  map[uint64]util.FullPath
+	path2inode  map[util.FullPath]uint64
+}
+
+func NewInodeToPath() *InodeToPath {
+	return &InodeToPath{
+		inode2path:  make(map[uint64]util.FullPath),
+		path2inode:  make(map[util.FullPath]uint64),
+		nextInodeId: 2, // the root inode id is 1
+	}
+}
+
+func (i *InodeToPath) GetInode(path util.FullPath) uint64 {
+	if path == "/" {
+		return 1
+	}
+	i.Lock()
+	defer i.Unlock()
+	inode, found := i.path2inode[path]
+	if !found {
+		inode = i.nextInodeId
+		i.nextInodeId++
+		i.path2inode[path] = inode
+		i.inode2path[inode] = path
+	}
+	return inode
+}
+
+func (i *InodeToPath) GetPath(inode uint64) util.FullPath {
+	if inode == 1 {
+		return "/"
+	}
+	i.RLock()
+	defer i.RUnlock()
+	path, found := i.inode2path[inode]
+	if !found {
+		glog.Fatal("not found inode %d", inode)
+	}
+	return path
+}
+
+func (i *InodeToPath) HasPath(path util.FullPath) bool {
+	if path == "/" {
+		return true
+	}
+	i.RLock()
+	defer i.RUnlock()
+	_, found := i.path2inode[path]
+	return found
+}

weed/mount/weedfs.go

@@ -1,6 +1,7 @@
 package mount
 
 import (
+	"context"
 	"github.com/chrislusf/seaweedfs/weed/filesys/meta_cache"
 	"github.com/chrislusf/seaweedfs/weed/pb"
 	"github.com/chrislusf/seaweedfs/weed/pb/filer_pb"
@@ -53,11 +54,12 @@ type WFS struct {
 	// follow https://github.com/hanwen/go-fuse/blob/master/fuse/api.go
 	fuse.RawFileSystem
 	fs.Inode
-	option    *Option
+	option      *Option
-	metaCache *meta_cache.MetaCache
+	metaCache   *meta_cache.MetaCache
-	stats     statsCache
+	stats       statsCache
-	root      Directory
+	root        Directory
-	signature int32
+	signature   int32
+	inodeToPath *InodeToPath
 }
 
 func NewSeaweedFileSystem(option *Option) *WFS {
@@ -65,6 +67,7 @@ func NewSeaweedFileSystem(option *Option) *WFS {
 		RawFileSystem: fuse.NewDefaultRawFileSystem(),
 		option:        option,
 		signature:     util.RandomInt32(),
+		inodeToPath:   NewInodeToPath(),
 	}
 
 	wfs.root = Directory{
@@ -91,6 +94,40 @@ func (wfs *WFS) String() string {
 	return "seaweedfs"
 }
 
+func (wfs *WFS) maybeReadEntry(inode uint64) (*filer_pb.Entry, fuse.Status) {
+	path := wfs.inodeToPath.GetPath(inode)
+	return wfs.maybeLoadEntry(path)
+}
+
+func (wfs *WFS) maybeLoadEntry(fullpath util.FullPath) (*filer_pb.Entry, fuse.Status) {
+
+	// glog.V(3).Infof("read entry cache miss %s", fullpath)
+	dir, name := fullpath.DirAndName()
+
+	// return a valid entry for the mount root
+	if string(fullpath) == wfs.option.FilerMountRootPath {
+		return &filer_pb.Entry{
+			Name:        name,
+			IsDirectory: true,
+			Attributes: &filer_pb.FuseAttributes{
+				Mtime:    wfs.option.MountMtime.Unix(),
+				FileMode: uint32(wfs.option.MountMode),
+				Uid:      wfs.option.MountUid,
+				Gid:      wfs.option.MountGid,
+				Crtime:   wfs.option.MountCtime.Unix(),
+			},
+		}, fuse.OK
+	}
+
+	// read from async meta cache
+	meta_cache.EnsureVisited(wfs.metaCache, wfs, util.FullPath(dir))
+	cachedEntry, cacheErr := wfs.metaCache.FindEntry(context.Background(), fullpath)
+	if cacheErr == filer_pb.ErrNotFound {
+		return nil, fuse.ENOENT
+	}
+	return cachedEntry.ToProtoEntry(), fuse.ENOSYS
+}
+
 func (option *Option) setupUniqueCacheDirectory() {
 	cacheUniqueId := util.Md5String([]byte(option.MountDirectory + string(option.FilerAddresses[0]) + option.FilerMountRootPath + util.Version()))[0:8]
 	option.uniqueCacheDir = path.Join(option.CacheDir, cacheUniqueId)

weed/mount/weedfs_attr.go

@@ -0,0 +1,98 @@
+package mount
+
+import (
+	"github.com/chrislusf/seaweedfs/weed/filer"
+	"github.com/chrislusf/seaweedfs/weed/pb/filer_pb"
+	"github.com/hanwen/go-fuse/v2/fuse"
+	"os"
+	"syscall"
+	"time"
+)
+
+func (wfs *WFS) GetAttr(cancel <-chan struct{}, input *fuse.GetAttrIn, out *fuse.AttrOut) (code fuse.Status) {
+	println("input node id", input.NodeId)
+	if input.NodeId == 1 {
+		wfs.setRootAttr(out)
+		return fuse.OK
+	}
+
+	entry, status := wfs.maybeReadEntry(input.NodeId)
+	if status != fuse.OK {
+		return status
+	}
+	if entry.IsDirectory {
+
+	}
+
+	return fuse.ENOSYS
+}
+
+func (wfs *WFS) SetAttr(cancel <-chan struct{}, input *fuse.SetAttrIn, out *fuse.AttrOut) (code fuse.Status) {
+	return fuse.ENOSYS
+}
+func (wfs *WFS) GetXAttr(cancel <-chan struct{}, header *fuse.InHeader, attr string, dest []byte) (size uint32, code fuse.Status) {
+	return 0, fuse.ENOSYS
+}
+
+func (wfs *WFS) SetXAttr(cancel <-chan struct{}, input *fuse.SetXAttrIn, attr string, data []byte) fuse.Status {
+	return fuse.ENOSYS
+}
+
+func (wfs *WFS) ListXAttr(cancel <-chan struct{}, header *fuse.InHeader, dest []byte) (n uint32, code fuse.Status) {
+	return 0, fuse.ENOSYS
+}
+
+func (wfs *WFS) RemoveXAttr(cancel <-chan struct{}, header *fuse.InHeader, attr string) fuse.Status {
+	return fuse.ENOSYS
+}
+
+func (wfs *WFS) setRootAttr(out *fuse.AttrOut) {
+	now := uint64(time.Now().Second())
+	out.AttrValid = 119
+	out.Ino = 1
+	setBlksize(&out.Attr, blockSize)
+	out.Uid = wfs.option.MountUid
+	out.Gid = wfs.option.MountGid
+	out.Mtime = now
+	out.Ctime = now
+	out.Atime = now
+	out.Mode = uint32(syscall.S_IFDIR | wfs.option.MountMode)
+	out.Nlink = 1
+}
+
+func (wfs *WFS) setOutAttr(out *fuse.AttrOut, inode uint64, entry *filer_pb.Entry) {
+	out.AttrValid = 1
+	out.Ino = inode
+	out.Uid = entry.Attributes.Uid
+	out.Gid = entry.Attributes.Gid
+	out.Mode = entry.Attributes.FileMode
+	out.Mtime = uint64(entry.Attributes.Mtime)
+	out.Ctime = uint64(entry.Attributes.Mtime)
+	out.Atime = uint64(entry.Attributes.Mtime)
+	if entry.HardLinkCounter > 0 {
+		out.Nlink = uint32(entry.HardLinkCounter)
+	}
+	out.Size = filer.FileSize(entry)
+	out.Blocks = out.Size/blockSize + 1
+	setBlksize(&out.Attr, blockSize)
+	out.Nlink = 1
+}
+
+func osToSystemMode(mode os.FileMode) uint32 {
+	switch mode & 0x7F {
+	case os.ModeDir:
+		return syscall.S_IFDIR
+	case os.ModeSymlink:
+		return syscall.S_IFLNK
+	case os.ModeNamedPipe:
+		return syscall.S_IFIFO
+	case os.ModeSocket:
+		return syscall.S_IFSOCK
+	case os.ModeDevice:
+		return syscall.S_IFBLK
+	case os.ModeCharDevice:
+		return syscall.S_IFCHR
+	default:
+		return syscall.S_IFREG
+	}
+}

weed/mount/weedfs_attr_darwin.go

@@ -0,0 +1,8 @@
+package mount
+
+import (
+	"github.com/hanwen/go-fuse/v2/fuse"
+)
+
+func setBlksize(out *fuse.Attr, size uint32) {
+}

weed/mount/weedfs_attr_linux.go

@@ -0,0 +1,9 @@
+package mount
+
+import (
+	"github.com/hanwen/go-fuse/v2/fuse"
+)
+
+func setBlksize(out *fuse.Attr, size uint32) {
+	out.Blksize = size
+}