2016-07-17 22:03:23 +00:00
|
|
|
// FUSE main Fs
|
|
|
|
|
2023-10-29 14:15:34 +00:00
|
|
|
//go:build linux
|
|
|
|
// +build linux
|
2016-07-17 22:03:23 +00:00
|
|
|
|
|
|
|
package mount
|
|
|
|
|
|
|
|
import (
|
2019-05-07 12:53:16 +00:00
|
|
|
"context"
|
2017-05-11 12:15:51 +00:00
|
|
|
"syscall"
|
|
|
|
|
2016-07-17 22:03:23 +00:00
|
|
|
"bazil.org/fuse"
|
|
|
|
fusefs "bazil.org/fuse/fs"
|
2019-07-28 17:47:38 +00:00
|
|
|
"github.com/rclone/rclone/cmd/mountlib"
|
|
|
|
"github.com/rclone/rclone/fs"
|
2021-11-04 10:12:57 +00:00
|
|
|
"github.com/rclone/rclone/fs/fserrors"
|
2019-07-28 17:47:38 +00:00
|
|
|
"github.com/rclone/rclone/fs/log"
|
|
|
|
"github.com/rclone/rclone/vfs"
|
2016-07-17 22:03:23 +00:00
|
|
|
)
|
|
|
|
|
|
|
|
// FS represents the top level filing system
|
|
|
|
type FS struct {
|
2017-10-28 19:01:34 +00:00
|
|
|
*vfs.VFS
|
2021-03-16 13:23:36 +00:00
|
|
|
f fs.Fs
|
|
|
|
opt *mountlib.Options
|
|
|
|
server *fusefs.Server
|
2016-07-17 22:03:23 +00:00
|
|
|
}
|
|
|
|
|
2019-04-30 12:06:24 +00:00
|
|
|
// Check interface satisfied
|
2016-07-17 22:03:23 +00:00
|
|
|
var _ fusefs.FS = (*FS)(nil)
|
|
|
|
|
2017-05-02 21:35:07 +00:00
|
|
|
// NewFS makes a new FS
|
2020-07-23 16:17:01 +00:00
|
|
|
func NewFS(VFS *vfs.VFS, opt *mountlib.Options) *FS {
|
2017-05-02 21:35:07 +00:00
|
|
|
fsys := &FS{
|
2020-07-22 16:58:49 +00:00
|
|
|
VFS: VFS,
|
|
|
|
f: VFS.Fs(),
|
2020-07-23 16:17:01 +00:00
|
|
|
opt: opt,
|
2016-09-09 07:39:19 +00:00
|
|
|
}
|
2017-05-02 21:35:07 +00:00
|
|
|
return fsys
|
2016-09-09 07:39:19 +00:00
|
|
|
}
|
|
|
|
|
2017-05-02 21:35:07 +00:00
|
|
|
// Root returns the root node
|
2017-05-09 10:39:33 +00:00
|
|
|
func (f *FS) Root() (node fusefs.Node, err error) {
|
2018-01-12 16:30:54 +00:00
|
|
|
defer log.Trace("", "")("node=%+v, err=%v", &node, &err)
|
2017-10-28 19:01:34 +00:00
|
|
|
root, err := f.VFS.Root()
|
2017-05-04 20:49:06 +00:00
|
|
|
if err != nil {
|
2017-05-02 21:35:07 +00:00
|
|
|
return nil, translateError(err)
|
2016-07-17 22:03:23 +00:00
|
|
|
}
|
2020-07-23 16:17:01 +00:00
|
|
|
return &Dir{root, f}, nil
|
2016-07-17 22:03:23 +00:00
|
|
|
}
|
2016-11-20 22:54:03 +00:00
|
|
|
|
2019-04-30 12:06:24 +00:00
|
|
|
// Check interface satisfied
|
2016-11-20 22:54:03 +00:00
|
|
|
var _ fusefs.FSStatfser = (*FS)(nil)
|
|
|
|
|
|
|
|
// Statfs is called to obtain file system metadata.
|
|
|
|
// It should write that data to resp.
|
2017-05-09 10:39:33 +00:00
|
|
|
func (f *FS) Statfs(ctx context.Context, req *fuse.StatfsRequest, resp *fuse.StatfsResponse) (err error) {
|
2018-01-12 16:30:54 +00:00
|
|
|
defer log.Trace("", "")("stat=%+v, err=%v", resp, &err)
|
2016-11-20 22:54:03 +00:00
|
|
|
const blockSize = 4096
|
2020-04-08 17:29:50 +00:00
|
|
|
total, _, free := f.VFS.Statfs()
|
|
|
|
resp.Blocks = uint64(total) / blockSize // Total data blocks in file system.
|
|
|
|
resp.Bfree = uint64(free) / blockSize // Free blocks in file system.
|
|
|
|
resp.Bavail = resp.Bfree // Free blocks in file system if you're not root.
|
|
|
|
resp.Files = 1e9 // Total files in file system.
|
|
|
|
resp.Ffree = 1e9 // Free files in file system.
|
|
|
|
resp.Bsize = blockSize // Block size
|
|
|
|
resp.Namelen = 255 // Maximum file name length?
|
|
|
|
resp.Frsize = blockSize // Fragment size, smallest addressable data size in the file system.
|
2018-06-26 08:26:34 +00:00
|
|
|
mountlib.ClipBlocks(&resp.Blocks)
|
|
|
|
mountlib.ClipBlocks(&resp.Bfree)
|
|
|
|
mountlib.ClipBlocks(&resp.Bavail)
|
2016-11-20 22:54:03 +00:00
|
|
|
return nil
|
|
|
|
}
|
2017-05-04 20:49:06 +00:00
|
|
|
|
2017-05-02 21:35:07 +00:00
|
|
|
// Translate errors from mountlib
|
|
|
|
func translateError(err error) error {
|
|
|
|
if err == nil {
|
|
|
|
return nil
|
|
|
|
}
|
2021-11-04 10:12:57 +00:00
|
|
|
_, uErr := fserrors.Cause(err)
|
|
|
|
switch uErr {
|
2017-10-28 19:16:03 +00:00
|
|
|
case vfs.OK:
|
|
|
|
return nil
|
2020-04-21 15:31:43 +00:00
|
|
|
case vfs.ENOENT, fs.ErrorDirNotFound, fs.ErrorObjectNotFound:
|
2023-03-25 22:27:07 +00:00
|
|
|
return fuse.Errno(syscall.ENOENT)
|
2020-04-21 15:31:43 +00:00
|
|
|
case vfs.EEXIST, fs.ErrorDirExists:
|
2023-03-25 22:27:07 +00:00
|
|
|
return fuse.Errno(syscall.EEXIST)
|
2020-04-21 15:31:43 +00:00
|
|
|
case vfs.EPERM, fs.ErrorPermissionDenied:
|
2023-03-25 22:27:07 +00:00
|
|
|
return fuse.Errno(syscall.EPERM)
|
2017-11-03 11:35:36 +00:00
|
|
|
case vfs.ECLOSED:
|
|
|
|
return fuse.Errno(syscall.EBADF)
|
|
|
|
case vfs.ENOTEMPTY:
|
|
|
|
return fuse.Errno(syscall.ENOTEMPTY)
|
2017-10-28 19:16:03 +00:00
|
|
|
case vfs.ESPIPE:
|
|
|
|
return fuse.Errno(syscall.ESPIPE)
|
|
|
|
case vfs.EBADF:
|
|
|
|
return fuse.Errno(syscall.EBADF)
|
|
|
|
case vfs.EROFS:
|
|
|
|
return fuse.Errno(syscall.EROFS)
|
2020-04-21 15:31:43 +00:00
|
|
|
case vfs.ENOSYS, fs.ErrorNotImplemented:
|
2022-06-12 10:37:00 +00:00
|
|
|
return syscall.ENOSYS
|
2018-02-23 22:39:28 +00:00
|
|
|
case vfs.EINVAL:
|
|
|
|
return fuse.Errno(syscall.EINVAL)
|
2017-05-02 21:35:07 +00:00
|
|
|
}
|
2022-06-08 08:08:12 +00:00
|
|
|
fs.Errorf(nil, "IO error: %v", err)
|
2017-05-02 21:35:07 +00:00
|
|
|
return err
|
2017-05-04 20:49:06 +00:00
|
|
|
}
|