Home | History | Annotate | Line # | Download | only in libperfuse
perfuse_if.h revision 1.18
      1 /*  $NetBSD: perfuse_if.h,v 1.18 2011/12/28 17:33:53 manu Exp $ */
      2 
      3 /*-
      4  *  Copyright (c) 2010-2011 Emmanuel Dreyfus. All rights reserved.
      5  *
      6  *  Redistribution and use in source and binary forms, with or without
      7  *  modification, are permitted provided that the following conditions
      8  *  are met:
      9  *  1. Redistributions of source code must retain the above copyright
     10  *     notice, this list of conditions and the following disclaimer.
     11  *  2. Redistributions in binary form must reproduce the above copyright
     12  *     notice, this list of conditions and the following disclaimer in the
     13  *     documentation and/or other materials provided with the distribution.
     14  *
     15  *  THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
     16  *  ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
     17  *  TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
     18  *  PURPOSE ARE DISCLAIMED.  IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
     19  *  BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
     20  *  CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
     21  *  SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
     22  *  INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
     23  *  CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
     24  *  ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
     25  *  POSSIBILITY OF SUCH DAMAGE.
     26  */
     27 
     28 #ifndef _PERFUSE_IF_H
     29 #define _PERFUSE_IF_H
     30 
     31 #ifndef _PATH_PERFUSED
     32 #define _PATH_PERFUSED "/usr/sbin/perfused"
     33 #endif /* _PATH_PERFUSED */
     34 #define _PATH_FUSE "/dev/fuse"
     35 #define FUSE_COMMFD_ENV "_FUSE_COMMFD"
     36 #define PERFUSE_MOUNT_MAGIC "noFuseRq"
     37 #define PERFUSE_UNKNOWN_INO 0xffffffff
     38 #define PERFUSE_UNKNOWN_NODEID 0xffffffff
     39 
     40 /*
     41  * Diagnostic flags. This global is used only for DPRINTF/DERR/DWARN
     42  */
     43 extern int perfuse_diagflags;
     44 #define PDF_FOREGROUND	0x0001	/* we run in foreground */
     45 #define PDF_FUSE	0x0002	/* Display FUSE reqeusts and reply */
     46 #define PDF_DUMP	0x0004	/* Dump FUSE frames */
     47 #define PDF_PUFFS	0x0008	/* Display PUFFS requets and reply */
     48 #define PDF_FH		0x0010	/* File handles */
     49 #define PDF_RECLAIM	0x0020	/* Reclaimed files */
     50 #define PDF_READDIR	0x0040	/* readdir operations */
     51 #define PDF_REQUEUE	0x0080	/* reueued messages */
     52 #define PDF_SYNC	0x0100	/* fsync and dirty flags */
     53 #define PDF_MISC	0x0200	/* Miscelaneous messages */
     54 #define PDF_SYSLOG	0x0400	/* use syslog */
     55 #define PDF_FILENAME	0x0800	/* File names */
     56 #define PDF_RESIZE	0x1000	/* Resize operations */
     57 #define PDF_TRACE	0x2000	/* Trace FUSE calls */
     58 
     59 /*
     60  * Diagnostic functions
     61  */
     62 #define DPRINTF(fmt, ...) do {						\
     63 	if (perfuse_diagflags & PDF_SYSLOG)				\
     64 		syslog(LOG_INFO, fmt, ## __VA_ARGS__);			\
     65 									\
     66 	if (perfuse_diagflags & PDF_FOREGROUND)				\
     67 		(void)printf(fmt, ## __VA_ARGS__);			\
     68 } while (0 /* CONSTCOND */)
     69 
     70 #define DERRX(status, fmt, ...) do {					\
     71 	if (perfuse_diagflags & PDF_SYSLOG)				\
     72 		syslog(LOG_ERR, fmt, ## __VA_ARGS__);			\
     73 									\
     74 	if (perfuse_diagflags & PDF_FOREGROUND) {			\
     75 		(void)fprintf(stderr,  fmt, ## __VA_ARGS__);		\
     76 		abort();						\
     77 	} else {							\
     78 		errx(status, fmt, ## __VA_ARGS__);			\
     79 	}								\
     80 } while (0 /* CONSTCOND */)
     81 
     82 #define DERR(status, fmt, ...) do {					\
     83 	if (perfuse_diagflags & PDF_SYSLOG)				\
     84 		syslog(LOG_ERR, fmt ": %m", ## __VA_ARGS__);		\
     85 									\
     86 	if (perfuse_diagflags & PDF_FOREGROUND) {			\
     87 		char strerrbuf[BUFSIZ];					\
     88 									\
     89 		(void)strerror_r(errno, strerrbuf, sizeof(strerrbuf));	\
     90 		(void)fprintf(stderr,  fmt ": %s", ## __VA_ARGS__,	\
     91 		    strerrbuf);						\
     92 		abort();						\
     93 	} else {							\
     94 		err(status, fmt, ## __VA_ARGS__);			\
     95 	}								\
     96 } while (0 /* CONSTCOND */)
     97 
     98 #define DWARNX(fmt, ...) do {						\
     99 	if (perfuse_diagflags & PDF_SYSLOG)				\
    100 		syslog(LOG_WARNING, fmt, ## __VA_ARGS__);		\
    101 									\
    102 	warnx(fmt, ## __VA_ARGS__);					\
    103 } while (0 /* CONSTCOND */)
    104 
    105 #define DWARN(fmt, ...) do {						\
    106 									\
    107 	if (perfuse_diagflags & PDF_SYSLOG) 				\
    108 		syslog(LOG_WARNING, fmt ": %m", ## __VA_ARGS__);	\
    109 									\
    110 	warn(fmt, ## __VA_ARGS__);					\
    111 } while (0 /* CONSTCOND */)
    112 
    113 /*
    114  * frame handling callbacks
    115  */
    116 #ifndef PEFUSE_MSG_T
    117 #define PEFUSE_MSG_T struct perfuse_framebuf
    118 #endif
    119 typedef PEFUSE_MSG_T perfuse_msg_t;
    120 
    121 #define PERFUSE_UNSPEC_REPLY_LEN (size_t)-1
    122 
    123 enum perfuse_xchg_pb_reply { wait_reply, no_reply };
    124 typedef perfuse_msg_t *(*perfuse_new_msg_fn)(struct puffs_usermount *,
    125     puffs_cookie_t, int, size_t, const struct puffs_cred *);
    126 typedef int (*perfuse_xchg_msg_fn)(struct puffs_usermount *,
    127     perfuse_msg_t *, size_t, enum perfuse_xchg_pb_reply);
    128 typedef void (*perfuse_destroy_msg_fn)(perfuse_msg_t *);
    129 typedef struct fuse_out_header *(*perfuse_get_outhdr_fn)(perfuse_msg_t *);
    130 typedef struct fuse_in_header *(*perfuse_get_inhdr_fn)(perfuse_msg_t *);
    131 typedef char *(*perfuse_get_inpayload_fn)(perfuse_msg_t *);
    132 typedef char *(*perfuse_get_outpayload_fn)(perfuse_msg_t *);
    133 typedef void (*perfuse_umount_fn)(struct puffs_usermount *);
    134 
    135 struct perfuse_callbacks {
    136 	perfuse_new_msg_fn pc_new_msg;
    137 	perfuse_xchg_msg_fn pc_xchg_msg;
    138 	perfuse_destroy_msg_fn pc_destroy_msg;
    139 	perfuse_get_inhdr_fn pc_get_inhdr;
    140 	perfuse_get_inpayload_fn pc_get_inpayload;
    141 	perfuse_get_outhdr_fn pc_get_outhdr;
    142 	perfuse_get_outpayload_fn pc_get_outpayload;
    143 	perfuse_umount_fn pc_umount;
    144 };
    145 
    146 /*
    147  * mount request
    148  */
    149 struct perfuse_mount_out {
    150         uint32_t pmo_len;
    151         int32_t pmo_error;
    152         uint64_t pmo_unique;
    153 	char pmo_magic[sizeof(PERFUSE_MOUNT_MAGIC)];
    154 	uint32_t pmo_source_len;
    155 	uint32_t pmo_target_len;
    156 	uint32_t pmo_filesystemtype_len;
    157 	uint32_t pmo_mountflags;
    158 	uint32_t pmo_data_len;
    159 	uint32_t pmo_sock_len;
    160 };
    161 
    162 struct perfuse_mount_info {
    163 	const char *pmi_source;
    164 	const char *pmi_target;
    165 	const char *pmi_filesystemtype;
    166 	int pmi_mountflags;
    167 	void *pmi_data;
    168 	uid_t pmi_uid;
    169 };
    170 
    171 /*
    172  * Duplicated from fuse.h to avoid making it public
    173  */
    174 #ifndef FUSE_BUFSIZE
    175 #define FUSE_MIN_BUFSIZE 0x21000
    176 #define FUSE_PREF_BUFSIZE (sysconf(_SC_PAGESIZE) + 0x1000)
    177 #define FUSE_BUFSIZE MAX(FUSE_PREF_BUFSIZE /* CONSTCOND */, FUSE_MIN_BUFSIZE)
    178 #endif /* FUSE_BUFSIZE */
    179 
    180 struct fuse_in_header {
    181 	uint32_t	len;
    182 	uint32_t	opcode;
    183 	uint64_t	unique;
    184 	uint64_t	nodeid;
    185 	uint32_t	uid;
    186 	uint32_t	gid;
    187 	uint32_t	pid;
    188 	uint32_t	padding;
    189 };
    190 
    191 struct fuse_out_header {
    192 	uint32_t	len;
    193 	int32_t	error;
    194 	uint64_t	unique;
    195 };
    196 
    197 __BEGIN_DECLS
    198 
    199 struct puffs_usermount *perfuse_init(struct perfuse_callbacks *,
    200     struct perfuse_mount_info *);
    201 void perfuse_setspecific(struct puffs_usermount *, void *);
    202 void *perfuse_getspecific(struct puffs_usermount *);
    203 uint64_t perfuse_next_unique(struct puffs_usermount *);
    204 uint64_t perfuse_get_nodeid(struct puffs_usermount *, puffs_cookie_t);
    205 int perfuse_inloop(struct puffs_usermount *);
    206 const char *perfuse_opname(int);
    207 void perfuse_fs_init(struct puffs_usermount *);
    208 int perfuse_mainloop(struct puffs_usermount *);
    209 int perfuse_unmount(struct puffs_usermount *);
    210 void perfuse_trace_dump(struct puffs_usermount *, FILE *);
    211 
    212 #endif /* _PERFUSE_IF_H */
    213