NetBSD/lib/librefuse/refuse.c

852 lines
19 KiB
C
Raw Normal View History

/*
* Copyright <EFBFBD> 2007 Alistair Crooks. All rights reserved.
*
* Redistribution and use in source and binary forms, with or without
* modification, are permitted provided that the following conditions
* are met:
* 1. Redistributions of source code must retain the above copyright
* notice, this list of conditions and the following disclaimer.
* 2. Redistributions in binary form must reproduce the above copyright
* notice, this list of conditions and the following disclaimer in the
* documentation and/or other materials provided with the distribution.
* 3. The name of the author may not be used to endorse or promote
* products derived from this software without specific prior written
* permission.
*
* THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS
* OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
* WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
* ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY
* DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
* DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE
* GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
* INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
* WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING
* NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
* SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
*/
#include <err.h>
#include <errno.h>
#include <fuse.h>
#include <ucontext.h>
#include <unistd.h>
#include "defs.h"
typedef uint64_t fuse_ino_t;
struct fuse_config {
uid_t uid;
gid_t gid;
mode_t umask;
double entry_timeout;
double negative_timeout;
double attr_timeout;
double ac_attr_timeout;
int ac_attr_timeout_set;
int debug;
int hard_remove;
int use_ino;
int readdir_ino;
int set_mode;
int set_uid;
int set_gid;
int direct_io;
int kernel_cache;
int auto_cache;
int intr;
int intr_signal;
};
/* this is the private fuse structure */
struct fuse {
struct fuse_session *se; /* fuse session pointer */
struct fuse_operations op; /* switch table of operations */
int compat; /* compat level - not used in puffs_fuse */
struct node **name_table;
size_t name_table_size;
struct node **id_table;
size_t id_table_size;
fuse_ino_t ctr;
unsigned int generation;
unsigned int hidectr;
pthread_mutex_t lock;
pthread_rwlock_t tree_lock;
void *user_data;
struct fuse_config conf;
int intr_installed;
struct puffs_usermount *pu;
};
struct refusenode {
struct fuse_file_info file_info;
};
static struct puffs_node *
newrn(struct puffs_usermount *pu)
{
struct puffs_node *pn;
struct refusenode *rn;
rn = malloc(sizeof(struct refusenode));
if (!rn)
abort(); /*XXX*/
memset(rn, 0, sizeof(struct refusenode));
pn = puffs_pn_new(pu, rn);
return pn;
}
static void
nukern(struct puffs_node *pn)
{
free(pn->pn_data);
puffs_pn_put(pn);
}
static ino_t fakeino = 3;
/* XXX: rethinkme */
struct fuse_dirh {
struct dirent *dent;
size_t reslen;
off_t readoff;
};
/* ARGSUSED2 */
static int
puffs_fuse_fill_dir(void *buf, const char *name,
const struct stat *stbuf, off_t off)
{
struct fuse_dirh *deh = buf;
uint8_t dtype;
/* XXX: this is hacked *purely* for hellofs, so fiXXXme */
if (*name == '.')
dtype = DT_DIR;
else
dtype = DT_REG;
return !puffs_nextdent(&deh->dent, name, fakeino++, dtype,&deh->reslen);
}
static int
puffs_fuse_dirfil(fuse_dirh_t h, const char *name, int type, ino_t ino)
{
ino_t dino;
int dtype;
/* XXX: this is hacked *purely* for cddafs, so fiXXXme */
if (type == 0) {
if (*name == '.')
dtype = DT_DIR;
else
dtype = DT_REG;
} else
dtype = type;
if (ino)
dino = ino;
else
dino = fakeino++;
return !puffs_nextdent(&h->dent, name, dino, dtype, &h->reslen);
}
int
fuse_opt_add_arg(struct fuse_args *args, const char *arg)
{
char **oldargv;
int oldargc;
if (args->allocated) {
RENEW(char *, args->argv, args->argc + 1, "fuse_opt_add_arg1", return 0);
} else {
oldargv = args->argv;
oldargc = args->argc;
NEWARRAY(char *, args->argv, oldargc + 1, "fuse_opt_add_arg2", return 0);
(void) memcpy(args->argv, oldargv, oldargc * sizeof(char *));
args->allocated = 1;
}
args->argv[args->argc++] = strdup(arg);
return 1;
}
/* operation wrappers start here */
/* lookup the path */
/* ARGSUSED1 */
static int
puffs_fuse_node_lookup(struct puffs_cc *pcc, void *opc, void **newnode,
enum vtype *newtype, voff_t *newsize, dev_t *newrdev,
const struct puffs_cn *pcn)
{
struct puffs_usermount *pu = puffs_cc_getusermount(pcc);
struct stat st;
struct fuse *fuse;
const char *path = PCNPATH(pcn);
int ret;
/* XXX: THIS IS VERY WRONG */
fuse = (struct fuse *)pu->pu_privdata;
ret = fuse->op.getattr(path, &st);
ret = -ret; /* linux foo */
if (ret != 0) {
return ret;
}
*newnode = newrn(pu);
*newtype = (S_ISDIR(st.st_mode)) ? VDIR : VREG;
*newsize = st.st_size;
return ret;
}
/* get attributes for the path name */
/* ARGSUSED3 */
static int
puffs_fuse_node_getattr(struct puffs_cc *pcc, void *opc, struct vattr *va,
const struct puffs_cred *pcr, pid_t pid)
{
struct puffs_usermount *pu = puffs_cc_getusermount(pcc);
struct puffs_node *pn = opc;
struct stat st;
struct fuse *fuse;
const char *path = PNPATH(pn);
int ret;
fuse = (struct fuse *)pu->pu_privdata;
if (fuse->op.getattr == NULL) {
return ENOSYS;
}
/* wrap up return code */
ret = (*fuse->op.getattr)(path, &st);
if (ret == 0) {
/* fill in va from st */
va->va_mode = st.st_mode;
va->va_nlink = st.st_nlink;
va->va_uid = st.st_uid;
va->va_gid = st.st_gid;
va->va_fsid = st.st_rdev;
va->va_fileid = st.st_ino;
va->va_size = st.st_size;
va->va_blocksize = st.st_blksize;
va->va_atime = st.st_atimespec;
va->va_mtime = st.st_mtimespec;
va->va_ctime = st.st_ctimespec;
va->va_birthtime = st.st_birthtimespec;
va->va_gen = st.st_gen;
va->va_flags = st.st_flags;
va->va_rdev = st.st_rdev;
va->va_bytes = st.st_size;
va->va_filerev = st.st_gen;
va->va_vaflags = st.st_flags;
}
return ret;
}
/* read the contents of the symbolic link */
/* ARGSUSED2 */
static int
puffs_fuse_node_readlink(struct puffs_cc *pcc, void *opc,
const struct puffs_cred *cred, char *linkname, size_t *linklen)
{
struct puffs_usermount *pu = puffs_cc_getusermount(pcc);
struct puffs_node *pn = opc;
struct fuse *fuse;
const char *path = PNPATH(pn);
int ret;
fuse = (struct fuse *)pu->pu_privdata;
if (fuse->op.readlink == NULL) {
return ENOSYS;
}
/* wrap up return code */
ret = (*fuse->op.readlink)(path, linkname, *linklen);
if (ret == 0) {
}
return ret;
}
/* make the special node */
/* ARGSUSED1 */
static int
puffs_fuse_node_mknod(struct puffs_cc *pcc, void *opc, void **newnode,
const struct puffs_cn *pcn, const struct vattr *va)
{
struct puffs_usermount *pu = puffs_cc_getusermount(pcc);
struct puffs_node *pn;
struct fuse *fuse;
mode_t mode = va->va_mode;
const char *path = PCNPATH(pcn);
int ret;
fuse = (struct fuse *)pu->pu_privdata;
if (fuse->op.mknod == NULL) {
return ENOSYS;
}
/* wrap up return code */
ret = (*fuse->op.mknod)(path, mode, va->va_rdev);
if (ret == 0) {
/* fix up nodes */
pn = newrn(pu);
if (pn == NULL) {
unlink(PCNPATH(pcn));
return ENOMEM;
}
puffs_setvattr(&pn->pn_va, va);
*newnode = pn;
}
return ret;
}
/* make a directory */
/* ARGSUSED1 */
static int
puffs_fuse_node_mkdir(struct puffs_cc *pcc, void *opc, void **newnode,
const struct puffs_cn *pcn, const struct vattr *va)
{
struct puffs_usermount *pu = puffs_cc_getusermount(pcc);
struct puffs_node *pn;
struct fuse *fuse;
mode_t mode = va->va_mode;
const char *path = PCNPATH(pcn);
int ret;
fuse = (struct fuse *)pu->pu_privdata;
if (fuse->op.mkdir == NULL) {
return ENOSYS;
}
/* wrap up return code */
ret = (*fuse->op.mkdir)(path, mode);
if (ret == 0) {
/* fix up nodes */
pn = newrn(pu);
if (pn == NULL) {
rmdir(PCNPATH(pcn));
return ENOMEM;
}
puffs_setvattr(&pn->pn_va, va);
*newnode = pn;
}
return ret;
}
/* remove the directory entry */
/* ARGSUSED1 */
static int
puffs_fuse_node_remove(struct puffs_cc *pcc, void *opc, void *targ,
const struct puffs_cn *pcn)
{
struct puffs_usermount *pu = puffs_cc_getusermount(pcc);
struct fuse *fuse;
const char *path = PCNPATH(pcn);
int ret;
fuse = (struct fuse *)pu->pu_privdata;
if (fuse->op.unlink == NULL) {
return ENOSYS;
}
/* wrap up return code */
ret = (*fuse->op.unlink)(path);
return ret;
}
/* remove the directory */
/* ARGSUSED1 */
static int
puffs_fuse_node_rmdir(struct puffs_cc *pcc, void *opc, void *targ,
const struct puffs_cn *pcn)
{
struct puffs_usermount *pu = puffs_cc_getusermount(pcc);
struct fuse *fuse;
const char *path = PCNPATH(pcn);
int ret;
fuse = (struct fuse *)pu->pu_privdata;
if (fuse->op.rmdir == NULL) {
return ENOSYS;
}
/* wrap up return code */
ret = (*fuse->op.rmdir)(path);
return ret;
}
/* create a symbolic link */
/* ARGSUSED1 */
static int
puffs_fuse_node_symlink(struct puffs_cc *pcc, void *opc, void **newnode,
const struct puffs_cn *pcn_src, const struct vattr *va,
const char *link_target)
{
struct puffs_usermount *pu = puffs_cc_getusermount(pcc);
struct puffs_node *pn;
struct fuse *fuse;
const char *path = PCNPATH(pcn_src);
int ret;
fuse = (struct fuse *)pu->pu_privdata;
if (fuse->op.symlink == NULL) {
return ENOSYS;
}
/* wrap up return code */
ret = (*fuse->op.symlink)(path, link_target);
/* XXX - check I haven't transposed these args */
if (ret == 0) {
/* fix up nodes */
pn = newrn(pu);
if (pn == NULL) {
unlink(link_target);
return ENOMEM;
}
puffs_setvattr(&pn->pn_va, va);
*newnode = pn;
}
return ret;
}
/* rename a directory entry */
/* ARGSUSED1 */
static int
puffs_fuse_node_rename(struct puffs_cc *pcc, void *opc, void *src,
const struct puffs_cn *pcn_src, void *targ_dir, void *targ,
const struct puffs_cn *pcn_targ)
{
struct puffs_usermount *pu = puffs_cc_getusermount(pcc);
struct puffs_node *pn = opc;
struct vattr va;
struct fuse *fuse;
const char *path = PCNPATH(pcn_src);
int ret;
fuse = (struct fuse *)pu->pu_privdata;
if (fuse->op.rename == NULL) {
return ENOSYS;
}
/* wrap up return code */
ret = (*fuse->op.rename)(path, PCNPATH(pcn_targ));
/* XXX: what's this guy doing??? */
if (ret == 0) {
(void) memcpy(&va, &pn->pn_va, sizeof(va));
puffs_pn_put(pn);
pn = puffs_pn_new(pu, NULL);
if (pn == NULL) {
return ENOMEM;
}
puffs_setvattr(&pn->pn_va, &va);
}
return ret;
}
/* create a link in the file system */
/* ARGSUSED1 */
static int
puffs_fuse_node_link(struct puffs_cc *pcc, void *opc, void *targ,
const struct puffs_cn *pcn)
{
struct puffs_usermount *pu = puffs_cc_getusermount(pcc);
struct puffs_node *pn = targ;
struct fuse *fuse;
int ret;
fuse = (struct fuse *)pu->pu_privdata;
if (fuse->op.link == NULL) {
return ENOSYS;
}
/* wrap up return code */
ret = (*fuse->op.link)(PNPATH(pn), PCNPATH(pcn));
if (ret == 0) {
/* fix up nodes */
pn = newrn(pu);
if (pn == NULL) {
unlink(PCNPATH(pcn));
return ENOMEM;
}
}
return ret;
}
/*
We run into a slight problemette here - puffs provides
setattr/getattr, whilst fuse provides all the usual chown/chmod/chgrp
functionality. So that we don't miss out on anything when calling a
fuse operation, we have to get the vattr from the existing file,
find out what's changed, and then switch on that to call the fuse
function accordingly.
*/
/* ARGSUSED3 */
static int
puffs_fuse_node_setattr(struct puffs_cc *pcc, void *opc,
const struct vattr *va, const struct puffs_cred *pcr, pid_t pid)
{
struct puffs_usermount *pu = puffs_cc_getusermount(pcc);
struct puffs_node *pn = opc;
struct fuse *fuse;
const char *path = PNPATH(pn);
mode_t mode;
uid_t uid;
gid_t gid;
int ret;
fuse = (struct fuse *)pu->pu_privdata;
ret = -1;
mode = va->va_mode;
uid = va->va_uid;
gid = va->va_gid;
if (mode != 0) {
if (fuse->op.chmod == NULL) {
return ENOSYS;
}
ret = (*fuse->op.chmod)(path, mode);
}
if (uid != 0 || gid != 0) {
if (fuse->op.chown == NULL) {
return ENOSYS;
}
ret = (*fuse->op.chown)(path, uid, gid);
}
if (ret == 0) {
}
return ret;
}
/* ARGSUSED2 */
static int
puffs_fuse_node_open(struct puffs_cc *pcc, void *opc, int flags,
const struct puffs_cred *cred, pid_t pid)
{
struct puffs_usermount *pu = puffs_cc_getusermount(pcc);
struct puffs_node *pn = opc;
struct refusenode *rn = pn->pn_data;
struct fuse *fuse;
struct stat st;
const char *path = PNPATH(pn);
int ret;
fuse = (struct fuse *)pu->pu_privdata;
if (fuse->op.open == NULL) {
return ENOSYS;
}
/* examine type - if directory, return 0 rather than open */
ret = (fuse->op.getattr == NULL) ?
stat(path, &st) :
(*fuse->op.getattr)(path, &st);
if (ret == 0 && (st.st_mode & S_IFMT) == S_IFDIR) {
return 0;
}
if (strcmp(path, "/") == 0) {
return 0;
}
ret = (*fuse->op.open)(path, &rn->file_info);
if (ret == 0) {
}
return ret;
}
/* read some more from the file */
/* ARGSUSED5 */
static int
puffs_fuse_node_read(struct puffs_cc *pcc, void *opc, uint8_t *buf,
off_t offset, size_t *resid, const struct puffs_cred *pcr,
int ioflag)
{
struct puffs_usermount *pu = puffs_cc_getusermount(pcc);
struct puffs_node *pn = opc;
struct refusenode *rn = pn->pn_data;
struct fuse *fuse;
const char *path = PNPATH(pn);
int ret;
fuse = (struct fuse *)pu->pu_privdata;
if (fuse->op.read == NULL) {
return ENOSYS;
}
ret = (*fuse->op.read)(path, (char *)buf, *resid, offset, &rn->file_info);
if (ret > 0) {
*resid -= ret;
}
return 0;
}
/* write to the file */
/* ARGSUSED0 */
static int
puffs_fuse_node_write(struct puffs_cc *pcc, void *opc, uint8_t *buf,
off_t offset, size_t *resid, const struct puffs_cred *pcr,
int ioflag)
{
struct puffs_usermount *pu = puffs_cc_getusermount(pcc);
struct fuse_file_info file_info;
struct puffs_node *pn = opc;
struct fuse *fuse;
const char *path = PNPATH(pn);
int ret;
fuse = (struct fuse *)pu->pu_privdata;
if (fuse->op.write == NULL) {
return ENOSYS;
}
(void) memset(&file_info, 0x0, sizeof(file_info));
/* XXX fill in file_info here */
ret = (*fuse->op.write)(path, (char *)buf, *resid, offset, &file_info);
if (ret > 0) {
*resid -= ret;
}
return ret;
}
/* ARGSUSED3 */
static int
puffs_fuse_node_readdir(struct puffs_cc *pcc, void *opc,
struct dirent *dent, const struct puffs_cred *pcr, off_t *readoff,
size_t *reslen)
{
struct puffs_usermount *pu = puffs_cc_getusermount(pcc);
struct fuse_file_info file_info;
struct puffs_node *pn = opc;
struct fuse *fuse;
const char *path = PNPATH(pn);
struct fuse_dirh deh;
int ret;
fuse = (struct fuse *)pu->pu_privdata;
if (fuse->op.readdir == NULL && fuse->op.getdir == NULL) {
return ENOSYS;
}
/* XXX: how to handle this??? */
if (*readoff != 0) {
return 0;
}
(void) memset(&file_info, 0x0, sizeof(file_info));
/* XXX - fill in file_info here */
deh.dent = dent;
deh.reslen = *reslen;
deh.readoff = *readoff;
if (fuse->op.readdir)
ret = fuse->op.readdir(path, &deh, puffs_fuse_fill_dir, *readoff, &file_info);
else
ret = fuse->op.getdir(path, &deh, puffs_fuse_dirfil);
*reslen = deh.reslen;
*readoff = 1;
if (ret == 0) {
}
return ret;
}
/* ARGSUSED */
static int
puffs_fuse_node_reclaim(struct puffs_cc *pcc, void *opc, pid_t pid)
{
struct puffs_node *pn = opc;
nukern(pn);
return 0;
}
/* ARGSUSED1 */
static int
puffs_fuse_fs_unmount(struct puffs_cc *pcc, int flags, pid_t pid)
{
struct puffs_usermount *pu = puffs_cc_getusermount(pcc);
struct fuse *fuse;
fuse = (struct fuse *)pu->pu_privdata;
if (fuse->op.destroy == NULL) {
return 0;
}
(*fuse->op.destroy)(fuse);
return 0;
}
/* ARGSUSED0 */
static int
puffs_fuse_fs_sync(struct puffs_cc *pcc, int flags,
const struct puffs_cred *cr, pid_t pid)
{
return 0;
}
/* ARGSUSED2 */
static int
puffs_fuse_fs_statvfs(struct puffs_cc *pcc, struct statvfs *svfsb, pid_t pid)
{
struct puffs_usermount *pu = puffs_cc_getusermount(pcc);
struct fuse *fuse;
int ret;
fuse = (struct fuse *)pu->pu_privdata;
if (fuse->op.statfs == NULL) {
if ((ret = statvfs(PNPATH(pu->pu_pn_root), svfsb)) == -1) {
return errno;
}
} else {
ret = (*fuse->op.statfs)(PNPATH(pu->pu_pn_root), svfsb);
}
return ret;
}
/* End of puffs_fuse operations */
/* ARGSUSED3 */
int
fuse_main_real(int argc, char **argv, const struct fuse_operations *ops,
size_t size, void *userdata)
{
struct puffs_usermount *pu;
struct puffs_pathobj *po_root;
struct puffs_ops *pops;
struct statvfs svfsb;
struct fuse *fuse;
char name[64];
char *slash;
int ret;
/* initialise the puffs operations structure */
PUFFSOP_INIT(pops);
PUFFSOP_SET(pops, puffs_fuse, fs, sync);
PUFFSOP_SET(pops, puffs_fuse, fs, statvfs);
PUFFSOP_SET(pops, puffs_fuse, fs, unmount);
/*
* XXX: all of these don't possibly need to be
* unconditionally set
*/
PUFFSOP_SET(pops, puffs_fuse, node, lookup);
PUFFSOP_SET(pops, puffs_fuse, node, getattr);
PUFFSOP_SET(pops, puffs_fuse, node, readdir);
PUFFSOP_SET(pops, puffs_fuse, node, readlink);
PUFFSOP_SET(pops, puffs_fuse, node, mknod);
PUFFSOP_SET(pops, puffs_fuse, node, mkdir);
PUFFSOP_SET(pops, puffs_fuse, node, remove);
PUFFSOP_SET(pops, puffs_fuse, node, rmdir);
PUFFSOP_SET(pops, puffs_fuse, node, symlink);
PUFFSOP_SET(pops, puffs_fuse, node, rename);
PUFFSOP_SET(pops, puffs_fuse, node, link);
PUFFSOP_SET(pops, puffs_fuse, node, setattr);
PUFFSOP_SET(pops, puffs_fuse, node, open);
PUFFSOP_SET(pops, puffs_fuse, node, read);
PUFFSOP_SET(pops, puffs_fuse, node, write);
PUFFSOP_SET(pops, puffs_fuse, node, readdir);
PUFFSOP_SET(pops, puffs_fuse, node, read);
PUFFSOP_SET(pops, puffs_fuse, node, write);
PUFFSOP_SET(pops, puffs_fuse, node, reclaim);
NEW(struct fuse, fuse, "fuse_main_real", exit(EXIT_FAILURE));
/* copy fuse ops to their own stucture */
(void) memcpy(&fuse->op, ops, sizeof(fuse->op));
/* whilst this (assigning the pu_privdata in the puffs
* usermount struct to be the fuse struct) might seem like
* we are chasing our tail here, the logic is as follows:
+ the operation wrapper gets called with the puffs
calling conventions
+ we need to fix up args first
+ then call the fuse user-supplied operation
+ then we fix up any values on return that we need to
+ and fix up any nodes, etc
* so we need to be able to get at the fuse ops from within the
* puffs_usermount struct
*/
if ((slash = strrchr(*argv, '/')) == NULL) {
slash = *argv;
} else {
slash += 1;
}
(void) snprintf(name, sizeof(name), "refuse:%s", slash);
pu = puffs_mount(pops, argv[argc - 1], MNT_NODEV | MNT_NOSUID,
name, fuse,
PUFFS_FLAG_BUILDPATH | PUFFS_FLAG_OPDUMP, 0);
if (pu == NULL) {
err(EXIT_FAILURE, "puffs_mount");
}
fuse->pu = pu;
pu->pu_pn_root = puffs_pn_new(pu, NULL);
po_root = puffs_getrootpathobj(pu);
po_root->po_path = strdup("/");
po_root->po_len = 1;
statvfs(argv[argc - 1], &svfsb); /* XXX - not really the correct dir */
if (puffs_start(pu, pu->pu_pn_root, &svfsb) == -1) {
err(EXIT_FAILURE, "puffs_start");
}
ret = puffs_mainloop(fuse->pu, PUFFSLOOP_NODAEMON);
(void) free(po_root->po_path);
FREE(fuse);
return ret;
}
/* ARGSUSED0 */
int
fuse_opt_parse(struct fuse_args *args, void *data,
const struct fuse_opt *opts, fuse_opt_proc_t proc)
{
return 0;
}