puffs.c revision 1.43 1 1.43 pooka /* $NetBSD: puffs.c,v 1.43 2007/05/10 12:26:28 pooka Exp $ */
2 1.1 pooka
3 1.1 pooka /*
4 1.1 pooka * Copyright (c) 2005, 2006 Antti Kantee. All Rights Reserved.
5 1.1 pooka *
6 1.1 pooka * Development of this software was supported by the
7 1.1 pooka * Google Summer of Code program and the Ulla Tuominen Foundation.
8 1.1 pooka * The Google SoC project was mentored by Bill Studenmund.
9 1.1 pooka *
10 1.1 pooka * Redistribution and use in source and binary forms, with or without
11 1.1 pooka * modification, are permitted provided that the following conditions
12 1.1 pooka * are met:
13 1.1 pooka * 1. Redistributions of source code must retain the above copyright
14 1.1 pooka * notice, this list of conditions and the following disclaimer.
15 1.1 pooka * 2. Redistributions in binary form must reproduce the above copyright
16 1.1 pooka * notice, this list of conditions and the following disclaimer in the
17 1.1 pooka * documentation and/or other materials provided with the distribution.
18 1.1 pooka * 3. The name of the company nor the name of the author may be used to
19 1.1 pooka * endorse or promote products derived from this software without specific
20 1.1 pooka * prior written permission.
21 1.1 pooka *
22 1.1 pooka * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS
23 1.1 pooka * OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
24 1.1 pooka * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
25 1.1 pooka * DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE
26 1.1 pooka * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
27 1.1 pooka * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
28 1.1 pooka * SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
29 1.1 pooka * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
30 1.1 pooka * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
31 1.1 pooka * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
32 1.1 pooka * SUCH DAMAGE.
33 1.1 pooka */
34 1.1 pooka
35 1.1 pooka #include <sys/cdefs.h>
36 1.1 pooka #if !defined(lint)
37 1.43 pooka __RCSID("$NetBSD: puffs.c,v 1.43 2007/05/10 12:26:28 pooka Exp $");
38 1.1 pooka #endif /* !lint */
39 1.1 pooka
40 1.1 pooka #include <sys/param.h>
41 1.1 pooka #include <sys/mount.h>
42 1.1 pooka
43 1.9 pooka #include <assert.h>
44 1.12 pooka #include <err.h>
45 1.1 pooka #include <errno.h>
46 1.1 pooka #include <fcntl.h>
47 1.21 pooka #include <mntopts.h>
48 1.1 pooka #include <puffs.h>
49 1.1 pooka #include <puffsdump.h>
50 1.19 pooka #include <stdarg.h>
51 1.1 pooka #include <stdio.h>
52 1.1 pooka #include <stdlib.h>
53 1.1 pooka #include <string.h>
54 1.1 pooka #include <syslog.h>
55 1.1 pooka #include <unistd.h>
56 1.1 pooka
57 1.19 pooka #include "puffs_priv.h"
58 1.19 pooka
59 1.43 pooka /*
60 1.43 pooka * Set the following to 1 to not handle each request on a separate
61 1.43 pooka * stack. This is highly volatile kludge, therefore no external
62 1.43 pooka * interface.
63 1.43 pooka */
64 1.43 pooka int puffs_fakecc;
65 1.43 pooka
66 1.21 pooka /* Most file systems want this for opts, so just give it to them */
67 1.21 pooka const struct mntopt puffsmopts[] = {
68 1.21 pooka MOPT_STDOPTS,
69 1.21 pooka PUFFSMOPT_STD,
70 1.21 pooka MOPT_NULL,
71 1.21 pooka };
72 1.21 pooka
73 1.10 pooka #define FILLOP(lower, upper) \
74 1.10 pooka do { \
75 1.13 pooka if (pops->puffs_node_##lower) \
76 1.10 pooka opmask[PUFFS_VN_##upper] = 1; \
77 1.10 pooka } while (/*CONSTCOND*/0)
78 1.10 pooka static void
79 1.13 pooka fillvnopmask(struct puffs_ops *pops, uint8_t *opmask)
80 1.10 pooka {
81 1.10 pooka
82 1.10 pooka memset(opmask, 0, PUFFS_VN_MAX);
83 1.10 pooka
84 1.10 pooka FILLOP(create, CREATE);
85 1.10 pooka FILLOP(mknod, MKNOD);
86 1.10 pooka FILLOP(open, OPEN);
87 1.10 pooka FILLOP(close, CLOSE);
88 1.10 pooka FILLOP(access, ACCESS);
89 1.10 pooka FILLOP(getattr, GETATTR);
90 1.10 pooka FILLOP(setattr, SETATTR);
91 1.10 pooka FILLOP(poll, POLL); /* XXX: not ready in kernel */
92 1.16 pooka FILLOP(mmap, MMAP);
93 1.10 pooka FILLOP(fsync, FSYNC);
94 1.10 pooka FILLOP(seek, SEEK);
95 1.10 pooka FILLOP(remove, REMOVE);
96 1.10 pooka FILLOP(link, LINK);
97 1.10 pooka FILLOP(rename, RENAME);
98 1.10 pooka FILLOP(mkdir, MKDIR);
99 1.10 pooka FILLOP(rmdir, RMDIR);
100 1.10 pooka FILLOP(symlink, SYMLINK);
101 1.10 pooka FILLOP(readdir, READDIR);
102 1.10 pooka FILLOP(readlink, READLINK);
103 1.10 pooka FILLOP(reclaim, RECLAIM);
104 1.10 pooka FILLOP(inactive, INACTIVE);
105 1.10 pooka FILLOP(print, PRINT);
106 1.10 pooka FILLOP(read, READ);
107 1.10 pooka FILLOP(write, WRITE);
108 1.10 pooka
109 1.10 pooka /* XXX: not implemented in the kernel */
110 1.10 pooka FILLOP(getextattr, GETEXTATTR);
111 1.10 pooka FILLOP(setextattr, SETEXTATTR);
112 1.10 pooka FILLOP(listextattr, LISTEXTATTR);
113 1.19 pooka }
114 1.19 pooka #undef FILLOP
115 1.19 pooka
116 1.19 pooka int
117 1.19 pooka puffs_getselectable(struct puffs_usermount *pu)
118 1.19 pooka {
119 1.10 pooka
120 1.36 pooka return pu->pu_kargs.pa_fd;
121 1.10 pooka }
122 1.19 pooka
123 1.19 pooka int
124 1.19 pooka puffs_setblockingmode(struct puffs_usermount *pu, int mode)
125 1.19 pooka {
126 1.19 pooka int x;
127 1.19 pooka
128 1.19 pooka x = mode;
129 1.36 pooka return ioctl(pu->pu_kargs.pa_fd, FIONBIO, &x);
130 1.19 pooka }
131 1.19 pooka
132 1.19 pooka int
133 1.19 pooka puffs_getstate(struct puffs_usermount *pu)
134 1.19 pooka {
135 1.19 pooka
136 1.19 pooka return pu->pu_state;
137 1.19 pooka }
138 1.19 pooka
139 1.19 pooka void
140 1.19 pooka puffs_setstacksize(struct puffs_usermount *pu, size_t ss)
141 1.19 pooka {
142 1.19 pooka
143 1.19 pooka pu->pu_cc_stacksize = ss;
144 1.19 pooka }
145 1.19 pooka
146 1.24 pooka struct puffs_pathobj *
147 1.24 pooka puffs_getrootpathobj(struct puffs_usermount *pu)
148 1.19 pooka {
149 1.19 pooka struct puffs_node *pnr;
150 1.19 pooka
151 1.19 pooka pnr = pu->pu_pn_root;
152 1.19 pooka if (pnr == NULL) {
153 1.19 pooka errno = ENOENT;
154 1.24 pooka return NULL;
155 1.19 pooka }
156 1.19 pooka
157 1.24 pooka return &pnr->pn_po;
158 1.24 pooka }
159 1.24 pooka
160 1.35 pooka void
161 1.35 pooka puffs_setroot(struct puffs_usermount *pu, struct puffs_node *pn)
162 1.35 pooka {
163 1.35 pooka
164 1.35 pooka pu->pu_pn_root = pn;
165 1.35 pooka }
166 1.35 pooka
167 1.35 pooka struct puffs_node *
168 1.35 pooka puffs_getroot(struct puffs_usermount *pu)
169 1.35 pooka {
170 1.35 pooka
171 1.35 pooka return pu->pu_pn_root;
172 1.35 pooka }
173 1.35 pooka
174 1.35 pooka void *
175 1.35 pooka puffs_getspecific(struct puffs_usermount *pu)
176 1.35 pooka {
177 1.35 pooka
178 1.35 pooka return pu->pu_privdata;
179 1.35 pooka }
180 1.35 pooka
181 1.35 pooka size_t
182 1.35 pooka puffs_getmaxreqlen(struct puffs_usermount *pu)
183 1.35 pooka {
184 1.35 pooka
185 1.36 pooka return pu->pu_kargs.pa_maxreqlen;
186 1.35 pooka }
187 1.24 pooka
188 1.24 pooka void
189 1.37 pooka puffs_setmaxreqlen(struct puffs_usermount *pu, size_t reqlen)
190 1.37 pooka {
191 1.37 pooka
192 1.37 pooka if (pu->pu_state != PUFFS_STATE_BEFOREMOUNT)
193 1.37 pooka warnx("puffs_setmaxreqlen: call has effect only "
194 1.37 pooka "before mount\n");
195 1.37 pooka
196 1.37 pooka pu->pu_kargs.pa_maxreqlen = reqlen;
197 1.37 pooka }
198 1.37 pooka
199 1.37 pooka void
200 1.38 pooka puffs_setfhsize(struct puffs_usermount *pu, size_t fhsize, int flags)
201 1.37 pooka {
202 1.37 pooka
203 1.37 pooka if (pu->pu_state != PUFFS_STATE_BEFOREMOUNT)
204 1.37 pooka warnx("puffs_setfhsize: call has effect only before mount\n");
205 1.37 pooka
206 1.37 pooka pu->pu_kargs.pa_fhsize = fhsize;
207 1.38 pooka pu->pu_kargs.pa_fhflags = flags;
208 1.37 pooka }
209 1.37 pooka
210 1.37 pooka void
211 1.37 pooka puffs_setncookiehash(struct puffs_usermount *pu, int nhash)
212 1.37 pooka {
213 1.37 pooka
214 1.37 pooka if (pu->pu_state != PUFFS_STATE_BEFOREMOUNT)
215 1.37 pooka warnx("puffs_setfhsize: call has effect only before mount\n");
216 1.37 pooka
217 1.37 pooka pu->pu_kargs.pa_nhashbuckets = nhash;
218 1.37 pooka }
219 1.37 pooka
220 1.37 pooka void
221 1.24 pooka puffs_set_pathbuild(struct puffs_usermount *pu, pu_pathbuild_fn fn)
222 1.24 pooka {
223 1.24 pooka
224 1.24 pooka pu->pu_pathbuild = fn;
225 1.24 pooka }
226 1.24 pooka
227 1.24 pooka void
228 1.24 pooka puffs_set_pathtransform(struct puffs_usermount *pu, pu_pathtransform_fn fn)
229 1.24 pooka {
230 1.24 pooka
231 1.24 pooka pu->pu_pathtransform = fn;
232 1.24 pooka }
233 1.24 pooka
234 1.24 pooka void
235 1.24 pooka puffs_set_pathcmp(struct puffs_usermount *pu, pu_pathcmp_fn fn)
236 1.24 pooka {
237 1.24 pooka
238 1.24 pooka pu->pu_pathcmp = fn;
239 1.24 pooka }
240 1.24 pooka
241 1.24 pooka void
242 1.24 pooka puffs_set_pathfree(struct puffs_usermount *pu, pu_pathfree_fn fn)
243 1.24 pooka {
244 1.19 pooka
245 1.24 pooka pu->pu_pathfree = fn;
246 1.19 pooka }
247 1.19 pooka
248 1.24 pooka void
249 1.24 pooka puffs_set_namemod(struct puffs_usermount *pu, pu_namemod_fn fn)
250 1.24 pooka {
251 1.24 pooka
252 1.24 pooka pu->pu_namemod = fn;
253 1.24 pooka }
254 1.19 pooka
255 1.40 pooka void
256 1.40 pooka puffs_setback(struct puffs_cc *pcc, int whatback)
257 1.40 pooka {
258 1.40 pooka struct puffs_req *preq = pcc->pcc_preq;
259 1.40 pooka
260 1.40 pooka assert(PUFFSOP_OPCLASS(preq->preq_opclass) == PUFFSOP_VN && (
261 1.40 pooka preq->preq_optype == PUFFS_VN_OPEN ||
262 1.40 pooka preq->preq_optype == PUFFS_VN_MMAP ||
263 1.40 pooka preq->preq_optype == PUFFS_VN_REMOVE ||
264 1.40 pooka preq->preq_optype == PUFFS_VN_RMDIR));
265 1.40 pooka
266 1.40 pooka preq->preq_setbacks |= whatback & PUFFS_SETBACK_MASK;
267 1.40 pooka }
268 1.40 pooka
269 1.36 pooka int
270 1.36 pooka puffs_domount(struct puffs_usermount *pu, const char *dir, int mntflags)
271 1.36 pooka {
272 1.36 pooka
273 1.36 pooka #if 1
274 1.36 pooka /* XXXkludgehere */
275 1.36 pooka /* kauth doesn't provide this service any longer */
276 1.36 pooka if (geteuid() != 0)
277 1.36 pooka mntflags |= MNT_NOSUID | MNT_NODEV;
278 1.36 pooka #endif
279 1.36 pooka
280 1.36 pooka if (mount(MOUNT_PUFFS, dir, mntflags, &pu->pu_kargs) == -1)
281 1.36 pooka return -1;
282 1.36 pooka pu->pu_state = PUFFS_STATE_MOUNTING;
283 1.36 pooka
284 1.36 pooka return 0;
285 1.36 pooka }
286 1.10 pooka
287 1.1 pooka struct puffs_usermount *
288 1.36 pooka _puffs_init(int develv, struct puffs_ops *pops, const char *puffsname,
289 1.36 pooka void *priv, uint32_t pflags)
290 1.1 pooka {
291 1.1 pooka struct puffs_usermount *pu;
292 1.36 pooka struct puffs_kargs *pargs;
293 1.36 pooka int fd;
294 1.1 pooka
295 1.20 pooka if (develv != PUFFS_DEVEL_LIBVERSION) {
296 1.20 pooka warnx("puffs_mount: mounting with lib version %d, need %d",
297 1.20 pooka develv, PUFFS_DEVEL_LIBVERSION);
298 1.20 pooka errno = EINVAL;
299 1.20 pooka return NULL;
300 1.20 pooka }
301 1.20 pooka
302 1.1 pooka fd = open("/dev/puffs", O_RDONLY);
303 1.1 pooka if (fd == -1)
304 1.1 pooka return NULL;
305 1.12 pooka if (fd <= 2)
306 1.12 pooka warnx("puffs_mount: device fd %d (<= 2), sure this is "
307 1.12 pooka "what you want?", fd);
308 1.1 pooka
309 1.36 pooka pu = malloc(sizeof(struct puffs_usermount));
310 1.36 pooka if (pu == NULL)
311 1.36 pooka goto failfree;
312 1.1 pooka
313 1.36 pooka pargs = &pu->pu_kargs;
314 1.36 pooka memset(pargs, 0, sizeof(struct puffs_kargs));
315 1.36 pooka pargs->pa_vers = PUFFSDEVELVERS | PUFFSVERSION;
316 1.36 pooka pargs->pa_flags = PUFFS_FLAG_KERN(pflags);
317 1.36 pooka pargs->pa_fd = fd;
318 1.36 pooka fillvnopmask(pops, pargs->pa_vnopmask);
319 1.36 pooka (void)strlcpy(pargs->pa_name, puffsname, sizeof(pargs->pa_name));
320 1.1 pooka
321 1.1 pooka pu->pu_flags = pflags;
322 1.13 pooka pu->pu_ops = *pops;
323 1.21 pooka free(pops); /* XXX */
324 1.36 pooka
325 1.19 pooka pu->pu_privdata = priv;
326 1.19 pooka pu->pu_cc_stacksize = PUFFS_CC_STACKSIZE_DEFAULT;
327 1.1 pooka LIST_INIT(&pu->pu_pnodelst);
328 1.1 pooka
329 1.24 pooka /* defaults for some user-settable translation functions */
330 1.24 pooka pu->pu_cmap = NULL; /* identity translation */
331 1.24 pooka
332 1.30 pooka pu->pu_pathbuild = puffs_stdpath_buildpath;
333 1.30 pooka pu->pu_pathfree = puffs_stdpath_freepath;
334 1.30 pooka pu->pu_pathcmp = puffs_stdpath_cmppath;
335 1.24 pooka pu->pu_pathtransform = NULL;
336 1.24 pooka pu->pu_namemod = NULL;
337 1.24 pooka
338 1.36 pooka pu->pu_state = PUFFS_STATE_BEFOREMOUNT;
339 1.1 pooka
340 1.1 pooka return pu;
341 1.6 pooka
342 1.1 pooka failfree:
343 1.6 pooka /* can't unmount() from here for obvious reasons */
344 1.36 pooka close(fd);
345 1.1 pooka free(pu);
346 1.1 pooka return NULL;
347 1.1 pooka }
348 1.1 pooka
349 1.36 pooka struct puffs_usermount *
350 1.36 pooka _puffs_mount(int develv, struct puffs_ops *pops, const char *dir, int mntflags,
351 1.36 pooka const char *puffsname, void *priv, uint32_t pflags)
352 1.36 pooka {
353 1.36 pooka struct puffs_usermount *pu;
354 1.36 pooka int sverrno;
355 1.36 pooka
356 1.36 pooka pu = _puffs_init(develv, pops, puffsname, priv, pflags);
357 1.36 pooka if (pu == NULL)
358 1.36 pooka return NULL;
359 1.36 pooka
360 1.36 pooka if (puffs_domount(pu, dir, mntflags) == -1) {
361 1.36 pooka sverrno = errno;
362 1.36 pooka puffs_exit(pu, 1);
363 1.36 pooka errno = sverrno;
364 1.36 pooka return NULL;
365 1.36 pooka }
366 1.36 pooka
367 1.36 pooka return pu;
368 1.36 pooka }
369 1.36 pooka
370 1.1 pooka int
371 1.21 pooka puffs_start(struct puffs_usermount *pu, void *rootcookie, struct statvfs *sbp)
372 1.21 pooka {
373 1.21 pooka struct puffs_startreq sreq;
374 1.21 pooka
375 1.21 pooka memset(&sreq, 0, sizeof(struct puffs_startreq));
376 1.21 pooka sreq.psr_cookie = rootcookie;
377 1.21 pooka sreq.psr_sb = *sbp;
378 1.21 pooka
379 1.21 pooka /* tell kernel we're flying */
380 1.36 pooka if (ioctl(pu->pu_kargs.pa_fd, PUFFSSTARTOP, &sreq) == -1)
381 1.21 pooka return -1;
382 1.21 pooka
383 1.21 pooka pu->pu_state = PUFFS_STATE_RUNNING;
384 1.21 pooka
385 1.21 pooka return 0;
386 1.21 pooka }
387 1.21 pooka
388 1.21 pooka /*
389 1.21 pooka * XXX: there's currently no clean way to request unmount from
390 1.21 pooka * within the user server, so be very brutal about it.
391 1.21 pooka */
392 1.36 pooka /*ARGSUSED1*/
393 1.21 pooka int
394 1.21 pooka puffs_exit(struct puffs_usermount *pu, int force)
395 1.21 pooka {
396 1.24 pooka struct puffs_node *pn, *pn_next;
397 1.21 pooka
398 1.21 pooka force = 1; /* currently */
399 1.21 pooka
400 1.36 pooka if (pu->pu_kargs.pa_fd)
401 1.36 pooka close(pu->pu_kargs.pa_fd);
402 1.21 pooka
403 1.24 pooka pn = LIST_FIRST(&pu->pu_pnodelst);
404 1.24 pooka while (pn) {
405 1.24 pooka pn_next = LIST_NEXT(pn, pn_entries);
406 1.24 pooka puffs_pn_put(pn);
407 1.24 pooka pn = pn_next;
408 1.24 pooka }
409 1.21 pooka free(pu);
410 1.21 pooka
411 1.21 pooka return 0; /* always succesful for now, WILL CHANGE */
412 1.21 pooka }
413 1.21 pooka
414 1.21 pooka int
415 1.9 pooka puffs_mainloop(struct puffs_usermount *pu, int flags)
416 1.1 pooka {
417 1.19 pooka struct puffs_getreq *pgr;
418 1.19 pooka struct puffs_putreq *ppr;
419 1.1 pooka int rv;
420 1.1 pooka
421 1.19 pooka rv = -1;
422 1.36 pooka pgr = puffs_req_makeget(pu, puffs_getmaxreqlen(pu), 0);
423 1.19 pooka if (pgr == NULL)
424 1.19 pooka return -1;
425 1.18 alc
426 1.26 pooka ppr = puffs_req_makeput(pu);
427 1.19 pooka if (ppr == NULL) {
428 1.26 pooka puffs_req_destroyget(pgr);
429 1.1 pooka return -1;
430 1.19 pooka }
431 1.19 pooka
432 1.19 pooka if ((flags & PUFFSLOOP_NODAEMON) == 0)
433 1.22 pooka if (daemon(1, 0) == -1)
434 1.19 pooka goto out;
435 1.1 pooka
436 1.19 pooka /* XXX: should be a bit more robust with errors here */
437 1.41 pooka rv = 0;
438 1.19 pooka while (puffs_getstate(pu) == PUFFS_STATE_RUNNING
439 1.19 pooka || puffs_getstate(pu) == PUFFS_STATE_UNMOUNTING) {
440 1.26 pooka puffs_req_resetput(ppr);
441 1.19 pooka
442 1.42 pooka if (puffs_req_handle(pgr, ppr, 0) == -1) {
443 1.19 pooka rv = -1;
444 1.19 pooka break;
445 1.19 pooka }
446 1.26 pooka if (puffs_req_putput(ppr) == -1) {
447 1.19 pooka rv = -1;
448 1.19 pooka break;
449 1.19 pooka }
450 1.18 alc }
451 1.18 alc
452 1.19 pooka out:
453 1.26 pooka puffs_req_destroyput(ppr);
454 1.26 pooka puffs_req_destroyget(pgr);
455 1.18 alc return rv;
456 1.1 pooka }
457 1.1 pooka
458 1.1 pooka int
459 1.27 pooka puffs_dopreq(struct puffs_usermount *pu, struct puffs_req *preq,
460 1.27 pooka struct puffs_putreq *ppr)
461 1.19 pooka {
462 1.43 pooka struct puffs_cc fakecc;
463 1.19 pooka struct puffs_cc *pcc;
464 1.19 pooka int rv;
465 1.12 pooka
466 1.33 pooka /*
467 1.33 pooka * XXX: the structure is currently a mess. anyway, trap
468 1.33 pooka * the cacheops here already, since they don't need a cc.
469 1.33 pooka * I really should get around to revamping the operation
470 1.33 pooka * dispatching code one of these days.
471 1.33 pooka */
472 1.33 pooka if (PUFFSOP_OPCLASS(preq->preq_opclass) == PUFFSOP_CACHE) {
473 1.33 pooka struct puffs_cacheinfo *pci = (void *)preq;
474 1.33 pooka
475 1.33 pooka if (pu->pu_ops.puffs_cache_write == NULL)
476 1.33 pooka return 0;
477 1.33 pooka
478 1.33 pooka pu->pu_ops.puffs_cache_write(pu, preq->preq_cookie,
479 1.33 pooka pci->pcache_nruns, pci->pcache_runs);
480 1.33 pooka }
481 1.33 pooka
482 1.19 pooka if (pu->pu_flags & PUFFS_FLAG_OPDUMP)
483 1.19 pooka puffsdump_req(preq);
484 1.1 pooka
485 1.43 pooka if (puffs_fakecc) {
486 1.43 pooka pcc = &fakecc;
487 1.43 pooka pcc_init_local(pcc);
488 1.43 pooka
489 1.43 pooka pcc->pcc_pu = pu;
490 1.43 pooka pcc->pcc_preq = preq;
491 1.43 pooka pcc->pcc_flags = PCC_FAKECC;
492 1.43 pooka } else {
493 1.43 pooka pcc = puffs_cc_create(pu);
494 1.21 pooka
495 1.43 pooka /* XXX: temporary kludging */
496 1.43 pooka pcc->pcc_preq = malloc(preq->preq_buflen);
497 1.43 pooka if (pcc->pcc_preq == NULL)
498 1.43 pooka return -1;
499 1.43 pooka (void) memcpy(pcc->pcc_preq, preq, preq->preq_buflen);
500 1.43 pooka }
501 1.21 pooka
502 1.27 pooka rv = puffs_docc(pcc, ppr);
503 1.1 pooka
504 1.19 pooka if ((pcc->pcc_flags & PCC_DONE) == 0)
505 1.19 pooka return 0;
506 1.12 pooka
507 1.17 pooka return rv;
508 1.1 pooka }
509 1.1 pooka
510 1.36 pooka enum {PUFFCALL_ANSWER, PUFFCALL_IGNORE, PUFFCALL_AGAIN};
511 1.36 pooka
512 1.1 pooka int
513 1.27 pooka puffs_docc(struct puffs_cc *pcc, struct puffs_putreq *ppr)
514 1.1 pooka {
515 1.31 pooka struct puffs_usermount *pu = pcc->pcc_pu;
516 1.19 pooka int rv;
517 1.19 pooka
518 1.19 pooka assert((pcc->pcc_flags & PCC_DONE) == 0);
519 1.1 pooka
520 1.43 pooka if (pcc->pcc_flags & PCC_REALCC)
521 1.43 pooka puffs_cc_continue(pcc);
522 1.43 pooka else
523 1.43 pooka puffs_calldispatcher(pcc);
524 1.19 pooka rv = pcc->pcc_rv;
525 1.19 pooka
526 1.19 pooka if ((pcc->pcc_flags & PCC_DONE) == 0)
527 1.19 pooka rv = PUFFCALL_AGAIN;
528 1.1 pooka
529 1.19 pooka /* check if we need to store this reply */
530 1.19 pooka switch (rv) {
531 1.19 pooka case PUFFCALL_ANSWER:
532 1.31 pooka if (pu->pu_flags & PUFFS_FLAG_OPDUMP)
533 1.31 pooka puffsdump_rv(pcc->pcc_preq);
534 1.31 pooka
535 1.43 pooka if (pcc->pcc_flags & PCC_REALCC)
536 1.43 pooka puffs_req_putcc(ppr, pcc);
537 1.43 pooka else
538 1.43 pooka puffs_req_put(ppr, pcc->pcc_preq);
539 1.19 pooka break;
540 1.21 pooka case PUFFCALL_IGNORE:
541 1.43 pooka if (pcc->pcc_flags & PCC_REALCC)
542 1.43 pooka puffs_cc_destroy(pcc);
543 1.21 pooka break;
544 1.19 pooka case PUFFCALL_AGAIN:
545 1.43 pooka if (pcc->pcc_flags & PCC_FAKECC)
546 1.43 pooka assert(pcc->pcc_flags & PCC_DONE);
547 1.19 pooka break;
548 1.19 pooka default:
549 1.19 pooka assert(/*CONSTCOND*/0);
550 1.19 pooka }
551 1.1 pooka
552 1.19 pooka return 0;
553 1.1 pooka }
554 1.1 pooka
555 1.19 pooka /* library private, but linked from callcontext.c */
556 1.19 pooka
557 1.19 pooka void
558 1.19 pooka puffs_calldispatcher(struct puffs_cc *pcc)
559 1.1 pooka {
560 1.19 pooka struct puffs_usermount *pu = pcc->pcc_pu;
561 1.13 pooka struct puffs_ops *pops = &pu->pu_ops;
562 1.19 pooka struct puffs_req *preq = pcc->pcc_preq;
563 1.19 pooka void *auxbuf = preq; /* help with typecasting */
564 1.40 pooka void *opcookie = preq->preq_cookie;
565 1.19 pooka int error, rv, buildpath;
566 1.19 pooka
567 1.43 pooka assert(pcc->pcc_flags & (PCC_FAKECC | PCC_REALCC));
568 1.1 pooka
569 1.12 pooka if (PUFFSOP_WANTREPLY(preq->preq_opclass))
570 1.12 pooka rv = PUFFCALL_ANSWER;
571 1.12 pooka else
572 1.12 pooka rv = PUFFCALL_IGNORE;
573 1.1 pooka
574 1.19 pooka buildpath = pu->pu_flags & PUFFS_FLAG_BUILDPATH;
575 1.40 pooka preq->preq_setbacks = 0;
576 1.12 pooka
577 1.5 pooka if (PUFFSOP_OPCLASS(preq->preq_opclass) == PUFFSOP_VFS) {
578 1.1 pooka switch (preq->preq_optype) {
579 1.1 pooka case PUFFS_VFS_UNMOUNT:
580 1.1 pooka {
581 1.12 pooka struct puffs_vfsreq_unmount *auxt = auxbuf;
582 1.1 pooka
583 1.19 pooka pu->pu_state = PUFFS_STATE_UNMOUNTING;
584 1.19 pooka error = pops->puffs_fs_unmount(pcc,
585 1.1 pooka auxt->pvfsr_flags, auxt->pvfsr_pid);
586 1.19 pooka if (!error)
587 1.19 pooka pu->pu_state = PUFFS_STATE_UNMOUNTED;
588 1.19 pooka else
589 1.19 pooka pu->pu_state = PUFFS_STATE_RUNNING;
590 1.1 pooka break;
591 1.1 pooka }
592 1.34 pooka
593 1.1 pooka case PUFFS_VFS_STATVFS:
594 1.1 pooka {
595 1.12 pooka struct puffs_vfsreq_statvfs *auxt = auxbuf;
596 1.1 pooka
597 1.19 pooka error = pops->puffs_fs_statvfs(pcc,
598 1.1 pooka &auxt->pvfsr_sb, auxt->pvfsr_pid);
599 1.1 pooka break;
600 1.1 pooka }
601 1.34 pooka
602 1.1 pooka case PUFFS_VFS_SYNC:
603 1.1 pooka {
604 1.12 pooka struct puffs_vfsreq_sync *auxt = auxbuf;
605 1.1 pooka
606 1.19 pooka error = pops->puffs_fs_sync(pcc,
607 1.1 pooka auxt->pvfsr_waitfor, &auxt->pvfsr_cred,
608 1.1 pooka auxt->pvfsr_pid);
609 1.1 pooka break;
610 1.1 pooka }
611 1.34 pooka
612 1.34 pooka case PUFFS_VFS_FHTOVP:
613 1.34 pooka {
614 1.34 pooka struct puffs_vfsreq_fhtonode *auxt = auxbuf;
615 1.34 pooka
616 1.34 pooka error = pops->puffs_fs_fhtonode(pcc, auxt->pvfsr_data,
617 1.34 pooka auxt->pvfsr_dsize, &auxt->pvfsr_fhcookie,
618 1.34 pooka &auxt->pvfsr_vtype, &auxt->pvfsr_size,
619 1.34 pooka &auxt->pvfsr_rdev);
620 1.34 pooka
621 1.34 pooka break;
622 1.34 pooka }
623 1.34 pooka
624 1.34 pooka case PUFFS_VFS_VPTOFH:
625 1.34 pooka {
626 1.34 pooka struct puffs_vfsreq_nodetofh *auxt = auxbuf;
627 1.34 pooka
628 1.34 pooka error = pops->puffs_fs_nodetofh(pcc,
629 1.34 pooka auxt->pvfsr_fhcookie, auxt->pvfsr_data,
630 1.34 pooka &auxt->pvfsr_dsize);
631 1.34 pooka
632 1.34 pooka break;
633 1.34 pooka }
634 1.34 pooka
635 1.28 pooka case PUFFS_VFS_SUSPEND:
636 1.28 pooka {
637 1.28 pooka struct puffs_vfsreq_suspend *auxt = auxbuf;
638 1.28 pooka
639 1.28 pooka error = 0;
640 1.28 pooka if (pops->puffs_fs_suspend == NULL)
641 1.28 pooka break;
642 1.28 pooka
643 1.28 pooka pops->puffs_fs_suspend(pcc, auxt->pvfsr_status);
644 1.28 pooka break;
645 1.28 pooka }
646 1.28 pooka
647 1.1 pooka default:
648 1.1 pooka /*
649 1.1 pooka * I guess the kernel sees this one coming
650 1.1 pooka */
651 1.1 pooka error = EINVAL;
652 1.1 pooka break;
653 1.1 pooka }
654 1.1 pooka
655 1.1 pooka /* XXX: audit return values */
656 1.10 pooka /* XXX: sync with kernel */
657 1.5 pooka } else if (PUFFSOP_OPCLASS(preq->preq_opclass) == PUFFSOP_VN) {
658 1.1 pooka switch (preq->preq_optype) {
659 1.1 pooka case PUFFS_VN_LOOKUP:
660 1.1 pooka {
661 1.12 pooka struct puffs_vnreq_lookup *auxt = auxbuf;
662 1.19 pooka struct puffs_cn pcn;
663 1.19 pooka
664 1.19 pooka pcn.pcn_pkcnp = &auxt->pvnr_cn;
665 1.19 pooka if (buildpath) {
666 1.40 pooka error = puffs_path_pcnbuild(pu, &pcn, opcookie);
667 1.29 pooka if (error)
668 1.29 pooka break;
669 1.19 pooka }
670 1.1 pooka
671 1.1 pooka /* lookup *must* be present */
672 1.40 pooka error = pops->puffs_node_lookup(pcc, opcookie,
673 1.1 pooka &auxt->pvnr_newnode, &auxt->pvnr_vtype,
674 1.19 pooka &auxt->pvnr_size, &auxt->pvnr_rdev, &pcn);
675 1.19 pooka
676 1.19 pooka if (buildpath) {
677 1.19 pooka if (error) {
678 1.24 pooka pu->pu_pathfree(pu, &pcn.pcn_po_full);
679 1.19 pooka } else {
680 1.19 pooka struct puffs_node *pn;
681 1.19 pooka
682 1.19 pooka /*
683 1.19 pooka * did we get a new node or a
684 1.19 pooka * recycled node?
685 1.19 pooka */
686 1.24 pooka pn = PU_CMAP(pu, auxt->pvnr_newnode);
687 1.24 pooka if (pn->pn_po.po_path == NULL)
688 1.24 pooka pn->pn_po = pcn.pcn_po_full;
689 1.24 pooka else
690 1.24 pooka pu->pu_pathfree(pu,
691 1.24 pooka &pcn.pcn_po_full);
692 1.19 pooka }
693 1.19 pooka }
694 1.19 pooka
695 1.1 pooka break;
696 1.1 pooka }
697 1.1 pooka
698 1.1 pooka case PUFFS_VN_CREATE:
699 1.1 pooka {
700 1.12 pooka struct puffs_vnreq_create *auxt = auxbuf;
701 1.19 pooka struct puffs_cn pcn;
702 1.13 pooka if (pops->puffs_node_create == NULL) {
703 1.1 pooka error = 0;
704 1.1 pooka break;
705 1.1 pooka }
706 1.1 pooka
707 1.19 pooka pcn.pcn_pkcnp = &auxt->pvnr_cn;
708 1.19 pooka if (buildpath) {
709 1.40 pooka error = puffs_path_pcnbuild(pu, &pcn, opcookie);
710 1.19 pooka if (error)
711 1.19 pooka break;
712 1.19 pooka }
713 1.19 pooka
714 1.19 pooka error = pops->puffs_node_create(pcc,
715 1.40 pooka opcookie, &auxt->pvnr_newnode,
716 1.19 pooka &pcn, &auxt->pvnr_va);
717 1.19 pooka
718 1.19 pooka if (buildpath) {
719 1.19 pooka if (error) {
720 1.24 pooka pu->pu_pathfree(pu, &pcn.pcn_po_full);
721 1.19 pooka } else {
722 1.19 pooka struct puffs_node *pn;
723 1.19 pooka
724 1.24 pooka pn = PU_CMAP(pu, auxt->pvnr_newnode);
725 1.24 pooka pn->pn_po = pcn.pcn_po_full;
726 1.19 pooka }
727 1.19 pooka }
728 1.19 pooka
729 1.1 pooka break;
730 1.1 pooka }
731 1.1 pooka
732 1.1 pooka case PUFFS_VN_MKNOD:
733 1.1 pooka {
734 1.12 pooka struct puffs_vnreq_mknod *auxt = auxbuf;
735 1.19 pooka struct puffs_cn pcn;
736 1.13 pooka if (pops->puffs_node_mknod == NULL) {
737 1.1 pooka error = 0;
738 1.1 pooka break;
739 1.1 pooka }
740 1.1 pooka
741 1.19 pooka pcn.pcn_pkcnp = &auxt->pvnr_cn;
742 1.19 pooka if (buildpath) {
743 1.40 pooka error = puffs_path_pcnbuild(pu, &pcn, opcookie);
744 1.19 pooka if (error)
745 1.19 pooka break;
746 1.19 pooka }
747 1.19 pooka
748 1.19 pooka error = pops->puffs_node_mknod(pcc,
749 1.40 pooka opcookie, &auxt->pvnr_newnode,
750 1.19 pooka &pcn, &auxt->pvnr_va);
751 1.19 pooka
752 1.19 pooka if (buildpath) {
753 1.19 pooka if (error) {
754 1.24 pooka pu->pu_pathfree(pu, &pcn.pcn_po_full);
755 1.19 pooka } else {
756 1.19 pooka struct puffs_node *pn;
757 1.19 pooka
758 1.24 pooka pn = PU_CMAP(pu, auxt->pvnr_newnode);
759 1.24 pooka pn->pn_po = pcn.pcn_po_full;
760 1.19 pooka }
761 1.19 pooka }
762 1.19 pooka
763 1.1 pooka break;
764 1.1 pooka }
765 1.1 pooka
766 1.1 pooka case PUFFS_VN_OPEN:
767 1.1 pooka {
768 1.12 pooka struct puffs_vnreq_open *auxt = auxbuf;
769 1.13 pooka if (pops->puffs_node_open == NULL) {
770 1.1 pooka error = 0;
771 1.1 pooka break;
772 1.1 pooka }
773 1.1 pooka
774 1.19 pooka error = pops->puffs_node_open(pcc,
775 1.40 pooka opcookie, auxt->pvnr_mode,
776 1.1 pooka &auxt->pvnr_cred, auxt->pvnr_pid);
777 1.1 pooka break;
778 1.1 pooka }
779 1.1 pooka
780 1.1 pooka case PUFFS_VN_CLOSE:
781 1.1 pooka {
782 1.12 pooka struct puffs_vnreq_close *auxt = auxbuf;
783 1.13 pooka if (pops->puffs_node_close == NULL) {
784 1.1 pooka error = 0;
785 1.1 pooka break;
786 1.1 pooka }
787 1.1 pooka
788 1.19 pooka error = pops->puffs_node_close(pcc,
789 1.40 pooka opcookie, auxt->pvnr_fflag,
790 1.1 pooka &auxt->pvnr_cred, auxt->pvnr_pid);
791 1.1 pooka break;
792 1.1 pooka }
793 1.1 pooka
794 1.1 pooka case PUFFS_VN_ACCESS:
795 1.1 pooka {
796 1.12 pooka struct puffs_vnreq_access *auxt = auxbuf;
797 1.13 pooka if (pops->puffs_node_access == NULL) {
798 1.1 pooka error = 0;
799 1.1 pooka break;
800 1.1 pooka }
801 1.1 pooka
802 1.19 pooka error = pops->puffs_node_access(pcc,
803 1.40 pooka opcookie, auxt->pvnr_mode,
804 1.1 pooka &auxt->pvnr_cred, auxt->pvnr_pid);
805 1.1 pooka break;
806 1.1 pooka }
807 1.1 pooka
808 1.1 pooka case PUFFS_VN_GETATTR:
809 1.1 pooka {
810 1.12 pooka struct puffs_vnreq_getattr *auxt = auxbuf;
811 1.13 pooka if (pops->puffs_node_getattr == NULL) {
812 1.12 pooka error = EOPNOTSUPP;
813 1.1 pooka break;
814 1.1 pooka }
815 1.1 pooka
816 1.19 pooka error = pops->puffs_node_getattr(pcc,
817 1.40 pooka opcookie, &auxt->pvnr_va,
818 1.1 pooka &auxt->pvnr_cred, auxt->pvnr_pid);
819 1.1 pooka break;
820 1.1 pooka }
821 1.1 pooka
822 1.1 pooka case PUFFS_VN_SETATTR:
823 1.1 pooka {
824 1.12 pooka struct puffs_vnreq_setattr *auxt = auxbuf;
825 1.13 pooka if (pops->puffs_node_setattr == NULL) {
826 1.12 pooka error = EOPNOTSUPP;
827 1.1 pooka break;
828 1.1 pooka }
829 1.1 pooka
830 1.19 pooka error = pops->puffs_node_setattr(pcc,
831 1.40 pooka opcookie, &auxt->pvnr_va,
832 1.1 pooka &auxt->pvnr_cred, auxt->pvnr_pid);
833 1.1 pooka break;
834 1.1 pooka }
835 1.1 pooka
836 1.1 pooka case PUFFS_VN_MMAP:
837 1.1 pooka {
838 1.12 pooka struct puffs_vnreq_mmap *auxt = auxbuf;
839 1.13 pooka if (pops->puffs_node_mmap == NULL) {
840 1.1 pooka error = 0;
841 1.1 pooka break;
842 1.1 pooka }
843 1.1 pooka
844 1.19 pooka error = pops->puffs_node_mmap(pcc,
845 1.40 pooka opcookie, auxt->pvnr_fflags,
846 1.15 pooka &auxt->pvnr_cred, auxt->pvnr_pid);
847 1.1 pooka break;
848 1.1 pooka }
849 1.1 pooka
850 1.1 pooka case PUFFS_VN_FSYNC:
851 1.1 pooka {
852 1.12 pooka struct puffs_vnreq_fsync *auxt = auxbuf;
853 1.13 pooka if (pops->puffs_node_fsync == NULL) {
854 1.1 pooka error = 0;
855 1.1 pooka break;
856 1.1 pooka }
857 1.1 pooka
858 1.19 pooka error = pops->puffs_node_fsync(pcc,
859 1.40 pooka opcookie, &auxt->pvnr_cred,
860 1.1 pooka auxt->pvnr_flags, auxt->pvnr_offlo,
861 1.1 pooka auxt->pvnr_offhi, auxt->pvnr_pid);
862 1.1 pooka break;
863 1.1 pooka }
864 1.1 pooka
865 1.1 pooka case PUFFS_VN_SEEK:
866 1.1 pooka {
867 1.12 pooka struct puffs_vnreq_seek *auxt = auxbuf;
868 1.13 pooka if (pops->puffs_node_seek == NULL) {
869 1.1 pooka error = 0;
870 1.1 pooka break;
871 1.1 pooka }
872 1.1 pooka
873 1.19 pooka error = pops->puffs_node_seek(pcc,
874 1.40 pooka opcookie, auxt->pvnr_oldoff,
875 1.1 pooka auxt->pvnr_newoff, &auxt->pvnr_cred);
876 1.1 pooka break;
877 1.1 pooka }
878 1.1 pooka
879 1.1 pooka case PUFFS_VN_REMOVE:
880 1.1 pooka {
881 1.12 pooka struct puffs_vnreq_remove *auxt = auxbuf;
882 1.19 pooka struct puffs_cn pcn;
883 1.13 pooka if (pops->puffs_node_remove == NULL) {
884 1.1 pooka error = 0;
885 1.1 pooka break;
886 1.1 pooka }
887 1.1 pooka
888 1.19 pooka pcn.pcn_pkcnp = &auxt->pvnr_cn;
889 1.19 pooka
890 1.19 pooka error = pops->puffs_node_remove(pcc,
891 1.40 pooka opcookie, auxt->pvnr_cookie_targ, &pcn);
892 1.1 pooka break;
893 1.1 pooka }
894 1.1 pooka
895 1.1 pooka case PUFFS_VN_LINK:
896 1.1 pooka {
897 1.12 pooka struct puffs_vnreq_link *auxt = auxbuf;
898 1.19 pooka struct puffs_cn pcn;
899 1.13 pooka if (pops->puffs_node_link == NULL) {
900 1.1 pooka error = 0;
901 1.1 pooka break;
902 1.1 pooka }
903 1.1 pooka
904 1.19 pooka pcn.pcn_pkcnp = &auxt->pvnr_cn;
905 1.22 pooka if (buildpath) {
906 1.40 pooka error = puffs_path_pcnbuild(pu, &pcn, opcookie);
907 1.22 pooka if (error)
908 1.22 pooka break;
909 1.22 pooka }
910 1.19 pooka
911 1.19 pooka error = pops->puffs_node_link(pcc,
912 1.40 pooka opcookie, auxt->pvnr_cookie_targ, &pcn);
913 1.22 pooka if (buildpath)
914 1.24 pooka pu->pu_pathfree(pu, &pcn.pcn_po_full);
915 1.22 pooka
916 1.1 pooka break;
917 1.1 pooka }
918 1.1 pooka
919 1.1 pooka case PUFFS_VN_RENAME:
920 1.1 pooka {
921 1.12 pooka struct puffs_vnreq_rename *auxt = auxbuf;
922 1.19 pooka struct puffs_cn pcn_src, pcn_targ;
923 1.19 pooka struct puffs_node *pn_src;
924 1.19 pooka
925 1.13 pooka if (pops->puffs_node_rename == NULL) {
926 1.1 pooka error = 0;
927 1.1 pooka break;
928 1.1 pooka }
929 1.1 pooka
930 1.19 pooka pcn_src.pcn_pkcnp = &auxt->pvnr_cn_src;
931 1.19 pooka pcn_targ.pcn_pkcnp = &auxt->pvnr_cn_targ;
932 1.19 pooka if (buildpath) {
933 1.19 pooka pn_src = auxt->pvnr_cookie_src;
934 1.24 pooka pcn_src.pcn_po_full = pn_src->pn_po;
935 1.19 pooka
936 1.24 pooka error = puffs_path_pcnbuild(pu, &pcn_targ,
937 1.19 pooka auxt->pvnr_cookie_targdir);
938 1.19 pooka if (error)
939 1.19 pooka break;
940 1.19 pooka }
941 1.19 pooka
942 1.19 pooka error = pops->puffs_node_rename(pcc,
943 1.40 pooka opcookie, auxt->pvnr_cookie_src,
944 1.19 pooka &pcn_src, auxt->pvnr_cookie_targdir,
945 1.19 pooka auxt->pvnr_cookie_targ, &pcn_targ);
946 1.19 pooka
947 1.19 pooka if (buildpath) {
948 1.19 pooka if (error) {
949 1.24 pooka pu->pu_pathfree(pu,
950 1.24 pooka &pcn_targ.pcn_po_full);
951 1.19 pooka } else {
952 1.24 pooka struct puffs_pathinfo pi;
953 1.24 pooka struct puffs_pathobj po_old;
954 1.23 pooka
955 1.23 pooka /* handle this node */
956 1.24 pooka po_old = pn_src->pn_po;
957 1.24 pooka pn_src->pn_po = pcn_targ.pcn_po_full;
958 1.23 pooka
959 1.23 pooka if (pn_src->pn_va.va_type != VDIR) {
960 1.24 pooka pu->pu_pathfree(pu, &po_old);
961 1.23 pooka break;
962 1.23 pooka }
963 1.23 pooka
964 1.23 pooka /* handle all child nodes for DIRs */
965 1.24 pooka pi.pi_old = &pcn_src.pcn_po_full;
966 1.24 pooka pi.pi_new = &pcn_targ.pcn_po_full;
967 1.23 pooka
968 1.23 pooka if (puffs_pn_nodewalk(pu,
969 1.24 pooka puffs_path_prefixadj, &pi) != NULL)
970 1.23 pooka error = ENOMEM;
971 1.24 pooka pu->pu_pathfree(pu, &po_old);
972 1.19 pooka }
973 1.19 pooka }
974 1.1 pooka break;
975 1.1 pooka }
976 1.1 pooka
977 1.1 pooka case PUFFS_VN_MKDIR:
978 1.1 pooka {
979 1.12 pooka struct puffs_vnreq_mkdir *auxt = auxbuf;
980 1.19 pooka struct puffs_cn pcn;
981 1.13 pooka if (pops->puffs_node_mkdir == NULL) {
982 1.1 pooka error = 0;
983 1.1 pooka break;
984 1.1 pooka }
985 1.1 pooka
986 1.19 pooka pcn.pcn_pkcnp = &auxt->pvnr_cn;
987 1.19 pooka if (buildpath) {
988 1.40 pooka error = puffs_path_pcnbuild(pu, &pcn, opcookie);
989 1.19 pooka if (error)
990 1.19 pooka break;
991 1.19 pooka }
992 1.19 pooka
993 1.19 pooka error = pops->puffs_node_mkdir(pcc,
994 1.40 pooka opcookie, &auxt->pvnr_newnode,
995 1.19 pooka &pcn, &auxt->pvnr_va);
996 1.19 pooka
997 1.19 pooka if (buildpath) {
998 1.19 pooka if (error) {
999 1.24 pooka pu->pu_pathfree(pu, &pcn.pcn_po_full);
1000 1.19 pooka } else {
1001 1.19 pooka struct puffs_node *pn;
1002 1.19 pooka
1003 1.24 pooka pn = PU_CMAP(pu, auxt->pvnr_newnode);
1004 1.24 pooka pn->pn_po = pcn.pcn_po_full;
1005 1.19 pooka }
1006 1.19 pooka }
1007 1.19 pooka
1008 1.1 pooka break;
1009 1.1 pooka }
1010 1.1 pooka
1011 1.1 pooka case PUFFS_VN_RMDIR:
1012 1.1 pooka {
1013 1.12 pooka struct puffs_vnreq_rmdir *auxt = auxbuf;
1014 1.19 pooka struct puffs_cn pcn;
1015 1.13 pooka if (pops->puffs_node_rmdir == NULL) {
1016 1.1 pooka error = 0;
1017 1.1 pooka break;
1018 1.1 pooka }
1019 1.1 pooka
1020 1.19 pooka pcn.pcn_pkcnp = &auxt->pvnr_cn;
1021 1.19 pooka
1022 1.19 pooka error = pops->puffs_node_rmdir(pcc,
1023 1.40 pooka opcookie, auxt->pvnr_cookie_targ, &pcn);
1024 1.1 pooka break;
1025 1.1 pooka }
1026 1.1 pooka
1027 1.1 pooka case PUFFS_VN_SYMLINK:
1028 1.1 pooka {
1029 1.12 pooka struct puffs_vnreq_symlink *auxt = auxbuf;
1030 1.19 pooka struct puffs_cn pcn;
1031 1.13 pooka if (pops->puffs_node_symlink == NULL) {
1032 1.1 pooka error = 0;
1033 1.1 pooka break;
1034 1.1 pooka }
1035 1.1 pooka
1036 1.19 pooka pcn.pcn_pkcnp = &auxt->pvnr_cn;
1037 1.19 pooka if (buildpath) {
1038 1.40 pooka error = puffs_path_pcnbuild(pu, &pcn, opcookie);
1039 1.19 pooka if (error)
1040 1.19 pooka break;
1041 1.19 pooka }
1042 1.19 pooka
1043 1.19 pooka error = pops->puffs_node_symlink(pcc,
1044 1.40 pooka opcookie, &auxt->pvnr_newnode,
1045 1.19 pooka &pcn, &auxt->pvnr_va, auxt->pvnr_link);
1046 1.19 pooka
1047 1.19 pooka if (buildpath) {
1048 1.19 pooka if (error) {
1049 1.24 pooka pu->pu_pathfree(pu, &pcn.pcn_po_full);
1050 1.19 pooka } else {
1051 1.19 pooka struct puffs_node *pn;
1052 1.19 pooka
1053 1.24 pooka pn = PU_CMAP(pu, auxt->pvnr_newnode);
1054 1.24 pooka pn->pn_po = pcn.pcn_po_full;
1055 1.19 pooka }
1056 1.19 pooka }
1057 1.19 pooka
1058 1.1 pooka break;
1059 1.1 pooka }
1060 1.1 pooka
1061 1.1 pooka case PUFFS_VN_READDIR:
1062 1.1 pooka {
1063 1.12 pooka struct puffs_vnreq_readdir *auxt = auxbuf;
1064 1.34 pooka struct dirent *dent;
1065 1.34 pooka off_t *cookies;
1066 1.39 pooka size_t res, origcookies;
1067 1.1 pooka
1068 1.13 pooka if (pops->puffs_node_readdir == NULL) {
1069 1.1 pooka error = 0;
1070 1.1 pooka break;
1071 1.1 pooka }
1072 1.1 pooka
1073 1.34 pooka if (auxt->pvnr_ncookies) {
1074 1.34 pooka /* LINTED: pvnr_data is __aligned() */
1075 1.34 pooka cookies = (off_t *)auxt->pvnr_data;
1076 1.39 pooka origcookies = auxt->pvnr_ncookies;
1077 1.34 pooka } else {
1078 1.34 pooka cookies = NULL;
1079 1.39 pooka origcookies = 0;
1080 1.34 pooka }
1081 1.34 pooka /* LINTED: dentoff is aligned in the kernel */
1082 1.34 pooka dent = (struct dirent *)
1083 1.34 pooka (auxt->pvnr_data + auxt->pvnr_dentoff);
1084 1.34 pooka
1085 1.1 pooka res = auxt->pvnr_resid;
1086 1.19 pooka error = pops->puffs_node_readdir(pcc,
1087 1.40 pooka opcookie, dent, &auxt->pvnr_offset,
1088 1.34 pooka &auxt->pvnr_resid, &auxt->pvnr_cred,
1089 1.34 pooka &auxt->pvnr_eofflag, cookies, &auxt->pvnr_ncookies);
1090 1.1 pooka
1091 1.39 pooka /* much easier to track non-working NFS */
1092 1.39 pooka assert(auxt->pvnr_ncookies <= origcookies);
1093 1.39 pooka
1094 1.1 pooka /* need to move a bit more */
1095 1.19 pooka preq->preq_buflen = sizeof(struct puffs_vnreq_readdir)
1096 1.34 pooka + auxt->pvnr_dentoff + (res - auxt->pvnr_resid);
1097 1.1 pooka break;
1098 1.1 pooka }
1099 1.1 pooka
1100 1.1 pooka case PUFFS_VN_READLINK:
1101 1.1 pooka {
1102 1.12 pooka struct puffs_vnreq_readlink *auxt = auxbuf;
1103 1.13 pooka if (pops->puffs_node_readlink == NULL) {
1104 1.1 pooka error = EOPNOTSUPP;
1105 1.1 pooka break;
1106 1.1 pooka }
1107 1.1 pooka
1108 1.19 pooka error = pops->puffs_node_readlink(pcc,
1109 1.40 pooka opcookie, &auxt->pvnr_cred,
1110 1.1 pooka auxt->pvnr_link, &auxt->pvnr_linklen);
1111 1.1 pooka break;
1112 1.1 pooka }
1113 1.1 pooka
1114 1.1 pooka case PUFFS_VN_RECLAIM:
1115 1.1 pooka {
1116 1.12 pooka struct puffs_vnreq_reclaim *auxt = auxbuf;
1117 1.13 pooka if (pops->puffs_node_reclaim == NULL) {
1118 1.1 pooka error = 0;
1119 1.1 pooka break;
1120 1.1 pooka }
1121 1.1 pooka
1122 1.19 pooka error = pops->puffs_node_reclaim(pcc,
1123 1.40 pooka opcookie, auxt->pvnr_pid);
1124 1.1 pooka break;
1125 1.1 pooka }
1126 1.1 pooka
1127 1.3 pooka case PUFFS_VN_INACTIVE:
1128 1.3 pooka {
1129 1.12 pooka struct puffs_vnreq_inactive *auxt = auxbuf;
1130 1.13 pooka if (pops->puffs_node_inactive == NULL) {
1131 1.3 pooka error = EOPNOTSUPP;
1132 1.3 pooka break;
1133 1.3 pooka }
1134 1.3 pooka
1135 1.19 pooka error = pops->puffs_node_inactive(pcc,
1136 1.40 pooka opcookie, auxt->pvnr_pid,
1137 1.3 pooka &auxt->pvnr_backendrefs);
1138 1.3 pooka break;
1139 1.3 pooka }
1140 1.3 pooka
1141 1.1 pooka case PUFFS_VN_PATHCONF:
1142 1.1 pooka {
1143 1.12 pooka struct puffs_vnreq_pathconf *auxt = auxbuf;
1144 1.13 pooka if (pops->puffs_node_pathconf == NULL) {
1145 1.1 pooka error = 0;
1146 1.1 pooka break;
1147 1.1 pooka }
1148 1.1 pooka
1149 1.19 pooka error = pops->puffs_node_pathconf(pcc,
1150 1.40 pooka opcookie, auxt->pvnr_name,
1151 1.1 pooka &auxt->pvnr_retval);
1152 1.1 pooka break;
1153 1.1 pooka }
1154 1.1 pooka
1155 1.1 pooka case PUFFS_VN_ADVLOCK:
1156 1.1 pooka {
1157 1.12 pooka struct puffs_vnreq_advlock *auxt = auxbuf;
1158 1.13 pooka if (pops->puffs_node_advlock == NULL) {
1159 1.1 pooka error = 0;
1160 1.1 pooka break;
1161 1.1 pooka }
1162 1.1 pooka
1163 1.19 pooka error = pops->puffs_node_advlock(pcc,
1164 1.40 pooka opcookie, auxt->pvnr_id, auxt->pvnr_op,
1165 1.1 pooka &auxt->pvnr_fl, auxt->pvnr_flags);
1166 1.1 pooka break;
1167 1.1 pooka }
1168 1.1 pooka
1169 1.1 pooka case PUFFS_VN_PRINT:
1170 1.1 pooka {
1171 1.13 pooka if (pops->puffs_node_print == NULL) {
1172 1.1 pooka error = 0;
1173 1.1 pooka break;
1174 1.1 pooka }
1175 1.1 pooka
1176 1.19 pooka error = pops->puffs_node_print(pcc,
1177 1.40 pooka opcookie);
1178 1.1 pooka break;
1179 1.1 pooka }
1180 1.1 pooka
1181 1.1 pooka case PUFFS_VN_READ:
1182 1.1 pooka {
1183 1.12 pooka struct puffs_vnreq_read *auxt = auxbuf;
1184 1.1 pooka size_t res;
1185 1.1 pooka
1186 1.13 pooka if (pops->puffs_node_read == NULL) {
1187 1.1 pooka error = EIO;
1188 1.1 pooka break;
1189 1.1 pooka }
1190 1.1 pooka
1191 1.1 pooka res = auxt->pvnr_resid;
1192 1.19 pooka error = pops->puffs_node_read(pcc,
1193 1.40 pooka opcookie, auxt->pvnr_data,
1194 1.1 pooka auxt->pvnr_offset, &auxt->pvnr_resid,
1195 1.1 pooka &auxt->pvnr_cred, auxt->pvnr_ioflag);
1196 1.1 pooka
1197 1.1 pooka /* need to move a bit more */
1198 1.19 pooka preq->preq_buflen = sizeof(struct puffs_vnreq_read)
1199 1.12 pooka + (res - auxt->pvnr_resid);
1200 1.1 pooka break;
1201 1.1 pooka }
1202 1.1 pooka
1203 1.1 pooka case PUFFS_VN_WRITE:
1204 1.1 pooka {
1205 1.12 pooka struct puffs_vnreq_write *auxt = auxbuf;
1206 1.1 pooka
1207 1.13 pooka if (pops->puffs_node_write == NULL) {
1208 1.1 pooka error = EIO;
1209 1.1 pooka break;
1210 1.1 pooka }
1211 1.1 pooka
1212 1.19 pooka error = pops->puffs_node_write(pcc,
1213 1.40 pooka opcookie, auxt->pvnr_data,
1214 1.1 pooka auxt->pvnr_offset, &auxt->pvnr_resid,
1215 1.1 pooka &auxt->pvnr_cred, auxt->pvnr_ioflag);
1216 1.1 pooka
1217 1.1 pooka /* don't need to move data back to the kernel */
1218 1.19 pooka preq->preq_buflen = sizeof(struct puffs_vnreq_write);
1219 1.1 pooka break;
1220 1.1 pooka }
1221 1.1 pooka
1222 1.19 pooka /* holy bitrot, ryydman! */
1223 1.19 pooka #if 0
1224 1.1 pooka case PUFFS_VN_IOCTL:
1225 1.40 pooka error = pops->puffs_node_ioctl1(pcc, opcookie,
1226 1.12 pooka (struct puffs_vnreq_ioctl *)auxbuf, &pop);
1227 1.1 pooka if (error != 0)
1228 1.1 pooka break;
1229 1.1 pooka pop.pso_reqid = preq->preq_id;
1230 1.1 pooka
1231 1.1 pooka /* let the kernel do it's intermediate duty */
1232 1.36 pooka error = ioctl(pu->pu_kargs.pa_fd, PUFFSSIZEOP, &pop);
1233 1.1 pooka /*
1234 1.1 pooka * XXX: I don't actually know what the correct
1235 1.1 pooka * thing to do in case of an error is, so I'll
1236 1.1 pooka * just ignore it for the time being.
1237 1.1 pooka */
1238 1.40 pooka error = pops->puffs_node_ioctl2(pcc, opcookie,
1239 1.12 pooka (struct puffs_vnreq_ioctl *)auxbuf, &pop);
1240 1.1 pooka break;
1241 1.1 pooka
1242 1.1 pooka case PUFFS_VN_FCNTL:
1243 1.40 pooka error = pops->puffs_node_fcntl1(pcc, opcookie,
1244 1.12 pooka (struct puffs_vnreq_fcntl *)auxbuf, &pop);
1245 1.1 pooka if (error != 0)
1246 1.1 pooka break;
1247 1.1 pooka pop.pso_reqid = preq->preq_id;
1248 1.1 pooka
1249 1.1 pooka /* let the kernel do it's intermediate duty */
1250 1.36 pooka error = ioctl(pu->pu_kargs.pa_fd, PUFFSSIZEOP, &pop);
1251 1.1 pooka /*
1252 1.1 pooka * XXX: I don't actually know what the correct
1253 1.1 pooka * thing to do in case of an error is, so I'll
1254 1.1 pooka * just ignore it for the time being.
1255 1.1 pooka */
1256 1.40 pooka error = pops->puffs_node_fcntl2(pcc, opcookie,
1257 1.12 pooka (struct puffs_vnreq_fcntl *)auxbuf, &pop);
1258 1.1 pooka break;
1259 1.19 pooka #endif
1260 1.1 pooka
1261 1.1 pooka default:
1262 1.1 pooka printf("inval op %d\n", preq->preq_optype);
1263 1.1 pooka error = EINVAL;
1264 1.1 pooka break;
1265 1.1 pooka }
1266 1.1 pooka } else {
1267 1.1 pooka /*
1268 1.1 pooka * this one also
1269 1.1 pooka */
1270 1.1 pooka error = EINVAL;
1271 1.1 pooka }
1272 1.1 pooka
1273 1.1 pooka preq->preq_rv = error;
1274 1.19 pooka
1275 1.19 pooka pcc->pcc_rv = rv;
1276 1.19 pooka pcc->pcc_flags |= PCC_DONE;
1277 1.19 pooka }
1278 1.19 pooka
1279 1.1 pooka
1280 1.1 pooka #if 0
1281 1.14 pooka case PUFFS_VN_POLL:
1282 1.1 pooka {
1283 1.14 pooka struct puffs_vnreq_poll *auxt = auxbuf;
1284 1.14 pooka if (pops->puffs_node_poll == NULL) {
1285 1.1 pooka error = 0;
1286 1.1 pooka break;
1287 1.1 pooka }
1288 1.1 pooka
1289 1.19 pooka error = pops->puffs_node_poll(pcc,
1290 1.40 pooka opcookie, preq-);
1291 1.1 pooka break;
1292 1.1 pooka }
1293 1.1 pooka
1294 1.14 pooka case PUFFS_VN_KQFILTER:
1295 1.1 pooka {
1296 1.14 pooka struct puffs_vnreq_kqfilter *auxt = auxbuf;
1297 1.14 pooka if (pops->puffs_node_kqfilter == NULL) {
1298 1.1 pooka error = 0;
1299 1.1 pooka break;
1300 1.1 pooka }
1301 1.1 pooka
1302 1.19 pooka error = pops->puffs_node_kqfilter(pcc,
1303 1.40 pooka opcookie, );
1304 1.1 pooka break;
1305 1.1 pooka }
1306 1.1 pooka
1307 1.1 pooka case PUFFS_VN_CLOSEEXTATTR:
1308 1.1 pooka {
1309 1.12 pooka struct puffs_vnreq_closeextattr *auxt = auxbuf;
1310 1.13 pooka if (pops->puffs_closeextattr == NULL) {
1311 1.1 pooka error = 0;
1312 1.1 pooka break;
1313 1.1 pooka }
1314 1.1 pooka
1315 1.19 pooka error = pops->puffs_closeextattr(pcc,
1316 1.40 pooka opcookie, );
1317 1.1 pooka break;
1318 1.1 pooka }
1319 1.1 pooka
1320 1.1 pooka case PUFFS_VN_GETEXTATTR:
1321 1.1 pooka {
1322 1.12 pooka struct puffs_vnreq_getextattr *auxt = auxbuf;
1323 1.13 pooka if (pops->puffs_getextattr == NULL) {
1324 1.1 pooka error = 0;
1325 1.1 pooka break;
1326 1.1 pooka }
1327 1.1 pooka
1328 1.19 pooka error = pops->puffs_getextattr(pcc,
1329 1.40 pooka opcookie, );
1330 1.1 pooka break;
1331 1.1 pooka }
1332 1.1 pooka
1333 1.1 pooka case PUFFS_VN_LISTEXTATTR:
1334 1.1 pooka {
1335 1.12 pooka struct puffs_vnreq_listextattr *auxt = auxbuf;
1336 1.13 pooka if (pops->puffs_listextattr == NULL) {
1337 1.1 pooka error = 0;
1338 1.1 pooka break;
1339 1.1 pooka }
1340 1.1 pooka
1341 1.19 pooka error = pops->puffs_listextattr(pcc,
1342 1.40 pooka opcookie, );
1343 1.1 pooka break;
1344 1.1 pooka }
1345 1.1 pooka
1346 1.1 pooka case PUFFS_VN_OPENEXTATTR:
1347 1.1 pooka {
1348 1.12 pooka struct puffs_vnreq_openextattr *auxt = auxbuf;
1349 1.13 pooka if (pops->puffs_openextattr == NULL) {
1350 1.1 pooka error = 0;
1351 1.1 pooka break;
1352 1.1 pooka }
1353 1.1 pooka
1354 1.19 pooka error = pops->puffs_openextattr(pcc,
1355 1.40 pooka opcookie, );
1356 1.1 pooka break;
1357 1.1 pooka }
1358 1.1 pooka
1359 1.1 pooka case PUFFS_VN_DELETEEXTATTR:
1360 1.1 pooka {
1361 1.12 pooka struct puffs_vnreq_deleteextattr *auxt = auxbuf;
1362 1.13 pooka if (pops->puffs_deleteextattr == NULL) {
1363 1.1 pooka error = 0;
1364 1.1 pooka break;
1365 1.1 pooka }
1366 1.1 pooka
1367 1.19 pooka error = pops->puffs_deleteextattr(pcc,
1368 1.40 pooka opcookie, );
1369 1.1 pooka break;
1370 1.1 pooka }
1371 1.1 pooka
1372 1.1 pooka case PUFFS_VN_SETEXTATTR:
1373 1.1 pooka {
1374 1.12 pooka struct puffs_vnreq_setextattr *auxt = auxbuf;
1375 1.13 pooka if (pops->puffs_setextattr == NULL) {
1376 1.1 pooka error = 0;
1377 1.1 pooka break;
1378 1.1 pooka }
1379 1.1 pooka
1380 1.19 pooka error = pops->puffs_setextattr(pcc,
1381 1.40 pooka opcookie, );
1382 1.1 pooka break;
1383 1.1 pooka }
1384 1.1 pooka
1385 1.1 pooka #endif
1386