perfuse_if.h revision 1.20 1 /* $NetBSD: perfuse_if.h,v 1.20 2012/07/21 05:49:42 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 puffs_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 typedef void (*perfuse_fsreq_fn)(struct puffs_usermount *, perfuse_msg_t *);
135
136 struct perfuse_callbacks {
137 perfuse_new_msg_fn pc_new_msg;
138 perfuse_xchg_msg_fn pc_xchg_msg;
139 perfuse_destroy_msg_fn pc_destroy_msg;
140 perfuse_get_inhdr_fn pc_get_inhdr;
141 perfuse_get_inpayload_fn pc_get_inpayload;
142 perfuse_get_outhdr_fn pc_get_outhdr;
143 perfuse_get_outpayload_fn pc_get_outpayload;
144 perfuse_umount_fn pc_umount;
145 perfuse_fsreq_fn pc_fsreq;
146 void *pc_reserved[15];
147 };
148
149 /*
150 * mount request
151 */
152 struct perfuse_mount_out {
153 uint32_t pmo_len;
154 int32_t pmo_error;
155 uint64_t pmo_unique;
156 char pmo_magic[sizeof(PERFUSE_MOUNT_MAGIC)];
157 uint32_t pmo_source_len;
158 uint32_t pmo_target_len;
159 uint32_t pmo_filesystemtype_len;
160 uint32_t pmo_mountflags;
161 uint32_t pmo_data_len;
162 uint32_t pmo_sock_len;
163 };
164
165 struct perfuse_mount_info {
166 const char *pmi_source;
167 const char *pmi_target;
168 const char *pmi_filesystemtype;
169 int pmi_mountflags;
170 void *pmi_data;
171 uid_t pmi_uid;
172 };
173
174 /*
175 * Duplicated from fuse.h to avoid making it public
176 */
177 #ifndef FUSE_BUFSIZE
178 #define FUSE_MIN_BUFSIZE 0x21000
179 #define FUSE_PREF_BUFSIZE (sysconf(_SC_PAGESIZE) + 0x1000)
180 #define FUSE_BUFSIZE MAX(FUSE_PREF_BUFSIZE /* CONSTCOND */, FUSE_MIN_BUFSIZE)
181 #endif /* FUSE_BUFSIZE */
182
183 struct fuse_in_header {
184 uint32_t len;
185 uint32_t opcode;
186 uint64_t unique;
187 uint64_t nodeid;
188 uint32_t uid;
189 uint32_t gid;
190 uint32_t pid;
191 uint32_t padding;
192 };
193
194 struct fuse_out_header {
195 uint32_t len;
196 int32_t error;
197 uint64_t unique;
198 };
199
200 __BEGIN_DECLS
201
202 struct puffs_usermount *perfuse_init(struct perfuse_callbacks *,
203 struct perfuse_mount_info *);
204 void perfuse_setspecific(struct puffs_usermount *, void *);
205 void *perfuse_getspecific(struct puffs_usermount *);
206 uint64_t perfuse_next_unique(struct puffs_usermount *);
207 uint64_t perfuse_get_nodeid(struct puffs_usermount *, puffs_cookie_t);
208 int perfuse_inloop(struct puffs_usermount *);
209 const char *perfuse_opname(int);
210 void perfuse_fs_init(struct puffs_usermount *);
211 int perfuse_mainloop(struct puffs_usermount *);
212 int perfuse_unmount(struct puffs_usermount *);
213 void perfuse_trace_dump(struct puffs_usermount *, FILE *);
214 void perfuse_fsreq(struct puffs_usermount *, perfuse_msg_t *);
215
216 #endif /* _PERFUSE_IF_H */
217