/* $NetBSD: perfuse_priv.h,v 1.36 2014/10/31 15:12:15 manu Exp $ */ /*- * Copyright (c) 2010-2011 Emmanuel Dreyfus. 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. * * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS * ``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 FOUNDATION OR CONTRIBUTORS * 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. */ #ifndef _PERFUSE_PRIV_H_ #define _PERFUSE_PRIV_H_ #include #include #include #include #include #include #include #include "perfuse_if.h" #include "fuse.h" /* From src/sys/fs/puffs/puffs_vfsops.c */ #ifndef PUFFS_PNODEBUCKETS #define PUFFS_PNODEBUCKETS 256 #endif /* PUFFS_PNODEBUCKETS */ #define PERFUSE_TRACECOUNT_MAX 4096 #define PERFUSE_TRACEPATH_MAX 256 struct perfuse_trace { int pt_opcode; char pt_path[PERFUSE_TRACEPATH_MAX]; char pt_extra[BUFSIZ]; int pt_error; enum { inxchg, done } pt_status; struct timespec pt_start; struct timespec pt_end; TAILQ_ENTRY(perfuse_trace) pt_list; }; LIST_HEAD(perfuse_node_hashlist, perfuse_node_data); struct perfuse_state { void *ps_private; /* Private field for libperfuse user */ struct puffs_usermount *ps_pu; struct puffs_node *ps_root; uid_t ps_owner_uid; int ps_flags; #define PS_NO_ACCESS 0x0001 /* access is unimplemented; */ #define PS_NO_CREAT 0x0004 /* create is unimplemented */ #define PS_INLOOP 0x0008 /* puffs mainloop started */ #define PS_NO_FALLOCATE 0x0010 /* fallocate is unimplemented */ uint64_t ps_fsid; uint32_t ps_max_readahead; uint32_t ps_max_write; uint64_t ps_syncreads; uint64_t ps_syncwrites; uint64_t ps_asyncreads; uint64_t ps_asyncwrites; char *ps_source; char *ps_target; char *ps_filesystemtype; int ps_mountflags; uint64_t ps_unique; perfuse_new_msg_fn ps_new_msg; perfuse_xchg_msg_fn ps_xchg_msg; perfuse_destroy_msg_fn ps_destroy_msg; perfuse_get_inhdr_fn ps_get_inhdr; perfuse_get_inpayload_fn ps_get_inpayload; perfuse_get_outhdr_fn ps_get_outhdr; perfuse_get_outpayload_fn ps_get_outpayload; perfuse_umount_fn ps_umount; TAILQ_HEAD(,perfuse_trace) ps_trace; uint64_t ps_tracecount; struct perfuse_node_hashlist *ps_nidhash; int ps_nnidhash; int ps_nodecount; int ps_nodeleakcount; int ps_xchgcount; }; enum perfuse_qtype { PCQ_READDIR, PCQ_READ, PCQ_WRITE, PCQ_AFTERWRITE, PCQ_OPEN, PCQ_AFTERXCHG, PCQ_RESIZE, PCQ_REF }; #ifdef PERFUSE_DEBUG extern const char * const perfuse_qtypestr[]; #endif struct perfuse_cc_queue { enum perfuse_qtype pcq_type; struct puffs_cc *pcq_cc; TAILQ_ENTRY(perfuse_cc_queue) pcq_next; const char *pcq_func; int pcq_line; }; struct perfuse_node_data { uint64_t pnd_rfh; uint64_t pnd_wfh; uint64_t pnd_nodeid; /* nodeid, this is not inode */ uint64_t pnd_parent_nodeid; /* parent's nodeid */ uint32_t pnd_hashidx; /* node hash index */ uint64_t pnd_fuse_nlookup; /* vnode refcount */ int pnd_puffs_nlookup; /* vnode refcount */ uint64_t pnd_lock_owner; struct dirent *pnd_dirent; /* native buffer for readdir */ off_t pnd_dirent_len; struct fuse_dirent *pnd_all_fd; /* FUSE buffer for readdir */ size_t pnd_all_fd_len; uint64_t pnd_fd_cookie; /* opaque readdir ref from fs */ TAILQ_HEAD(,perfuse_cc_queue) pnd_pcq; /* queued requests */ int pnd_flags; #define PND_RECLAIMED 0x001 /* reclaim pending */ #define PND_INREADDIR 0x002 /* readdir in progress */ #define PND_DIRTY 0x004 /* There is some data to sync */ #define PND_RFH 0x008 /* Read FH allocated */ #define PND_WFH 0x010 /* Write FH allocated */ #define PND_REMOVED 0x020 /* Node was removed */ #define PND_INWRITE 0x040 /* write in progress */ #define PND_INOPEN 0x100 /* open in progress */ #define PND_NODELEAK 0x200 /* node reclaim ignored */ #define PND_INVALID 0x400 /* node freed, usage is a bug */ #define PND_INRESIZE 0x800 /* resize in progress */ #define PND_OPEN (PND_RFH|PND_WFH) /* File is open */ #define PND_BUSY (PND_INREADDIR|PND_INWRITE|PND_INOPEN) LIST_ENTRY(perfuse_node_data) pnd_nident; puffs_cookie_t pnd_pn; char pnd_name[MAXPATHLEN]; /* node name */ struct timespec pnd_cn_expire; int pnd_inxchg; int pnd_ref; }; #define PERFUSE_NODE_DATA(opc) \ ((struct perfuse_node_data *)puffs_pn_getpriv((struct puffs_node *)opc)) #define UNSPEC_REPLY_LEN PERFUSE_UNSPEC_REPLY_LEN /* shorter! */ #define NO_PAYLOAD_REPLY_LEN 0 #define GET_INHDR(ps, pm) ps->ps_get_inhdr(pm) #define GET_INPAYLOAD(ps, pm, type) \ (struct type *)(void *)ps->ps_get_inpayload(pm) #define _GET_INPAYLOAD(ps, pm, type) (type)ps->ps_get_inpayload(pm) #define GET_OUTHDR(ps, pm) ps->ps_get_outhdr(pm) #define GET_OUTPAYLOAD(ps, pm, type) \ (struct type *)(void *)ps->ps_get_outpayload(pm) #define _GET_OUTPAYLOAD(ps, pm, type) (type)ps->ps_get_outpayload(pm) __BEGIN_DECLS struct puffs_node *perfuse_new_pn(struct puffs_usermount *, const char *, struct puffs_node *); void perfuse_destroy_pn(struct puffs_usermount *, struct puffs_node *); void perfuse_new_fh(puffs_cookie_t, uint64_t, int); void perfuse_destroy_fh(puffs_cookie_t, uint64_t); uint64_t perfuse_get_fh(puffs_cookie_t, int); uint64_t perfuse_next_unique(struct puffs_usermount *); char *perfuse_node_path(struct perfuse_state *, puffs_cookie_t); int perfuse_node_close_common(struct puffs_usermount *, puffs_cookie_t, int); int perfuse_ns_match(const int, const char *); const char *perfuse_native_ns(const int, const char *, char *); char *perfuse_fs_mount(int, ssize_t); /* * ops.c - filesystem operations */ int perfuse_fs_unmount(struct puffs_usermount *, int); int perfuse_fs_statvfs(struct puffs_usermount *, struct statvfs *); int perfuse_fs_sync(struct puffs_usermount *, int, const struct puffs_cred *); int perfuse_fs_fhtonode(struct puffs_usermount *, void *, size_t, struct puffs_newinfo *); int perfuse_fs_nodetofh(struct puffs_usermount *, puffs_cookie_t, void *, size_t *); void perfuse_fs_suspend(struct puffs_usermount *, int); int perfuse_node_lookup(struct puffs_usermount *, puffs_cookie_t, struct puffs_newinfo *, const struct puffs_cn *); int perfuse_node_create(struct puffs_usermount *, puffs_cookie_t, struct puffs_newinfo *, const struct puffs_cn *, const struct vattr *); int perfuse_node_mknod(struct puffs_usermount *, puffs_cookie_t, struct puffs_newinfo *, const struct puffs_cn *, const struct vattr *); int perfuse_node_open(struct puffs_usermount *, puffs_cookie_t, int, const struct puffs_cred *); int perfuse_node_close(struct puffs_usermount *, puffs_cookie_t, int, const struct puffs_cred *); int perfuse_node_access(struct puffs_usermount *, puffs_cookie_t, int, const struct puffs_cred *); int perfuse_node_getattr(struct puffs_usermount *, puffs_cookie_t, struct vattr *, const struct puffs_cred *); int perfuse_node_setattr(struct puffs_usermount *, puffs_cookie_t, const struct vattr *, const struct puffs_cred *); int perfuse_node_poll(struct puffs_usermount *, puffs_cookie_t, int *); int perfuse_node_fsync(struct puffs_usermount *, puffs_cookie_t, const struct puffs_cred *, int, off_t, off_t); int perfuse_node_remove(struct puffs_usermount *, puffs_cookie_t, puffs_cookie_t, const struct puffs_cn *); int perfuse_node_link(struct puffs_usermount *, puffs_cookie_t, puffs_cookie_t, const struct puffs_cn *); int perfuse_node_rename(struct puffs_usermount *, puffs_cookie_t, puffs_cookie_t, const struct puffs_cn *, puffs_cookie_t, puffs_cookie_t, const struct puffs_cn *); int perfuse_node_mkdir(struct puffs_usermount *, puffs_cookie_t, struct puffs_newinfo *, const struct puffs_cn *, const struct vattr *); int perfuse_node_rmdir(struct puffs_usermount *, puffs_cookie_t, puffs_cookie_t, const struct puffs_cn *); int perfuse_node_symlink(struct puffs_usermount *, puffs_cookie_t, struct puffs_newinfo *, const struct puffs_cn *, const struct vattr *, const char *); int perfuse_node_readdir(struct puffs_usermount *, puffs_cookie_t, struct dirent *, off_t *, size_t *, const struct puffs_cred *, int *, off_t *, size_t *); int perfuse_node_readlink(struct puffs_usermount *, puffs_cookie_t, const struct puffs_cred *, char *, size_t *); int perfuse_node_reclaim(struct puffs_usermount *, puffs_cookie_t); int perfuse_node_inactive(struct puffs_usermount *, puffs_cookie_t); int perfuse_node_print(struct puffs_usermount *, puffs_cookie_t); int perfuse_node_pathconf(struct puffs_usermount *, puffs_cookie_t, int, register_t *); int perfuse_node_advlock(struct puffs_usermount *, puffs_cookie_t, void *, int, struct flock *, int); int perfuse_node_read(struct puffs_usermount *, puffs_cookie_t, uint8_t *, off_t, size_t *, const struct puffs_cred *, int); int perfuse_node_write(struct puffs_usermount *, puffs_cookie_t, uint8_t *, off_t, size_t *, const struct puffs_cred *, int); int perfuse_node_write2(struct puffs_usermount *, puffs_cookie_t, uint8_t *, off_t, size_t *, const struct puffs_cred *, int, int); int perfuse_node_open2(struct puffs_usermount *, puffs_cookie_t, int, const struct puffs_cred *, int *); void perfuse_cache_write(struct puffs_usermount *, puffs_cookie_t, size_t, struct puffs_cacherun *); int perfuse_node_getextattr(struct puffs_usermount *, puffs_cookie_t, int, const char *, size_t *, uint8_t *, size_t *, const struct puffs_cred *); int perfuse_node_setextattr(struct puffs_usermount *, puffs_cookie_t, int, const char *, uint8_t *, size_t *, const struct puffs_cred *); int perfuse_node_listextattr(struct puffs_usermount *, puffs_cookie_t, int, size_t *, uint8_t *, size_t *, int, const struct puffs_cred *); int perfuse_node_deleteextattr(struct puffs_usermount *, puffs_cookie_t, int, const char *, const struct puffs_cred *); int perfuse_node_getattr_ttl(struct puffs_usermount *, puffs_cookie_t, struct vattr *, const struct puffs_cred *, struct timespec *); int perfuse_node_setattr_ttl(struct puffs_usermount *, puffs_cookie_t, struct vattr *, const struct puffs_cred *, struct timespec *, int); int perfuse_node_fallocate(struct puffs_usermount *, puffs_cookie_t, off_t, off_t); struct perfuse_trace *perfuse_trace_begin(struct perfuse_state *, puffs_cookie_t, perfuse_msg_t *); void perfuse_trace_end(struct perfuse_state *, struct perfuse_trace *, int); char *perfuse_opdump_in(struct perfuse_state *, perfuse_msg_t *); struct perfuse_node_data *perfuse_node_bynodeid(struct perfuse_state *, uint64_t); void perfuse_node_cache(struct perfuse_state *, puffs_cookie_t); void perfuse_cache_flush(puffs_cookie_t); __END_DECLS #endif /* _PERFUSE_PRIV_H_ */