refuse.c revision 1.14 1 1.14 pooka /* $NetBSD: refuse.c,v 1.14 2007/02/15 19:33:52 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.14 pooka __RCSID("$NetBSD: refuse.c,v 1.14 2007/02/15 19:33:52 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.13 pooka ino_t dino;
134 1.1 agc uint8_t dtype;
135 1.1 agc
136 1.13 pooka if (stbuf == NULL) {
137 1.13 pooka dtype = DT_UNKNOWN;
138 1.13 pooka dino = fakeino++;
139 1.13 pooka } else {
140 1.13 pooka dtype = puffs_vtype2dt(puffs_mode2vt(stbuf->st_mode));
141 1.13 pooka dino = stbuf->st_ino;
142 1.13 pooka }
143 1.1 agc
144 1.13 pooka return !puffs_nextdent(&deh->dent, name, dino, dtype, &deh->reslen);
145 1.4 pooka }
146 1.4 pooka
147 1.4 pooka static int
148 1.4 pooka puffs_fuse_dirfil(fuse_dirh_t h, const char *name, int type, ino_t ino)
149 1.4 pooka {
150 1.4 pooka ino_t dino;
151 1.4 pooka int dtype;
152 1.4 pooka
153 1.13 pooka if (type == 0)
154 1.13 pooka dtype = DT_UNKNOWN;
155 1.13 pooka else
156 1.4 pooka dtype = type;
157 1.4 pooka
158 1.4 pooka if (ino)
159 1.4 pooka dino = ino;
160 1.4 pooka else
161 1.4 pooka dino = fakeino++;
162 1.4 pooka
163 1.6 pooka return !puffs_nextdent(&h->dent, name, dino, dtype, &h->reslen);
164 1.1 agc }
165 1.1 agc
166 1.1 agc int
167 1.1 agc fuse_opt_add_arg(struct fuse_args *args, const char *arg)
168 1.1 agc {
169 1.1 agc char **oldargv;
170 1.1 agc int oldargc;
171 1.1 agc
172 1.1 agc if (args->allocated) {
173 1.7 pooka RENEW(char *, args->argv, args->argc + 1,
174 1.7 pooka "fuse_opt_add_arg1", return 0);
175 1.1 agc } else {
176 1.1 agc oldargv = args->argv;
177 1.1 agc oldargc = args->argc;
178 1.7 pooka NEWARRAY(char *, args->argv, oldargc + 1,
179 1.7 pooka "fuse_opt_add_arg2", return 0);
180 1.1 agc (void) memcpy(args->argv, oldargv, oldargc * sizeof(char *));
181 1.1 agc args->allocated = 1;
182 1.1 agc }
183 1.1 agc args->argv[args->argc++] = strdup(arg);
184 1.1 agc return 1;
185 1.1 agc }
186 1.1 agc
187 1.1 agc /* operation wrappers start here */
188 1.1 agc
189 1.1 agc /* lookup the path */
190 1.1 agc /* ARGSUSED1 */
191 1.1 agc static int
192 1.1 agc puffs_fuse_node_lookup(struct puffs_cc *pcc, void *opc, void **newnode,
193 1.1 agc enum vtype *newtype, voff_t *newsize, dev_t *newrdev,
194 1.1 agc const struct puffs_cn *pcn)
195 1.1 agc {
196 1.1 agc struct puffs_usermount *pu = puffs_cc_getusermount(pcc);
197 1.12 pooka struct puffs_node *pn_res;
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 fuse = (struct fuse *)pu->pu_privdata;
204 1.1 agc ret = fuse->op.getattr(path, &st);
205 1.12 pooka
206 1.1 agc if (ret != 0) {
207 1.12 pooka return -ret; /* XXX: linux foo */
208 1.12 pooka }
209 1.12 pooka
210 1.12 pooka /* XXX: fiXXXme unconst */
211 1.12 pooka pn_res = puffs_pn_nodewalk(pu, puffs_path_walkcmp,
212 1.12 pooka __UNCONST(&pcn->pcn_po_full));
213 1.12 pooka if (pn_res == NULL) {
214 1.12 pooka pn_res = newrn(pu);
215 1.12 pooka if (pn_res == NULL)
216 1.12 pooka return errno;
217 1.12 pooka puffs_stat2vattr(&pn_res->pn_va, &st);
218 1.1 agc }
219 1.12 pooka
220 1.12 pooka *newnode = pn_res;
221 1.12 pooka *newtype = pn_res->pn_va.va_type;
222 1.12 pooka *newsize = pn_res->pn_va.va_size;
223 1.12 pooka *newrdev = pn_res->pn_va.va_rdev;
224 1.12 pooka
225 1.12 pooka return 0;
226 1.1 agc }
227 1.1 agc
228 1.1 agc /* get attributes for the path name */
229 1.1 agc /* ARGSUSED3 */
230 1.1 agc static int
231 1.1 agc puffs_fuse_node_getattr(struct puffs_cc *pcc, void *opc, struct vattr *va,
232 1.1 agc const struct puffs_cred *pcr, pid_t pid)
233 1.1 agc {
234 1.1 agc struct puffs_usermount *pu = puffs_cc_getusermount(pcc);
235 1.1 agc struct puffs_node *pn = opc;
236 1.1 agc struct stat st;
237 1.1 agc struct fuse *fuse;
238 1.1 agc const char *path = PNPATH(pn);
239 1.1 agc int ret;
240 1.1 agc
241 1.1 agc fuse = (struct fuse *)pu->pu_privdata;
242 1.1 agc if (fuse->op.getattr == NULL) {
243 1.1 agc return ENOSYS;
244 1.1 agc }
245 1.1 agc
246 1.1 agc /* wrap up return code */
247 1.1 agc ret = (*fuse->op.getattr)(path, &st);
248 1.1 agc
249 1.1 agc if (ret == 0) {
250 1.1 agc /* fill in va from st */
251 1.1 agc va->va_mode = st.st_mode;
252 1.1 agc va->va_nlink = st.st_nlink;
253 1.1 agc va->va_uid = st.st_uid;
254 1.1 agc va->va_gid = st.st_gid;
255 1.1 agc va->va_fsid = st.st_rdev;
256 1.1 agc va->va_fileid = st.st_ino;
257 1.1 agc va->va_size = st.st_size;
258 1.1 agc va->va_blocksize = st.st_blksize;
259 1.1 agc va->va_atime = st.st_atimespec;
260 1.1 agc va->va_mtime = st.st_mtimespec;
261 1.1 agc va->va_ctime = st.st_ctimespec;
262 1.1 agc va->va_birthtime = st.st_birthtimespec;
263 1.1 agc va->va_gen = st.st_gen;
264 1.1 agc va->va_flags = st.st_flags;
265 1.1 agc va->va_rdev = st.st_rdev;
266 1.1 agc va->va_bytes = st.st_size;
267 1.1 agc va->va_filerev = st.st_gen;
268 1.1 agc va->va_vaflags = st.st_flags;
269 1.1 agc
270 1.1 agc }
271 1.1 agc
272 1.1 agc return ret;
273 1.1 agc }
274 1.1 agc
275 1.1 agc /* read the contents of the symbolic link */
276 1.1 agc /* ARGSUSED2 */
277 1.1 agc static int
278 1.1 agc puffs_fuse_node_readlink(struct puffs_cc *pcc, void *opc,
279 1.1 agc const struct puffs_cred *cred, char *linkname, size_t *linklen)
280 1.1 agc {
281 1.1 agc struct puffs_usermount *pu = puffs_cc_getusermount(pcc);
282 1.1 agc struct puffs_node *pn = opc;
283 1.1 agc struct fuse *fuse;
284 1.13 pooka const char *path = PNPATH(pn), *p;
285 1.1 agc int ret;
286 1.1 agc
287 1.1 agc fuse = (struct fuse *)pu->pu_privdata;
288 1.1 agc if (fuse->op.readlink == NULL) {
289 1.1 agc return ENOSYS;
290 1.1 agc }
291 1.1 agc
292 1.1 agc /* wrap up return code */
293 1.1 agc ret = (*fuse->op.readlink)(path, linkname, *linklen);
294 1.1 agc
295 1.1 agc if (ret == 0) {
296 1.13 pooka p = memchr(linkname, '\0', *linklen);
297 1.13 pooka if (!p)
298 1.13 pooka return EINVAL;
299 1.13 pooka
300 1.14 pooka *linklen = p - linkname;
301 1.1 agc }
302 1.1 agc
303 1.13 pooka return -ret;
304 1.1 agc }
305 1.1 agc
306 1.1 agc /* make the special node */
307 1.1 agc /* ARGSUSED1 */
308 1.1 agc static int
309 1.1 agc puffs_fuse_node_mknod(struct puffs_cc *pcc, void *opc, void **newnode,
310 1.1 agc const struct puffs_cn *pcn, const struct vattr *va)
311 1.1 agc {
312 1.1 agc struct puffs_usermount *pu = puffs_cc_getusermount(pcc);
313 1.1 agc struct puffs_node *pn;
314 1.1 agc struct fuse *fuse;
315 1.1 agc mode_t mode = va->va_mode;
316 1.1 agc const char *path = PCNPATH(pcn);
317 1.1 agc int ret;
318 1.1 agc
319 1.1 agc fuse = (struct fuse *)pu->pu_privdata;
320 1.1 agc if (fuse->op.mknod == NULL) {
321 1.1 agc return ENOSYS;
322 1.1 agc }
323 1.1 agc
324 1.1 agc /* wrap up return code */
325 1.1 agc ret = (*fuse->op.mknod)(path, mode, va->va_rdev);
326 1.1 agc
327 1.1 agc if (ret == 0) {
328 1.1 agc /* fix up nodes */
329 1.5 pooka pn = newrn(pu);
330 1.1 agc if (pn == NULL) {
331 1.1 agc unlink(PCNPATH(pcn));
332 1.1 agc return ENOMEM;
333 1.1 agc }
334 1.1 agc puffs_setvattr(&pn->pn_va, va);
335 1.1 agc
336 1.1 agc *newnode = pn;
337 1.1 agc }
338 1.1 agc
339 1.1 agc return ret;
340 1.1 agc }
341 1.1 agc
342 1.1 agc /* make a directory */
343 1.1 agc /* ARGSUSED1 */
344 1.1 agc static int
345 1.1 agc puffs_fuse_node_mkdir(struct puffs_cc *pcc, void *opc, void **newnode,
346 1.1 agc const struct puffs_cn *pcn, const struct vattr *va)
347 1.1 agc {
348 1.1 agc struct puffs_usermount *pu = puffs_cc_getusermount(pcc);
349 1.1 agc struct puffs_node *pn;
350 1.1 agc struct fuse *fuse;
351 1.1 agc mode_t mode = va->va_mode;
352 1.1 agc const char *path = PCNPATH(pcn);
353 1.1 agc int ret;
354 1.1 agc
355 1.1 agc fuse = (struct fuse *)pu->pu_privdata;
356 1.1 agc if (fuse->op.mkdir == NULL) {
357 1.1 agc return ENOSYS;
358 1.1 agc }
359 1.1 agc
360 1.1 agc /* wrap up return code */
361 1.1 agc ret = (*fuse->op.mkdir)(path, mode);
362 1.1 agc
363 1.1 agc if (ret == 0) {
364 1.1 agc /* fix up nodes */
365 1.5 pooka pn = newrn(pu);
366 1.1 agc if (pn == NULL) {
367 1.1 agc rmdir(PCNPATH(pcn));
368 1.1 agc return ENOMEM;
369 1.1 agc }
370 1.1 agc puffs_setvattr(&pn->pn_va, va);
371 1.1 agc
372 1.1 agc *newnode = pn;
373 1.1 agc }
374 1.1 agc
375 1.1 agc return ret;
376 1.1 agc }
377 1.1 agc
378 1.1 agc /* remove the directory entry */
379 1.1 agc /* ARGSUSED1 */
380 1.1 agc static int
381 1.1 agc puffs_fuse_node_remove(struct puffs_cc *pcc, void *opc, void *targ,
382 1.1 agc const struct puffs_cn *pcn)
383 1.1 agc {
384 1.1 agc struct puffs_usermount *pu = puffs_cc_getusermount(pcc);
385 1.1 agc struct fuse *fuse;
386 1.1 agc const char *path = PCNPATH(pcn);
387 1.1 agc int ret;
388 1.1 agc
389 1.1 agc fuse = (struct fuse *)pu->pu_privdata;
390 1.1 agc if (fuse->op.unlink == NULL) {
391 1.1 agc return ENOSYS;
392 1.1 agc }
393 1.1 agc
394 1.1 agc /* wrap up return code */
395 1.1 agc ret = (*fuse->op.unlink)(path);
396 1.1 agc
397 1.1 agc return ret;
398 1.1 agc }
399 1.1 agc
400 1.1 agc /* remove the directory */
401 1.1 agc /* ARGSUSED1 */
402 1.1 agc static int
403 1.1 agc puffs_fuse_node_rmdir(struct puffs_cc *pcc, void *opc, void *targ,
404 1.1 agc const struct puffs_cn *pcn)
405 1.1 agc {
406 1.1 agc struct puffs_usermount *pu = puffs_cc_getusermount(pcc);
407 1.1 agc struct fuse *fuse;
408 1.1 agc const char *path = PCNPATH(pcn);
409 1.1 agc int ret;
410 1.1 agc
411 1.1 agc fuse = (struct fuse *)pu->pu_privdata;
412 1.1 agc if (fuse->op.rmdir == NULL) {
413 1.1 agc return ENOSYS;
414 1.1 agc }
415 1.1 agc
416 1.1 agc /* wrap up return code */
417 1.1 agc ret = (*fuse->op.rmdir)(path);
418 1.1 agc
419 1.1 agc return ret;
420 1.1 agc }
421 1.1 agc
422 1.1 agc /* create a symbolic link */
423 1.1 agc /* ARGSUSED1 */
424 1.1 agc static int
425 1.1 agc puffs_fuse_node_symlink(struct puffs_cc *pcc, void *opc, void **newnode,
426 1.1 agc const struct puffs_cn *pcn_src, const struct vattr *va,
427 1.1 agc const char *link_target)
428 1.1 agc {
429 1.1 agc struct puffs_usermount *pu = puffs_cc_getusermount(pcc);
430 1.1 agc struct puffs_node *pn;
431 1.1 agc struct fuse *fuse;
432 1.1 agc const char *path = PCNPATH(pcn_src);
433 1.1 agc int ret;
434 1.1 agc
435 1.1 agc fuse = (struct fuse *)pu->pu_privdata;
436 1.1 agc if (fuse->op.symlink == NULL) {
437 1.1 agc return ENOSYS;
438 1.1 agc }
439 1.1 agc
440 1.1 agc /* wrap up return code */
441 1.1 agc ret = (*fuse->op.symlink)(path, link_target);
442 1.1 agc /* XXX - check I haven't transposed these args */
443 1.1 agc
444 1.1 agc if (ret == 0) {
445 1.1 agc /* fix up nodes */
446 1.5 pooka pn = newrn(pu);
447 1.1 agc if (pn == NULL) {
448 1.1 agc unlink(link_target);
449 1.1 agc return ENOMEM;
450 1.1 agc }
451 1.1 agc puffs_setvattr(&pn->pn_va, va);
452 1.1 agc
453 1.1 agc *newnode = pn;
454 1.1 agc }
455 1.1 agc
456 1.1 agc return ret;
457 1.1 agc }
458 1.1 agc
459 1.1 agc /* rename a directory entry */
460 1.1 agc /* ARGSUSED1 */
461 1.1 agc static int
462 1.1 agc puffs_fuse_node_rename(struct puffs_cc *pcc, void *opc, void *src,
463 1.1 agc const struct puffs_cn *pcn_src, void *targ_dir, void *targ,
464 1.1 agc const struct puffs_cn *pcn_targ)
465 1.1 agc {
466 1.1 agc struct puffs_usermount *pu = puffs_cc_getusermount(pcc);
467 1.1 agc struct puffs_node *pn = opc;
468 1.1 agc struct vattr va;
469 1.1 agc struct fuse *fuse;
470 1.1 agc const char *path = PCNPATH(pcn_src);
471 1.1 agc int ret;
472 1.1 agc
473 1.1 agc fuse = (struct fuse *)pu->pu_privdata;
474 1.1 agc if (fuse->op.rename == NULL) {
475 1.1 agc return ENOSYS;
476 1.1 agc }
477 1.1 agc
478 1.1 agc /* wrap up return code */
479 1.1 agc ret = (*fuse->op.rename)(path, PCNPATH(pcn_targ));
480 1.1 agc
481 1.5 pooka /* XXX: what's this guy doing??? */
482 1.1 agc if (ret == 0) {
483 1.1 agc (void) memcpy(&va, &pn->pn_va, sizeof(va));
484 1.1 agc
485 1.1 agc puffs_pn_put(pn);
486 1.1 agc
487 1.1 agc pn = puffs_pn_new(pu, NULL);
488 1.1 agc if (pn == NULL) {
489 1.1 agc return ENOMEM;
490 1.1 agc }
491 1.1 agc puffs_setvattr(&pn->pn_va, &va);
492 1.1 agc
493 1.1 agc }
494 1.1 agc
495 1.1 agc return ret;
496 1.1 agc }
497 1.1 agc
498 1.1 agc /* create a link in the file system */
499 1.1 agc /* ARGSUSED1 */
500 1.1 agc static int
501 1.1 agc puffs_fuse_node_link(struct puffs_cc *pcc, void *opc, void *targ,
502 1.1 agc const struct puffs_cn *pcn)
503 1.1 agc {
504 1.1 agc struct puffs_usermount *pu = puffs_cc_getusermount(pcc);
505 1.1 agc struct puffs_node *pn = targ;
506 1.1 agc struct fuse *fuse;
507 1.1 agc int ret;
508 1.1 agc
509 1.1 agc fuse = (struct fuse *)pu->pu_privdata;
510 1.1 agc if (fuse->op.link == NULL) {
511 1.1 agc return ENOSYS;
512 1.1 agc }
513 1.1 agc
514 1.1 agc /* wrap up return code */
515 1.1 agc ret = (*fuse->op.link)(PNPATH(pn), PCNPATH(pcn));
516 1.1 agc
517 1.1 agc return ret;
518 1.1 agc }
519 1.1 agc
520 1.1 agc /*
521 1.7 pooka * We run into a slight problemette here - puffs provides
522 1.7 pooka * setattr/getattr, whilst fuse provides all the usual chown/chmod/chgrp
523 1.7 pooka * functionality. So that we don't miss out on anything when calling a
524 1.7 pooka * fuse operation, we have to get the vattr from the existing file,
525 1.7 pooka * find out what's changed, and then switch on that to call the fuse
526 1.7 pooka * function accordingly.
527 1.7 pooka */
528 1.1 agc /* ARGSUSED3 */
529 1.1 agc static int
530 1.1 agc puffs_fuse_node_setattr(struct puffs_cc *pcc, void *opc,
531 1.1 agc const struct vattr *va, const struct puffs_cred *pcr, pid_t pid)
532 1.1 agc {
533 1.1 agc struct puffs_usermount *pu = puffs_cc_getusermount(pcc);
534 1.1 agc struct puffs_node *pn = opc;
535 1.1 agc struct fuse *fuse;
536 1.1 agc const char *path = PNPATH(pn);
537 1.1 agc mode_t mode;
538 1.1 agc uid_t uid;
539 1.1 agc gid_t gid;
540 1.1 agc int ret;
541 1.1 agc
542 1.1 agc fuse = (struct fuse *)pu->pu_privdata;
543 1.1 agc
544 1.1 agc ret = -1;
545 1.1 agc
546 1.1 agc mode = va->va_mode;
547 1.1 agc uid = va->va_uid;
548 1.1 agc gid = va->va_gid;
549 1.1 agc
550 1.9 pooka if (mode != (mode_t)PUFFS_VNOVAL) {
551 1.1 agc if (fuse->op.chmod == NULL) {
552 1.1 agc return ENOSYS;
553 1.1 agc }
554 1.1 agc ret = (*fuse->op.chmod)(path, mode);
555 1.1 agc }
556 1.9 pooka if (uid != (uid_t)PUFFS_VNOVAL || gid != (gid_t)PUFFS_VNOVAL) {
557 1.1 agc if (fuse->op.chown == NULL) {
558 1.1 agc return ENOSYS;
559 1.1 agc }
560 1.1 agc ret = (*fuse->op.chown)(path, uid, gid);
561 1.1 agc }
562 1.1 agc
563 1.1 agc if (ret == 0) {
564 1.1 agc }
565 1.1 agc
566 1.1 agc return ret;
567 1.1 agc }
568 1.1 agc
569 1.1 agc /* ARGSUSED2 */
570 1.1 agc static int
571 1.1 agc puffs_fuse_node_open(struct puffs_cc *pcc, void *opc, int flags,
572 1.1 agc const struct puffs_cred *cred, pid_t pid)
573 1.1 agc {
574 1.1 agc struct puffs_usermount *pu = puffs_cc_getusermount(pcc);
575 1.1 agc struct puffs_node *pn = opc;
576 1.5 pooka struct refusenode *rn = pn->pn_data;
577 1.1 agc struct fuse *fuse;
578 1.1 agc struct stat st;
579 1.1 agc const char *path = PNPATH(pn);
580 1.1 agc int ret;
581 1.1 agc
582 1.1 agc fuse = (struct fuse *)pu->pu_privdata;
583 1.1 agc if (fuse->op.open == NULL) {
584 1.1 agc return ENOSYS;
585 1.1 agc }
586 1.1 agc
587 1.1 agc /* examine type - if directory, return 0 rather than open */
588 1.1 agc ret = (fuse->op.getattr == NULL) ?
589 1.1 agc stat(path, &st) :
590 1.1 agc (*fuse->op.getattr)(path, &st);
591 1.1 agc if (ret == 0 && (st.st_mode & S_IFMT) == S_IFDIR) {
592 1.1 agc return 0;
593 1.1 agc }
594 1.1 agc
595 1.1 agc if (strcmp(path, "/") == 0) {
596 1.1 agc return 0;
597 1.1 agc }
598 1.1 agc
599 1.5 pooka ret = (*fuse->op.open)(path, &rn->file_info);
600 1.1 agc
601 1.1 agc if (ret == 0) {
602 1.1 agc }
603 1.1 agc
604 1.1 agc return ret;
605 1.1 agc }
606 1.1 agc
607 1.1 agc /* read some more from the file */
608 1.1 agc /* ARGSUSED5 */
609 1.1 agc static int
610 1.1 agc puffs_fuse_node_read(struct puffs_cc *pcc, void *opc, uint8_t *buf,
611 1.1 agc off_t offset, size_t *resid, const struct puffs_cred *pcr,
612 1.1 agc int ioflag)
613 1.1 agc {
614 1.1 agc struct puffs_usermount *pu = puffs_cc_getusermount(pcc);
615 1.1 agc struct puffs_node *pn = opc;
616 1.5 pooka struct refusenode *rn = pn->pn_data;
617 1.1 agc struct fuse *fuse;
618 1.1 agc const char *path = PNPATH(pn);
619 1.1 agc int ret;
620 1.1 agc
621 1.1 agc fuse = (struct fuse *)pu->pu_privdata;
622 1.1 agc if (fuse->op.read == NULL) {
623 1.1 agc return ENOSYS;
624 1.1 agc }
625 1.1 agc
626 1.7 pooka ret = (*fuse->op.read)(path, (char *)buf, *resid, offset,
627 1.7 pooka &rn->file_info);
628 1.1 agc
629 1.1 agc if (ret > 0) {
630 1.1 agc *resid -= ret;
631 1.1 agc }
632 1.1 agc
633 1.1 agc return 0;
634 1.1 agc }
635 1.1 agc
636 1.1 agc /* write to the file */
637 1.1 agc /* ARGSUSED0 */
638 1.1 agc static int
639 1.1 agc puffs_fuse_node_write(struct puffs_cc *pcc, void *opc, uint8_t *buf,
640 1.1 agc off_t offset, size_t *resid, const struct puffs_cred *pcr,
641 1.1 agc int ioflag)
642 1.1 agc {
643 1.1 agc struct puffs_usermount *pu = puffs_cc_getusermount(pcc);
644 1.1 agc struct puffs_node *pn = opc;
645 1.8 pooka struct refusenode *rn = pn->pn_data;
646 1.1 agc struct fuse *fuse;
647 1.1 agc const char *path = PNPATH(pn);
648 1.1 agc int ret;
649 1.1 agc
650 1.1 agc fuse = (struct fuse *)pu->pu_privdata;
651 1.1 agc if (fuse->op.write == NULL) {
652 1.1 agc return ENOSYS;
653 1.1 agc }
654 1.1 agc
655 1.8 pooka ret = (*fuse->op.write)(path, (char *)buf, *resid, offset,
656 1.8 pooka &rn->file_info);
657 1.1 agc
658 1.1 agc if (ret > 0) {
659 1.1 agc *resid -= ret;
660 1.1 agc }
661 1.1 agc
662 1.1 agc return ret;
663 1.1 agc }
664 1.1 agc
665 1.1 agc
666 1.1 agc /* ARGSUSED3 */
667 1.1 agc static int
668 1.1 agc puffs_fuse_node_readdir(struct puffs_cc *pcc, void *opc,
669 1.1 agc struct dirent *dent, const struct puffs_cred *pcr, off_t *readoff,
670 1.1 agc size_t *reslen)
671 1.1 agc {
672 1.1 agc struct puffs_usermount *pu = puffs_cc_getusermount(pcc);
673 1.1 agc struct puffs_node *pn = opc;
674 1.8 pooka struct refusenode *rn = pn->pn_data;
675 1.1 agc struct fuse *fuse;
676 1.1 agc const char *path = PNPATH(pn);
677 1.4 pooka struct fuse_dirh deh;
678 1.1 agc int ret;
679 1.1 agc
680 1.1 agc fuse = (struct fuse *)pu->pu_privdata;
681 1.4 pooka if (fuse->op.readdir == NULL && fuse->op.getdir == NULL) {
682 1.1 agc return ENOSYS;
683 1.1 agc }
684 1.1 agc
685 1.1 agc /* XXX: how to handle this??? */
686 1.1 agc if (*readoff != 0) {
687 1.1 agc return 0;
688 1.1 agc }
689 1.1 agc
690 1.4 pooka deh.dent = dent;
691 1.4 pooka deh.reslen = *reslen;
692 1.4 pooka deh.readoff = *readoff;
693 1.4 pooka
694 1.4 pooka if (fuse->op.readdir)
695 1.7 pooka ret = fuse->op.readdir(path, &deh, puffs_fuse_fill_dir,
696 1.8 pooka *readoff, &rn->file_info);
697 1.4 pooka else
698 1.4 pooka ret = fuse->op.getdir(path, &deh, puffs_fuse_dirfil);
699 1.4 pooka *reslen = deh.reslen;
700 1.1 agc *readoff = 1;
701 1.1 agc
702 1.1 agc if (ret == 0) {
703 1.1 agc }
704 1.1 agc
705 1.1 agc return ret;
706 1.1 agc }
707 1.1 agc
708 1.3 pooka /* ARGSUSED */
709 1.3 pooka static int
710 1.3 pooka puffs_fuse_node_reclaim(struct puffs_cc *pcc, void *opc, pid_t pid)
711 1.3 pooka {
712 1.3 pooka struct puffs_node *pn = opc;
713 1.3 pooka
714 1.5 pooka nukern(pn);
715 1.3 pooka
716 1.3 pooka return 0;
717 1.3 pooka }
718 1.3 pooka
719 1.1 agc /* ARGSUSED1 */
720 1.1 agc static int
721 1.1 agc puffs_fuse_fs_unmount(struct puffs_cc *pcc, int flags, pid_t pid)
722 1.1 agc {
723 1.1 agc struct puffs_usermount *pu = puffs_cc_getusermount(pcc);
724 1.1 agc struct fuse *fuse;
725 1.1 agc
726 1.1 agc fuse = (struct fuse *)pu->pu_privdata;
727 1.1 agc if (fuse->op.destroy == NULL) {
728 1.2 pooka return 0;
729 1.1 agc }
730 1.1 agc (*fuse->op.destroy)(fuse);
731 1.1 agc return 0;
732 1.1 agc }
733 1.1 agc
734 1.1 agc /* ARGSUSED0 */
735 1.1 agc static int
736 1.1 agc puffs_fuse_fs_sync(struct puffs_cc *pcc, int flags,
737 1.1 agc const struct puffs_cred *cr, pid_t pid)
738 1.1 agc {
739 1.1 agc return 0;
740 1.1 agc }
741 1.1 agc
742 1.1 agc /* ARGSUSED2 */
743 1.1 agc static int
744 1.1 agc puffs_fuse_fs_statvfs(struct puffs_cc *pcc, struct statvfs *svfsb, pid_t pid)
745 1.1 agc {
746 1.1 agc struct puffs_usermount *pu = puffs_cc_getusermount(pcc);
747 1.1 agc struct fuse *fuse;
748 1.1 agc int ret;
749 1.1 agc
750 1.1 agc fuse = (struct fuse *)pu->pu_privdata;
751 1.1 agc if (fuse->op.statfs == NULL) {
752 1.1 agc if ((ret = statvfs(PNPATH(pu->pu_pn_root), svfsb)) == -1) {
753 1.1 agc return errno;
754 1.1 agc }
755 1.1 agc } else {
756 1.1 agc ret = (*fuse->op.statfs)(PNPATH(pu->pu_pn_root), svfsb);
757 1.1 agc }
758 1.1 agc
759 1.1 agc return ret;
760 1.1 agc }
761 1.1 agc
762 1.1 agc
763 1.1 agc
764 1.1 agc
765 1.1 agc /* End of puffs_fuse operations */
766 1.1 agc
767 1.11 pooka /*
768 1.11 pooka * XXX: do this otherwise if/when we grow thread support
769 1.11 pooka *
770 1.11 pooka * XXX2: does not supply uid, gid or pid currently
771 1.11 pooka */
772 1.11 pooka static struct fuse_context fcon;
773 1.11 pooka
774 1.1 agc /* ARGSUSED3 */
775 1.1 agc int
776 1.1 agc fuse_main_real(int argc, char **argv, const struct fuse_operations *ops,
777 1.1 agc size_t size, void *userdata)
778 1.1 agc {
779 1.1 agc struct puffs_usermount *pu;
780 1.1 agc struct puffs_pathobj *po_root;
781 1.1 agc struct puffs_ops *pops;
782 1.1 agc struct statvfs svfsb;
783 1.1 agc struct fuse *fuse;
784 1.1 agc char name[64];
785 1.1 agc char *slash;
786 1.1 agc int ret;
787 1.1 agc
788 1.1 agc /* initialise the puffs operations structure */
789 1.1 agc PUFFSOP_INIT(pops);
790 1.1 agc
791 1.1 agc PUFFSOP_SET(pops, puffs_fuse, fs, sync);
792 1.1 agc PUFFSOP_SET(pops, puffs_fuse, fs, statvfs);
793 1.1 agc PUFFSOP_SET(pops, puffs_fuse, fs, unmount);
794 1.1 agc
795 1.2 pooka /*
796 1.2 pooka * XXX: all of these don't possibly need to be
797 1.2 pooka * unconditionally set
798 1.2 pooka */
799 1.1 agc PUFFSOP_SET(pops, puffs_fuse, node, lookup);
800 1.1 agc PUFFSOP_SET(pops, puffs_fuse, node, getattr);
801 1.1 agc PUFFSOP_SET(pops, puffs_fuse, node, readdir);
802 1.1 agc PUFFSOP_SET(pops, puffs_fuse, node, readlink);
803 1.1 agc PUFFSOP_SET(pops, puffs_fuse, node, mknod);
804 1.1 agc PUFFSOP_SET(pops, puffs_fuse, node, mkdir);
805 1.1 agc PUFFSOP_SET(pops, puffs_fuse, node, remove);
806 1.1 agc PUFFSOP_SET(pops, puffs_fuse, node, rmdir);
807 1.1 agc PUFFSOP_SET(pops, puffs_fuse, node, symlink);
808 1.1 agc PUFFSOP_SET(pops, puffs_fuse, node, rename);
809 1.1 agc PUFFSOP_SET(pops, puffs_fuse, node, link);
810 1.1 agc PUFFSOP_SET(pops, puffs_fuse, node, setattr);
811 1.1 agc PUFFSOP_SET(pops, puffs_fuse, node, open);
812 1.1 agc PUFFSOP_SET(pops, puffs_fuse, node, read);
813 1.1 agc PUFFSOP_SET(pops, puffs_fuse, node, write);
814 1.1 agc PUFFSOP_SET(pops, puffs_fuse, node, readdir);
815 1.1 agc PUFFSOP_SET(pops, puffs_fuse, node, read);
816 1.1 agc PUFFSOP_SET(pops, puffs_fuse, node, write);
817 1.3 pooka PUFFSOP_SET(pops, puffs_fuse, node, reclaim);
818 1.1 agc
819 1.1 agc NEW(struct fuse, fuse, "fuse_main_real", exit(EXIT_FAILURE));
820 1.1 agc
821 1.1 agc /* copy fuse ops to their own stucture */
822 1.1 agc (void) memcpy(&fuse->op, ops, sizeof(fuse->op));
823 1.1 agc
824 1.11 pooka fcon.fuse = fuse;
825 1.11 pooka fcon.private_data = userdata;
826 1.11 pooka
827 1.1 agc /* whilst this (assigning the pu_privdata in the puffs
828 1.1 agc * usermount struct to be the fuse struct) might seem like
829 1.1 agc * we are chasing our tail here, the logic is as follows:
830 1.1 agc + the operation wrapper gets called with the puffs
831 1.1 agc calling conventions
832 1.1 agc + we need to fix up args first
833 1.1 agc + then call the fuse user-supplied operation
834 1.1 agc + then we fix up any values on return that we need to
835 1.1 agc + and fix up any nodes, etc
836 1.7 pooka * so we need to be able to get at the fuse ops from within the
837 1.7 pooka * puffs_usermount struct
838 1.7 pooka */
839 1.1 agc if ((slash = strrchr(*argv, '/')) == NULL) {
840 1.1 agc slash = *argv;
841 1.1 agc } else {
842 1.1 agc slash += 1;
843 1.1 agc }
844 1.1 agc (void) snprintf(name, sizeof(name), "refuse:%s", slash);
845 1.1 agc pu = puffs_mount(pops, argv[argc - 1], MNT_NODEV | MNT_NOSUID,
846 1.1 agc name, fuse,
847 1.1 agc PUFFS_FLAG_BUILDPATH | PUFFS_FLAG_OPDUMP, 0);
848 1.1 agc if (pu == NULL) {
849 1.1 agc err(EXIT_FAILURE, "puffs_mount");
850 1.1 agc }
851 1.1 agc
852 1.1 agc fuse->pu = pu;
853 1.1 agc pu->pu_pn_root = puffs_pn_new(pu, NULL);
854 1.1 agc po_root = puffs_getrootpathobj(pu);
855 1.1 agc po_root->po_path = strdup("/");
856 1.1 agc po_root->po_len = 1;
857 1.1 agc
858 1.11 pooka if (fuse->op.init)
859 1.11 pooka fcon.private_data = fuse->op.init(NULL); /* XXX */
860 1.11 pooka
861 1.1 agc statvfs(argv[argc - 1], &svfsb); /* XXX - not really the correct dir */
862 1.1 agc if (puffs_start(pu, pu->pu_pn_root, &svfsb) == -1) {
863 1.1 agc err(EXIT_FAILURE, "puffs_start");
864 1.1 agc }
865 1.1 agc
866 1.1 agc ret = puffs_mainloop(fuse->pu, PUFFSLOOP_NODAEMON);
867 1.1 agc
868 1.1 agc (void) free(po_root->po_path);
869 1.1 agc FREE(fuse);
870 1.1 agc return ret;
871 1.1 agc }
872 1.1 agc
873 1.1 agc /* ARGSUSED0 */
874 1.1 agc int
875 1.1 agc fuse_opt_parse(struct fuse_args *args, void *data,
876 1.1 agc const struct fuse_opt *opts, fuse_opt_proc_t proc)
877 1.1 agc {
878 1.1 agc return 0;
879 1.1 agc }
880 1.11 pooka
881 1.11 pooka /* XXX: threads */
882 1.11 pooka struct fuse_context *
883 1.11 pooka fuse_get_context()
884 1.11 pooka {
885 1.11 pooka
886 1.11 pooka return &fcon;
887 1.11 pooka }
888