aboutsummaryrefslogtreecommitdiff
path: root/weed/filesys/file.go
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2020-03-26 00:08:14 -0700
committerChris Lu <chris.lu@gmail.com>2020-03-26 00:08:14 -0700
commit7f0d87b2065ffb5e7be1bd0591416b9649839c9e (patch)
tree11a60d3bc6fed6cbc97987e09f8e428ddc0a3c97 /weed/filesys/file.go
parent2e4fadd10aa8835e7bcbbe25b46169a6335154f6 (diff)
downloadseaweedfs-7f0d87b2065ffb5e7be1bd0591416b9649839c9e.tar.xz
seaweedfs-7f0d87b2065ffb5e7be1bd0591416b9649839c9e.zip
tree structured fs cache
FsCache for FsNode, wrapping fs.Node
Diffstat (limited to 'weed/filesys/file.go')
-rw-r--r--weed/filesys/file.go14
1 files changed, 7 insertions, 7 deletions
diff --git a/weed/filesys/file.go b/weed/filesys/file.go
index 148f767ac..6f67081a6 100644
--- a/weed/filesys/file.go
+++ b/weed/filesys/file.go
@@ -38,7 +38,7 @@ type File struct {
}
func (file *File) fullpath() util.FullPath {
- return util.NewFullPath(file.dir.Path, file.Name)
+ return util.NewFullPath(file.dir.FullPath(), file.Name)
}
func (file *File) Attr(ctx context.Context, attr *fuse.Attr) error {
@@ -211,21 +211,21 @@ func (file *File) Listxattr(ctx context.Context, req *fuse.ListxattrRequest, res
func (file *File) Fsync(ctx context.Context, req *fuse.FsyncRequest) error {
// fsync works at OS level
// write the file chunks to the filerGrpcAddress
- glog.V(3).Infof("%s/%s fsync file %+v", file.dir.Path, file.Name, req)
+ glog.V(3).Infof("%s/%s fsync file %+v", file.dir.FullPath(), file.Name, req)
return nil
}
func (file *File) Forget() {
- glog.V(3).Infof("Forget file %s/%s", file.dir.Path, file.Name)
+ glog.V(3).Infof("Forget file %s/%s", file.dir.FullPath(), file.Name)
- file.wfs.fsNodeCache.DeleteFsNode(util.NewFullPath(file.dir.Path, file.Name))
+ file.wfs.fsNodeCache.DeleteFsNode(util.NewFullPath(file.dir.FullPath(), file.Name))
}
func (file *File) maybeLoadEntry(ctx context.Context) error {
if file.entry == nil || file.isOpen <= 0 {
- entry, err := file.wfs.maybeLoadEntry(file.dir.Path, file.Name)
+ entry, err := file.wfs.maybeLoadEntry(file.dir.FullPath(), file.Name)
if err != nil {
return err
}
@@ -266,14 +266,14 @@ func (file *File) saveEntry() error {
return file.wfs.WithFilerClient(func(client filer_pb.SeaweedFilerClient) error {
request := &filer_pb.UpdateEntryRequest{
- Directory: file.dir.Path,
+ Directory: file.dir.FullPath(),
Entry: file.entry,
}
glog.V(1).Infof("save file entry: %v", request)
_, err := client.UpdateEntry(context.Background(), request)
if err != nil {
- glog.V(0).Infof("UpdateEntry file %s/%s: %v", file.dir.Path, file.Name, err)
+ glog.V(0).Infof("UpdateEntry file %s/%s: %v", file.dir.FullPath(), file.Name, err)
return fuse.EIO
}