/* $OpenBSD: fuse_ops.c,v 1.25 2016/08/30 16:45:54 natano Exp $ */ /* * Copyright (c) 2013 Sylvestre Gallon * * Permission to use, copy, modify, and distribute this software for any * purpose with or without fee is hereby granted, provided that the above * copyright notice and this permission notice appear in all copies. * * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE. */ #include #include #include #include "fuse_private.h" #include "debug.h" #define CHECK_OPT(opname) DPRINTF("Opcode:\t%s\n", #opname); \ DPRINTF("Inode:\t%llu\n", \ (unsigned long long)fbuf->fb_ino); \ if (!f->op.opname) { \ fbuf->fb_err = -ENOSYS; \ return (0); \ } static int update_attr(struct fuse *f, struct stat *attr, const char *realname, struct fuse_vnode *vn) { int ret; memset(attr, 0, sizeof(struct stat)); ret = f->op.getattr(realname, attr); if (attr->st_blksize == 0) attr->st_blksize = 512; if (attr->st_blocks == 0) attr->st_blocks = 4; attr->st_ino = vn->ino; if (f->conf.set_mode) attr->st_mode = (attr->st_mode & S_IFMT) | (0777 & ~f->conf.umask); if (f->conf.set_uid) attr->st_uid = f->conf.uid; if (f->conf.set_gid) attr->st_gid = f->conf.gid; return (ret); } static int ifuse_ops_init(struct fuse *f) { struct fuse_conn_info fci; DPRINTF("Opcode:\tinit\n"); if (f->op.init) { bzero(&fci, sizeof fci); fci.proto_minor = FUSE_MINOR_VERSION; fci.proto_major = FUSE_MAJOR_VERSION; f->op.init(&fci); } return (0); } static int ifuse_ops_getattr(struct fuse *f, struct fusebuf *fbuf) { struct fuse_vnode *vn; char *realname; DPRINTF("Opcode:\tgetattr\n"); DPRINTF("Inode:\t%llu\n", (unsigned long long)fbuf->fb_ino); memset(&fbuf->fb_attr, 0, sizeof(struct stat)); vn = tree_get(&f->vnode_tree, fbuf->fb_ino); if (vn == NULL) { fbuf->fb_err = -errno; return (0); } realname = build_realname(f, vn->ino); if (realname == NULL) { fbuf->fb_err = -errno; return (0); } fbuf->fb_err = update_attr(f, &fbuf->fb_attr, realname, vn); free(realname); return (0); } static int ifuse_ops_access(struct fuse *f, struct fusebuf *fbuf) { struct fuse_vnode *vn; char *realname; CHECK_OPT(access); vn = tree_get(&f->vnode_tree, fbuf->fb_ino); if (vn == NULL) { fbuf->fb_err = -errno; return (0); } realname = build_realname(f, vn->ino); if (realname == NULL) { fbuf->fb_err = -errno; return (0); } fbuf->fb_err = f->op.access(realname, fbuf->fb_io_mode); free(realname); return (0); } static int ifuse_ops_open(struct fuse *f, struct fusebuf *fbuf) { struct fuse_file_info ffi; struct fuse_vnode *vn; char *realname; CHECK_OPT(open); bzero(&ffi, sizeof(ffi)); ffi.flags = fbuf->fb_io_flags; vn = tree_get(&f->vnode_tree, fbuf->fb_ino); if (vn == NULL) { fbuf->fb_err = -errno; return (0); } realname = build_realname(f, vn->ino); if (realname == NULL) { fbuf->fb_err = -errno; return (0); } fbuf->fb_err = f->op.open(realname, &ffi); free(realname); if (!fbuf->fb_err) fbuf->fb_io_fd = ffi.fh; return (0); } static int ifuse_ops_opendir(struct fuse *f, struct fusebuf *fbuf) { struct fuse_file_info ffi; struct fuse_vnode *vn; char *realname; DPRINTF("Opcode:\topendir\n"); DPRINTF("Inode:\t%llu\n", (unsigned long long)fbuf->fb_ino); memset(&ffi, 0, sizeof(ffi)); ffi.flags = fbuf->fb_io_flags; vn = tree_get(&f->vnode_tree, fbuf->fb_ino); if (vn == NULL) { fbuf->fb_err = -errno; return (0); } if (f->op.opendir) { realname = build_realname(f, vn->ino); if (realname == NULL) { fbuf->fb_err = -errno; return (0); } fbuf->fb_err = f->op.opendir(realname, &ffi); free(realname); } if (!fbuf->fb_err) { fbuf->fb_io_fd = ffi.fh; vn->fd = calloc(1, sizeof(*vn->fd)); if (vn->fd == NULL) { fbuf->fb_err = -errno; return (0); } vn->fd->filled = 0; vn->fd->size = 0; vn->fd->start = 0; } return (0); } #define GENERIC_DIRSIZ(NLEN) \ ((sizeof (struct dirent) - (MAXNAMLEN+1)) + ((NLEN+1 + 7) &~ 7)) static int ifuse_fill_readdir(void *dh, const char *name, const struct stat *stbuf, off_t off) { struct fuse_dirhandle *fd = dh; struct fusebuf *fbuf; struct dirent *dir; uint32_t namelen; uint32_t len; fbuf = fd->buf; namelen = strnlen(name, MAXNAMLEN); len = GENERIC_DIRSIZ(namelen); if (fd->full || (fbuf->fb_len + len > fd->size)) { fd->full = 1; return (0); } if (fd->start != 0 && fd->idx < fd->start) { fd->idx += len; return (0); } dir = (struct dirent *) &fbuf->fb_dat[fbuf->fb_len]; if (off) fd->filled = 0; if (stbuf) { dir->d_fileno = stbuf->st_ino; dir->d_type = IFTODT(stbuf->st_mode); } else { dir->d_fileno = 0xffffffff; dir->d_type = DT_UNKNOWN; } dir->d_reclen = len; dir->d_off = off + len; /* XXX */ strlcpy(dir->d_name, name, sizeof(dir->d_name)); dir->d_namlen = strlen(dir->d_name); fbuf->fb_len += len; fd->start += len; fd->idx += len; return (0); } static int ifuse_fill_getdir(fuse_dirh_t fd, const char *name, int type, ino_t ino) { struct stat st; bzero(&st, sizeof(st)); st.st_mode = type << 12; if (ino == 0) st.st_ino = 0xffffffff; else st.st_ino = ino; return (fd->filler(fd, name, &st, 0)); } static int ifuse_ops_readdir(struct fuse *f, struct fusebuf *fbuf) { struct fuse_file_info ffi; struct fuse_vnode *vn; char *realname; uint64_t offset; uint32_t size; uint32_t startsave; DPRINTF("Opcode:\treaddir\n"); DPRINTF("Inode:\t%llu\n", (unsigned long long)fbuf->fb_ino); DPRINTF("Offset:\t%llu\n", fbuf->fb_io_off); DPRINTF("Size:\t%lu\n", fbuf->fb_io_len); bzero(&ffi, sizeof(ffi)); ffi.fh = fbuf->fb_io_fd; offset = fbuf->fb_io_off; size = fbuf->fb_io_len; startsave = 0; fbuf->fb_dat = calloc(1, size); if (fbuf->fb_dat == NULL) { fbuf->fb_err = -errno; return (0); } vn = tree_get(&f->vnode_tree, fbuf->fb_ino); if (vn == NULL) { fbuf->fb_err = -errno; free(fbuf->fb_dat); return (0); } if (!vn->fd->filled) { vn->fd->filler = ifuse_fill_readdir; vn->fd->buf = fbuf; vn->fd->filled = 0; vn->fd->full = 0; vn->fd->size = size; vn->fd->off = offset; vn->fd->idx = 0; startsave = vn->fd->start; realname = build_realname(f, vn->ino); if (realname == NULL) { fbuf->fb_err = -errno; free(fbuf->fb_dat); return (0); } if (f->op.readdir) fbuf->fb_err = f->op.readdir(realname, vn->fd, ifuse_fill_readdir, offset, &ffi); else if (f->op.getdir) fbuf->fb_err = f->op.getdir(realname, vn->fd, ifuse_fill_getdir); else fbuf->fb_err = -ENOSYS; free(realname); } if (!vn->fd->full && vn->fd->start == startsave) vn->fd->filled = 1; if (fbuf->fb_err) { fbuf->fb_len = 0; vn->fd->filled = 1; } if (fbuf->fb_len == 0) free(fbuf->fb_dat); return (0); } static int ifuse_ops_releasedir(struct fuse *f, struct fusebuf *fbuf) { struct fuse_file_info ffi; struct fuse_vnode *vn; char *realname; DPRINTF("Opcode:\treleasedir\n"); DPRINTF("Inode:\t%llu\n", (unsigned long long)fbuf->fb_ino); bzero(&ffi, sizeof(ffi)); ffi.fh = fbuf->fb_io_fd; ffi.fh_old = ffi.fh; ffi.flags = fbuf->fb_io_flags; vn = tree_get(&f->vnode_tree, fbuf->fb_ino); if (vn == NULL) { fbuf->fb_err = -errno; return (0); } if (f->op.releasedir) { realname = build_realname(f, vn->ino); if (realname == NULL) { fbuf->fb_err = -errno; return (0); } fbuf->fb_err = f->op.releasedir(realname, &ffi); free(realname); } if (!fbuf->fb_err) free(vn->fd); return (0); } static int ifuse_ops_release(struct fuse *f, struct fusebuf *fbuf) { struct fuse_file_info ffi; struct fuse_vnode *vn; char *realname; CHECK_OPT(release); bzero(&ffi, sizeof(ffi)); ffi.fh = fbuf->fb_io_fd; ffi.fh_old = ffi.fh; ffi.flags = fbuf->fb_io_flags; vn = tree_get(&f->vnode_tree, fbuf->fb_ino); if (vn == NULL) { fbuf->fb_err = -errno; return (0); } realname = build_realname(f, vn->ino); if (realname == NULL) { fbuf->fb_err = -errno; return (0); } fbuf->fb_err = f->op.release(realname, &ffi); free(realname); return (0); } static int ifuse_ops_lookup(struct fuse *f, struct fusebuf *fbuf) { struct fuse_vnode *vn; char *realname; DPRINTF("Opcode:\tlookup\n"); DPRINTF("Inode:\t%llu\n", (unsigned long long)fbuf->fb_ino); DPRINTF("For file %s\n", fbuf->fb_dat); vn = get_vn_by_name_and_parent(f, fbuf->fb_dat, fbuf->fb_ino); if (vn == NULL) { vn = alloc_vn(f, (const char *)fbuf->fb_dat, -1, fbuf->fb_ino); if (vn == NULL) { fbuf->fb_err = -errno; free(fbuf->fb_dat); return (0); } set_vn(f, vn); /*XXX*/ } DPRINTF("new ino %llu\n", (unsigned long long)vn->ino); realname = build_realname(f, vn->ino); if (realname == NULL) { fbuf->fb_err = -errno; free(fbuf->fb_dat); return (0); } fbuf->fb_err = update_attr(f, &fbuf->fb_attr, realname, vn); free(fbuf->fb_dat); free(realname); return (0); } static int ifuse_ops_read(struct fuse *f, struct fusebuf *fbuf) { struct fuse_file_info ffi; struct fuse_vnode *vn; char *realname; uint64_t offset; uint32_t size; int ret; CHECK_OPT(read); bzero(&ffi, sizeof(ffi)); ffi.fh = fbuf->fb_io_fd; size = fbuf->fb_io_len; offset = fbuf->fb_io_off; fbuf->fb_dat = malloc(size); if (fbuf->fb_dat == NULL) { fbuf->fb_err = -errno; return (0); } vn = tree_get(&f->vnode_tree, fbuf->fb_ino); if (vn == NULL) { fbuf->fb_err = -errno; free(fbuf->fb_dat); return (0); } realname = build_realname(f, vn->ino); if (realname == NULL) { fbuf->fb_err = -errno; free(fbuf->fb_dat); return (0); } ret = f->op.read(realname, (char *)fbuf->fb_dat, size, offset, &ffi); free(realname); if (ret >= 0) fbuf->fb_len = ret; else fbuf->fb_err = ret; if (fbuf->fb_len == 0) free(fbuf->fb_dat); return (0); } static int ifuse_ops_write(struct fuse *f, struct fusebuf *fbuf) { struct fuse_file_info ffi; struct fuse_vnode *vn; char *realname; uint64_t offset; uint32_t size; int ret; CHECK_OPT(write); bzero(&ffi, sizeof(ffi)); ffi.fh = fbuf->fb_io_fd; ffi.fh_old = ffi.fh; ffi.writepage = fbuf->fb_io_flags & 1; size = fbuf->fb_io_len; offset = fbuf->fb_io_off; vn = tree_get(&f->vnode_tree, fbuf->fb_ino); if (vn == NULL) { fbuf->fb_err = -errno; free(fbuf->fb_dat); return (0); } realname = build_realname(f, vn->ino); if (realname == NULL) { fbuf->fb_err = -errno; free(fbuf->fb_dat); return (0); } ret = f->op.write(realname, (char *)fbuf->fb_dat, size, offset, &ffi); free(realname); free(fbuf->fb_dat); if (ret >= 0) fbuf->fb_io_len = ret; else fbuf->fb_err = ret; return (0); } static int ifuse_ops_create(struct fuse *f, struct fusebuf *fbuf) { struct fuse_file_info ffi; struct fuse_vnode *vn; uint32_t mode; char *realname; DPRINTF("Opcode:\tcreate\n"); DPRINTF("Inode:\t%llu\n", (unsigned long long)fbuf->fb_ino); bzero(&ffi, sizeof(ffi)); ffi.flags = fbuf->fb_io_flags; mode = fbuf->fb_io_mode; vn = get_vn_by_name_and_parent(f, fbuf->fb_dat, fbuf->fb_ino); if (vn == NULL) { fbuf->fb_err = -errno; free(fbuf->fb_dat); return (0); } free(fbuf->fb_dat); realname = build_realname(f, vn->ino); if (realname == NULL) { fbuf->fb_err = -errno; return (0); } if (f->op.create) fbuf->fb_err = f->op.create(realname, mode, &ffi); else if (f->op.mknod) fbuf->fb_err = f->op.mknod(realname, S_IFREG | mode, 0); else fbuf->fb_err = -ENOSYS; if (!fbuf->fb_err) { fbuf->fb_err = update_attr(f, &fbuf->fb_attr, realname, vn); fbuf->fb_ino = fbuf->fb_attr.st_ino; fbuf->fb_io_mode = fbuf->fb_attr.st_mode; } free(realname); return (0); } static int ifuse_ops_mkdir(struct fuse *f, struct fusebuf *fbuf) { struct fuse_vnode *vn; char *realname; uint32_t mode; CHECK_OPT(mkdir); mode = fbuf->fb_io_mode; vn = get_vn_by_name_and_parent(f, fbuf->fb_dat, fbuf->fb_ino); if (vn == NULL) { fbuf->fb_err = -errno; free(fbuf->fb_dat); return (0); } free(fbuf->fb_dat); realname = build_realname(f, vn->ino); if (realname == NULL) { fbuf->fb_err = -errno; return (0); } fbuf->fb_err = f->op.mkdir(realname, mode); if (!fbuf->fb_err) { fbuf->fb_err = update_attr(f, &fbuf->fb_attr, realname, vn); fbuf->fb_io_mode = fbuf->fb_attr.st_mode; fbuf->fb_ino = vn->ino; } free(realname); return (0); } static int ifuse_ops_rmdir(struct fuse *f, struct fusebuf *fbuf) { struct fuse_vnode *vn; char *realname; CHECK_OPT(rmdir); vn = get_vn_by_name_and_parent(f, fbuf->fb_dat, fbuf->fb_ino); if (vn == NULL) { fbuf->fb_err = -errno; free(fbuf->fb_dat); return (0); } free(fbuf->fb_dat); realname = build_realname(f, vn->ino); if (realname == NULL) { fbuf->fb_err = -errno; return (0); } fbuf->fb_err = f->op.rmdir(realname); free(realname); return (0); } static int ifuse_ops_readlink(struct fuse *f, struct fusebuf *fbuf) { struct fuse_vnode *vn; char *realname; char name[PATH_MAX + 1]; int len, ret; DPRINTF("Opcode:\treadlink\n"); DPRINTF("Inode:\t%llu\n", (unsigned long long)fbuf->fb_ino); vn = tree_get(&f->vnode_tree, fbuf->fb_ino); if (vn == NULL) { fbuf->fb_err = -errno; return (0); } realname = build_realname(f, vn->ino); if (realname == NULL) { fbuf->fb_err = -errno; return (0); } if (f->op.readlink) ret = f->op.readlink(realname, name, sizeof(name)); else ret = -ENOSYS; free(realname); fbuf->fb_err = ret; if (!ret) { len = strnlen(name, PATH_MAX); fbuf->fb_len = len; fbuf->fb_dat = malloc(fbuf->fb_len); if (fbuf->fb_dat == NULL) { fbuf->fb_err = -errno; return (0); } memcpy(fbuf->fb_dat, name, len); } else fbuf->fb_len = 0; return (0); } static int ifuse_ops_unlink(struct fuse *f, struct fusebuf *fbuf) { struct fuse_vnode *vn; char *realname; CHECK_OPT(unlink); vn = get_vn_by_name_and_parent(f, fbuf->fb_dat, fbuf->fb_ino); if (vn == NULL) { free(fbuf->fb_dat); fbuf->fb_err = -errno; return (0); } free(fbuf->fb_dat); realname = build_realname(f, vn->ino); if (realname == NULL) { fbuf->fb_err = -errno; return (0); } fbuf->fb_err = f->op.unlink(realname); free(realname); return (0); } static int ifuse_ops_statfs(struct fuse *f, struct fusebuf *fbuf) { struct fuse_vnode *vn; char *realname; bzero(&fbuf->fb_stat, sizeof(fbuf->fb_stat)); CHECK_OPT(statfs); vn = tree_get(&f->vnode_tree, fbuf->fb_ino); if (vn == NULL) { fbuf->fb_err = -errno; return (0); } realname = build_realname(f, vn->ino); if (realname == NULL) { fbuf->fb_err = -errno; return (0); } fbuf->fb_err = f->op.statfs(realname, &fbuf->fb_stat); free(realname); return (0); } static int ifuse_ops_link(struct fuse *f, struct fusebuf *fbuf) { struct fuse_vnode *vn; char *realname; char *realname_ln; ino_t oldnodeid; CHECK_OPT(link); oldnodeid = fbuf->fb_io_ino; vn = get_vn_by_name_and_parent(f, fbuf->fb_dat, fbuf->fb_ino); if (vn == NULL) { fbuf->fb_err = -errno; free(fbuf->fb_dat); return (0); } free(fbuf->fb_dat); realname = build_realname(f, oldnodeid); if (realname == NULL) { fbuf->fb_err = -errno; return (0); } realname_ln = build_realname(f, vn->ino); if (realname_ln == NULL) { fbuf->fb_err = -errno; free(realname); return (0); } fbuf->fb_err = f->op.link(realname, realname_ln); free(realname); free(realname_ln); return (0); } static int ifuse_ops_setattr(struct fuse *f, struct fusebuf *fbuf) { struct fuse_vnode *vn; struct timespec ts[2]; struct utimbuf tbuf; struct fb_io *io; char *realname; uid_t uid; gid_t gid; DPRINTF("Opcode:\tsetattr\n"); DPRINTF("Inode:\t%llu\n", (unsigned long long)fbuf->fb_ino); vn = tree_get(&f->vnode_tree, fbuf->fb_ino); if (vn == NULL) { fbuf->fb_err = -errno; free(fbuf->fb_dat); return (0); } realname = build_realname(f, vn->ino); if (realname == NULL) { fbuf->fb_err = -errno; free(fbuf->fb_dat); return (0); } io = fbtod(fbuf, struct fb_io *); if (io->fi_flags & FUSE_FATTR_MODE) { if (f->op.chmod) fbuf->fb_err = f->op.chmod(realname, fbuf->fb_attr.st_mode); else fbuf->fb_err = -ENOSYS; } if (!fbuf->fb_err && (io->fi_flags & FUSE_FATTR_UID || io->fi_flags & FUSE_FATTR_GID) ) { uid = (io->fi_flags & FUSE_FATTR_UID) ? fbuf->fb_attr.st_uid : (gid_t)-1; gid = (io->fi_flags & FUSE_FATTR_GID) ? fbuf->fb_attr.st_gid : (uid_t)-1; if (f->op.chown) fbuf->fb_err = f->op.chown(realname, uid, gid); else fbuf->fb_err = -ENOSYS; } if (!fbuf->fb_err && ( io->fi_flags & FUSE_FATTR_MTIME || io->fi_flags & FUSE_FATTR_ATIME)) { ts[0] = fbuf->fb_attr.st_atim; ts[1] = fbuf->fb_attr.st_mtim; tbuf.actime = ts[0].tv_sec; tbuf.modtime = ts[1].tv_sec; if (f->op.utimens) fbuf->fb_err = f->op.utimens(realname, ts); else if (f->op.utime) fbuf->fb_err = f->op.utime(realname, &tbuf); else fbuf->fb_err = -ENOSYS; } if (!fbuf->fb_err && (io->fi_flags & FUSE_FATTR_SIZE)) { if (f->op.truncate) fbuf->fb_err = f->op.truncate(realname, fbuf->fb_attr.st_size); else fbuf->fb_err = -ENOSYS; } memset(&fbuf->fb_attr, 0, sizeof(struct stat)); if (!fbuf->fb_err) fbuf->fb_err = update_attr(f, &fbuf->fb_attr, realname, vn); free(realname); free(fbuf->fb_dat); return (0); } static int ifuse_ops_symlink(unused struct fuse *f, struct fusebuf *fbuf) { struct fuse_vnode *vn; char *realname; int len; CHECK_OPT(symlink); vn = get_vn_by_name_and_parent(f, fbuf->fb_dat, fbuf->fb_ino); if (vn == NULL) { fbuf->fb_err = -errno; free(fbuf->fb_dat); return (0); } len = strlen((char *)fbuf->fb_dat); realname = build_realname(f, vn->ino); if (realname == NULL) { fbuf->fb_err = -errno; free(fbuf->fb_dat); return (0); } /* fuse invert the symlink params */ fbuf->fb_err = f->op.symlink((const char *)&fbuf->fb_dat[len + 1], realname); fbuf->fb_ino = vn->ino; free(fbuf->fb_dat); free(realname); return (0); } static int ifuse_ops_rename(struct fuse *f, struct fusebuf *fbuf) { struct fuse_vnode *vnt; struct fuse_vnode *vnf; char *realnamef; char *realnamet; int len; CHECK_OPT(rename); len = strlen((char *)fbuf->fb_dat); vnf = get_vn_by_name_and_parent(f, fbuf->fb_dat, fbuf->fb_ino); if (vnf == NULL) { fbuf->fb_err = -errno; free(fbuf->fb_dat); return (0); } vnt = get_vn_by_name_and_parent(f, &fbuf->fb_dat[len + 1], fbuf->fb_io_ino); if (vnt == NULL) { fbuf->fb_err = -errno; free(fbuf->fb_dat); return (0); } free(fbuf->fb_dat); realnamef = build_realname(f, vnf->ino); if (realnamef == NULL) { fbuf->fb_err = -errno; return (0); } realnamet = build_realname(f, vnt->ino); if (realnamet == NULL) { fbuf->fb_err = -errno; free(realnamef); return (0); } fbuf->fb_err = f->op.rename(realnamef, realnamet); free(realnamef); free(realnamet); return (0); } static int ifuse_ops_destroy(struct fuse *f) { struct fuse_context *ctx; DPRINTF("Opcode:\tdestroy\n"); if (f->op.destroy) { ctx = fuse_get_context(); f->op.destroy((ctx)?ctx->private_data:NULL); } f->fc->dead = 1; return (0); } static int ifuse_ops_reclaim(struct fuse *f, struct fusebuf *fbuf) { struct fuse_vnode *vn; vn = tree_pop(&f->vnode_tree, fbuf->fb_ino); if (vn) { remove_vnode_from_name_tree(f, vn); free(vn); } return (0); } static int ifuse_ops_mknod(struct fuse *f, struct fusebuf *fbuf) { struct fuse_vnode *vn; char *realname; uint32_t mode; dev_t dev; CHECK_OPT(mknod); mode = fbuf->fb_io_mode; dev = fbuf->fb_io_rdev; vn = get_vn_by_name_and_parent(f, fbuf->fb_dat, fbuf->fb_ino); if (vn == NULL) { fbuf->fb_err = -errno; free(fbuf->fb_dat); return (0); } free(fbuf->fb_dat); realname = build_realname(f, vn->ino); if (realname == NULL) { fbuf->fb_err = -errno; return (0); } fbuf->fb_err = f->op.mknod(realname, mode, dev); if (!fbuf->fb_err) { fbuf->fb_err = update_attr(f, &fbuf->fb_attr, realname, vn); fbuf->fb_io_mode = fbuf->fb_attr.st_mode; fbuf->fb_ino = fbuf->fb_attr.st_ino; } free(realname); return (0); } int ifuse_exec_opcode(struct fuse *f, struct fusebuf *fbuf) { int ret = 0; fbuf->fb_len = 0; fbuf->fb_err = 0; switch (fbuf->fb_type) { case FBT_LOOKUP: ret = ifuse_ops_lookup(f, fbuf); break; case FBT_GETATTR: ret = ifuse_ops_getattr(f, fbuf); break; case FBT_SETATTR: ret = ifuse_ops_setattr(f, fbuf); break; case FBT_READLINK: ret = ifuse_ops_readlink(f, fbuf); break; case FBT_MKDIR: ret = ifuse_ops_mkdir(f, fbuf); break; case FBT_UNLINK: ret = ifuse_ops_unlink(f, fbuf); break; case FBT_RMDIR: ret = ifuse_ops_rmdir(f, fbuf); break; case FBT_LINK: ret = ifuse_ops_link(f, fbuf); break; case FBT_OPEN: ret = ifuse_ops_open(f, fbuf); break; case FBT_READ: ret = ifuse_ops_read(f, fbuf); break; case FBT_WRITE: ret = ifuse_ops_write(f, fbuf); break; case FBT_STATFS: ret = ifuse_ops_statfs(f, fbuf); break; case FBT_RELEASE: ret = ifuse_ops_release(f, fbuf); break; case FBT_INIT: ret = ifuse_ops_init(f); break; case FBT_OPENDIR: ret = ifuse_ops_opendir(f, fbuf); break; case FBT_READDIR: ret = ifuse_ops_readdir(f, fbuf); break; case FBT_RELEASEDIR: ret = ifuse_ops_releasedir(f, fbuf); break; case FBT_ACCESS: ret = ifuse_ops_access(f, fbuf); break; case FBT_CREATE: ret = ifuse_ops_create(f, fbuf); break; case FBT_SYMLINK: ret = ifuse_ops_symlink(f, fbuf); break; case FBT_RENAME: ret = ifuse_ops_rename(f, fbuf); break; case FBT_DESTROY: ret = ifuse_ops_destroy(f); break; case FBT_RECLAIM: ret = ifuse_ops_reclaim(f, fbuf); break; case FBT_MKNOD: ret = ifuse_ops_mknod(f, fbuf); break; default: DPRINTF("Opcode:\t%i not supported\n", fbuf->fb_type); DPRINTF("Inode:\t%llu\n", (unsigned long long)fbuf->fb_ino); fbuf->fb_err = -ENOSYS; fbuf->fb_len = 0; } DPRINTF("\n"); /* fuse api use negative errno */ fbuf->fb_err = -fbuf->fb_err; return (ret); }