refuse.c revision 1.7 1 1.7 pooka /* $NetBSD: refuse.c,v 1.7 2007/02/11 16:02:24 pooka Exp $ */
2 1.7 pooka
3 1.1 agc /*
4 1.1 agc * Copyright 2007 Alistair Crooks. All rights reserved.
5 1.1 agc *
6 1.1 agc * Redistribution and use in source and binary forms, with or without
7 1.1 agc * modification, are permitted provided that the following conditions
8 1.1 agc * are met:
9 1.1 agc * 1. Redistributions of source code must retain the above copyright
10 1.1 agc * notice, this list of conditions and the following disclaimer.
11 1.1 agc * 2. Redistributions in binary form must reproduce the above copyright
12 1.1 agc * notice, this list of conditions and the following disclaimer in the
13 1.1 agc * documentation and/or other materials provided with the distribution.
14 1.1 agc * 3. The name of the author may not be used to endorse or promote
15 1.1 agc * products derived from this software without specific prior written
16 1.1 agc * permission.
17 1.1 agc *
18 1.1 agc * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS
19 1.1 agc * OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
20 1.1 agc * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
21 1.1 agc * ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY
22 1.1 agc * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
23 1.1 agc * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE
24 1.1 agc * GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
25 1.1 agc * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
26 1.1 agc * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING
27 1.1 agc * NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
28 1.1 agc * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
29 1.1 agc */
30 1.7 pooka
31 1.7 pooka #include <sys/cdefs.h>
32 1.7 pooka #if !defined(lint)
33 1.7 pooka __RCSID("$NetBSD: refuse.c,v 1.7 2007/02/11 16:02:24 pooka Exp $");
34 1.7 pooka #endif /* !lint */
35 1.7 pooka
36 1.1 agc #include <err.h>
37 1.1 agc #include <errno.h>
38 1.1 agc #include <fuse.h>
39 1.1 agc #include <ucontext.h>
40 1.1 agc #include <unistd.h>
41 1.1 agc
42 1.1 agc #include "defs.h"
43 1.1 agc
44 1.1 agc typedef uint64_t fuse_ino_t;
45 1.1 agc
46 1.1 agc struct fuse_config {
47 1.1 agc uid_t uid;
48 1.1 agc gid_t gid;
49 1.1 agc mode_t umask;
50 1.1 agc double entry_timeout;
51 1.1 agc double negative_timeout;
52 1.1 agc double attr_timeout;
53 1.1 agc double ac_attr_timeout;
54 1.1 agc int ac_attr_timeout_set;
55 1.1 agc int debug;
56 1.1 agc int hard_remove;
57 1.1 agc int use_ino;
58 1.1 agc int readdir_ino;
59 1.1 agc int set_mode;
60 1.1 agc int set_uid;
61 1.1 agc int set_gid;
62 1.1 agc int direct_io;
63 1.1 agc int kernel_cache;
64 1.1 agc int auto_cache;
65 1.1 agc int intr;
66 1.1 agc int intr_signal;
67 1.1 agc };
68 1.1 agc
69 1.1 agc /* this is the private fuse structure */
70 1.1 agc struct fuse {
71 1.1 agc struct fuse_session *se; /* fuse session pointer */
72 1.1 agc struct fuse_operations op; /* switch table of operations */
73 1.7 pooka int compat; /* compat level -
74 1.7 pooka * not used in puffs_fuse */
75 1.1 agc struct node **name_table;
76 1.1 agc size_t name_table_size;
77 1.1 agc struct node **id_table;
78 1.1 agc size_t id_table_size;
79 1.1 agc fuse_ino_t ctr;
80 1.1 agc unsigned int generation;
81 1.1 agc unsigned int hidectr;
82 1.1 agc pthread_mutex_t lock;
83 1.1 agc pthread_rwlock_t tree_lock;
84 1.1 agc void *user_data;
85 1.1 agc struct fuse_config conf;
86 1.1 agc int intr_installed;
87 1.1 agc struct puffs_usermount *pu;
88 1.1 agc };
89 1.1 agc
90 1.5 pooka struct refusenode {
91 1.5 pooka struct fuse_file_info file_info;
92 1.5 pooka };
93 1.5 pooka
94 1.5 pooka static struct puffs_node *
95 1.5 pooka newrn(struct puffs_usermount *pu)
96 1.5 pooka {
97 1.5 pooka struct puffs_node *pn;
98 1.5 pooka struct refusenode *rn;
99 1.5 pooka
100 1.5 pooka rn = malloc(sizeof(struct refusenode));
101 1.5 pooka if (!rn)
102 1.5 pooka abort(); /*XXX*/
103 1.5 pooka
104 1.5 pooka memset(rn, 0, sizeof(struct refusenode));
105 1.5 pooka pn = puffs_pn_new(pu, rn);
106 1.5 pooka
107 1.5 pooka return pn;
108 1.5 pooka }
109 1.5 pooka
110 1.5 pooka static void
111 1.5 pooka nukern(struct puffs_node *pn)
112 1.5 pooka {
113 1.5 pooka
114 1.5 pooka free(pn->pn_data);
115 1.5 pooka puffs_pn_put(pn);
116 1.5 pooka }
117 1.5 pooka
118 1.1 agc static ino_t fakeino = 3;
119 1.1 agc
120 1.4 pooka /* XXX: rethinkme */
121 1.4 pooka struct fuse_dirh {
122 1.1 agc struct dirent *dent;
123 1.1 agc size_t reslen;
124 1.4 pooka off_t readoff;
125 1.1 agc };
126 1.1 agc
127 1.1 agc /* ARGSUSED2 */
128 1.1 agc static int
129 1.4 pooka puffs_fuse_fill_dir(void *buf, const char *name,
130 1.1 agc const struct stat *stbuf, off_t off)
131 1.1 agc {
132 1.4 pooka struct fuse_dirh *deh = buf;
133 1.1 agc uint8_t dtype;
134 1.1 agc
135 1.2 pooka /* XXX: this is hacked *purely* for hellofs, so fiXXXme */
136 1.1 agc if (*name == '.')
137 1.1 agc dtype = DT_DIR;
138 1.1 agc else
139 1.1 agc dtype = DT_REG;
140 1.1 agc
141 1.6 pooka return !puffs_nextdent(&deh->dent, name, fakeino++, dtype,&deh->reslen);
142 1.4 pooka }
143 1.4 pooka
144 1.4 pooka static int
145 1.4 pooka puffs_fuse_dirfil(fuse_dirh_t h, const char *name, int type, ino_t ino)
146 1.4 pooka {
147 1.4 pooka ino_t dino;
148 1.4 pooka int dtype;
149 1.4 pooka
150 1.4 pooka /* XXX: this is hacked *purely* for cddafs, so fiXXXme */
151 1.4 pooka if (type == 0) {
152 1.4 pooka if (*name == '.')
153 1.4 pooka dtype = DT_DIR;
154 1.4 pooka else
155 1.4 pooka dtype = DT_REG;
156 1.4 pooka } else
157 1.4 pooka dtype = type;
158 1.4 pooka
159 1.4 pooka if (ino)
160 1.4 pooka dino = ino;
161 1.4 pooka else
162 1.4 pooka dino = fakeino++;
163 1.4 pooka
164 1.6 pooka return !puffs_nextdent(&h->dent, name, dino, dtype, &h->reslen);
165 1.1 agc }
166 1.1 agc
167 1.1 agc int
168 1.1 agc fuse_opt_add_arg(struct fuse_args *args, const char *arg)
169 1.1 agc {
170 1.1 agc char **oldargv;
171 1.1 agc int oldargc;
172 1.1 agc
173 1.1 agc if (args->allocated) {
174 1.7 pooka RENEW(char *, args->argv, args->argc + 1,
175 1.7 pooka "fuse_opt_add_arg1", return 0);
176 1.1 agc } else {
177 1.1 agc oldargv = args->argv;
178 1.1 agc oldargc = args->argc;
179 1.7 pooka NEWARRAY(char *, args->argv, oldargc + 1,
180 1.7 pooka "fuse_opt_add_arg2", return 0);
181 1.1 agc (void) memcpy(args->argv, oldargv, oldargc * sizeof(char *));
182 1.1 agc args->allocated = 1;
183 1.1 agc }
184 1.1 agc args->argv[args->argc++] = strdup(arg);
185 1.1 agc return 1;
186 1.1 agc }
187 1.1 agc
188 1.1 agc /* operation wrappers start here */
189 1.1 agc
190 1.1 agc /* lookup the path */
191 1.1 agc /* ARGSUSED1 */
192 1.1 agc static int
193 1.1 agc puffs_fuse_node_lookup(struct puffs_cc *pcc, void *opc, void **newnode,
194 1.1 agc enum vtype *newtype, voff_t *newsize, dev_t *newrdev,
195 1.1 agc const struct puffs_cn *pcn)
196 1.1 agc {
197 1.1 agc struct puffs_usermount *pu = puffs_cc_getusermount(pcc);
198 1.1 agc struct stat st;
199 1.1 agc struct fuse *fuse;
200 1.1 agc const char *path = PCNPATH(pcn);
201 1.1 agc int ret;
202 1.1 agc
203 1.1 agc /* XXX: THIS IS VERY WRONG */
204 1.1 agc fuse = (struct fuse *)pu->pu_privdata;
205 1.1 agc ret = fuse->op.getattr(path, &st);
206 1.1 agc ret = -ret; /* linux foo */
207 1.1 agc if (ret != 0) {
208 1.1 agc return ret;
209 1.1 agc }
210 1.5 pooka *newnode = newrn(pu);
211 1.1 agc *newtype = (S_ISDIR(st.st_mode)) ? VDIR : VREG;
212 1.1 agc *newsize = st.st_size;
213 1.1 agc return ret;
214 1.1 agc }
215 1.1 agc
216 1.1 agc /* get attributes for the path name */
217 1.1 agc /* ARGSUSED3 */
218 1.1 agc static int
219 1.1 agc puffs_fuse_node_getattr(struct puffs_cc *pcc, void *opc, struct vattr *va,
220 1.1 agc const struct puffs_cred *pcr, pid_t pid)
221 1.1 agc {
222 1.1 agc struct puffs_usermount *pu = puffs_cc_getusermount(pcc);
223 1.1 agc struct puffs_node *pn = opc;
224 1.1 agc struct stat st;
225 1.1 agc struct fuse *fuse;
226 1.1 agc const char *path = PNPATH(pn);
227 1.1 agc int ret;
228 1.1 agc
229 1.1 agc fuse = (struct fuse *)pu->pu_privdata;
230 1.1 agc if (fuse->op.getattr == NULL) {
231 1.1 agc return ENOSYS;
232 1.1 agc }
233 1.1 agc
234 1.1 agc /* wrap up return code */
235 1.1 agc ret = (*fuse->op.getattr)(path, &st);
236 1.1 agc
237 1.1 agc if (ret == 0) {
238 1.1 agc /* fill in va from st */
239 1.1 agc va->va_mode = st.st_mode;
240 1.1 agc va->va_nlink = st.st_nlink;
241 1.1 agc va->va_uid = st.st_uid;
242 1.1 agc va->va_gid = st.st_gid;
243 1.1 agc va->va_fsid = st.st_rdev;
244 1.1 agc va->va_fileid = st.st_ino;
245 1.1 agc va->va_size = st.st_size;
246 1.1 agc va->va_blocksize = st.st_blksize;
247 1.1 agc va->va_atime = st.st_atimespec;
248 1.1 agc va->va_mtime = st.st_mtimespec;
249 1.1 agc va->va_ctime = st.st_ctimespec;
250 1.1 agc va->va_birthtime = st.st_birthtimespec;
251 1.1 agc va->va_gen = st.st_gen;
252 1.1 agc va->va_flags = st.st_flags;
253 1.1 agc va->va_rdev = st.st_rdev;
254 1.1 agc va->va_bytes = st.st_size;
255 1.1 agc va->va_filerev = st.st_gen;
256 1.1 agc va->va_vaflags = st.st_flags;
257 1.1 agc
258 1.1 agc }
259 1.1 agc
260 1.1 agc return ret;
261 1.1 agc }
262 1.1 agc
263 1.1 agc /* read the contents of the symbolic link */
264 1.1 agc /* ARGSUSED2 */
265 1.1 agc static int
266 1.1 agc puffs_fuse_node_readlink(struct puffs_cc *pcc, void *opc,
267 1.1 agc const struct puffs_cred *cred, char *linkname, size_t *linklen)
268 1.1 agc {
269 1.1 agc struct puffs_usermount *pu = puffs_cc_getusermount(pcc);
270 1.1 agc struct puffs_node *pn = opc;
271 1.1 agc struct fuse *fuse;
272 1.1 agc const char *path = PNPATH(pn);
273 1.1 agc int ret;
274 1.1 agc
275 1.1 agc fuse = (struct fuse *)pu->pu_privdata;
276 1.1 agc if (fuse->op.readlink == NULL) {
277 1.1 agc return ENOSYS;
278 1.1 agc }
279 1.1 agc
280 1.1 agc /* wrap up return code */
281 1.1 agc ret = (*fuse->op.readlink)(path, linkname, *linklen);
282 1.1 agc
283 1.1 agc if (ret == 0) {
284 1.1 agc }
285 1.1 agc
286 1.1 agc return ret;
287 1.1 agc }
288 1.1 agc
289 1.1 agc /* make the special node */
290 1.1 agc /* ARGSUSED1 */
291 1.1 agc static int
292 1.1 agc puffs_fuse_node_mknod(struct puffs_cc *pcc, void *opc, void **newnode,
293 1.1 agc const struct puffs_cn *pcn, const struct vattr *va)
294 1.1 agc {
295 1.1 agc struct puffs_usermount *pu = puffs_cc_getusermount(pcc);
296 1.1 agc struct puffs_node *pn;
297 1.1 agc struct fuse *fuse;
298 1.1 agc mode_t mode = va->va_mode;
299 1.1 agc const char *path = PCNPATH(pcn);
300 1.1 agc int ret;
301 1.1 agc
302 1.1 agc fuse = (struct fuse *)pu->pu_privdata;
303 1.1 agc if (fuse->op.mknod == NULL) {
304 1.1 agc return ENOSYS;
305 1.1 agc }
306 1.1 agc
307 1.1 agc /* wrap up return code */
308 1.1 agc ret = (*fuse->op.mknod)(path, mode, va->va_rdev);
309 1.1 agc
310 1.1 agc if (ret == 0) {
311 1.1 agc /* fix up nodes */
312 1.5 pooka pn = newrn(pu);
313 1.1 agc if (pn == NULL) {
314 1.1 agc unlink(PCNPATH(pcn));
315 1.1 agc return ENOMEM;
316 1.1 agc }
317 1.1 agc puffs_setvattr(&pn->pn_va, va);
318 1.1 agc
319 1.1 agc *newnode = pn;
320 1.1 agc }
321 1.1 agc
322 1.1 agc return ret;
323 1.1 agc }
324 1.1 agc
325 1.1 agc /* make a directory */
326 1.1 agc /* ARGSUSED1 */
327 1.1 agc static int
328 1.1 agc puffs_fuse_node_mkdir(struct puffs_cc *pcc, void *opc, void **newnode,
329 1.1 agc const struct puffs_cn *pcn, const struct vattr *va)
330 1.1 agc {
331 1.1 agc struct puffs_usermount *pu = puffs_cc_getusermount(pcc);
332 1.1 agc struct puffs_node *pn;
333 1.1 agc struct fuse *fuse;
334 1.1 agc mode_t mode = va->va_mode;
335 1.1 agc const char *path = PCNPATH(pcn);
336 1.1 agc int ret;
337 1.1 agc
338 1.1 agc fuse = (struct fuse *)pu->pu_privdata;
339 1.1 agc if (fuse->op.mkdir == NULL) {
340 1.1 agc return ENOSYS;
341 1.1 agc }
342 1.1 agc
343 1.1 agc /* wrap up return code */
344 1.1 agc ret = (*fuse->op.mkdir)(path, mode);
345 1.1 agc
346 1.1 agc if (ret == 0) {
347 1.1 agc /* fix up nodes */
348 1.5 pooka pn = newrn(pu);
349 1.1 agc if (pn == NULL) {
350 1.1 agc rmdir(PCNPATH(pcn));
351 1.1 agc return ENOMEM;
352 1.1 agc }
353 1.1 agc puffs_setvattr(&pn->pn_va, va);
354 1.1 agc
355 1.1 agc *newnode = pn;
356 1.1 agc }
357 1.1 agc
358 1.1 agc return ret;
359 1.1 agc }
360 1.1 agc
361 1.1 agc /* remove the directory entry */
362 1.1 agc /* ARGSUSED1 */
363 1.1 agc static int
364 1.1 agc puffs_fuse_node_remove(struct puffs_cc *pcc, void *opc, void *targ,
365 1.1 agc const struct puffs_cn *pcn)
366 1.1 agc {
367 1.1 agc struct puffs_usermount *pu = puffs_cc_getusermount(pcc);
368 1.1 agc struct fuse *fuse;
369 1.1 agc const char *path = PCNPATH(pcn);
370 1.1 agc int ret;
371 1.1 agc
372 1.1 agc fuse = (struct fuse *)pu->pu_privdata;
373 1.1 agc if (fuse->op.unlink == NULL) {
374 1.1 agc return ENOSYS;
375 1.1 agc }
376 1.1 agc
377 1.1 agc /* wrap up return code */
378 1.1 agc ret = (*fuse->op.unlink)(path);
379 1.1 agc
380 1.1 agc return ret;
381 1.1 agc }
382 1.1 agc
383 1.1 agc /* remove the directory */
384 1.1 agc /* ARGSUSED1 */
385 1.1 agc static int
386 1.1 agc puffs_fuse_node_rmdir(struct puffs_cc *pcc, void *opc, void *targ,
387 1.1 agc const struct puffs_cn *pcn)
388 1.1 agc {
389 1.1 agc struct puffs_usermount *pu = puffs_cc_getusermount(pcc);
390 1.1 agc struct fuse *fuse;
391 1.1 agc const char *path = PCNPATH(pcn);
392 1.1 agc int ret;
393 1.1 agc
394 1.1 agc fuse = (struct fuse *)pu->pu_privdata;
395 1.1 agc if (fuse->op.rmdir == NULL) {
396 1.1 agc return ENOSYS;
397 1.1 agc }
398 1.1 agc
399 1.1 agc /* wrap up return code */
400 1.1 agc ret = (*fuse->op.rmdir)(path);
401 1.1 agc
402 1.1 agc return ret;
403 1.1 agc }
404 1.1 agc
405 1.1 agc /* create a symbolic link */
406 1.1 agc /* ARGSUSED1 */
407 1.1 agc static int
408 1.1 agc puffs_fuse_node_symlink(struct puffs_cc *pcc, void *opc, void **newnode,
409 1.1 agc const struct puffs_cn *pcn_src, const struct vattr *va,
410 1.1 agc const char *link_target)
411 1.1 agc {
412 1.1 agc struct puffs_usermount *pu = puffs_cc_getusermount(pcc);
413 1.1 agc struct puffs_node *pn;
414 1.1 agc struct fuse *fuse;
415 1.1 agc const char *path = PCNPATH(pcn_src);
416 1.1 agc int ret;
417 1.1 agc
418 1.1 agc fuse = (struct fuse *)pu->pu_privdata;
419 1.1 agc if (fuse->op.symlink == NULL) {
420 1.1 agc return ENOSYS;
421 1.1 agc }
422 1.1 agc
423 1.1 agc /* wrap up return code */
424 1.1 agc ret = (*fuse->op.symlink)(path, link_target);
425 1.1 agc /* XXX - check I haven't transposed these args */
426 1.1 agc
427 1.1 agc if (ret == 0) {
428 1.1 agc /* fix up nodes */
429 1.5 pooka pn = newrn(pu);
430 1.1 agc if (pn == NULL) {
431 1.1 agc unlink(link_target);
432 1.1 agc return ENOMEM;
433 1.1 agc }
434 1.1 agc puffs_setvattr(&pn->pn_va, va);
435 1.1 agc
436 1.1 agc *newnode = pn;
437 1.1 agc }
438 1.1 agc
439 1.1 agc return ret;
440 1.1 agc }
441 1.1 agc
442 1.1 agc /* rename a directory entry */
443 1.1 agc /* ARGSUSED1 */
444 1.1 agc static int
445 1.1 agc puffs_fuse_node_rename(struct puffs_cc *pcc, void *opc, void *src,
446 1.1 agc const struct puffs_cn *pcn_src, void *targ_dir, void *targ,
447 1.1 agc const struct puffs_cn *pcn_targ)
448 1.1 agc {
449 1.1 agc struct puffs_usermount *pu = puffs_cc_getusermount(pcc);
450 1.1 agc struct puffs_node *pn = opc;
451 1.1 agc struct vattr va;
452 1.1 agc struct fuse *fuse;
453 1.1 agc const char *path = PCNPATH(pcn_src);
454 1.1 agc int ret;
455 1.1 agc
456 1.1 agc fuse = (struct fuse *)pu->pu_privdata;
457 1.1 agc if (fuse->op.rename == NULL) {
458 1.1 agc return ENOSYS;
459 1.1 agc }
460 1.1 agc
461 1.1 agc /* wrap up return code */
462 1.1 agc ret = (*fuse->op.rename)(path, PCNPATH(pcn_targ));
463 1.1 agc
464 1.5 pooka /* XXX: what's this guy doing??? */
465 1.1 agc if (ret == 0) {
466 1.1 agc (void) memcpy(&va, &pn->pn_va, sizeof(va));
467 1.1 agc
468 1.1 agc puffs_pn_put(pn);
469 1.1 agc
470 1.1 agc pn = puffs_pn_new(pu, NULL);
471 1.1 agc if (pn == NULL) {
472 1.1 agc return ENOMEM;
473 1.1 agc }
474 1.1 agc puffs_setvattr(&pn->pn_va, &va);
475 1.1 agc
476 1.1 agc }
477 1.1 agc
478 1.1 agc return ret;
479 1.1 agc }
480 1.1 agc
481 1.1 agc /* create a link in the file system */
482 1.1 agc /* ARGSUSED1 */
483 1.1 agc static int
484 1.1 agc puffs_fuse_node_link(struct puffs_cc *pcc, void *opc, void *targ,
485 1.1 agc const struct puffs_cn *pcn)
486 1.1 agc {
487 1.1 agc struct puffs_usermount *pu = puffs_cc_getusermount(pcc);
488 1.1 agc struct puffs_node *pn = targ;
489 1.1 agc struct fuse *fuse;
490 1.1 agc int ret;
491 1.1 agc
492 1.1 agc fuse = (struct fuse *)pu->pu_privdata;
493 1.1 agc if (fuse->op.link == NULL) {
494 1.1 agc return ENOSYS;
495 1.1 agc }
496 1.1 agc
497 1.1 agc /* wrap up return code */
498 1.1 agc ret = (*fuse->op.link)(PNPATH(pn), PCNPATH(pcn));
499 1.1 agc
500 1.1 agc if (ret == 0) {
501 1.1 agc /* fix up nodes */
502 1.5 pooka pn = newrn(pu);
503 1.1 agc if (pn == NULL) {
504 1.1 agc unlink(PCNPATH(pcn));
505 1.1 agc return ENOMEM;
506 1.1 agc }
507 1.1 agc }
508 1.1 agc
509 1.1 agc return ret;
510 1.1 agc }
511 1.1 agc
512 1.1 agc /*
513 1.7 pooka * We run into a slight problemette here - puffs provides
514 1.7 pooka * setattr/getattr, whilst fuse provides all the usual chown/chmod/chgrp
515 1.7 pooka * functionality. So that we don't miss out on anything when calling a
516 1.7 pooka * fuse operation, we have to get the vattr from the existing file,
517 1.7 pooka * find out what's changed, and then switch on that to call the fuse
518 1.7 pooka * function accordingly.
519 1.7 pooka */
520 1.1 agc /* ARGSUSED3 */
521 1.1 agc static int
522 1.1 agc puffs_fuse_node_setattr(struct puffs_cc *pcc, void *opc,
523 1.1 agc const struct vattr *va, const struct puffs_cred *pcr, pid_t pid)
524 1.1 agc {
525 1.1 agc struct puffs_usermount *pu = puffs_cc_getusermount(pcc);
526 1.1 agc struct puffs_node *pn = opc;
527 1.1 agc struct fuse *fuse;
528 1.1 agc const char *path = PNPATH(pn);
529 1.1 agc mode_t mode;
530 1.1 agc uid_t uid;
531 1.1 agc gid_t gid;
532 1.1 agc int ret;
533 1.1 agc
534 1.1 agc fuse = (struct fuse *)pu->pu_privdata;
535 1.1 agc
536 1.1 agc ret = -1;
537 1.1 agc
538 1.1 agc mode = va->va_mode;
539 1.1 agc uid = va->va_uid;
540 1.1 agc gid = va->va_gid;
541 1.1 agc
542 1.1 agc if (mode != 0) {
543 1.1 agc if (fuse->op.chmod == NULL) {
544 1.1 agc return ENOSYS;
545 1.1 agc }
546 1.1 agc ret = (*fuse->op.chmod)(path, mode);
547 1.1 agc }
548 1.1 agc if (uid != 0 || gid != 0) {
549 1.1 agc if (fuse->op.chown == NULL) {
550 1.1 agc return ENOSYS;
551 1.1 agc }
552 1.1 agc ret = (*fuse->op.chown)(path, uid, gid);
553 1.1 agc }
554 1.1 agc
555 1.1 agc if (ret == 0) {
556 1.1 agc }
557 1.1 agc
558 1.1 agc return ret;
559 1.1 agc }
560 1.1 agc
561 1.1 agc /* ARGSUSED2 */
562 1.1 agc static int
563 1.1 agc puffs_fuse_node_open(struct puffs_cc *pcc, void *opc, int flags,
564 1.1 agc const struct puffs_cred *cred, pid_t pid)
565 1.1 agc {
566 1.1 agc struct puffs_usermount *pu = puffs_cc_getusermount(pcc);
567 1.1 agc struct puffs_node *pn = opc;
568 1.5 pooka struct refusenode *rn = pn->pn_data;
569 1.1 agc struct fuse *fuse;
570 1.1 agc struct stat st;
571 1.1 agc const char *path = PNPATH(pn);
572 1.1 agc int ret;
573 1.1 agc
574 1.1 agc fuse = (struct fuse *)pu->pu_privdata;
575 1.1 agc if (fuse->op.open == NULL) {
576 1.1 agc return ENOSYS;
577 1.1 agc }
578 1.1 agc
579 1.1 agc /* examine type - if directory, return 0 rather than open */
580 1.1 agc ret = (fuse->op.getattr == NULL) ?
581 1.1 agc stat(path, &st) :
582 1.1 agc (*fuse->op.getattr)(path, &st);
583 1.1 agc if (ret == 0 && (st.st_mode & S_IFMT) == S_IFDIR) {
584 1.1 agc return 0;
585 1.1 agc }
586 1.1 agc
587 1.1 agc if (strcmp(path, "/") == 0) {
588 1.1 agc return 0;
589 1.1 agc }
590 1.1 agc
591 1.5 pooka ret = (*fuse->op.open)(path, &rn->file_info);
592 1.1 agc
593 1.1 agc if (ret == 0) {
594 1.1 agc }
595 1.1 agc
596 1.1 agc return ret;
597 1.1 agc }
598 1.1 agc
599 1.1 agc /* read some more from the file */
600 1.1 agc /* ARGSUSED5 */
601 1.1 agc static int
602 1.1 agc puffs_fuse_node_read(struct puffs_cc *pcc, void *opc, uint8_t *buf,
603 1.1 agc off_t offset, size_t *resid, const struct puffs_cred *pcr,
604 1.1 agc int ioflag)
605 1.1 agc {
606 1.1 agc struct puffs_usermount *pu = puffs_cc_getusermount(pcc);
607 1.1 agc struct puffs_node *pn = opc;
608 1.5 pooka struct refusenode *rn = pn->pn_data;
609 1.1 agc struct fuse *fuse;
610 1.1 agc const char *path = PNPATH(pn);
611 1.1 agc int ret;
612 1.1 agc
613 1.1 agc fuse = (struct fuse *)pu->pu_privdata;
614 1.1 agc if (fuse->op.read == NULL) {
615 1.1 agc return ENOSYS;
616 1.1 agc }
617 1.1 agc
618 1.7 pooka ret = (*fuse->op.read)(path, (char *)buf, *resid, offset,
619 1.7 pooka &rn->file_info);
620 1.1 agc
621 1.1 agc if (ret > 0) {
622 1.1 agc *resid -= ret;
623 1.1 agc }
624 1.1 agc
625 1.1 agc return 0;
626 1.1 agc }
627 1.1 agc
628 1.1 agc /* write to the file */
629 1.1 agc /* ARGSUSED0 */
630 1.1 agc static int
631 1.1 agc puffs_fuse_node_write(struct puffs_cc *pcc, void *opc, uint8_t *buf,
632 1.1 agc off_t offset, size_t *resid, const struct puffs_cred *pcr,
633 1.1 agc int ioflag)
634 1.1 agc {
635 1.1 agc struct puffs_usermount *pu = puffs_cc_getusermount(pcc);
636 1.1 agc struct fuse_file_info file_info;
637 1.1 agc struct puffs_node *pn = opc;
638 1.1 agc struct fuse *fuse;
639 1.1 agc const char *path = PNPATH(pn);
640 1.1 agc int ret;
641 1.1 agc
642 1.1 agc fuse = (struct fuse *)pu->pu_privdata;
643 1.1 agc if (fuse->op.write == NULL) {
644 1.1 agc return ENOSYS;
645 1.1 agc }
646 1.1 agc
647 1.1 agc (void) memset(&file_info, 0x0, sizeof(file_info));
648 1.1 agc
649 1.1 agc /* XXX fill in file_info here */
650 1.1 agc
651 1.1 agc ret = (*fuse->op.write)(path, (char *)buf, *resid, offset, &file_info);
652 1.1 agc
653 1.1 agc if (ret > 0) {
654 1.1 agc *resid -= ret;
655 1.1 agc }
656 1.1 agc
657 1.1 agc return ret;
658 1.1 agc }
659 1.1 agc
660 1.1 agc
661 1.1 agc /* ARGSUSED3 */
662 1.1 agc static int
663 1.1 agc puffs_fuse_node_readdir(struct puffs_cc *pcc, void *opc,
664 1.1 agc struct dirent *dent, const struct puffs_cred *pcr, off_t *readoff,
665 1.1 agc size_t *reslen)
666 1.1 agc {
667 1.1 agc struct puffs_usermount *pu = puffs_cc_getusermount(pcc);
668 1.1 agc struct fuse_file_info file_info;
669 1.1 agc struct puffs_node *pn = opc;
670 1.1 agc struct fuse *fuse;
671 1.1 agc const char *path = PNPATH(pn);
672 1.4 pooka struct fuse_dirh deh;
673 1.1 agc int ret;
674 1.1 agc
675 1.1 agc fuse = (struct fuse *)pu->pu_privdata;
676 1.4 pooka if (fuse->op.readdir == NULL && fuse->op.getdir == NULL) {
677 1.1 agc return ENOSYS;
678 1.1 agc }
679 1.1 agc
680 1.1 agc /* XXX: how to handle this??? */
681 1.1 agc if (*readoff != 0) {
682 1.1 agc return 0;
683 1.1 agc }
684 1.1 agc
685 1.1 agc (void) memset(&file_info, 0x0, sizeof(file_info));
686 1.1 agc /* XXX - fill in file_info here */
687 1.1 agc
688 1.4 pooka deh.dent = dent;
689 1.4 pooka deh.reslen = *reslen;
690 1.4 pooka deh.readoff = *readoff;
691 1.4 pooka
692 1.4 pooka if (fuse->op.readdir)
693 1.7 pooka ret = fuse->op.readdir(path, &deh, puffs_fuse_fill_dir,
694 1.7 pooka *readoff, &file_info);
695 1.4 pooka else
696 1.4 pooka ret = fuse->op.getdir(path, &deh, puffs_fuse_dirfil);
697 1.4 pooka *reslen = deh.reslen;
698 1.1 agc *readoff = 1;
699 1.1 agc
700 1.1 agc if (ret == 0) {
701 1.1 agc }
702 1.1 agc
703 1.1 agc return ret;
704 1.1 agc }
705 1.1 agc
706 1.3 pooka /* ARGSUSED */
707 1.3 pooka static int
708 1.3 pooka puffs_fuse_node_reclaim(struct puffs_cc *pcc, void *opc, pid_t pid)
709 1.3 pooka {
710 1.3 pooka struct puffs_node *pn = opc;
711 1.3 pooka
712 1.5 pooka nukern(pn);
713 1.3 pooka
714 1.3 pooka return 0;
715 1.3 pooka }
716 1.3 pooka
717 1.1 agc /* ARGSUSED1 */
718 1.1 agc static int
719 1.1 agc puffs_fuse_fs_unmount(struct puffs_cc *pcc, int flags, pid_t pid)
720 1.1 agc {
721 1.1 agc struct puffs_usermount *pu = puffs_cc_getusermount(pcc);
722 1.1 agc struct fuse *fuse;
723 1.1 agc
724 1.1 agc fuse = (struct fuse *)pu->pu_privdata;
725 1.1 agc if (fuse->op.destroy == NULL) {
726 1.2 pooka return 0;
727 1.1 agc }
728 1.1 agc (*fuse->op.destroy)(fuse);
729 1.1 agc return 0;
730 1.1 agc }
731 1.1 agc
732 1.1 agc /* ARGSUSED0 */
733 1.1 agc static int
734 1.1 agc puffs_fuse_fs_sync(struct puffs_cc *pcc, int flags,
735 1.1 agc const struct puffs_cred *cr, pid_t pid)
736 1.1 agc {
737 1.1 agc return 0;
738 1.1 agc }
739 1.1 agc
740 1.1 agc /* ARGSUSED2 */
741 1.1 agc static int
742 1.1 agc puffs_fuse_fs_statvfs(struct puffs_cc *pcc, struct statvfs *svfsb, pid_t pid)
743 1.1 agc {
744 1.1 agc struct puffs_usermount *pu = puffs_cc_getusermount(pcc);
745 1.1 agc struct fuse *fuse;
746 1.1 agc int ret;
747 1.1 agc
748 1.1 agc fuse = (struct fuse *)pu->pu_privdata;
749 1.1 agc if (fuse->op.statfs == NULL) {
750 1.1 agc if ((ret = statvfs(PNPATH(pu->pu_pn_root), svfsb)) == -1) {
751 1.1 agc return errno;
752 1.1 agc }
753 1.1 agc } else {
754 1.1 agc ret = (*fuse->op.statfs)(PNPATH(pu->pu_pn_root), svfsb);
755 1.1 agc }
756 1.1 agc
757 1.1 agc return ret;
758 1.1 agc }
759 1.1 agc
760 1.1 agc
761 1.1 agc
762 1.1 agc
763 1.1 agc /* End of puffs_fuse operations */
764 1.1 agc
765 1.1 agc /* ARGSUSED3 */
766 1.1 agc int
767 1.1 agc fuse_main_real(int argc, char **argv, const struct fuse_operations *ops,
768 1.1 agc size_t size, void *userdata)
769 1.1 agc {
770 1.1 agc struct puffs_usermount *pu;
771 1.1 agc struct puffs_pathobj *po_root;
772 1.1 agc struct puffs_ops *pops;
773 1.1 agc struct statvfs svfsb;
774 1.1 agc struct fuse *fuse;
775 1.1 agc char name[64];
776 1.1 agc char *slash;
777 1.1 agc int ret;
778 1.1 agc
779 1.1 agc /* initialise the puffs operations structure */
780 1.1 agc PUFFSOP_INIT(pops);
781 1.1 agc
782 1.1 agc PUFFSOP_SET(pops, puffs_fuse, fs, sync);
783 1.1 agc PUFFSOP_SET(pops, puffs_fuse, fs, statvfs);
784 1.1 agc PUFFSOP_SET(pops, puffs_fuse, fs, unmount);
785 1.1 agc
786 1.2 pooka /*
787 1.2 pooka * XXX: all of these don't possibly need to be
788 1.2 pooka * unconditionally set
789 1.2 pooka */
790 1.1 agc PUFFSOP_SET(pops, puffs_fuse, node, lookup);
791 1.1 agc PUFFSOP_SET(pops, puffs_fuse, node, getattr);
792 1.1 agc PUFFSOP_SET(pops, puffs_fuse, node, readdir);
793 1.1 agc PUFFSOP_SET(pops, puffs_fuse, node, readlink);
794 1.1 agc PUFFSOP_SET(pops, puffs_fuse, node, mknod);
795 1.1 agc PUFFSOP_SET(pops, puffs_fuse, node, mkdir);
796 1.1 agc PUFFSOP_SET(pops, puffs_fuse, node, remove);
797 1.1 agc PUFFSOP_SET(pops, puffs_fuse, node, rmdir);
798 1.1 agc PUFFSOP_SET(pops, puffs_fuse, node, symlink);
799 1.1 agc PUFFSOP_SET(pops, puffs_fuse, node, rename);
800 1.1 agc PUFFSOP_SET(pops, puffs_fuse, node, link);
801 1.1 agc PUFFSOP_SET(pops, puffs_fuse, node, setattr);
802 1.1 agc PUFFSOP_SET(pops, puffs_fuse, node, open);
803 1.1 agc PUFFSOP_SET(pops, puffs_fuse, node, read);
804 1.1 agc PUFFSOP_SET(pops, puffs_fuse, node, write);
805 1.1 agc PUFFSOP_SET(pops, puffs_fuse, node, readdir);
806 1.1 agc PUFFSOP_SET(pops, puffs_fuse, node, read);
807 1.1 agc PUFFSOP_SET(pops, puffs_fuse, node, write);
808 1.3 pooka PUFFSOP_SET(pops, puffs_fuse, node, reclaim);
809 1.1 agc
810 1.1 agc NEW(struct fuse, fuse, "fuse_main_real", exit(EXIT_FAILURE));
811 1.1 agc
812 1.1 agc /* copy fuse ops to their own stucture */
813 1.1 agc (void) memcpy(&fuse->op, ops, sizeof(fuse->op));
814 1.1 agc
815 1.1 agc /* whilst this (assigning the pu_privdata in the puffs
816 1.1 agc * usermount struct to be the fuse struct) might seem like
817 1.1 agc * we are chasing our tail here, the logic is as follows:
818 1.1 agc + the operation wrapper gets called with the puffs
819 1.1 agc calling conventions
820 1.1 agc + we need to fix up args first
821 1.1 agc + then call the fuse user-supplied operation
822 1.1 agc + then we fix up any values on return that we need to
823 1.1 agc + and fix up any nodes, etc
824 1.7 pooka * so we need to be able to get at the fuse ops from within the
825 1.7 pooka * puffs_usermount struct
826 1.7 pooka */
827 1.1 agc if ((slash = strrchr(*argv, '/')) == NULL) {
828 1.1 agc slash = *argv;
829 1.1 agc } else {
830 1.1 agc slash += 1;
831 1.1 agc }
832 1.1 agc (void) snprintf(name, sizeof(name), "refuse:%s", slash);
833 1.1 agc pu = puffs_mount(pops, argv[argc - 1], MNT_NODEV | MNT_NOSUID,
834 1.1 agc name, fuse,
835 1.1 agc PUFFS_FLAG_BUILDPATH | PUFFS_FLAG_OPDUMP, 0);
836 1.1 agc if (pu == NULL) {
837 1.1 agc err(EXIT_FAILURE, "puffs_mount");
838 1.1 agc }
839 1.1 agc
840 1.1 agc fuse->pu = pu;
841 1.1 agc pu->pu_pn_root = puffs_pn_new(pu, NULL);
842 1.1 agc po_root = puffs_getrootpathobj(pu);
843 1.1 agc po_root->po_path = strdup("/");
844 1.1 agc po_root->po_len = 1;
845 1.1 agc
846 1.1 agc statvfs(argv[argc - 1], &svfsb); /* XXX - not really the correct dir */
847 1.1 agc if (puffs_start(pu, pu->pu_pn_root, &svfsb) == -1) {
848 1.1 agc err(EXIT_FAILURE, "puffs_start");
849 1.1 agc }
850 1.1 agc
851 1.1 agc ret = puffs_mainloop(fuse->pu, PUFFSLOOP_NODAEMON);
852 1.1 agc
853 1.1 agc (void) free(po_root->po_path);
854 1.1 agc FREE(fuse);
855 1.1 agc return ret;
856 1.1 agc }
857 1.1 agc
858 1.1 agc /* ARGSUSED0 */
859 1.1 agc int
860 1.1 agc fuse_opt_parse(struct fuse_args *args, void *data,
861 1.1 agc const struct fuse_opt *opts, fuse_opt_proc_t proc)
862 1.1 agc {
863 1.1 agc return 0;
864 1.1 agc }
865