mirror of
https://github.com/seaweedfs/seaweedfs.git
synced 2024-01-19 02:48:24 +00:00
Revert "mount: fake support for socket/block/character/fifo devices"
This reverts commit 61ef2d8658
.
This commit is contained in:
parent
61ef2d8658
commit
3d5cb7eb86
|
@ -128,9 +128,44 @@ func (dir *Dir) newDirectory(fullpath util.FullPath, entry *filer_pb.Entry) fs.N
|
||||||
func (dir *Dir) Create(ctx context.Context, req *fuse.CreateRequest,
|
func (dir *Dir) Create(ctx context.Context, req *fuse.CreateRequest,
|
||||||
resp *fuse.CreateResponse) (fs.Node, fs.Handle, error) {
|
resp *fuse.CreateResponse) (fs.Node, fs.Handle, error) {
|
||||||
|
|
||||||
request, err := dir.doCreateEntry(req.Name, req.Mode, req.Uid, req.Gid, req.Flags&fuse.OpenExclusive != 0)
|
request := &filer_pb.CreateEntryRequest{
|
||||||
|
Directory: dir.FullPath(),
|
||||||
|
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,
|
||||||
|
},
|
||||||
|
},
|
||||||
|
OExcl: req.Flags&fuse.OpenExclusive != 0,
|
||||||
|
Signatures: []int32{dir.wfs.signature},
|
||||||
|
}
|
||||||
|
glog.V(1).Infof("create %s/%s: %v", dir.FullPath(), req.Name, req.Flags)
|
||||||
|
|
||||||
if err != nil {
|
if 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", dir.FullPath(), req.Name, err)
|
||||||
|
return fuse.EIO
|
||||||
|
}
|
||||||
|
|
||||||
|
dir.wfs.metaCache.InsertEntry(context.Background(), filer.FromPbEntry(request.Directory, request.Entry))
|
||||||
|
|
||||||
|
return nil
|
||||||
|
}); err != nil {
|
||||||
return nil, nil, err
|
return nil, nil, err
|
||||||
}
|
}
|
||||||
var node fs.Node
|
var node fs.Node
|
||||||
|
@ -147,57 +182,17 @@ func (dir *Dir) Create(ctx context.Context, req *fuse.CreateRequest,
|
||||||
}
|
}
|
||||||
|
|
||||||
func (dir *Dir) Mknod(ctx context.Context, req *fuse.MknodRequest) (fs.Node, error) {
|
func (dir *Dir) Mknod(ctx context.Context, req *fuse.MknodRequest) (fs.Node, error) {
|
||||||
|
if req.Mode&os.ModeNamedPipe != 0 {
|
||||||
request, err := dir.doCreateEntry(req.Name, req.Mode, req.Uid, req.Gid, false)
|
glog.V(1).Infof("mknod named pipe %s", req.String())
|
||||||
|
return nil, fuse.ENOSYS
|
||||||
if err != nil {
|
|
||||||
return nil, err
|
|
||||||
}
|
}
|
||||||
var node fs.Node
|
if req.Mode&req.Mode&os.ModeSocket != 0 {
|
||||||
node = dir.newFile(req.Name, request.Entry)
|
glog.V(1).Infof("mknod socket %s", req.String())
|
||||||
return node, nil
|
return nil, fuse.ENOSYS
|
||||||
}
|
|
||||||
|
|
||||||
func (dir *Dir) doCreateEntry(name string, mode os.FileMode, uid, gid uint32, exlusive bool) (*filer_pb.CreateEntryRequest, error) {
|
|
||||||
request := &filer_pb.CreateEntryRequest{
|
|
||||||
Directory: dir.FullPath(),
|
|
||||||
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,
|
|
||||||
},
|
|
||||||
},
|
|
||||||
OExcl: exlusive,
|
|
||||||
Signatures: []int32{dir.wfs.signature},
|
|
||||||
}
|
}
|
||||||
glog.V(1).Infof("create %s/%s: %v", dir.FullPath(), name)
|
// not going to support mknod for normal files either
|
||||||
|
glog.V(1).Infof("mknod %s", req.String())
|
||||||
err := dir.wfs.WithFilerClient(func(client filer_pb.SeaweedFilerClient) error {
|
return nil, fuse.ENOSYS
|
||||||
|
|
||||||
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", dir.FullPath(), name, err)
|
|
||||||
return fuse.EIO
|
|
||||||
}
|
|
||||||
|
|
||||||
dir.wfs.metaCache.InsertEntry(context.Background(), filer.FromPbEntry(request.Directory, request.Entry))
|
|
||||||
|
|
||||||
return nil
|
|
||||||
})
|
|
||||||
return request, err
|
|
||||||
}
|
}
|
||||||
|
|
||||||
func (dir *Dir) Mkdir(ctx context.Context, req *fuse.MkdirRequest) (fs.Node, error) {
|
func (dir *Dir) Mkdir(ctx context.Context, req *fuse.MkdirRequest) (fs.Node, error) {
|
||||||
|
|
Loading…
Reference in a new issue