seaweedfs/weed/filesys/dir.go

605 lines
16 KiB
Go
Raw Normal View History

2018-05-06 05:47:16 +00:00
package filesys
import (
"bytes"
2018-05-06 05:47:16 +00:00
"context"
"math"
2018-05-06 06:39:29 +00:00
"os"
"strings"
"syscall"
"time"
2020-06-28 17:14:17 +00:00
"github.com/seaweedfs/fuse"
"github.com/seaweedfs/fuse/fs"
2020-09-01 07:21:19 +00:00
"github.com/chrislusf/seaweedfs/weed/filer"
2020-06-19 16:45:27 +00:00
"github.com/chrislusf/seaweedfs/weed/filesys/meta_cache"
2018-05-08 08:59:43 +00:00
"github.com/chrislusf/seaweedfs/weed/glog"
2018-05-10 06:18:02 +00:00
"github.com/chrislusf/seaweedfs/weed/pb/filer_pb"
2020-03-23 07:01:34 +00:00
"github.com/chrislusf/seaweedfs/weed/util"
2018-05-06 05:47:16 +00:00
)
type Dir struct {
name string
wfs *WFS
entry *filer_pb.Entry
parent *Dir
2021-04-17 17:48:22 +00:00
id uint64
2018-05-06 05:47:16 +00:00
}
2018-05-19 20:51:44 +00:00
var _ = fs.Node(&Dir{})
//var _ = fs.NodeIdentifier(&Dir{})
2018-05-25 07:57:25 +00:00
var _ = fs.NodeCreater(&Dir{})
2020-10-31 06:51:32 +00:00
var _ = fs.NodeMknoder(&Dir{})
2018-05-25 07:57:25 +00:00
var _ = fs.NodeMkdirer(&Dir{})
var _ = fs.NodeFsyncer(&Dir{})
var _ = fs.NodeRequestLookuper(&Dir{})
2018-05-19 20:51:44 +00:00
var _ = fs.HandleReadDirAller(&Dir{})
2018-05-25 07:57:25 +00:00
var _ = fs.NodeRemover(&Dir{})
2018-06-07 05:11:01 +00:00
var _ = fs.NodeRenamer(&Dir{})
var _ = fs.NodeSetattrer(&Dir{})
2019-12-16 05:07:01 +00:00
var _ = fs.NodeGetxattrer(&Dir{})
var _ = fs.NodeSetxattrer(&Dir{})
var _ = fs.NodeRemovexattrer(&Dir{})
var _ = fs.NodeListxattrer(&Dir{})
var _ = fs.NodeForgetter(&Dir{})
2018-05-19 20:51:44 +00:00
func (dir *Dir) xId() uint64 {
2021-04-17 17:48:22 +00:00
return dir.id
}
2019-03-16 00:20:24 +00:00
func (dir *Dir) Attr(ctx context.Context, attr *fuse.Attr) error {
2018-05-21 08:25:30 +00:00
2018-11-18 15:49:14 +00:00
// https://github.com/bazil/fuse/issues/196
attr.Valid = time.Second
if dir.FullPath() == dir.wfs.option.FilerMountRootPath {
2019-05-10 22:03:31 +00:00
dir.setRootDirAttributes(attr)
glog.V(3).Infof("root dir Attr %s, attr: %+v", dir.FullPath(), attr)
2018-05-21 08:25:30 +00:00
return nil
}
2021-04-15 03:26:13 +00:00
entry, err := dir.maybeLoadEntry()
if err != nil {
glog.V(3).Infof("dir Attr %s,err: %+v", dir.FullPath(), err)
2019-12-16 05:07:01 +00:00
return err
2019-12-13 18:35:23 +00:00
}
// attr.Inode = dir.Id()
2021-04-15 03:26:13 +00:00
attr.Mode = os.FileMode(entry.Attributes.FileMode) | os.ModeDir
attr.Mtime = time.Unix(entry.Attributes.Mtime, 0)
attr.Crtime = time.Unix(entry.Attributes.Crtime, 0)
attr.Gid = entry.Attributes.Gid
attr.Uid = entry.Attributes.Uid
2020-08-31 03:12:04 +00:00
glog.V(4).Infof("dir Attr %s, attr: %+v", dir.FullPath(), attr)
2019-12-16 05:07:01 +00:00
return nil
}
2019-12-16 05:07:01 +00:00
func (dir *Dir) Getxattr(ctx context.Context, req *fuse.GetxattrRequest, resp *fuse.GetxattrResponse) error {
glog.V(4).Infof("dir Getxattr %s", dir.FullPath())
2021-04-15 03:26:13 +00:00
entry, err := dir.maybeLoadEntry()
if err != nil {
2018-05-21 08:25:30 +00:00
return err
}
2021-04-15 03:26:13 +00:00
return getxattr(entry, req, resp)
2018-05-06 05:47:16 +00:00
}
2019-05-10 22:03:31 +00:00
func (dir *Dir) setRootDirAttributes(attr *fuse.Attr) {
// attr.Inode = 1 // filer2.FullPath(dir.Path).AsInode()
attr.Valid = time.Second
attr.Inode = 1 // dir.Id()
attr.Uid = dir.wfs.option.MountUid
attr.Gid = dir.wfs.option.MountGid
attr.Mode = dir.wfs.option.MountMode
2019-05-10 22:03:31 +00:00
attr.Crtime = dir.wfs.option.MountCtime
attr.Ctime = dir.wfs.option.MountCtime
attr.Mtime = dir.wfs.option.MountMtime
attr.Atime = dir.wfs.option.MountMtime
attr.BlockSize = blockSize
2019-05-10 22:03:31 +00:00
}
func (dir *Dir) Fsync(ctx context.Context, req *fuse.FsyncRequest) error {
// fsync works at OS level
// write the file chunks to the filerGrpcAddress
glog.V(3).Infof("dir %s fsync %+v", dir.FullPath(), req)
return nil
}
func (dir *Dir) newFile(name string) fs.Node {
2021-04-17 17:48:22 +00:00
fileFullPath := util.NewFullPath(dir.FullPath(), name)
fileId := fileFullPath.AsInode()
dir.wfs.handlesLock.Lock()
existingHandle, found := dir.wfs.handles[fileId]
dir.wfs.handlesLock.Unlock()
if found {
glog.V(4).Infof("newFile found opened file handle: %+v", fileFullPath)
return existingHandle.f
}
return &File{
2021-04-17 17:48:22 +00:00
Name: name,
dir: dir,
wfs: dir.wfs,
id: fileId,
}
}
2021-04-15 03:26:13 +00:00
func (dir *Dir) newDirectory(fullpath util.FullPath) fs.Node {
2020-03-26 05:19:19 +00:00
2021-04-17 17:48:22 +00:00
return &Dir{name: fullpath.Name(), wfs: dir.wfs, parent: dir, id: fullpath.AsInode()}
}
func (dir *Dir) Create(ctx context.Context, req *fuse.CreateRequest,
resp *fuse.CreateResponse) (fs.Node, fs.Handle, error) {
exclusive := req.Flags&fuse.OpenExclusive != 0
isDirectory := req.Mode&os.ModeDir > 0
if exclusive || isDirectory {
_, err := dir.doCreateEntry(req.Name, req.Mode, req.Uid, req.Gid, exclusive)
if err != nil {
return nil, nil, err
}
}
var node fs.Node
if isDirectory {
2021-04-15 03:26:13 +00:00
node = dir.newDirectory(util.NewFullPath(dir.FullPath(), req.Name))
return node, nil, nil
}
node = dir.newFile(req.Name)
file := node.(*File)
file.entry = &filer_pb.Entry{
Name: req.Name,
IsDirectory: req.Mode&os.ModeDir > 0,
Attributes: &filer_pb.FuseAttributes{
Mtime: time.Now().Unix(),
Crtime: time.Now().Unix(),
FileMode: uint32(req.Mode &^ dir.wfs.option.Umask),
Uid: req.Uid,
Gid: req.Gid,
Collection: dir.wfs.option.Collection,
Replication: dir.wfs.option.Replication,
TtlSec: dir.wfs.option.TtlSec,
},
}
file.dirtyMetadata = true
fh := dir.wfs.AcquireHandle(file, req.Uid, req.Gid)
return file, fh, nil
}
func (dir *Dir) Mknod(ctx context.Context, req *fuse.MknodRequest) (fs.Node, error) {
_, err := dir.doCreateEntry(req.Name, req.Mode, req.Uid, req.Gid, false)
if err != nil {
return nil, err
}
var node fs.Node
node = dir.newFile(req.Name)
return node, nil
}
2021-04-15 06:21:38 +00:00
func (dir *Dir) doCreateEntry(name string, mode os.FileMode, uid, gid uint32, exclusive bool) (*filer_pb.CreateEntryRequest, error) {
dirFullPath := dir.FullPath()
request := &filer_pb.CreateEntryRequest{
Directory: dirFullPath,
Entry: &filer_pb.Entry{
Name: name,
IsDirectory: mode&os.ModeDir > 0,
Attributes: &filer_pb.FuseAttributes{
Mtime: time.Now().Unix(),
Crtime: time.Now().Unix(),
FileMode: uint32(mode &^ dir.wfs.option.Umask),
Uid: uid,
Gid: gid,
Collection: dir.wfs.option.Collection,
Replication: dir.wfs.option.Replication,
TtlSec: dir.wfs.option.TtlSec,
},
},
2021-04-15 06:21:38 +00:00
OExcl: exclusive,
Signatures: []int32{dir.wfs.signature},
}
glog.V(1).Infof("create %s/%s", dirFullPath, name)
err := dir.wfs.WithFilerClient(func(client filer_pb.SeaweedFilerClient) error {
dir.wfs.mapPbIdFromLocalToFiler(request.Entry)
defer dir.wfs.mapPbIdFromFilerToLocal(request.Entry)
if err := filer_pb.CreateEntry(client, request); err != nil {
if strings.Contains(err.Error(), "EEXIST") {
return fuse.EEXIST
}
glog.V(0).Infof("create %s/%s: %v", dirFullPath, name, err)
return fuse.EIO
}
if err := dir.wfs.metaCache.InsertEntry(context.Background(), filer.FromPbEntry(request.Directory, request.Entry)); err != nil {
glog.Errorf("local InsertEntry dir %s/%s: %v", dirFullPath, name, err)
return fuse.EIO
}
return nil
})
return request, err
2020-10-31 06:51:32 +00:00
}
2018-05-08 08:59:43 +00:00
func (dir *Dir) Mkdir(ctx context.Context, req *fuse.MkdirRequest) (fs.Node, error) {
glog.V(4).Infof("mkdir %s: %s", dir.FullPath(), req.Name)
newEntry := &filer_pb.Entry{
Name: req.Name,
IsDirectory: true,
Attributes: &filer_pb.FuseAttributes{
Mtime: time.Now().Unix(),
Crtime: time.Now().Unix(),
FileMode: uint32(req.Mode &^ dir.wfs.option.Umask),
Uid: req.Uid,
Gid: req.Gid,
},
}
dirFullPath := dir.FullPath()
err := dir.wfs.WithFilerClient(func(client filer_pb.SeaweedFilerClient) error {
2018-05-08 08:59:43 +00:00
dir.wfs.mapPbIdFromLocalToFiler(newEntry)
defer dir.wfs.mapPbIdFromFilerToLocal(newEntry)
request := &filer_pb.CreateEntryRequest{
Directory: dirFullPath,
Entry: newEntry,
Signatures: []int32{dir.wfs.signature},
}
2018-05-08 08:59:43 +00:00
glog.V(1).Infof("mkdir: %v", request)
if err := filer_pb.CreateEntry(client, request); err != nil {
glog.V(0).Infof("mkdir %s/%s: %v", dirFullPath, req.Name, err)
2020-01-24 09:41:31 +00:00
return err
}
if err := dir.wfs.metaCache.InsertEntry(context.Background(), filer.FromPbEntry(request.Directory, request.Entry)); err != nil {
glog.Errorf("local mkdir dir %s/%s: %v", dirFullPath, req.Name, err)
return fuse.EIO
}
return nil
})
if err == nil {
node := dir.newDirectory(util.NewFullPath(dirFullPath, req.Name))
return node, nil
}
glog.V(0).Infof("mkdir %s/%s: %v", dirFullPath, req.Name, err)
2020-01-24 09:41:31 +00:00
return nil, fuse.EIO
2018-05-08 08:59:43 +00:00
}
func (dir *Dir) Lookup(ctx context.Context, req *fuse.LookupRequest, resp *fuse.LookupResponse) (node fs.Node, err error) {
2018-05-06 06:50:34 +00:00
2020-06-28 17:14:17 +00:00
dirPath := util.FullPath(dir.FullPath())
glog.V(4).Infof("dir Lookup %s: %s by %s", dirPath, req.Name, req.Header.String())
fullFilePath := dirPath.Child(req.Name)
visitErr := meta_cache.EnsureVisited(dir.wfs.metaCache, dir.wfs, dirPath)
if visitErr != nil {
glog.Errorf("dir Lookup %s: %v", dirPath, visitErr)
return nil, fuse.EIO
}
localEntry, cacheErr := dir.wfs.metaCache.FindEntry(context.Background(), fullFilePath)
2020-06-28 17:18:32 +00:00
if cacheErr == filer_pb.ErrNotFound {
return nil, fuse.ENOENT
}
if localEntry == nil {
2020-01-25 08:31:53 +00:00
// glog.V(3).Infof("dir Lookup cache miss %s", fullFilePath)
entry, err := filer_pb.GetEntry(dir.wfs, fullFilePath)
2019-05-03 07:24:35 +00:00
if err != nil {
2020-01-16 03:08:54 +00:00
glog.V(1).Infof("dir GetEntry %s: %v", fullFilePath, err)
return nil, fuse.ENOENT
2019-05-03 07:24:35 +00:00
}
localEntry = filer.FromPbEntry(string(dirPath), entry)
} else {
2020-08-31 03:12:04 +00:00
glog.V(4).Infof("dir Lookup cache hit %s", fullFilePath)
2018-11-07 19:35:13 +00:00
}
2018-05-08 08:59:43 +00:00
if localEntry != nil {
if localEntry.IsDirectory() {
2021-04-15 03:26:13 +00:00
node = dir.newDirectory(fullFilePath)
2018-05-08 08:59:43 +00:00
} else {
node = dir.newFile(req.Name)
2018-05-06 05:47:16 +00:00
}
// resp.EntryValid = time.Second
2021-04-17 21:32:49 +00:00
resp.Attr.Inode = fullFilePath.AsInode()
resp.Attr.Valid = time.Second
resp.Attr.Mtime = localEntry.Attr.Mtime
resp.Attr.Crtime = localEntry.Attr.Crtime
resp.Attr.Mode = localEntry.Attr.Mode
resp.Attr.Gid = localEntry.Attr.Gid
resp.Attr.Uid = localEntry.Attr.Uid
if localEntry.HardLinkCounter > 0 {
resp.Attr.Nlink = uint32(localEntry.HardLinkCounter)
2020-09-24 10:06:44 +00:00
}
2018-05-06 06:50:34 +00:00
return node, nil
2018-05-06 05:47:16 +00:00
}
2020-02-25 19:13:06 +00:00
glog.V(4).Infof("not found dir GetEntry %s: %v", fullFilePath, err)
return nil, fuse.ENOENT
2018-05-06 05:47:16 +00:00
}
2018-05-08 08:59:43 +00:00
func (dir *Dir) ReadDirAll(ctx context.Context) (ret []fuse.Dirent, err error) {
dirPath := util.FullPath(dir.FullPath())
glog.V(4).Infof("dir ReadDirAll %s", dirPath)
processEachEntryFn := func(entry *filer.Entry, isLast bool) {
if entry.IsDirectory() {
2021-04-16 05:42:24 +00:00
dirent := fuse.Dirent{Name: entry.Name(), Type: fuse.DT_Dir, Inode: dirPath.Child(entry.Name()).AsInode()}
2019-12-13 08:22:37 +00:00
ret = append(ret, dirent)
} else {
2021-04-16 05:42:24 +00:00
dirent := fuse.Dirent{Name: entry.Name(), Type: findFileType(uint16(entry.Attr.Mode)), Inode: dirPath.Child(entry.Name()).AsInode()}
2019-12-13 08:22:37 +00:00
ret = append(ret, dirent)
2018-05-08 08:59:43 +00:00
}
}
if err = meta_cache.EnsureVisited(dir.wfs.metaCache, dir.wfs, dirPath); err != nil {
glog.Errorf("dir ReadDirAll %s: %v", dirPath, err)
return nil, fuse.EIO
}
listErr := dir.wfs.metaCache.ListDirectoryEntries(context.Background(), dirPath, "", false, int64(math.MaxInt32), func(entry *filer.Entry) bool {
processEachEntryFn(entry, false)
2021-01-16 07:56:24 +00:00
return true
})
2020-06-28 17:18:32 +00:00
if listErr != nil {
glog.Errorf("list meta cache: %v", listErr)
return nil, fuse.EIO
}
2020-06-28 17:18:32 +00:00
return
2018-05-06 05:47:16 +00:00
}
func findFileType(mode uint16) fuse.DirentType {
switch mode & (syscall.S_IFMT & 0xffff) {
case syscall.S_IFSOCK:
return fuse.DT_Socket
case syscall.S_IFLNK:
return fuse.DT_Link
case syscall.S_IFREG:
return fuse.DT_File
case syscall.S_IFBLK:
return fuse.DT_Block
case syscall.S_IFDIR:
return fuse.DT_Dir
case syscall.S_IFCHR:
return fuse.DT_Char
case syscall.S_IFIFO:
return fuse.DT_FIFO
}
return fuse.DT_File
}
2018-05-06 05:47:16 +00:00
func (dir *Dir) Remove(ctx context.Context, req *fuse.RemoveRequest) error {
2018-05-06 06:50:34 +00:00
2019-01-01 10:33:57 +00:00
if !req.Dir {
return dir.removeOneFile(req)
2019-01-01 10:33:57 +00:00
}
return dir.removeFolder(req)
2019-01-01 10:33:57 +00:00
}
func (dir *Dir) removeOneFile(req *fuse.RemoveRequest) error {
2019-01-01 10:33:57 +00:00
dirFullPath := dir.FullPath()
filePath := util.NewFullPath(dirFullPath, req.Name)
2020-03-23 07:01:34 +00:00
entry, err := filer_pb.GetEntry(dir.wfs, filePath)
2019-01-01 10:33:57 +00:00
if err != nil {
return err
}
2020-08-19 06:40:53 +00:00
// first, ensure the filer store can correctly delete
2020-03-23 08:25:38 +00:00
glog.V(3).Infof("remove file: %v", req)
2021-04-15 09:29:04 +00:00
isDeleteData := entry != nil && entry.HardLinkCounter <= 1
err = filer_pb.Remove(dir.wfs, dirFullPath, req.Name, isDeleteData, false, false, false, []int32{dir.wfs.signature})
2020-03-23 08:25:38 +00:00
if err != nil {
glog.V(3).Infof("not found remove file %s: %v", filePath, err)
2020-03-23 08:25:38 +00:00
return fuse.ENOENT
}
2019-01-01 10:33:57 +00:00
2020-08-19 06:40:53 +00:00
// then, delete meta cache and fsNode cache
if err = dir.wfs.metaCache.DeleteEntry(context.Background(), filePath); err != nil {
glog.V(3).Infof("local DeleteEntry %s: %v", filePath, err)
return fuse.ESTALE
}
// remove current file handle if any
dir.wfs.handlesLock.Lock()
defer dir.wfs.handlesLock.Unlock()
inodeId := filePath.AsInode()
delete(dir.wfs.handles, inodeId)
2020-03-23 08:25:38 +00:00
return nil
2019-01-01 10:33:57 +00:00
}
func (dir *Dir) removeFolder(req *fuse.RemoveRequest) error {
2019-01-01 10:33:57 +00:00
2021-04-15 08:51:10 +00:00
dirFullPath := dir.FullPath()
2020-03-23 08:25:38 +00:00
glog.V(3).Infof("remove directory entry: %v", req)
ignoreRecursiveErr := true // ignore recursion error since the OS should manage it
2021-04-15 08:51:10 +00:00
err := filer_pb.Remove(dir.wfs, dirFullPath, req.Name, true, true, ignoreRecursiveErr, false, []int32{dir.wfs.signature})
2020-03-23 08:25:38 +00:00
if err != nil {
2021-04-15 08:51:10 +00:00
glog.V(0).Infof("remove %s/%s: %v", dirFullPath, req.Name, err)
if strings.Contains(err.Error(), "non-empty") {
return fuse.EEXIST
}
2020-03-23 08:25:38 +00:00
return fuse.ENOENT
}
2021-04-15 08:51:10 +00:00
t := util.NewFullPath(dirFullPath, req.Name)
dir.wfs.metaCache.DeleteEntry(context.Background(), t)
2020-03-23 08:25:38 +00:00
return nil
2018-05-08 08:59:43 +00:00
2018-05-06 05:47:16 +00:00
}
func (dir *Dir) Setattr(ctx context.Context, req *fuse.SetattrRequest, resp *fuse.SetattrResponse) error {
2020-08-14 07:22:21 +00:00
glog.V(4).Infof("%v dir setattr %+v", dir.FullPath(), req)
2021-04-15 03:26:13 +00:00
entry, err := dir.maybeLoadEntry()
if err != nil {
2019-12-16 05:07:01 +00:00
return err
}
if req.Valid.Mode() {
2021-04-15 03:26:13 +00:00
entry.Attributes.FileMode = uint32(req.Mode)
}
if req.Valid.Uid() {
2021-04-15 03:26:13 +00:00
entry.Attributes.Uid = req.Uid
}
if req.Valid.Gid() {
2021-04-15 03:26:13 +00:00
entry.Attributes.Gid = req.Gid
}
if req.Valid.Mtime() {
2021-04-15 03:26:13 +00:00
entry.Attributes.Mtime = req.Mtime.Unix()
}
2021-04-15 03:26:13 +00:00
return dir.saveEntry(entry)
2019-12-16 05:07:01 +00:00
}
func (dir *Dir) Setxattr(ctx context.Context, req *fuse.SetxattrRequest) error {
glog.V(4).Infof("dir Setxattr %s: %s", dir.FullPath(), req.Name)
2019-12-16 05:07:01 +00:00
2021-04-15 03:26:13 +00:00
entry, err := dir.maybeLoadEntry()
if err != nil {
2019-12-16 05:07:01 +00:00
return err
}
2021-04-15 03:26:13 +00:00
if err := setxattr(entry, req); err != nil {
2019-12-16 05:07:01 +00:00
return err
}
2021-04-15 03:26:13 +00:00
return dir.saveEntry(entry)
2019-12-16 05:07:01 +00:00
}
func (dir *Dir) Removexattr(ctx context.Context, req *fuse.RemovexattrRequest) error {
glog.V(4).Infof("dir Removexattr %s: %s", dir.FullPath(), req.Name)
2019-12-16 05:07:01 +00:00
2021-04-15 03:26:13 +00:00
entry, err := dir.maybeLoadEntry()
if err != nil {
2019-12-16 05:07:01 +00:00
return err
}
2021-04-15 03:26:13 +00:00
if err := removexattr(entry, req); err != nil {
2019-12-16 05:07:01 +00:00
return err
}
2021-04-15 03:26:13 +00:00
return dir.saveEntry(entry)
2019-12-16 05:07:01 +00:00
}
func (dir *Dir) Listxattr(ctx context.Context, req *fuse.ListxattrRequest, resp *fuse.ListxattrResponse) error {
glog.V(4).Infof("dir Listxattr %s", dir.FullPath())
2019-12-16 05:07:01 +00:00
2021-04-15 03:26:13 +00:00
entry, err := dir.maybeLoadEntry()
if err != nil {
2019-12-16 05:07:01 +00:00
return err
}
2021-04-15 03:26:13 +00:00
if err := listxattr(entry, req, resp); err != nil {
2019-12-16 05:07:01 +00:00
return err
}
2019-12-18 04:38:56 +00:00
return nil
2019-12-16 05:07:01 +00:00
}
func (dir *Dir) Forget() {
2020-08-31 03:12:04 +00:00
glog.V(4).Infof("Forget dir %s", dir.FullPath())
}
2021-04-15 03:26:13 +00:00
func (dir *Dir) maybeLoadEntry() (*filer_pb.Entry, error) {
parentDirPath, name := util.FullPath(dir.FullPath()).DirAndName()
return dir.wfs.maybeLoadEntry(parentDirPath, name)
2019-12-16 05:07:01 +00:00
}
2021-04-15 03:26:13 +00:00
func (dir *Dir) saveEntry(entry *filer_pb.Entry) error {
2019-12-16 05:07:01 +00:00
parentDir, name := util.FullPath(dir.FullPath()).DirAndName()
2019-12-16 05:07:01 +00:00
return dir.wfs.WithFilerClient(func(client filer_pb.SeaweedFilerClient) error {
2021-04-15 03:26:13 +00:00
dir.wfs.mapPbIdFromLocalToFiler(entry)
defer dir.wfs.mapPbIdFromFilerToLocal(entry)
request := &filer_pb.UpdateEntryRequest{
Directory: parentDir,
2021-04-15 03:26:13 +00:00
Entry: entry,
Signatures: []int32{dir.wfs.signature},
}
2019-12-16 05:07:01 +00:00
glog.V(1).Infof("save dir entry: %v", request)
_, err := client.UpdateEntry(context.Background(), request)
if err != nil {
2020-08-19 06:42:09 +00:00
glog.Errorf("UpdateEntry dir %s/%s: %v", parentDir, name, err)
return fuse.EIO
}
if err := dir.wfs.metaCache.UpdateEntry(context.Background(), filer.FromPbEntry(request.Directory, request.Entry)); err != nil {
glog.Errorf("UpdateEntry dir %s/%s: %v", parentDir, name, err)
return fuse.ESTALE
}
return nil
})
}
func (dir *Dir) FullPath() string {
var parts []string
for p := dir; p != nil; p = p.parent {
if strings.HasPrefix(p.name, "/") {
if len(p.name) > 1 {
parts = append(parts, p.name[1:])
}
} else {
parts = append(parts, p.name)
}
}
if len(parts) == 0 {
return "/"
}
var buf bytes.Buffer
for i := len(parts) - 1; i >= 0; i-- {
buf.WriteString("/")
buf.WriteString(parts[i])
}
return buf.String()
}