xref: /netbsd-src/lib/libperfuse/perfuse_if.h (revision daf6c4152fcddc27c445489775ed1f66ab4ea9a9)
1 /*  $NetBSD: perfuse_if.h,v 1.10 2010/10/11 05:37:58 manu Exp $ */
2 
3 /*-
4  *  Copyright (c) 2010 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 _REFUSE_PERFUSE_H
29 #define _REFUSE_PERFUSE_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 
39 /*
40  * Diagnostic flags. This global is used only for DPRINTF/DERR/DWARN
41  */
42 extern int perfuse_diagflags;
43 #define PDF_FOREGROUND	0x001	/* we run in foreground */
44 #define PDF_FUSE	0x002	/* Display FUSE reqeusts and reply */
45 #define PDF_DUMP	0x004	/* Dump FUSE frames */
46 #define PDF_PUFFS	0x008	/* Display PUFFS requets and reply */
47 #define PDF_FH		0x010	/* File handles */
48 #define PDF_RECLAIM	0x020	/* Reclaimed files */
49 #define PDF_READDIR	0x040	/* readdir operations */
50 #define PDF_REQUEUE	0x080	/* reueued messages */
51 #define PDF_SYNC	0x100	/* fsync and dirty flags */
52 #define PDF_MISC	0x200	/* Miscelaneous messages */
53 #define PDF_SYSLOG	0x400	/* use syslog */
54 #define PDF_FILENAME	0x800	/* File names */
55 
56 /*
57  * Diagnostic functions
58  */
59 #define DPRINTF(fmt, ...) do {						\
60 	if (perfuse_diagflags & PDF_SYSLOG)				\
61 		syslog(LOG_INFO, fmt, ## __VA_ARGS__);			\
62 									\
63 	if (perfuse_diagflags & PDF_FOREGROUND)				\
64 		(void)printf(fmt, ## __VA_ARGS__);			\
65 } while (0 /* CONSTCOND */)
66 
67 #define DERRX(status, fmt, ...) do {					\
68 	if (perfuse_diagflags & PDF_SYSLOG)				\
69 		syslog(LOG_ERR, fmt, ## __VA_ARGS__);			\
70 									\
71 	if (perfuse_diagflags & PDF_FOREGROUND) {			\
72 		(void)fprintf(stderr,  fmt, ## __VA_ARGS__);		\
73 		abort();						\
74 	} else {							\
75 		errx(status, fmt, ## __VA_ARGS__);			\
76 	}								\
77 } while (0 /* CONSTCOND */)
78 
79 #define DERR(status, fmt, ...) do {					\
80 	char fmterr[BUFSIZ];						\
81 	char strerrbuf[BUFSIZ];						\
82 									\
83 	(void)strerror_r(errno, strerrbuf, sizeof(strerrbuf));		\
84 	(void)sprintf(fmterr, "%s: %s\n", fmt, strerrbuf);		\
85 									\
86 	if (perfuse_diagflags & PDF_SYSLOG)				\
87 		syslog(LOG_ERR, fmterr, ## __VA_ARGS__);		\
88 									\
89 	if (perfuse_diagflags & PDF_FOREGROUND) {			\
90 		(void)fprintf(stderr,  fmterr, ## __VA_ARGS__);		\
91 		abort();						\
92 	} else {							\
93 		errx(status, fmt, ## __VA_ARGS__);			\
94 	}								\
95 } while (0 /* CONSTCOND */)
96 
97 #define DWARNX(fmt, ...) do {						\
98 	if (perfuse_diagflags & PDF_SYSLOG)				\
99 		syslog(LOG_WARNING, fmt, ## __VA_ARGS__);		\
100 									\
101 	warnx(fmt, ## __VA_ARGS__);					\
102 } while (0 /* CONSTCOND */)
103 
104 #define DWARN(fmt, ...) do {						\
105 	char fmterr[BUFSIZ];						\
106 	char strerrbuf[BUFSIZ];						\
107 									\
108 	(void)strerror_r(errno, strerrbuf, sizeof(strerrbuf));		\
109 	(void)sprintf(fmterr, "%s: %s\n", fmt, strerrbuf);		\
110 									\
111 	if (perfuse_diagflags & PDF_SYSLOG)				\
112 		syslog(LOG_WARNING, fmterr, ## __VA_ARGS__);		\
113 									\
114 	warn(fmterr, ## __VA_ARGS__);					\
115 } while (0 /* CONSTCOND */)
116 
117 /*
118  * frame handling callbacks
119  */
120 #ifndef PEFUSE_MSG_T
121 #define PEFUSE_MSG_T struct perfuse_framebuf
122 #endif
123 typedef PEFUSE_MSG_T perfuse_msg_t;
124 
125 #define PERFUSE_UNSPEC_REPLY_LEN (size_t)-1
126 
127 enum perfuse_xchg_pb_reply { wait_reply, no_reply };
128 typedef perfuse_msg_t *(*perfuse_new_msg_fn)(struct puffs_usermount *,
129     puffs_cookie_t, int, size_t, const struct puffs_cred *);
130 typedef int (*perfuse_xchg_msg_fn)(struct puffs_usermount *,
131     perfuse_msg_t *, size_t, enum perfuse_xchg_pb_reply);
132 typedef void (*perfuse_destroy_msg_fn)(perfuse_msg_t *);
133 typedef struct fuse_out_header *(*perfuse_get_outhdr_fn)(perfuse_msg_t *);
134 typedef struct fuse_in_header *(*perfuse_get_inhdr_fn)(perfuse_msg_t *);
135 typedef char *(*perfuse_get_inpayload_fn)(perfuse_msg_t *);
136 typedef char *(*perfuse_get_outpayload_fn)(perfuse_msg_t *);
137 
138 struct perfuse_callbacks {
139 	perfuse_new_msg_fn pc_new_msg;
140 	perfuse_xchg_msg_fn pc_xchg_msg;
141 	perfuse_destroy_msg_fn pc_destroy_msg;
142 	perfuse_get_inhdr_fn pc_get_inhdr;
143 	perfuse_get_inpayload_fn pc_get_inpayload;
144 	perfuse_get_outhdr_fn pc_get_outhdr;
145 	perfuse_get_outpayload_fn pc_get_outpayload;
146 };
147 
148 /*
149  * mount request
150  */
151 struct perfuse_mount_out {
152         uint32_t pmo_len;
153         int32_t pmo_error;
154         uint64_t pmo_unique;
155 	char pmo_magic[sizeof(PERFUSE_MOUNT_MAGIC)];
156 	uint32_t pmo_source_len;
157 	uint32_t pmo_target_len;
158 	uint32_t pmo_filesystemtype_len;
159 	uint32_t pmo_mountflags;
160 	uint32_t pmo_data_len;
161 	uint32_t pmo_sock_len;
162 };
163 
164 struct perfuse_mount_info {
165 	const char *pmi_source;
166 	const char *pmi_target;
167 	const char *pmi_filesystemtype;
168 	int pmi_mountflags;
169 	void *pmi_data;
170 	uid_t pmi_uid;
171 };
172 
173 /*
174  * Duplicated fro fuse.h to avoid making it public
175  */
176 #ifndef FUSE_BUFSIZE
177 #define FUSE_MIN_BUFSIZE 0x21000
178 #define FUSE_PREF_BUFSIZE (PAGE_SIZE + 0x1000)
179 #define FUSE_BUFSIZE MAX(FUSE_PREF_BUFSIZE /* CONSTCOND */, FUSE_MIN_BUFSIZE)
180 #endif /* FUSE_BUFSIZE */
181 
182 struct fuse_in_header {
183 	uint32_t	len;
184 	uint32_t	opcode;
185 	uint64_t	unique;
186 	uint64_t	nodeid;
187 	uint32_t	uid;
188 	uint32_t	gid;
189 	uint32_t	pid;
190 	uint32_t	padding;
191 };
192 
193 struct fuse_out_header {
194 	uint32_t	len;
195 	int32_t	error;
196 	uint64_t	unique;
197 };
198 
199 __BEGIN_DECLS
200 
201 struct puffs_usermount *perfuse_init(struct perfuse_callbacks *,
202     struct perfuse_mount_info *);
203 void perfuse_setspecific(struct puffs_usermount *, void *);
204 void *perfuse_getspecific(struct puffs_usermount *);
205 uint64_t perfuse_next_unique(struct puffs_usermount *);
206 uint64_t perfuse_get_ino(struct puffs_usermount *, puffs_cookie_t);
207 int perfuse_inloop(struct puffs_usermount *);
208 const char *perfuse_opname(int);
209 void perfuse_fs_init(struct puffs_usermount *);
210 int perfuse_mainloop(struct puffs_usermount *);
211 int perfuse_unmount(struct puffs_usermount *);
212 
213 #endif /* _REFUSE_PERFUSE_H */
214