puffs.c revision 1.79 1 1.79 pooka /* $NetBSD: puffs.c,v 1.79 2007/12/04 21:24:11 pooka Exp $ */
2 1.1 pooka
3 1.1 pooka /*
4 1.44 pooka * Copyright (c) 2005, 2006, 2007 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 *
19 1.1 pooka * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS
20 1.1 pooka * OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
21 1.1 pooka * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
22 1.1 pooka * DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE
23 1.1 pooka * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
24 1.1 pooka * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
25 1.1 pooka * SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
26 1.1 pooka * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
27 1.1 pooka * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
28 1.1 pooka * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
29 1.1 pooka * SUCH DAMAGE.
30 1.1 pooka */
31 1.1 pooka
32 1.1 pooka #include <sys/cdefs.h>
33 1.1 pooka #if !defined(lint)
34 1.79 pooka __RCSID("$NetBSD: puffs.c,v 1.79 2007/12/04 21:24:11 pooka Exp $");
35 1.1 pooka #endif /* !lint */
36 1.1 pooka
37 1.1 pooka #include <sys/param.h>
38 1.1 pooka #include <sys/mount.h>
39 1.1 pooka
40 1.9 pooka #include <assert.h>
41 1.12 pooka #include <err.h>
42 1.1 pooka #include <errno.h>
43 1.1 pooka #include <fcntl.h>
44 1.21 pooka #include <mntopts.h>
45 1.58 pooka #include <paths.h>
46 1.1 pooka #include <puffs.h>
47 1.1 pooka #include <stdio.h>
48 1.1 pooka #include <stdlib.h>
49 1.1 pooka #include <string.h>
50 1.1 pooka #include <syslog.h>
51 1.1 pooka #include <unistd.h>
52 1.1 pooka
53 1.19 pooka #include "puffs_priv.h"
54 1.19 pooka
55 1.21 pooka /* Most file systems want this for opts, so just give it to them */
56 1.21 pooka const struct mntopt puffsmopts[] = {
57 1.21 pooka MOPT_STDOPTS,
58 1.21 pooka PUFFSMOPT_STD,
59 1.21 pooka MOPT_NULL,
60 1.21 pooka };
61 1.21 pooka
62 1.72 pooka #ifdef PUFFS_WITH_THREADS
63 1.72 pooka #include <pthread.h>
64 1.72 pooka pthread_mutex_t pu_lock = PTHREAD_MUTEX_INITIALIZER;
65 1.72 pooka #endif
66 1.72 pooka
67 1.10 pooka #define FILLOP(lower, upper) \
68 1.10 pooka do { \
69 1.13 pooka if (pops->puffs_node_##lower) \
70 1.10 pooka opmask[PUFFS_VN_##upper] = 1; \
71 1.10 pooka } while (/*CONSTCOND*/0)
72 1.10 pooka static void
73 1.13 pooka fillvnopmask(struct puffs_ops *pops, uint8_t *opmask)
74 1.10 pooka {
75 1.10 pooka
76 1.10 pooka memset(opmask, 0, PUFFS_VN_MAX);
77 1.10 pooka
78 1.10 pooka FILLOP(create, CREATE);
79 1.10 pooka FILLOP(mknod, MKNOD);
80 1.10 pooka FILLOP(open, OPEN);
81 1.10 pooka FILLOP(close, CLOSE);
82 1.10 pooka FILLOP(access, ACCESS);
83 1.10 pooka FILLOP(getattr, GETATTR);
84 1.10 pooka FILLOP(setattr, SETATTR);
85 1.10 pooka FILLOP(poll, POLL); /* XXX: not ready in kernel */
86 1.16 pooka FILLOP(mmap, MMAP);
87 1.10 pooka FILLOP(fsync, FSYNC);
88 1.10 pooka FILLOP(seek, SEEK);
89 1.10 pooka FILLOP(remove, REMOVE);
90 1.10 pooka FILLOP(link, LINK);
91 1.10 pooka FILLOP(rename, RENAME);
92 1.10 pooka FILLOP(mkdir, MKDIR);
93 1.10 pooka FILLOP(rmdir, RMDIR);
94 1.10 pooka FILLOP(symlink, SYMLINK);
95 1.10 pooka FILLOP(readdir, READDIR);
96 1.10 pooka FILLOP(readlink, READLINK);
97 1.10 pooka FILLOP(reclaim, RECLAIM);
98 1.10 pooka FILLOP(inactive, INACTIVE);
99 1.10 pooka FILLOP(print, PRINT);
100 1.10 pooka FILLOP(read, READ);
101 1.10 pooka FILLOP(write, WRITE);
102 1.19 pooka }
103 1.19 pooka #undef FILLOP
104 1.19 pooka
105 1.79 pooka /*
106 1.79 pooka * Go over all framev entries and write everything we can. This is
107 1.79 pooka * mostly for the benefit of delivering "unmount" to the kernel.
108 1.79 pooka */
109 1.79 pooka static void
110 1.79 pooka finalpush(struct puffs_usermount *pu)
111 1.79 pooka {
112 1.79 pooka struct puffs_fctrl_io *fio;
113 1.79 pooka
114 1.79 pooka LIST_FOREACH(fio, &pu->pu_ios, fio_entries) {
115 1.79 pooka if (fio->stat & FIO_WRGONE)
116 1.79 pooka continue;
117 1.79 pooka
118 1.79 pooka puffs_framev_output(pu, fio->fctrl, fio);
119 1.79 pooka }
120 1.79 pooka }
121 1.79 pooka
122 1.64 pooka /*ARGSUSED*/
123 1.63 pooka static void
124 1.63 pooka puffs_defaulterror(struct puffs_usermount *pu, uint8_t type,
125 1.65 pooka int error, const char *str, void *cookie)
126 1.63 pooka {
127 1.63 pooka
128 1.77 pooka fprintf(stderr, "abort: type %d, error %d, cookie %p (%s)\n",
129 1.77 pooka type, error, cookie, str);
130 1.63 pooka abort();
131 1.63 pooka }
132 1.63 pooka
133 1.19 pooka int
134 1.19 pooka puffs_getselectable(struct puffs_usermount *pu)
135 1.19 pooka {
136 1.10 pooka
137 1.60 pooka return pu->pu_fd;
138 1.10 pooka }
139 1.19 pooka
140 1.19 pooka int
141 1.19 pooka puffs_setblockingmode(struct puffs_usermount *pu, int mode)
142 1.19 pooka {
143 1.46 pooka int rv, x;
144 1.46 pooka
145 1.74 pooka assert(puffs_getstate(pu) == PUFFS_STATE_RUNNING);
146 1.74 pooka
147 1.46 pooka if (mode != PUFFSDEV_BLOCK && mode != PUFFSDEV_NONBLOCK) {
148 1.46 pooka errno = EINVAL;
149 1.46 pooka return -1;
150 1.46 pooka }
151 1.19 pooka
152 1.19 pooka x = mode;
153 1.60 pooka rv = ioctl(pu->pu_fd, FIONBIO, &x);
154 1.46 pooka
155 1.46 pooka if (rv == 0) {
156 1.46 pooka if (mode == PUFFSDEV_BLOCK)
157 1.46 pooka pu->pu_state &= ~PU_ASYNCFD;
158 1.46 pooka else
159 1.46 pooka pu->pu_state |= PU_ASYNCFD;
160 1.46 pooka }
161 1.46 pooka
162 1.46 pooka return rv;
163 1.19 pooka }
164 1.19 pooka
165 1.19 pooka int
166 1.19 pooka puffs_getstate(struct puffs_usermount *pu)
167 1.19 pooka {
168 1.19 pooka
169 1.44 pooka return pu->pu_state & PU_STATEMASK;
170 1.19 pooka }
171 1.19 pooka
172 1.19 pooka void
173 1.19 pooka puffs_setstacksize(struct puffs_usermount *pu, size_t ss)
174 1.19 pooka {
175 1.78 pooka long psize;
176 1.69 pooka int stackshift;
177 1.78 pooka
178 1.78 pooka psize = sysconf(_SC_PAGESIZE);
179 1.78 pooka if (ss < 2*psize) {
180 1.78 pooka ss = 2*psize;
181 1.78 pooka fprintf(stderr, "puffs_setstacksize: adjusting stacksize "
182 1.78 pooka "to minimum %zu\n", ss);
183 1.78 pooka }
184 1.69 pooka
185 1.69 pooka assert(puffs_getstate(pu) == PUFFS_STATE_BEFOREMOUNT);
186 1.69 pooka stackshift = -1;
187 1.69 pooka while (ss) {
188 1.69 pooka ss >>= 1;
189 1.69 pooka stackshift++;
190 1.69 pooka }
191 1.69 pooka pu->pu_cc_stackshift = stackshift;
192 1.69 pooka assert(1<<stackshift == ss);
193 1.19 pooka }
194 1.19 pooka
195 1.24 pooka struct puffs_pathobj *
196 1.24 pooka puffs_getrootpathobj(struct puffs_usermount *pu)
197 1.19 pooka {
198 1.19 pooka struct puffs_node *pnr;
199 1.19 pooka
200 1.19 pooka pnr = pu->pu_pn_root;
201 1.19 pooka if (pnr == NULL) {
202 1.19 pooka errno = ENOENT;
203 1.24 pooka return NULL;
204 1.19 pooka }
205 1.19 pooka
206 1.24 pooka return &pnr->pn_po;
207 1.24 pooka }
208 1.24 pooka
209 1.35 pooka void
210 1.35 pooka puffs_setroot(struct puffs_usermount *pu, struct puffs_node *pn)
211 1.35 pooka {
212 1.35 pooka
213 1.35 pooka pu->pu_pn_root = pn;
214 1.35 pooka }
215 1.35 pooka
216 1.35 pooka struct puffs_node *
217 1.35 pooka puffs_getroot(struct puffs_usermount *pu)
218 1.35 pooka {
219 1.35 pooka
220 1.35 pooka return pu->pu_pn_root;
221 1.35 pooka }
222 1.35 pooka
223 1.49 pooka void
224 1.49 pooka puffs_setrootinfo(struct puffs_usermount *pu, enum vtype vt,
225 1.49 pooka vsize_t vsize, dev_t rdev)
226 1.49 pooka {
227 1.60 pooka struct puffs_kargs *pargs = pu->pu_kargp;
228 1.49 pooka
229 1.60 pooka if (puffs_getstate(pu) != PUFFS_STATE_BEFOREMOUNT) {
230 1.49 pooka warnx("puffs_setrootinfo: call has effect only "
231 1.49 pooka "before mount\n");
232 1.60 pooka return;
233 1.60 pooka }
234 1.49 pooka
235 1.49 pooka pargs->pa_root_vtype = vt;
236 1.49 pooka pargs->pa_root_vsize = vsize;
237 1.49 pooka pargs->pa_root_rdev = rdev;
238 1.49 pooka }
239 1.49 pooka
240 1.35 pooka void *
241 1.35 pooka puffs_getspecific(struct puffs_usermount *pu)
242 1.35 pooka {
243 1.35 pooka
244 1.35 pooka return pu->pu_privdata;
245 1.35 pooka }
246 1.35 pooka
247 1.35 pooka size_t
248 1.35 pooka puffs_getmaxreqlen(struct puffs_usermount *pu)
249 1.35 pooka {
250 1.35 pooka
251 1.60 pooka return pu->pu_maxreqlen;
252 1.35 pooka }
253 1.24 pooka
254 1.24 pooka void
255 1.37 pooka puffs_setmaxreqlen(struct puffs_usermount *pu, size_t reqlen)
256 1.37 pooka {
257 1.37 pooka
258 1.44 pooka if (puffs_getstate(pu) != PUFFS_STATE_BEFOREMOUNT)
259 1.37 pooka warnx("puffs_setmaxreqlen: call has effect only "
260 1.37 pooka "before mount\n");
261 1.37 pooka
262 1.66 pooka pu->pu_kargp->pa_maxmsglen = reqlen;
263 1.37 pooka }
264 1.37 pooka
265 1.37 pooka void
266 1.38 pooka puffs_setfhsize(struct puffs_usermount *pu, size_t fhsize, int flags)
267 1.37 pooka {
268 1.37 pooka
269 1.44 pooka if (puffs_getstate(pu) != PUFFS_STATE_BEFOREMOUNT)
270 1.37 pooka warnx("puffs_setfhsize: call has effect only before mount\n");
271 1.37 pooka
272 1.60 pooka pu->pu_kargp->pa_fhsize = fhsize;
273 1.60 pooka pu->pu_kargp->pa_fhflags = flags;
274 1.37 pooka }
275 1.37 pooka
276 1.37 pooka void
277 1.37 pooka puffs_setncookiehash(struct puffs_usermount *pu, int nhash)
278 1.37 pooka {
279 1.37 pooka
280 1.44 pooka if (puffs_getstate(pu) != PUFFS_STATE_BEFOREMOUNT)
281 1.37 pooka warnx("puffs_setfhsize: call has effect only before mount\n");
282 1.37 pooka
283 1.60 pooka pu->pu_kargp->pa_nhashbuckets = nhash;
284 1.37 pooka }
285 1.37 pooka
286 1.37 pooka void
287 1.24 pooka puffs_set_pathbuild(struct puffs_usermount *pu, pu_pathbuild_fn fn)
288 1.24 pooka {
289 1.24 pooka
290 1.24 pooka pu->pu_pathbuild = fn;
291 1.24 pooka }
292 1.24 pooka
293 1.24 pooka void
294 1.24 pooka puffs_set_pathtransform(struct puffs_usermount *pu, pu_pathtransform_fn fn)
295 1.24 pooka {
296 1.24 pooka
297 1.24 pooka pu->pu_pathtransform = fn;
298 1.24 pooka }
299 1.24 pooka
300 1.24 pooka void
301 1.24 pooka puffs_set_pathcmp(struct puffs_usermount *pu, pu_pathcmp_fn fn)
302 1.24 pooka {
303 1.24 pooka
304 1.24 pooka pu->pu_pathcmp = fn;
305 1.24 pooka }
306 1.24 pooka
307 1.24 pooka void
308 1.24 pooka puffs_set_pathfree(struct puffs_usermount *pu, pu_pathfree_fn fn)
309 1.24 pooka {
310 1.19 pooka
311 1.24 pooka pu->pu_pathfree = fn;
312 1.19 pooka }
313 1.19 pooka
314 1.24 pooka void
315 1.24 pooka puffs_set_namemod(struct puffs_usermount *pu, pu_namemod_fn fn)
316 1.24 pooka {
317 1.24 pooka
318 1.24 pooka pu->pu_namemod = fn;
319 1.24 pooka }
320 1.19 pooka
321 1.40 pooka void
322 1.63 pooka puffs_set_errnotify(struct puffs_usermount *pu, pu_errnotify_fn fn)
323 1.63 pooka {
324 1.63 pooka
325 1.63 pooka pu->pu_errnotify = fn;
326 1.63 pooka }
327 1.63 pooka
328 1.63 pooka void
329 1.46 pooka puffs_ml_setloopfn(struct puffs_usermount *pu, puffs_ml_loop_fn lfn)
330 1.46 pooka {
331 1.46 pooka
332 1.46 pooka pu->pu_ml_lfn = lfn;
333 1.46 pooka }
334 1.46 pooka
335 1.46 pooka void
336 1.46 pooka puffs_ml_settimeout(struct puffs_usermount *pu, struct timespec *ts)
337 1.46 pooka {
338 1.46 pooka
339 1.46 pooka if (ts == NULL) {
340 1.46 pooka pu->pu_ml_timep = NULL;
341 1.46 pooka } else {
342 1.46 pooka pu->pu_ml_timeout = *ts;
343 1.46 pooka pu->pu_ml_timep = &pu->pu_ml_timeout;
344 1.46 pooka }
345 1.46 pooka }
346 1.46 pooka
347 1.46 pooka void
348 1.71 pooka puffs_set_prepost(struct puffs_usermount *pu,
349 1.71 pooka pu_prepost_fn pre, pu_prepost_fn pst)
350 1.71 pooka {
351 1.71 pooka
352 1.71 pooka pu->pu_oppre = pre;
353 1.71 pooka pu->pu_oppost = pst;
354 1.71 pooka }
355 1.71 pooka
356 1.71 pooka void
357 1.40 pooka puffs_setback(struct puffs_cc *pcc, int whatback)
358 1.40 pooka {
359 1.79 pooka struct puffs_req *preq = puffs__framebuf_getdataptr(pcc->pcc_pb);
360 1.40 pooka
361 1.40 pooka assert(PUFFSOP_OPCLASS(preq->preq_opclass) == PUFFSOP_VN && (
362 1.40 pooka preq->preq_optype == PUFFS_VN_OPEN ||
363 1.40 pooka preq->preq_optype == PUFFS_VN_MMAP ||
364 1.40 pooka preq->preq_optype == PUFFS_VN_REMOVE ||
365 1.54 pooka preq->preq_optype == PUFFS_VN_RMDIR ||
366 1.54 pooka preq->preq_optype == PUFFS_VN_INACTIVE));
367 1.40 pooka
368 1.40 pooka preq->preq_setbacks |= whatback & PUFFS_SETBACK_MASK;
369 1.40 pooka }
370 1.40 pooka
371 1.36 pooka int
372 1.75 pooka puffs_daemon(struct puffs_usermount *pu, int nochdir, int noclose)
373 1.75 pooka {
374 1.75 pooka ssize_t n;
375 1.75 pooka int parent, value, fd;
376 1.75 pooka
377 1.75 pooka if (pipe(pu->pu_dpipe) == -1)
378 1.75 pooka return -1;
379 1.75 pooka
380 1.75 pooka switch (fork()) {
381 1.75 pooka case -1:
382 1.75 pooka return -1;
383 1.75 pooka case 0:
384 1.75 pooka parent = 0;
385 1.75 pooka break;
386 1.75 pooka default:
387 1.75 pooka parent = 1;
388 1.75 pooka break;
389 1.75 pooka }
390 1.75 pooka pu->pu_state |= PU_PUFFSDAEMON;
391 1.75 pooka
392 1.75 pooka if (parent) {
393 1.75 pooka n = read(pu->pu_dpipe[0], &value, sizeof(int));
394 1.75 pooka if (n == -1)
395 1.75 pooka err(1, "puffs_daemon");
396 1.75 pooka assert(n == sizeof(value));
397 1.75 pooka if (value) {
398 1.75 pooka errno = value;
399 1.75 pooka err(1, "puffs_daemon");
400 1.75 pooka }
401 1.75 pooka exit(0);
402 1.75 pooka } else {
403 1.75 pooka if (setsid() == -1)
404 1.75 pooka goto fail;
405 1.75 pooka
406 1.75 pooka if (!nochdir)
407 1.75 pooka chdir("/");
408 1.75 pooka
409 1.75 pooka if (!noclose) {
410 1.75 pooka fd = open(_PATH_DEVNULL, O_RDWR, 0);
411 1.75 pooka if (fd == -1)
412 1.75 pooka goto fail;
413 1.75 pooka dup2(fd, STDIN_FILENO);
414 1.75 pooka dup2(fd, STDOUT_FILENO);
415 1.75 pooka dup2(fd, STDERR_FILENO);
416 1.75 pooka if (fd > STDERR_FILENO)
417 1.75 pooka close(fd);
418 1.75 pooka }
419 1.75 pooka return 0;
420 1.75 pooka }
421 1.75 pooka
422 1.75 pooka fail:
423 1.75 pooka n = write(pu->pu_dpipe[1], &errno, sizeof(int));
424 1.75 pooka assert(n == 4);
425 1.75 pooka return -1;
426 1.75 pooka }
427 1.75 pooka
428 1.75 pooka int
429 1.49 pooka puffs_mount(struct puffs_usermount *pu, const char *dir, int mntflags,
430 1.49 pooka void *cookie)
431 1.36 pooka {
432 1.62 pooka char rp[MAXPATHLEN];
433 1.75 pooka ssize_t n;
434 1.75 pooka int rv, fd, sverrno;
435 1.36 pooka
436 1.36 pooka #if 1
437 1.36 pooka /* XXXkludgehere */
438 1.36 pooka /* kauth doesn't provide this service any longer */
439 1.36 pooka if (geteuid() != 0)
440 1.36 pooka mntflags |= MNT_NOSUID | MNT_NODEV;
441 1.36 pooka #endif
442 1.36 pooka
443 1.76 pooka if (realpath(dir, rp) == NULL) {
444 1.76 pooka rv = -1;
445 1.76 pooka goto out;
446 1.76 pooka }
447 1.62 pooka
448 1.62 pooka if (strcmp(dir, rp) != 0) {
449 1.62 pooka warnx("puffs_mount: \"%s\" is a relative path.", dir);
450 1.62 pooka warnx("puffs_mount: using \"%s\" instead.", rp);
451 1.62 pooka }
452 1.62 pooka
453 1.76 pooka fd = open(_PATH_PUFFS, O_RDWR);
454 1.74 pooka if (fd == -1) {
455 1.74 pooka warnx("puffs_mount: cannot open %s", _PATH_PUFFS);
456 1.76 pooka rv = -1;
457 1.76 pooka goto out;
458 1.74 pooka }
459 1.74 pooka if (fd <= 2)
460 1.74 pooka warnx("puffs_init: device fd %d (<= 2), sure this is "
461 1.74 pooka "what you want?", fd);
462 1.74 pooka
463 1.74 pooka pu->pu_kargp->pa_fd = pu->pu_fd = fd;
464 1.60 pooka pu->pu_kargp->pa_root_cookie = cookie;
465 1.62 pooka if ((rv = mount(MOUNT_PUFFS, rp, mntflags,
466 1.60 pooka pu->pu_kargp, sizeof(struct puffs_kargs))) == -1)
467 1.60 pooka goto out;
468 1.66 pooka #if 0
469 1.60 pooka if ((rv = ioctl(pu->pu_fd, PUFFSREQSIZEOP, &pu->pu_maxreqlen)) == -1)
470 1.60 pooka goto out;
471 1.66 pooka #endif
472 1.49 pooka PU_SETSTATE(pu, PUFFS_STATE_RUNNING);
473 1.36 pooka
474 1.60 pooka out:
475 1.76 pooka if (rv != 0)
476 1.76 pooka sverrno = errno;
477 1.76 pooka else
478 1.76 pooka sverrno = 0;
479 1.60 pooka free(pu->pu_kargp);
480 1.60 pooka pu->pu_kargp = NULL;
481 1.60 pooka
482 1.75 pooka if (pu->pu_state & PU_PUFFSDAEMON) {
483 1.75 pooka n = write(pu->pu_dpipe[1], &sverrno, sizeof(int));
484 1.75 pooka assert(n == 4);
485 1.75 pooka close(pu->pu_dpipe[0]);
486 1.75 pooka close(pu->pu_dpipe[1]);
487 1.75 pooka }
488 1.75 pooka
489 1.75 pooka errno = sverrno;
490 1.60 pooka return rv;
491 1.36 pooka }
492 1.10 pooka
493 1.1 pooka struct puffs_usermount *
494 1.58 pooka _puffs_init(int develv, struct puffs_ops *pops, const char *mntfromname,
495 1.58 pooka const char *puffsname, void *priv, uint32_t pflags)
496 1.1 pooka {
497 1.1 pooka struct puffs_usermount *pu;
498 1.36 pooka struct puffs_kargs *pargs;
499 1.74 pooka int sverrno;
500 1.1 pooka
501 1.20 pooka if (develv != PUFFS_DEVEL_LIBVERSION) {
502 1.53 pooka warnx("puffs_init: mounting with lib version %d, need %d",
503 1.20 pooka develv, PUFFS_DEVEL_LIBVERSION);
504 1.20 pooka errno = EINVAL;
505 1.20 pooka return NULL;
506 1.20 pooka }
507 1.20 pooka
508 1.36 pooka pu = malloc(sizeof(struct puffs_usermount));
509 1.36 pooka if (pu == NULL)
510 1.36 pooka goto failfree;
511 1.47 pooka memset(pu, 0, sizeof(struct puffs_usermount));
512 1.1 pooka
513 1.60 pooka pargs = pu->pu_kargp = malloc(sizeof(struct puffs_kargs));
514 1.60 pooka if (pargs == NULL)
515 1.60 pooka goto failfree;
516 1.60 pooka memset(pargs, 0, sizeof(struct puffs_kargs));
517 1.60 pooka
518 1.36 pooka pargs->pa_vers = PUFFSDEVELVERS | PUFFSVERSION;
519 1.36 pooka pargs->pa_flags = PUFFS_FLAG_KERN(pflags);
520 1.36 pooka fillvnopmask(pops, pargs->pa_vnopmask);
521 1.58 pooka (void)strlcpy(pargs->pa_typename, puffsname,
522 1.58 pooka sizeof(pargs->pa_typename));
523 1.58 pooka (void)strlcpy(pargs->pa_mntfromname, mntfromname,
524 1.58 pooka sizeof(pargs->pa_mntfromname));
525 1.1 pooka
526 1.49 pooka puffs_zerostatvfs(&pargs->pa_svfsb);
527 1.49 pooka pargs->pa_root_cookie = NULL;
528 1.49 pooka pargs->pa_root_vtype = VDIR;
529 1.49 pooka pargs->pa_root_vsize = 0;
530 1.49 pooka pargs->pa_root_rdev = 0;
531 1.66 pooka pargs->pa_maxmsglen = 0;
532 1.49 pooka
533 1.1 pooka pu->pu_flags = pflags;
534 1.13 pooka pu->pu_ops = *pops;
535 1.21 pooka free(pops); /* XXX */
536 1.36 pooka
537 1.19 pooka pu->pu_privdata = priv;
538 1.69 pooka pu->pu_cc_stackshift = PUFFS_CC_STACKSHIFT_DEFAULT;
539 1.1 pooka LIST_INIT(&pu->pu_pnodelst);
540 1.79 pooka LIST_INIT(&pu->pu_ios);
541 1.79 pooka LIST_INIT(&pu->pu_ios_rmlist);
542 1.46 pooka LIST_INIT(&pu->pu_ccnukelst);
543 1.67 pooka TAILQ_INIT(&pu->pu_sched);
544 1.70 pooka TAILQ_INIT(&pu->pu_exq);
545 1.1 pooka
546 1.79 pooka pu->pu_framectrl[PU_FRAMECTRL_FS].rfb = puffs_fsframe_read;
547 1.79 pooka pu->pu_framectrl[PU_FRAMECTRL_FS].wfb = puffs_fsframe_write;
548 1.79 pooka pu->pu_framectrl[PU_FRAMECTRL_FS].cmpfb = puffs_fsframe_cmp;
549 1.79 pooka pu->pu_framectrl[PU_FRAMECTRL_FS].gotfb = puffs_fsframe_gotframe;
550 1.79 pooka pu->pu_framectrl[PU_FRAMECTRL_FS].fdnotfn = puffs_framev_unmountonclose;
551 1.79 pooka
552 1.24 pooka /* defaults for some user-settable translation functions */
553 1.24 pooka pu->pu_cmap = NULL; /* identity translation */
554 1.24 pooka
555 1.30 pooka pu->pu_pathbuild = puffs_stdpath_buildpath;
556 1.30 pooka pu->pu_pathfree = puffs_stdpath_freepath;
557 1.30 pooka pu->pu_pathcmp = puffs_stdpath_cmppath;
558 1.24 pooka pu->pu_pathtransform = NULL;
559 1.24 pooka pu->pu_namemod = NULL;
560 1.24 pooka
561 1.63 pooka pu->pu_errnotify = puffs_defaulterror;
562 1.63 pooka
563 1.44 pooka PU_SETSTATE(pu, PUFFS_STATE_BEFOREMOUNT);
564 1.1 pooka
565 1.1 pooka return pu;
566 1.6 pooka
567 1.1 pooka failfree:
568 1.6 pooka /* can't unmount() from here for obvious reasons */
569 1.60 pooka sverrno = errno;
570 1.1 pooka free(pu);
571 1.60 pooka errno = sverrno;
572 1.1 pooka return NULL;
573 1.1 pooka }
574 1.1 pooka
575 1.21 pooka /*
576 1.21 pooka * XXX: there's currently no clean way to request unmount from
577 1.21 pooka * within the user server, so be very brutal about it.
578 1.21 pooka */
579 1.36 pooka /*ARGSUSED1*/
580 1.21 pooka int
581 1.21 pooka puffs_exit(struct puffs_usermount *pu, int force)
582 1.21 pooka {
583 1.44 pooka struct puffs_node *pn;
584 1.21 pooka
585 1.21 pooka force = 1; /* currently */
586 1.21 pooka
587 1.60 pooka if (pu->pu_fd)
588 1.60 pooka close(pu->pu_fd);
589 1.21 pooka
590 1.44 pooka while ((pn = LIST_FIRST(&pu->pu_pnodelst)) != NULL)
591 1.24 pooka puffs_pn_put(pn);
592 1.44 pooka
593 1.79 pooka finalpush(pu);
594 1.46 pooka puffs_framev_exit(pu);
595 1.68 pooka if (pu->pu_state & PU_HASKQ)
596 1.44 pooka close(pu->pu_kq);
597 1.21 pooka free(pu);
598 1.21 pooka
599 1.21 pooka return 0; /* always succesful for now, WILL CHANGE */
600 1.21 pooka }
601 1.21 pooka
602 1.21 pooka int
603 1.73 pooka puffs_mainloop(struct puffs_usermount *pu)
604 1.1 pooka {
605 1.79 pooka struct puffs_framectrl *pfctrl;
606 1.44 pooka struct puffs_fctrl_io *fio;
607 1.67 pooka struct puffs_cc *pcc;
608 1.79 pooka struct kevent *curev;
609 1.44 pooka size_t nchanges;
610 1.79 pooka int ndone, sverrno;
611 1.44 pooka
612 1.44 pooka assert(puffs_getstate(pu) >= PUFFS_STATE_RUNNING);
613 1.1 pooka
614 1.79 pooka pu->pu_kq = kqueue();
615 1.79 pooka if (pu->pu_kq == -1)
616 1.44 pooka goto out;
617 1.79 pooka pu->pu_state |= PU_HASKQ;
618 1.18 alc
619 1.79 pooka puffs_setblockingmode(pu, PUFFSDEV_NONBLOCK);
620 1.79 pooka if (puffs__framev_addfd_ctrl(pu, puffs_getselectable(pu),
621 1.79 pooka PUFFS_FBIO_READ | PUFFS_FBIO_WRITE,
622 1.79 pooka &pu->pu_framectrl[PU_FRAMECTRL_FS]) == -1)
623 1.44 pooka goto out;
624 1.44 pooka
625 1.79 pooka curev = realloc(pu->pu_evs, (2*pu->pu_nfds)*sizeof(struct kevent));
626 1.79 pooka if (curev == NULL)
627 1.44 pooka goto out;
628 1.79 pooka pu->pu_evs = curev;
629 1.19 pooka
630 1.79 pooka LIST_FOREACH(fio, &pu->pu_ios, fio_entries) {
631 1.44 pooka EV_SET(curev, fio->io_fd, EVFILT_READ, EV_ADD,
632 1.44 pooka 0, 0, (uintptr_t)fio);
633 1.44 pooka curev++;
634 1.44 pooka EV_SET(curev, fio->io_fd, EVFILT_WRITE, EV_ADD | EV_DISABLE,
635 1.44 pooka 0, 0, (uintptr_t)fio);
636 1.44 pooka curev++;
637 1.44 pooka }
638 1.79 pooka if (kevent(pu->pu_kq, pu->pu_evs, 2*pu->pu_nfds, NULL, 0, NULL) == -1)
639 1.44 pooka goto out;
640 1.44 pooka
641 1.79 pooka pu->pu_state |= PU_INLOOP;
642 1.79 pooka
643 1.44 pooka while (puffs_getstate(pu) != PUFFS_STATE_UNMOUNTED) {
644 1.46 pooka if (pu->pu_ml_lfn)
645 1.46 pooka pu->pu_ml_lfn(pu);
646 1.46 pooka
647 1.79 pooka /* XXX: can we still do these optimizations? */
648 1.79 pooka #if 0
649 1.55 pooka /*
650 1.55 pooka * Do this here, because:
651 1.55 pooka * a) loopfunc might generate some results
652 1.55 pooka * b) it's still "after" event handling (except for round 1)
653 1.55 pooka */
654 1.55 pooka if (puffs_req_putput(ppr) == -1)
655 1.55 pooka goto out;
656 1.55 pooka puffs_req_resetput(ppr);
657 1.55 pooka
658 1.46 pooka /* micro optimization: skip kevent syscall if possible */
659 1.79 pooka if (pu->pu_nfds == 1 && pu->pu_ml_timep == NULL
660 1.46 pooka && (pu->pu_state & PU_ASYNCFD) == 0) {
661 1.79 pooka pfctrl = XXX->fctrl;
662 1.79 pooka puffs_framev_input(pu, pfctrl, XXX);
663 1.46 pooka continue;
664 1.46 pooka }
665 1.79 pooka #endif
666 1.55 pooka
667 1.46 pooka /* else: do full processing */
668 1.79 pooka /* Don't bother worrying about O(n) for now */
669 1.79 pooka nchanges = 0;
670 1.1 pooka
671 1.79 pooka LIST_FOREACH(fio, &pu->pu_ios, fio_entries) {
672 1.46 pooka if (fio->stat & FIO_WRGONE)
673 1.46 pooka continue;
674 1.46 pooka
675 1.79 pooka pfctrl = fio->fctrl;
676 1.79 pooka
677 1.44 pooka /*
678 1.44 pooka * Try to write out everything to avoid the
679 1.44 pooka * need for enabling EVFILT_WRITE. The likely
680 1.44 pooka * case is that we can fit everything into the
681 1.44 pooka * socket buffer.
682 1.44 pooka */
683 1.79 pooka puffs_framev_output(pu, pfctrl, fio);
684 1.79 pooka }
685 1.79 pooka
686 1.79 pooka /*
687 1.79 pooka * Build list of which to enable/disable in writecheck.
688 1.79 pooka */
689 1.79 pooka LIST_FOREACH(fio, &pu->pu_ios, fio_entries) {
690 1.79 pooka if (fio->stat & FIO_WRGONE)
691 1.79 pooka continue;
692 1.19 pooka
693 1.46 pooka /* en/disable write checks for kqueue as needed */
694 1.44 pooka assert((FIO_EN_WRITE(fio) && FIO_RM_WRITE(fio)) == 0);
695 1.44 pooka if (FIO_EN_WRITE(fio)) {
696 1.79 pooka EV_SET(&pu->pu_evs[nchanges], fio->io_fd,
697 1.44 pooka EVFILT_WRITE, EV_ENABLE, 0, 0,
698 1.44 pooka (uintptr_t)fio);
699 1.46 pooka fio->stat |= FIO_WR;
700 1.44 pooka nchanges++;
701 1.44 pooka }
702 1.44 pooka if (FIO_RM_WRITE(fio)) {
703 1.79 pooka EV_SET(&pu->pu_evs[nchanges], fio->io_fd,
704 1.44 pooka EVFILT_WRITE, EV_DISABLE, 0, 0,
705 1.44 pooka (uintptr_t)fio);
706 1.46 pooka fio->stat &= ~FIO_WR;
707 1.44 pooka nchanges++;
708 1.44 pooka }
709 1.79 pooka assert(nchanges <= pu->pu_nfds);
710 1.19 pooka }
711 1.44 pooka
712 1.79 pooka ndone = kevent(pu->pu_kq, pu->pu_evs, nchanges,
713 1.79 pooka pu->pu_evs, 2*pu->pu_nfds, pu->pu_ml_timep);
714 1.50 pooka
715 1.50 pooka if (ndone == -1) {
716 1.50 pooka if (errno != EINTR)
717 1.50 pooka goto out;
718 1.50 pooka else
719 1.50 pooka continue;
720 1.50 pooka }
721 1.50 pooka
722 1.50 pooka /* uoptimize */
723 1.46 pooka if (ndone == 0)
724 1.46 pooka continue;
725 1.44 pooka
726 1.44 pooka /* iterate over the results */
727 1.79 pooka for (curev = pu->pu_evs; ndone--; curev++) {
728 1.61 pooka int what;
729 1.61 pooka
730 1.79 pooka #if 0
731 1.44 pooka /* get & possibly dispatch events from kernel */
732 1.44 pooka if (curev->ident == puffsfd) {
733 1.44 pooka if (puffs_req_handle(pgr, ppr, 0) == -1)
734 1.44 pooka goto out;
735 1.44 pooka continue;
736 1.44 pooka }
737 1.79 pooka #endif
738 1.44 pooka
739 1.46 pooka fio = (void *)curev->udata;
740 1.79 pooka pfctrl = fio->fctrl;
741 1.46 pooka if (curev->flags & EV_ERROR) {
742 1.46 pooka assert(curev->filter == EVFILT_WRITE);
743 1.46 pooka fio->stat &= ~FIO_WR;
744 1.46 pooka
745 1.46 pooka /* XXX: how to know if it's a transient error */
746 1.46 pooka puffs_framev_writeclose(pu, fio,
747 1.46 pooka (int)curev->data);
748 1.61 pooka puffs_framev_notify(fio, PUFFS_FBIO_ERROR);
749 1.46 pooka continue;
750 1.44 pooka }
751 1.44 pooka
752 1.61 pooka what = 0;
753 1.61 pooka if (curev->filter == EVFILT_READ) {
754 1.79 pooka puffs_framev_input(pu, pfctrl, fio);
755 1.61 pooka what |= PUFFS_FBIO_READ;
756 1.61 pooka }
757 1.56 pooka
758 1.61 pooka else if (curev->filter == EVFILT_WRITE) {
759 1.79 pooka puffs_framev_output(pu, pfctrl, fio);
760 1.61 pooka what |= PUFFS_FBIO_WRITE;
761 1.61 pooka }
762 1.61 pooka if (what)
763 1.61 pooka puffs_framev_notify(fio, what);
764 1.19 pooka }
765 1.44 pooka
766 1.46 pooka /*
767 1.67 pooka * Schedule continuations.
768 1.67 pooka */
769 1.67 pooka while ((pcc = TAILQ_FIRST(&pu->pu_sched)) != NULL) {
770 1.67 pooka TAILQ_REMOVE(&pu->pu_sched, pcc, entries);
771 1.67 pooka puffs_goto(pcc);
772 1.67 pooka }
773 1.67 pooka
774 1.67 pooka /*
775 1.46 pooka * Really free fd's now that we don't have references
776 1.46 pooka * to them.
777 1.46 pooka */
778 1.79 pooka while ((fio = LIST_FIRST(&pu->pu_ios_rmlist)) != NULL) {
779 1.46 pooka LIST_REMOVE(fio, fio_entries);
780 1.46 pooka free(fio);
781 1.46 pooka }
782 1.18 alc }
783 1.79 pooka finalpush(pu);
784 1.44 pooka errno = 0;
785 1.18 alc
786 1.19 pooka out:
787 1.44 pooka /* store the real error for a while */
788 1.44 pooka sverrno = errno;
789 1.44 pooka
790 1.44 pooka errno = sverrno;
791 1.44 pooka if (errno)
792 1.44 pooka return -1;
793 1.44 pooka else
794 1.44 pooka return 0;
795 1.1 pooka }
796