mirror of
https://github.com/seaweedfs/seaweedfs.git
synced 2024-01-19 02:48:24 +00:00
FUSE can change file or folder attributes
FUSE can change file or folder attributes
This commit is contained in:
parent
a09ef6002a
commit
13e5541e17
|
@ -4,17 +4,20 @@ import (
|
||||||
"context"
|
"context"
|
||||||
"os"
|
"os"
|
||||||
"path"
|
"path"
|
||||||
|
"path/filepath"
|
||||||
|
"time"
|
||||||
|
|
||||||
"bazil.org/fuse"
|
"bazil.org/fuse"
|
||||||
"bazil.org/fuse/fs"
|
"bazil.org/fuse/fs"
|
||||||
"github.com/chrislusf/seaweedfs/weed/glog"
|
"github.com/chrislusf/seaweedfs/weed/glog"
|
||||||
"github.com/chrislusf/seaweedfs/weed/pb/filer_pb"
|
"github.com/chrislusf/seaweedfs/weed/pb/filer_pb"
|
||||||
"path/filepath"
|
"github.com/chrislusf/seaweedfs/weed/filer2"
|
||||||
"time"
|
|
||||||
)
|
)
|
||||||
|
|
||||||
type Dir struct {
|
type Dir struct {
|
||||||
Path string
|
Path string
|
||||||
wfs *WFS
|
wfs *WFS
|
||||||
|
attributes *filer_pb.FuseAttributes
|
||||||
}
|
}
|
||||||
|
|
||||||
var _ = fs.Node(&Dir{})
|
var _ = fs.Node(&Dir{})
|
||||||
|
@ -24,6 +27,7 @@ var _ = fs.NodeRequestLookuper(&Dir{})
|
||||||
var _ = fs.HandleReadDirAller(&Dir{})
|
var _ = fs.HandleReadDirAller(&Dir{})
|
||||||
var _ = fs.NodeRemover(&Dir{})
|
var _ = fs.NodeRemover(&Dir{})
|
||||||
var _ = fs.NodeRenamer(&Dir{})
|
var _ = fs.NodeRenamer(&Dir{})
|
||||||
|
var _ = fs.NodeSetattrer(&Dir{})
|
||||||
|
|
||||||
func (dir *Dir) Attr(context context.Context, attr *fuse.Attr) error {
|
func (dir *Dir) Attr(context context.Context, attr *fuse.Attr) error {
|
||||||
|
|
||||||
|
@ -48,8 +52,6 @@ func (dir *Dir) Attr(context context.Context, attr *fuse.Attr) error {
|
||||||
|
|
||||||
parent, name := filepath.Split(dir.Path)
|
parent, name := filepath.Split(dir.Path)
|
||||||
|
|
||||||
var attributes *filer_pb.FuseAttributes
|
|
||||||
|
|
||||||
err := dir.wfs.withFilerClient(func(client filer_pb.SeaweedFilerClient) error {
|
err := dir.wfs.withFilerClient(func(client filer_pb.SeaweedFilerClient) error {
|
||||||
|
|
||||||
request := &filer_pb.GetEntryAttributesRequest{
|
request := &filer_pb.GetEntryAttributesRequest{
|
||||||
|
@ -64,7 +66,7 @@ func (dir *Dir) Attr(context context.Context, attr *fuse.Attr) error {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
attributes = resp.Attributes
|
dir.attributes = resp.Attributes
|
||||||
|
|
||||||
return nil
|
return nil
|
||||||
})
|
})
|
||||||
|
@ -76,26 +78,26 @@ func (dir *Dir) Attr(context context.Context, attr *fuse.Attr) error {
|
||||||
// glog.V(1).Infof("dir %s: %v", dir.Path, attributes)
|
// glog.V(1).Infof("dir %s: %v", dir.Path, attributes)
|
||||||
// glog.V(1).Infof("dir %s permission: %v", dir.Path, os.FileMode(attributes.FileMode))
|
// glog.V(1).Infof("dir %s permission: %v", dir.Path, os.FileMode(attributes.FileMode))
|
||||||
|
|
||||||
attr.Mode = os.FileMode(attributes.FileMode) | os.ModeDir
|
attr.Mode = os.FileMode(dir.attributes.FileMode) | os.ModeDir
|
||||||
if dir.Path == "/" && attributes.FileMode == 0 {
|
if dir.Path == "/" && dir.attributes.FileMode == 0 {
|
||||||
attr.Valid = time.Second
|
attr.Valid = time.Second
|
||||||
}
|
}
|
||||||
|
|
||||||
attr.Mtime = time.Unix(attributes.Mtime, 0)
|
attr.Mtime = time.Unix(dir.attributes.Mtime, 0)
|
||||||
attr.Ctime = time.Unix(attributes.Crtime, 0)
|
attr.Ctime = time.Unix(dir.attributes.Crtime, 0)
|
||||||
attr.Gid = attributes.Gid
|
attr.Gid = dir.attributes.Gid
|
||||||
attr.Uid = attributes.Uid
|
attr.Uid = dir.attributes.Uid
|
||||||
|
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (dir *Dir) newFile(name string, chunks []*filer_pb.FileChunk) *File {
|
func (dir *Dir) newFile(name string, chunks []*filer_pb.FileChunk, attr *filer_pb.FuseAttributes) *File {
|
||||||
return &File{
|
return &File{
|
||||||
Name: name,
|
Name: name,
|
||||||
dir: dir,
|
dir: dir,
|
||||||
wfs: dir.wfs,
|
wfs: dir.wfs,
|
||||||
// attributes: &filer_pb.FuseAttributes{},
|
attributes: attr,
|
||||||
Chunks: chunks,
|
Chunks: chunks,
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -132,7 +134,7 @@ func (dir *Dir) Create(ctx context.Context, req *fuse.CreateRequest,
|
||||||
})
|
})
|
||||||
|
|
||||||
if err == nil {
|
if err == nil {
|
||||||
file := dir.newFile(req.Name, nil)
|
file := dir.newFile(req.Name, nil, &filer_pb.FuseAttributes{})
|
||||||
file.isOpen = true
|
file.isOpen = true
|
||||||
return file, dir.wfs.AcquireHandle(file, req.Uid, req.Gid), nil
|
return file, dir.wfs.AcquireHandle(file, req.Uid, req.Gid), nil
|
||||||
}
|
}
|
||||||
|
@ -200,9 +202,9 @@ func (dir *Dir) Lookup(ctx context.Context, req *fuse.LookupRequest, resp *fuse.
|
||||||
|
|
||||||
if entry != nil {
|
if entry != nil {
|
||||||
if entry.IsDirectory {
|
if entry.IsDirectory {
|
||||||
node = &Dir{Path: path.Join(dir.Path, req.Name), wfs: dir.wfs}
|
node = &Dir{Path: path.Join(dir.Path, req.Name), wfs: dir.wfs, attributes: entry.Attributes}
|
||||||
} else {
|
} else {
|
||||||
node = dir.newFile(req.Name, entry.Chunks)
|
node = dir.newFile(req.Name, entry.Chunks, entry.Attributes)
|
||||||
}
|
}
|
||||||
|
|
||||||
resp.EntryValid = time.Duration(0)
|
resp.EntryValid = time.Duration(0)
|
||||||
|
@ -272,3 +274,45 @@ func (dir *Dir) Remove(ctx context.Context, req *fuse.RemoveRequest) error {
|
||||||
})
|
})
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (dir *Dir) Setattr(ctx context.Context, req *fuse.SetattrRequest, resp *fuse.SetattrResponse) error {
|
||||||
|
|
||||||
|
glog.V(3).Infof("%v dir setattr %+v, fh=%d", dir.Path, req, req.Handle)
|
||||||
|
if req.Valid.Mode() {
|
||||||
|
dir.attributes.FileMode = uint32(req.Mode)
|
||||||
|
}
|
||||||
|
|
||||||
|
if req.Valid.Uid() {
|
||||||
|
dir.attributes.Uid = req.Uid
|
||||||
|
}
|
||||||
|
|
||||||
|
if req.Valid.Gid() {
|
||||||
|
dir.attributes.Gid = req.Gid
|
||||||
|
}
|
||||||
|
|
||||||
|
if req.Valid.Mtime() {
|
||||||
|
dir.attributes.Mtime = req.Mtime.Unix()
|
||||||
|
}
|
||||||
|
|
||||||
|
parentDir, name := filer2.FullPath(dir.Path).DirAndName()
|
||||||
|
return dir.wfs.withFilerClient(func(client filer_pb.SeaweedFilerClient) error {
|
||||||
|
|
||||||
|
request := &filer_pb.UpdateEntryRequest{
|
||||||
|
Directory: parentDir,
|
||||||
|
Entry: &filer_pb.Entry{
|
||||||
|
Name: name,
|
||||||
|
Attributes: dir.attributes,
|
||||||
|
},
|
||||||
|
}
|
||||||
|
|
||||||
|
glog.V(1).Infof("set attr directory entry: %v", request)
|
||||||
|
_, err := client.UpdateEntry(ctx, request)
|
||||||
|
if err != nil {
|
||||||
|
glog.V(0).Infof("UpdateEntry %s: %v", dir.Path, err)
|
||||||
|
return fuse.EIO
|
||||||
|
}
|
||||||
|
|
||||||
|
return nil
|
||||||
|
})
|
||||||
|
|
||||||
|
}
|
||||||
|
|
|
@ -34,7 +34,7 @@ func (file *File) Attr(ctx context.Context, attr *fuse.Attr) error {
|
||||||
|
|
||||||
if file.attributes == nil || !file.isOpen {
|
if file.attributes == nil || !file.isOpen {
|
||||||
item := file.wfs.listDirectoryEntriesCache.Get(file.fullpath())
|
item := file.wfs.listDirectoryEntriesCache.Get(file.fullpath())
|
||||||
if item != nil && !item.Expired(){
|
if item != nil && !item.Expired() {
|
||||||
entry := item.Value().(*filer_pb.Entry)
|
entry := item.Value().(*filer_pb.Entry)
|
||||||
file.Chunks = entry.Chunks
|
file.Chunks = entry.Chunks
|
||||||
file.attributes = entry.Attributes
|
file.attributes = entry.Attributes
|
||||||
|
@ -121,7 +121,26 @@ func (file *File) Setattr(ctx context.Context, req *fuse.SetattrRequest, resp *f
|
||||||
file.attributes.Mtime = req.Mtime.Unix()
|
file.attributes.Mtime = req.Mtime.Unix()
|
||||||
}
|
}
|
||||||
|
|
||||||
return nil
|
return file.wfs.withFilerClient(func(client filer_pb.SeaweedFilerClient) error {
|
||||||
|
|
||||||
|
request := &filer_pb.UpdateEntryRequest{
|
||||||
|
Directory: file.dir.Path,
|
||||||
|
Entry: &filer_pb.Entry{
|
||||||
|
Name: file.Name,
|
||||||
|
Attributes: file.attributes,
|
||||||
|
Chunks: file.Chunks,
|
||||||
|
},
|
||||||
|
}
|
||||||
|
|
||||||
|
glog.V(1).Infof("set attr file entry: %v", request)
|
||||||
|
_, err := client.UpdateEntry(ctx, request)
|
||||||
|
if err != nil {
|
||||||
|
glog.V(0).Infof("UpdateEntry file %s/%s: %v", file.dir.Path, file.Name, err)
|
||||||
|
return fuse.EIO
|
||||||
|
}
|
||||||
|
|
||||||
|
return nil
|
||||||
|
})
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue