puffs_vnops.c revision 1.55 1 /* $NetBSD: puffs_vnops.c,v 1.55 2007/03/29 16:04:26 pooka Exp $ */
2
3 /*
4 * Copyright (c) 2005, 2006 Antti Kantee. All Rights Reserved.
5 *
6 * Development of this software was supported by the
7 * Google Summer of Code program and the Ulla Tuominen Foundation.
8 * The Google SoC project was mentored by Bill Studenmund.
9 *
10 * Redistribution and use in source and binary forms, with or without
11 * modification, are permitted provided that the following conditions
12 * are met:
13 * 1. Redistributions of source code must retain the above copyright
14 * notice, this list of conditions and the following disclaimer.
15 * 2. Redistributions in binary form must reproduce the above copyright
16 * notice, this list of conditions and the following disclaimer in the
17 * documentation and/or other materials provided with the distribution.
18 * 3. The name of the company nor the name of the author may be used to
19 * endorse or promote products derived from this software without specific
20 * prior written permission.
21 *
22 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS
23 * OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
24 * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
25 * DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE
26 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
27 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
28 * SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
29 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
30 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
31 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
32 * SUCH DAMAGE.
33 */
34
35 #include <sys/cdefs.h>
36 __KERNEL_RCSID(0, "$NetBSD: puffs_vnops.c,v 1.55 2007/03/29 16:04:26 pooka Exp $");
37
38 #include <sys/param.h>
39 #include <sys/fstrans.h>
40 #include <sys/malloc.h>
41 #include <sys/mount.h>
42 #include <sys/namei.h>
43 #include <sys/vnode.h>
44 #include <uvm/uvm.h>
45
46 #include <fs/puffs/puffs_msgif.h>
47 #include <fs/puffs/puffs_sys.h>
48
49 #include <miscfs/fifofs/fifo.h>
50 #include <miscfs/genfs/genfs.h>
51 #include <miscfs/specfs/specdev.h>
52
53 int puffs_lookup(void *);
54 int puffs_create(void *);
55 int puffs_access(void *);
56 int puffs_mknod(void *);
57 int puffs_open(void *);
58 int puffs_close(void *);
59 int puffs_getattr(void *);
60 int puffs_setattr(void *);
61 int puffs_reclaim(void *);
62 int puffs_readdir(void *);
63 int puffs_poll(void *);
64 int puffs_fsync(void *);
65 int puffs_seek(void *);
66 int puffs_remove(void *);
67 int puffs_mkdir(void *);
68 int puffs_rmdir(void *);
69 int puffs_link(void *);
70 int puffs_readlink(void *);
71 int puffs_symlink(void *);
72 int puffs_rename(void *);
73 int puffs_read(void *);
74 int puffs_write(void *);
75 int puffs_fcntl(void *);
76 int puffs_ioctl(void *);
77 int puffs_inactive(void *);
78 int puffs_print(void *);
79 int puffs_pathconf(void *);
80 int puffs_advlock(void *);
81 int puffs_strategy(void *);
82 int puffs_bmap(void *);
83 int puffs_mmap(void *);
84 int puffs_getpages(void *);
85
86 int puffs_spec_read(void *);
87 int puffs_spec_write(void *);
88 int puffs_fifo_read(void *);
89 int puffs_fifo_write(void *);
90
91 int puffs_checkop(void *);
92
93
94 /* VOP_LEASE() not included */
95
96 int puffs_generic(void *);
97
98 #if 0
99 #define puffs_lock genfs_lock
100 #define puffs_unlock genfs_unlock
101 #define puffs_islocked genfs_islocked
102 #else
103 int puffs_lock(void *);
104 int puffs_unlock(void *);
105 int puffs_islocked(void *);
106 #endif
107
108 int (**puffs_vnodeop_p)(void *);
109 const struct vnodeopv_entry_desc puffs_vnodeop_entries[] = {
110 { &vop_default_desc, vn_default_error },
111 { &vop_lookup_desc, puffs_lookup }, /* REAL lookup */
112 { &vop_create_desc, puffs_checkop }, /* create */
113 { &vop_mknod_desc, puffs_checkop }, /* mknod */
114 { &vop_open_desc, puffs_open }, /* REAL open */
115 { &vop_close_desc, puffs_checkop }, /* close */
116 { &vop_access_desc, puffs_access }, /* REAL access */
117 { &vop_getattr_desc, puffs_checkop }, /* getattr */
118 { &vop_setattr_desc, puffs_checkop }, /* setattr */
119 { &vop_read_desc, puffs_checkop }, /* read */
120 { &vop_write_desc, puffs_checkop }, /* write */
121 { &vop_fcntl_desc, puffs_checkop }, /* fcntl */
122 { &vop_ioctl_desc, puffs_checkop }, /* ioctl */
123 { &vop_fsync_desc, puffs_fsync }, /* REAL fsync */
124 { &vop_seek_desc, puffs_checkop }, /* seek */
125 { &vop_remove_desc, puffs_checkop }, /* remove */
126 { &vop_link_desc, puffs_checkop }, /* link */
127 { &vop_rename_desc, puffs_checkop }, /* rename */
128 { &vop_mkdir_desc, puffs_checkop }, /* mkdir */
129 { &vop_rmdir_desc, puffs_checkop }, /* rmdir */
130 { &vop_symlink_desc, puffs_checkop }, /* symlink */
131 { &vop_readdir_desc, puffs_checkop }, /* readdir */
132 { &vop_readlink_desc, puffs_checkop }, /* readlink */
133 { &vop_getpages_desc, puffs_checkop }, /* getpages */
134 { &vop_putpages_desc, genfs_putpages }, /* REAL putpages */
135 { &vop_pathconf_desc, puffs_checkop }, /* pathconf */
136 { &vop_advlock_desc, puffs_checkop }, /* advlock */
137 { &vop_strategy_desc, puffs_strategy }, /* REAL strategy */
138 { &vop_revoke_desc, genfs_revoke }, /* REAL revoke */
139 { &vop_abortop_desc, genfs_abortop }, /* REAL abortop */
140 { &vop_inactive_desc, puffs_inactive }, /* REAL inactive */
141 { &vop_reclaim_desc, puffs_reclaim }, /* REAL reclaim */
142 { &vop_lock_desc, puffs_lock }, /* REAL lock */
143 { &vop_unlock_desc, puffs_unlock }, /* REAL unlock */
144 { &vop_bmap_desc, puffs_bmap }, /* REAL bmap */
145 { &vop_print_desc, puffs_print }, /* REAL print */
146 { &vop_islocked_desc, puffs_islocked }, /* REAL islocked */
147 { &vop_bwrite_desc, genfs_nullop }, /* REAL bwrite */
148 { &vop_mmap_desc, puffs_mmap }, /* REAL mmap */
149
150 { &vop_poll_desc, genfs_eopnotsupp }, /* poll XXX */
151 { &vop_poll_desc, genfs_eopnotsupp }, /* kqfilter XXX */
152 { NULL, NULL }
153 };
154 const struct vnodeopv_desc puffs_vnodeop_opv_desc =
155 { &puffs_vnodeop_p, puffs_vnodeop_entries };
156
157
158 int (**puffs_specop_p)(void *);
159 const struct vnodeopv_entry_desc puffs_specop_entries[] = {
160 { &vop_default_desc, vn_default_error },
161 { &vop_lookup_desc, spec_lookup }, /* lookup, ENOTDIR */
162 { &vop_create_desc, spec_create }, /* genfs_badop */
163 { &vop_mknod_desc, spec_mknod }, /* genfs_badop */
164 { &vop_open_desc, spec_open }, /* spec_open */
165 { &vop_close_desc, spec_close }, /* spec_close */
166 { &vop_access_desc, puffs_checkop }, /* access */
167 { &vop_getattr_desc, puffs_checkop }, /* getattr */
168 { &vop_setattr_desc, puffs_checkop }, /* setattr */
169 { &vop_read_desc, puffs_spec_read }, /* update, read */
170 { &vop_write_desc, puffs_spec_write }, /* update, write */
171 { &vop_lease_desc, spec_lease_check }, /* genfs_nullop */
172 { &vop_ioctl_desc, spec_ioctl }, /* spec_ioctl */
173 { &vop_fcntl_desc, genfs_fcntl }, /* dummy */
174 { &vop_poll_desc, spec_poll }, /* spec_poll */
175 { &vop_kqfilter_desc, spec_kqfilter }, /* spec_kqfilter */
176 { &vop_revoke_desc, spec_revoke }, /* genfs_revoke */
177 { &vop_mmap_desc, spec_mmap }, /* genfs_mmap (dummy) */
178 { &vop_fsync_desc, spec_fsync }, /* vflushbuf */
179 { &vop_seek_desc, spec_seek }, /* genfs_nullop */
180 { &vop_remove_desc, spec_remove }, /* genfs_badop */
181 { &vop_link_desc, spec_link }, /* genfs_badop */
182 { &vop_rename_desc, spec_rename }, /* genfs_badop */
183 { &vop_mkdir_desc, spec_mkdir }, /* genfs_badop */
184 { &vop_rmdir_desc, spec_rmdir }, /* genfs_badop */
185 { &vop_symlink_desc, spec_symlink }, /* genfs_badop */
186 { &vop_readdir_desc, spec_readdir }, /* genfs_badop */
187 { &vop_readlink_desc, spec_readlink }, /* genfs_badop */
188 { &vop_abortop_desc, spec_abortop }, /* genfs_badop */
189 { &vop_inactive_desc, puffs_inactive }, /* REAL inactive */
190 { &vop_reclaim_desc, puffs_reclaim }, /* REAL reclaim */
191 { &vop_lock_desc, puffs_lock }, /* REAL lock */
192 { &vop_unlock_desc, puffs_unlock }, /* REAL unlock */
193 { &vop_bmap_desc, spec_bmap }, /* dummy */
194 { &vop_strategy_desc, spec_strategy }, /* dev strategy */
195 { &vop_print_desc, puffs_print }, /* REAL print */
196 { &vop_islocked_desc, puffs_islocked }, /* REAL islocked */
197 { &vop_pathconf_desc, spec_pathconf }, /* pathconf */
198 { &vop_advlock_desc, spec_advlock }, /* lf_advlock */
199 { &vop_bwrite_desc, vn_bwrite }, /* bwrite */
200 { &vop_getpages_desc, spec_getpages }, /* genfs_getpages */
201 { &vop_putpages_desc, spec_putpages }, /* genfs_putpages */
202 #if 0
203 { &vop_openextattr_desc, _openextattr }, /* openextattr */
204 { &vop_closeextattr_desc, _closeextattr }, /* closeextattr */
205 { &vop_getextattr_desc, _getextattr }, /* getextattr */
206 { &vop_setextattr_desc, _setextattr }, /* setextattr */
207 { &vop_listextattr_desc, _listextattr }, /* listextattr */
208 { &vop_deleteextattr_desc, _deleteextattr }, /* deleteextattr */
209 #endif
210 { NULL, NULL }
211 };
212 const struct vnodeopv_desc puffs_specop_opv_desc =
213 { &puffs_specop_p, puffs_specop_entries };
214
215
216 int (**puffs_fifoop_p)(void *);
217 const struct vnodeopv_entry_desc puffs_fifoop_entries[] = {
218 { &vop_default_desc, vn_default_error },
219 { &vop_lookup_desc, fifo_lookup }, /* lookup, ENOTDIR */
220 { &vop_create_desc, fifo_create }, /* genfs_badop */
221 { &vop_mknod_desc, fifo_mknod }, /* genfs_badop */
222 { &vop_open_desc, fifo_open }, /* open */
223 { &vop_close_desc, fifo_close }, /* close */
224 { &vop_access_desc, puffs_checkop }, /* access */
225 { &vop_getattr_desc, puffs_checkop }, /* getattr */
226 { &vop_setattr_desc, puffs_checkop }, /* setattr */
227 { &vop_read_desc, puffs_fifo_read }, /* read, update */
228 { &vop_write_desc, puffs_fifo_write }, /* write, update */
229 { &vop_lease_desc, fifo_lease_check }, /* genfs_nullop */
230 { &vop_ioctl_desc, fifo_ioctl }, /* ioctl */
231 { &vop_fcntl_desc, genfs_fcntl }, /* dummy */
232 { &vop_poll_desc, fifo_poll }, /* poll */
233 { &vop_kqfilter_desc, fifo_kqfilter }, /* kqfilter */
234 { &vop_revoke_desc, fifo_revoke }, /* genfs_revoke */
235 { &vop_mmap_desc, fifo_mmap }, /* genfs_badop */
236 { &vop_fsync_desc, fifo_fsync }, /* genfs_nullop*/
237 { &vop_seek_desc, fifo_seek }, /* genfs_badop */
238 { &vop_remove_desc, fifo_remove }, /* genfs_badop */
239 { &vop_link_desc, fifo_link }, /* genfs_badop */
240 { &vop_rename_desc, fifo_rename }, /* genfs_badop */
241 { &vop_mkdir_desc, fifo_mkdir }, /* genfs_badop */
242 { &vop_rmdir_desc, fifo_rmdir }, /* genfs_badop */
243 { &vop_symlink_desc, fifo_symlink }, /* genfs_badop */
244 { &vop_readdir_desc, fifo_readdir }, /* genfs_badop */
245 { &vop_readlink_desc, fifo_readlink }, /* genfs_badop */
246 { &vop_abortop_desc, fifo_abortop }, /* genfs_badop */
247 { &vop_inactive_desc, puffs_inactive }, /* REAL inactive */
248 { &vop_reclaim_desc, puffs_reclaim }, /* REAL reclaim */
249 { &vop_lock_desc, puffs_lock }, /* REAL lock */
250 { &vop_unlock_desc, puffs_unlock }, /* REAL unlock */
251 { &vop_bmap_desc, fifo_bmap }, /* dummy */
252 { &vop_strategy_desc, fifo_strategy }, /* genfs_badop */
253 { &vop_print_desc, puffs_print }, /* REAL print */
254 { &vop_islocked_desc, puffs_islocked }, /* REAL islocked */
255 { &vop_pathconf_desc, fifo_pathconf }, /* pathconf */
256 { &vop_advlock_desc, fifo_advlock }, /* genfs_einval */
257 { &vop_bwrite_desc, vn_bwrite }, /* bwrite */
258 { &vop_putpages_desc, fifo_putpages }, /* genfs_null_putpages*/
259 #if 0
260 { &vop_openextattr_desc, _openextattr }, /* openextattr */
261 { &vop_closeextattr_desc, _closeextattr }, /* closeextattr */
262 { &vop_getextattr_desc, _getextattr }, /* getextattr */
263 { &vop_setextattr_desc, _setextattr }, /* setextattr */
264 { &vop_listextattr_desc, _listextattr }, /* listextattr */
265 { &vop_deleteextattr_desc, _deleteextattr }, /* deleteextattr */
266 #endif
267 { NULL, NULL }
268 };
269 const struct vnodeopv_desc puffs_fifoop_opv_desc =
270 { &puffs_fifoop_p, puffs_fifoop_entries };
271
272
273 /* "real" vnode operations */
274 int (**puffs_msgop_p)(void *);
275 const struct vnodeopv_entry_desc puffs_msgop_entries[] = {
276 { &vop_default_desc, vn_default_error },
277 { &vop_create_desc, puffs_create }, /* create */
278 { &vop_mknod_desc, puffs_mknod }, /* mknod */
279 { &vop_open_desc, puffs_open }, /* open */
280 { &vop_close_desc, puffs_close }, /* close */
281 { &vop_access_desc, puffs_access }, /* access */
282 { &vop_getattr_desc, puffs_getattr }, /* getattr */
283 { &vop_setattr_desc, puffs_setattr }, /* setattr */
284 { &vop_read_desc, puffs_read }, /* read */
285 { &vop_write_desc, puffs_write }, /* write */
286 { &vop_fcntl_desc, puffs_fcntl }, /* fcntl */
287 { &vop_ioctl_desc, puffs_ioctl }, /* ioctl */
288 { &vop_seek_desc, puffs_seek }, /* seek */
289 { &vop_remove_desc, puffs_remove }, /* remove */
290 { &vop_link_desc, puffs_link }, /* link */
291 { &vop_rename_desc, puffs_rename }, /* rename */
292 { &vop_mkdir_desc, puffs_mkdir }, /* mkdir */
293 { &vop_rmdir_desc, puffs_rmdir }, /* rmdir */
294 { &vop_symlink_desc, puffs_symlink }, /* symlink */
295 { &vop_readdir_desc, puffs_readdir }, /* readdir */
296 { &vop_readlink_desc, puffs_readlink }, /* readlink */
297 { &vop_print_desc, puffs_print }, /* print */
298 { &vop_islocked_desc, puffs_islocked }, /* islocked */
299 { &vop_pathconf_desc, puffs_pathconf }, /* pathconf */
300 { &vop_advlock_desc, puffs_advlock }, /* advlock */
301 { &vop_getpages_desc, puffs_getpages }, /* getpages */
302 { NULL, NULL }
303 };
304 const struct vnodeopv_desc puffs_msgop_opv_desc =
305 { &puffs_msgop_p, puffs_msgop_entries };
306
307
308 #define LOCKEDVP(a) (VOP_ISLOCKED(a) ? (a) : NULL)
309
310
311 /*
312 * This is a generic vnode operation handler. It checks if the necessary
313 * operations for the called vnode operation are implemented by userspace
314 * and either returns a dummy return value or proceeds to call the real
315 * vnode operation from puffs_msgop_v.
316 *
317 * XXX: this should described elsewhere and autogenerated, the complexity
318 * of the vnode operations vectors and their interrelationships is also
319 * getting a bit out of hand. Another problem is that we need this same
320 * information in the fs server code, so keeping the two in sync manually
321 * is not a viable (long term) plan.
322 */
323
324 /* not supported, handle locking protocol */
325 #define CHECKOP_NOTSUPP(op) \
326 case VOP_##op##_DESCOFFSET: \
327 if (pmp->pmp_vnopmask[PUFFS_VN_##op] == 0) \
328 return genfs_eopnotsupp(v); \
329 break
330
331 /* always succeed, no locking */
332 #define CHECKOP_SUCCESS(op) \
333 case VOP_##op##_DESCOFFSET: \
334 if (pmp->pmp_vnopmask[PUFFS_VN_##op] == 0) \
335 return 0; \
336 break
337
338 int
339 puffs_checkop(void *v)
340 {
341 struct vop_generic_args /* {
342 struct vnodeop_desc *a_desc;
343 spooky mystery contents;
344 } */ *ap = v;
345 struct vnodeop_desc *desc = ap->a_desc;
346 struct puffs_mount *pmp;
347 struct vnode *vp;
348 int offset;
349
350 DPRINTF_VERBOSE(("checkop call %s (%d)\n",
351 ap->a_desc->vdesc_name, ap->a_desc->vdesc_offset));
352
353 offset = ap->a_desc->vdesc_vp_offsets[0];
354 #ifdef DIAGNOSTIC
355 if (offset == VDESC_NO_OFFSET)
356 panic("puffs_checkop: no vnode, why did you call me?");
357 #endif
358 vp = *VOPARG_OFFSETTO(struct vnode **, offset, ap);
359 pmp = MPTOPUFFSMP(vp->v_mount);
360
361 if ((pmp->pmp_flags & PUFFS_KFLAG_ALLOPS) == 0) {
362 switch (desc->vdesc_offset) {
363 CHECKOP_NOTSUPP(CREATE);
364 CHECKOP_NOTSUPP(MKNOD);
365 CHECKOP_NOTSUPP(GETATTR);
366 CHECKOP_NOTSUPP(SETATTR);
367 CHECKOP_NOTSUPP(READ);
368 CHECKOP_NOTSUPP(WRITE);
369 CHECKOP_NOTSUPP(FCNTL);
370 CHECKOP_NOTSUPP(IOCTL);
371 CHECKOP_NOTSUPP(REMOVE);
372 CHECKOP_NOTSUPP(LINK);
373 CHECKOP_NOTSUPP(RENAME);
374 CHECKOP_NOTSUPP(MKDIR);
375 CHECKOP_NOTSUPP(RMDIR);
376 CHECKOP_NOTSUPP(SYMLINK);
377 CHECKOP_NOTSUPP(READDIR);
378 CHECKOP_NOTSUPP(READLINK);
379 CHECKOP_NOTSUPP(PRINT);
380 CHECKOP_NOTSUPP(PATHCONF);
381 CHECKOP_NOTSUPP(ADVLOCK);
382
383 CHECKOP_SUCCESS(ACCESS);
384 CHECKOP_SUCCESS(CLOSE);
385 CHECKOP_SUCCESS(SEEK);
386
387 case VOP_GETPAGES_DESCOFFSET:
388 if (!EXISTSOP(pmp, READ))
389 return genfs_eopnotsupp(v);
390 break;
391
392 default:
393 panic("puffs_checkop: unhandled vnop %d",
394 desc->vdesc_offset);
395 }
396 }
397
398 return VOCALL(puffs_msgop_p, ap->a_desc->vdesc_offset, v);
399 }
400
401
402 int
403 puffs_lookup(void *v)
404 {
405 struct vop_lookup_args /* {
406 const struct vnodeop_desc *a_desc;
407 struct vnode *a_dvp;
408 struct vnode **a_vpp;
409 struct componentname *a_cnp;
410 } */ *ap = v;
411 struct puffs_mount *pmp;
412 struct componentname *cnp;
413 struct vnode *vp, *dvp;
414 struct puffs_node *dpn;
415 int isdot;
416 int error;
417
418 PUFFS_VNREQ(lookup);
419
420 pmp = MPTOPUFFSMP(ap->a_dvp->v_mount);
421 cnp = ap->a_cnp;
422 dvp = ap->a_dvp;
423 *ap->a_vpp = NULL;
424
425 /* first things first: check access */
426 error = VOP_ACCESS(dvp, VEXEC, cnp->cn_cred, cnp->cn_lwp);
427 if (error)
428 return error;
429
430 isdot = cnp->cn_namelen == 1 && *cnp->cn_nameptr == '.';
431
432 DPRINTF(("puffs_lookup: \"%s\", parent vnode %p, op: %lx\n",
433 cnp->cn_nameptr, dvp, cnp->cn_nameiop));
434
435 /*
436 * Check if someone fed it into the cache
437 */
438 if (PUFFS_DOCACHE(pmp)) {
439 error = cache_lookup(dvp, ap->a_vpp, cnp);
440
441 if (error >= 0)
442 return error;
443 }
444
445 if (isdot) {
446 vp = ap->a_dvp;
447 vref(vp);
448 *ap->a_vpp = vp;
449 return 0;
450 }
451
452 puffs_makecn(&lookup_arg.pvnr_cn, cnp);
453
454 if (cnp->cn_flags & ISDOTDOT)
455 VOP_UNLOCK(dvp, 0);
456
457 error = puffs_vntouser(pmp, PUFFS_VN_LOOKUP,
458 &lookup_arg, sizeof(lookup_arg), VPTOPNC(dvp), LOCKEDVP(dvp), NULL);
459 DPRINTF(("puffs_lookup: return of the userspace, part %d\n", error));
460
461 /*
462 * In case of error, there is no new vnode to play with, so be
463 * happy with the NULL value given to vpp in the beginning.
464 * Also, check if this really was an error or the target was not
465 * present. Either treat it as a non-error for CREATE/RENAME or
466 * enter the component into the negative name cache (if desired).
467 */
468 if (error) {
469 if (error == ENOENT) {
470 if ((cnp->cn_flags & ISLASTCN)
471 && (cnp->cn_nameiop == CREATE
472 || cnp->cn_nameiop == RENAME)) {
473 cnp->cn_flags |= SAVENAME;
474 error = EJUSTRETURN;
475 } else {
476 if ((cnp->cn_flags & MAKEENTRY)
477 && PUFFS_DOCACHE(pmp))
478 cache_enter(dvp, NULL, cnp);
479 }
480 } else if (error < 0) {
481 error = EINVAL;
482 }
483 goto errout;
484 }
485
486 /*
487 * Check that we don't get our parent node back, that would cause
488 * a pretty obvious deadlock.
489 */
490 dpn = dvp->v_data;
491 if (lookup_arg.pvnr_newnode == dpn->pn_cookie) {
492 error = EINVAL;
493 goto errout;
494 }
495
496 /* XXX: race here */
497 /* XXX2: this check for node existence twice */
498 vp = puffs_pnode2vnode(pmp, lookup_arg.pvnr_newnode, 1);
499 if (!vp) {
500 error = puffs_getvnode(dvp->v_mount,
501 lookup_arg.pvnr_newnode, lookup_arg.pvnr_vtype,
502 lookup_arg.pvnr_size, lookup_arg.pvnr_rdev, &vp);
503 if (error) {
504 goto errout;
505 }
506 vn_lock(vp, LK_EXCLUSIVE | LK_RETRY);
507 }
508 *ap->a_vpp = vp;
509
510 if ((cnp->cn_flags & MAKEENTRY) != 0 && PUFFS_DOCACHE(pmp))
511 cache_enter(dvp, vp, cnp);
512
513 errout:
514 if (cnp->cn_flags & ISDOTDOT)
515 vn_lock(dvp, LK_EXCLUSIVE | LK_RETRY);
516
517 DPRINTF(("puffs_lookup: returning %d %p\n", error, *ap->a_vpp));
518 return error;
519 }
520
521 int
522 puffs_create(void *v)
523 {
524 struct vop_create_args /* {
525 const struct vnodeop_desc *a_desc;
526 struct vnode *a_dvp;
527 struct vnode **a_vpp;
528 struct componentname *a_cnp;
529 struct vattr *a_vap;
530 } */ *ap = v;
531 int error;
532
533 PUFFS_VNREQ(create);
534 DPRINTF(("puffs_create: dvp %p, cnp: %s\n",
535 ap->a_dvp, ap->a_cnp->cn_nameptr));
536
537 puffs_makecn(&create_arg.pvnr_cn, ap->a_cnp);
538 create_arg.pvnr_va = *ap->a_vap;
539
540 error = puffs_vntouser(MPTOPUFFSMP(ap->a_dvp->v_mount), PUFFS_VN_CREATE,
541 &create_arg, sizeof(create_arg), VPTOPNC(ap->a_dvp),
542 ap->a_dvp, NULL);
543 if (error)
544 goto out;
545
546 error = puffs_newnode(ap->a_dvp->v_mount, ap->a_dvp, ap->a_vpp,
547 create_arg.pvnr_newnode, ap->a_cnp, ap->a_vap->va_type, 0);
548 /* XXX: in case of error, need to uncommit userspace transaction */
549
550 out:
551 if (error || (ap->a_cnp->cn_flags & SAVESTART) == 0)
552 PNBUF_PUT(ap->a_cnp->cn_pnbuf);
553 vput(ap->a_dvp);
554
555 DPRINTF(("puffs_create: return %d\n", error));
556 return error;
557 }
558
559 int
560 puffs_mknod(void *v)
561 {
562 struct vop_mknod_args /* {
563 const struct vnodeop_desc *a_desc;
564 struct vnode *a_dvp;
565 struct vnode **a_vpp;
566 struct componentname *a_cnp;
567 struct vattr *a_vap;
568 } */ *ap = v;
569 int error;
570
571 PUFFS_VNREQ(mknod);
572
573 puffs_makecn(&mknod_arg.pvnr_cn, ap->a_cnp);
574 mknod_arg.pvnr_va = *ap->a_vap;
575
576 error = puffs_vntouser(MPTOPUFFSMP(ap->a_dvp->v_mount), PUFFS_VN_MKNOD,
577 &mknod_arg, sizeof(mknod_arg), VPTOPNC(ap->a_dvp), ap->a_dvp, NULL);
578 if (error)
579 goto out;
580
581 error = puffs_newnode(ap->a_dvp->v_mount, ap->a_dvp, ap->a_vpp,
582 mknod_arg.pvnr_newnode, ap->a_cnp, ap->a_vap->va_type,
583 ap->a_vap->va_rdev);
584
585 out:
586 if (error || (ap->a_cnp->cn_flags & SAVESTART) == 0)
587 PNBUF_PUT(ap->a_cnp->cn_pnbuf);
588 vput(ap->a_dvp);
589 return error;
590 }
591
592 int
593 puffs_open(void *v)
594 {
595 struct vop_open_args /* {
596 const struct vnodeop_desc *a_desc;
597 struct vnode *a_vp;
598 int a_mode;
599 kauth_cred_t a_cred;
600 struct lwp *a_l;
601 } */ *ap = v;
602 struct vnode *vp = ap->a_vp;
603 struct puffs_mount *pmp = MPTOPUFFSMP(vp->v_mount);
604 int mode = ap->a_mode;
605 int rv;
606
607 PUFFS_VNREQ(open);
608 DPRINTF(("puffs_open: vp %p, mode 0x%x\n", vp, mode));
609
610 if (vp->v_type == VREG && mode & FWRITE && !EXISTSOP(pmp, WRITE)) {
611 rv = EROFS;
612 goto out;
613 }
614
615 if (!EXISTSOP(pmp, OPEN)) {
616 rv = 0;
617 goto out;
618 }
619
620 open_arg.pvnr_mode = mode;
621 puffs_credcvt(&open_arg.pvnr_cred, ap->a_cred);
622 open_arg.pvnr_pid = puffs_lwp2pid(ap->a_l);
623
624 rv = puffs_vntouser(MPTOPUFFSMP(vp->v_mount), PUFFS_VN_OPEN,
625 &open_arg, sizeof(open_arg), VPTOPNC(vp), vp, NULL);
626
627 out:
628 DPRINTF(("puffs_open: returning %d\n", rv));
629 return rv;
630 }
631
632 int
633 puffs_close(void *v)
634 {
635 struct vop_close_args /* {
636 const struct vnodeop_desc *a_desc;
637 struct vnode *a_vp;
638 int a_fflag;
639 kauth_cred_t a_cred;
640 struct lwp *a_l;
641 } */ *ap = v;
642
643 PUFFS_VNREQ(close);
644
645 close_arg.pvnr_fflag = ap->a_fflag;
646 puffs_credcvt(&close_arg.pvnr_cred, ap->a_cred);
647 close_arg.pvnr_pid = puffs_lwp2pid(ap->a_l);
648
649 return puffs_vntouser(MPTOPUFFSMP(ap->a_vp->v_mount), PUFFS_VN_CLOSE,
650 &close_arg, sizeof(close_arg), VPTOPNC(ap->a_vp), ap->a_vp, NULL);
651 }
652
653 int
654 puffs_access(void *v)
655 {
656 struct vop_access_args /* {
657 const struct vnodeop_desc *a_desc;
658 struct vnode *a_vp;
659 int a_mode;
660 kauth_cred_t a_cred;
661 struct lwp *a_l;
662 } */ *ap = v;
663 struct vnode *vp = ap->a_vp;
664 struct puffs_mount *pmp = MPTOPUFFSMP(vp->v_mount);
665 int mode = ap->a_mode;
666
667 PUFFS_VNREQ(access);
668
669 if (vp->v_type == VREG && mode & VWRITE && !EXISTSOP(pmp, WRITE))
670 return EROFS;
671
672 if (!EXISTSOP(pmp, ACCESS))
673 return 0;
674
675 access_arg.pvnr_mode = ap->a_mode;
676 access_arg.pvnr_pid = puffs_lwp2pid(ap->a_l);
677 puffs_credcvt(&access_arg.pvnr_cred, ap->a_cred);
678
679 return puffs_vntouser(MPTOPUFFSMP(vp->v_mount), PUFFS_VN_ACCESS,
680 &access_arg, sizeof(access_arg), VPTOPNC(vp), vp, NULL);
681 }
682
683 int
684 puffs_getattr(void *v)
685 {
686 struct vop_getattr_args /* {
687 const struct vnodeop_desc *a_desc;
688 struct vnode *a_vp;
689 struct vattr *a_vap;
690 kauth_cred_t a_cred;
691 struct lwp *a_l;
692 } */ *ap = v;
693 struct mount *mp;
694 struct vnode *vp;
695 struct vattr *vap;
696 struct puffs_node *pn;
697 int error;
698
699 PUFFS_VNREQ(getattr);
700
701 vp = ap->a_vp;
702 mp = vp->v_mount;
703 vap = ap->a_vap;
704
705 vattr_null(&getattr_arg.pvnr_va);
706 puffs_credcvt(&getattr_arg.pvnr_cred, ap->a_cred);
707 getattr_arg.pvnr_pid = puffs_lwp2pid(ap->a_l);
708
709 /*
710 * XXX + XX (dos equis): this can't go through the unlock/lock
711 * cycle, since it can be called from uvn_attach(), which fiddles
712 * around with VXLOCK and therefore breaks vn_lock(). Proper
713 * fix pending.
714 */
715 error = puffs_vntouser(MPTOPUFFSMP(vp->v_mount), PUFFS_VN_GETATTR,
716 &getattr_arg, sizeof(getattr_arg), VPTOPNC(vp),
717 NULL /* XXXseeabove: should be LOCKEDVP(vp) */, NULL);
718 if (error)
719 return error;
720
721 (void) memcpy(vap, &getattr_arg.pvnr_va, sizeof(struct vattr));
722 vap->va_fsid = mp->mnt_stat.f_fsidx.__fsid_val[0];
723
724 pn = VPTOPP(vp);
725 if (pn->pn_stat & PNODE_METACACHE_ATIME)
726 vap->va_atime = pn->pn_mc_atime;
727 if (pn->pn_stat & PNODE_METACACHE_CTIME)
728 vap->va_ctime = pn->pn_mc_ctime;
729 if (pn->pn_stat & PNODE_METACACHE_MTIME)
730 vap->va_mtime = pn->pn_mc_mtime;
731 if (pn->pn_stat & PNODE_METACACHE_SIZE) {
732 vap->va_size = pn->pn_mc_size;
733 } else {
734 if (getattr_arg.pvnr_va.va_size != VNOVAL)
735 uvm_vnp_setsize(vp, getattr_arg.pvnr_va.va_size);
736 }
737
738 return 0;
739 }
740
741 int
742 puffs_setattr(void *v)
743 {
744 struct vop_getattr_args /* {
745 const struct vnodeop_desc *a_desc;
746 struct vnode *a_vp;
747 struct vattr *a_vap;
748 kauth_cred_t a_cred;
749 struct lwp *a_l;
750 } */ *ap = v;
751 int error;
752
753 PUFFS_VNREQ(setattr);
754
755 (void)memcpy(&setattr_arg.pvnr_va, ap->a_vap, sizeof(struct vattr));
756 puffs_credcvt(&setattr_arg.pvnr_cred, ap->a_cred);
757 setattr_arg.pvnr_pid = puffs_lwp2pid(ap->a_l);
758
759 error = puffs_vntouser(MPTOPUFFSMP(ap->a_vp->v_mount), PUFFS_VN_SETATTR,
760 &setattr_arg, sizeof(setattr_arg), VPTOPNC(ap->a_vp),
761 ap->a_vp, NULL);
762 if (error)
763 return error;
764
765 if (ap->a_vap->va_size != VNOVAL)
766 uvm_vnp_setsize(ap->a_vp, ap->a_vap->va_size);
767
768 return 0;
769 }
770
771 int
772 puffs_inactive(void *v)
773 {
774 struct vop_inactive_args /* {
775 const struct vnodeop_desc *a_desc;
776 struct vnode *a_vp;
777 struct lwp *a_l;
778 } */ *ap = v;
779 struct puffs_mount *pmp;
780 struct puffs_node *pnode;
781 int rv, vnrefs;
782
783 PUFFS_VNREQ(inactive);
784
785 /*
786 * XXX: think about this after we really start unlocking
787 * when going to userspace
788 */
789 pnode = ap->a_vp->v_data;
790
791 pmp = MPTOPUFFSMP(ap->a_vp->v_mount);
792
793 inactive_arg.pvnr_pid = puffs_lwp2pid(ap->a_l);
794
795 if (EXISTSOP(pmp, INACTIVE))
796 rv = puffs_vntouser(pmp, PUFFS_VN_INACTIVE,
797 &inactive_arg, sizeof(inactive_arg), VPTOPNC(ap->a_vp),
798 ap->a_vp, NULL);
799 else
800 rv = 1; /* see below */
801
802 /* can't trust userspace return value? simulate safe answer */
803 if (rv)
804 vnrefs = 1;
805 else
806 vnrefs = inactive_arg.pvnr_backendrefs;
807
808 VOP_UNLOCK(ap->a_vp, 0);
809
810 /*
811 * user server thinks it's gone? then don't be afraid care,
812 * node's life was already all it would ever be
813 */
814 if (vnrefs == 0) {
815 pnode->pn_stat |= PNODE_NOREFS;
816 vrecycle(ap->a_vp, NULL, ap->a_l);
817 }
818
819 return 0;
820 }
821
822 /*
823 * always FAF, we don't really care if the server wants to fail to
824 * reclaim the node or not
825 */
826 int
827 puffs_reclaim(void *v)
828 {
829 struct vop_reclaim_args /* {
830 const struct vnodeop_desc *a_desc;
831 struct vnode *a_vp;
832 struct lwp *a_l;
833 } */ *ap = v;
834 struct puffs_mount *pmp;
835 struct puffs_vnreq_reclaim *reclaim_argp;
836
837 pmp = MPTOPUFFSMP(ap->a_vp->v_mount);
838
839 /*
840 * first things first: check if someone is trying to reclaim the
841 * root vnode. do not allow that to travel to userspace.
842 * Note that we don't need to take the lock similarly to
843 * puffs_root(), since there is only one of us.
844 */
845 if (ap->a_vp->v_flag & VROOT) {
846 mutex_enter(&pmp->pmp_lock);
847 KASSERT(pmp->pmp_root != NULL);
848 pmp->pmp_root = NULL;
849 mutex_exit(&pmp->pmp_lock);
850 goto out;
851 }
852
853 if (!EXISTSOP(pmp, RECLAIM))
854 goto out;
855
856 reclaim_argp = malloc(sizeof(struct puffs_vnreq_reclaim),
857 M_PUFFS, M_WAITOK | M_ZERO);
858 reclaim_argp->pvnr_pid = puffs_lwp2pid(ap->a_l);
859
860 puffs_vntouser_faf(pmp, PUFFS_VN_RECLAIM,
861 reclaim_argp, sizeof(struct puffs_vnreq_reclaim),
862 VPTOPNC(ap->a_vp));
863
864 out:
865 if (PUFFS_DOCACHE(pmp))
866 cache_purge(ap->a_vp);
867 puffs_putvnode(ap->a_vp);
868
869 return 0;
870 }
871
872 int
873 puffs_readdir(void *v)
874 {
875 struct vop_readdir_args /* {
876 const struct vnodeop_desc *a_desc;
877 struct vnode *a_vp;
878 struct uio *a_uio;
879 kauth_cred_t a_cred;
880 int *a_eofflag;
881 off_t **a_cookies;
882 int *a_ncookies;
883 } */ *ap = v;
884 struct puffs_vnreq_readdir *readdir_argp;
885 size_t argsize;
886 struct uio *uio = ap->a_uio;
887 size_t howmuch;
888 int error;
889
890 /* worry about these later */
891 if (!(ap->a_cookies == NULL && ap->a_ncookies == NULL))
892 return EOPNOTSUPP;
893
894 argsize = sizeof(struct puffs_vnreq_readdir) + uio->uio_resid;
895 readdir_argp = malloc(argsize, M_PUFFS, M_ZERO | M_WAITOK);
896
897 puffs_credcvt(&readdir_argp->pvnr_cred, ap->a_cred);
898 readdir_argp->pvnr_offset = uio->uio_offset;
899 readdir_argp->pvnr_resid = uio->uio_resid;
900
901 error = puffs_vntouser_delta(MPTOPUFFSMP(ap->a_vp->v_mount),
902 PUFFS_VN_READDIR, readdir_argp, argsize,
903 uio->uio_resid, VPTOPNC(ap->a_vp), ap->a_vp, NULL);
904 if (error)
905 goto out;
906
907 /* userspace is cheating? */
908 if (readdir_argp->pvnr_resid > uio->uio_resid) {
909 error = EINVAL;
910 goto out;
911 }
912
913 /* bouncy-wouncy with the directory data */
914 howmuch = uio->uio_resid - readdir_argp->pvnr_resid;
915 /* XXX: we could let userlandia tell its opinion first time 'round */
916 if (howmuch == 0) {
917 *ap->a_eofflag = 1;
918 goto out;
919 }
920 error = uiomove(readdir_argp->pvnr_dent, howmuch, uio);
921 if (error)
922 goto out;
923 uio->uio_offset = readdir_argp->pvnr_offset;
924
925 out:
926 free(readdir_argp, M_PUFFS);
927 return error;
928 }
929
930 int
931 puffs_poll(void *v)
932 {
933 struct vop_poll_args /* {
934 const struct vnodeop_desc *a_desc;
935 struct vnode *a_vp;
936 int a_events;
937 struct lwp *a_l;
938 }*/ *ap = v;
939
940 PUFFS_VNREQ(poll);
941
942 poll_arg.pvnr_events = ap->a_events;
943 poll_arg.pvnr_pid = puffs_lwp2pid(ap->a_l);
944
945 return puffs_vntouser(MPTOPUFFSMP(ap->a_vp->v_mount), PUFFS_VN_POLL,
946 &poll_arg, sizeof(poll_arg), VPTOPNC(ap->a_vp), NULL, NULL);
947 }
948
949 int
950 puffs_fsync(void *v)
951 {
952 struct vop_fsync_args /* {
953 const struct vnodeop_desc *a_desc;
954 struct vnode *a_vp;
955 kauth_cred_t a_cred;
956 int a_flags;
957 off_t a_offlo;
958 off_t a_offhi;
959 struct lwp *a_l;
960 } */ *ap = v;
961 struct vattr va;
962 struct puffs_mount *pmp;
963 struct puffs_vnreq_fsync *fsync_argp;
964 struct vnode *vp;
965 struct puffs_node *pn;
966 int pflags, error, dofaf;
967
968 PUFFS_VNREQ(fsync);
969
970 vp = ap->a_vp;
971 pn = VPTOPP(vp);
972 pmp = MPTOPUFFSMP(vp->v_mount);
973
974 /* flush out information from our metacache */
975 if (pn->pn_stat & PNODE_METACACHE_MASK) {
976 vattr_null(&va);
977 if (pn->pn_stat & PNODE_METACACHE_ATIME)
978 va.va_atime = pn->pn_mc_atime;
979 if (pn->pn_stat & PNODE_METACACHE_CTIME)
980 va.va_ctime = pn->pn_mc_ctime;
981 if (pn->pn_stat & PNODE_METACACHE_MTIME)
982 va.va_mtime = pn->pn_mc_ctime;
983 if (pn->pn_stat & PNODE_METACACHE_SIZE)
984 va.va_size = pn->pn_mc_size;
985
986 error = VOP_SETATTR(vp, &va, FSCRED, NULL);
987 if (error)
988 return error;
989
990 pn->pn_stat &= ~PNODE_METACACHE_MASK;
991 }
992
993 /*
994 * flush pages to avoid being overly dirty
995 */
996 pflags = PGO_CLEANIT;
997 if (ap->a_flags & FSYNC_WAIT)
998 pflags |= PGO_SYNCIO;
999 simple_lock(&vp->v_interlock);
1000 error = VOP_PUTPAGES(vp, trunc_page(ap->a_offlo),
1001 round_page(ap->a_offhi), pflags);
1002 if (error)
1003 return error;
1004
1005 /*
1006 * HELLO! We exit already here if the user server does not
1007 * support fsync OR if we should call fsync for a node which
1008 * has references neither in the kernel or the fs server.
1009 * Otherwise we continue to issue fsync() forward.
1010 */
1011 if (!EXISTSOP(pmp, FSYNC) || (pn->pn_stat & PNODE_NOREFS))
1012 return 0;
1013
1014 dofaf = (ap->a_flags & FSYNC_WAIT) == 0 || ap->a_flags == FSYNC_LAZY;
1015 /*
1016 * We abuse VXLOCK to mean "vnode is going to die", so we issue
1017 * only FAFs for those. Otherwise there's a danger of deadlock,
1018 * since the execution context here might be the user server
1019 * doing some operation on another fs, which in turn caused a
1020 * vnode to be reclaimed from the freelist for this fs.
1021 */
1022 if (dofaf == 0) {
1023 simple_lock(&vp->v_interlock);
1024 if (vp->v_flag & VXLOCK)
1025 dofaf = 1;
1026 simple_unlock(&vp->v_interlock);
1027 }
1028
1029 if (dofaf == 0) {
1030 fsync_argp = &fsync_arg;
1031 } else {
1032 fsync_argp = malloc(sizeof(struct puffs_vnreq_fsync),
1033 M_PUFFS, M_ZERO | M_NOWAIT);
1034 if (fsync_argp == NULL)
1035 return ENOMEM;
1036 }
1037
1038 puffs_credcvt(&fsync_argp->pvnr_cred, ap->a_cred);
1039 fsync_argp->pvnr_flags = ap->a_flags;
1040 fsync_argp->pvnr_offlo = ap->a_offlo;
1041 fsync_argp->pvnr_offhi = ap->a_offhi;
1042 fsync_argp->pvnr_pid = puffs_lwp2pid(ap->a_l);
1043
1044 /*
1045 * XXX: see comment at puffs_getattr about locking
1046 *
1047 * If we are not required to wait, do a FAF operation.
1048 * Otherwise block here.
1049 */
1050 if (dofaf == 0) {
1051 error = puffs_vntouser(MPTOPUFFSMP(vp->v_mount),
1052 PUFFS_VN_FSYNC, fsync_argp, sizeof(*fsync_argp),
1053 VPTOPNC(vp), NULL /* XXXshouldbe: vp */, NULL);
1054 } else {
1055 /* FAF is always "succesful" */
1056 error = 0;
1057 puffs_vntouser_faf(MPTOPUFFSMP(vp->v_mount),
1058 PUFFS_VN_FSYNC, fsync_argp, sizeof(*fsync_argp),
1059 VPTOPNC(vp));
1060 }
1061
1062 return error;
1063 }
1064
1065 int
1066 puffs_seek(void *v)
1067 {
1068 struct vop_seek_args /* {
1069 const struct vnodeop_desc *a_desc;
1070 struct vnode *a_vp;
1071 off_t a_oldoff;
1072 off_t a_newoff;
1073 kauth_cred_t a_cred;
1074 } */ *ap = v;
1075
1076 PUFFS_VNREQ(seek);
1077
1078 seek_arg.pvnr_oldoff = ap->a_oldoff;
1079 seek_arg.pvnr_newoff = ap->a_newoff;
1080 puffs_credcvt(&seek_arg.pvnr_cred, ap->a_cred);
1081
1082 /*
1083 * XXX: seems like seek is called with an unlocked vp, but
1084 * it can't hurt to play safe
1085 */
1086 return puffs_vntouser(MPTOPUFFSMP(ap->a_vp->v_mount), PUFFS_VN_SEEK,
1087 &seek_arg, sizeof(seek_arg), VPTOPNC(ap->a_vp),
1088 LOCKEDVP(ap->a_vp), NULL);
1089 }
1090
1091 int
1092 puffs_remove(void *v)
1093 {
1094 struct vop_remove_args /* {
1095 const struct vnodeop_desc *a_desc;
1096 struct vnode *a_dvp;
1097 struct vnode *a_vp;
1098 struct componentname *a_cnp;
1099 } */ *ap = v;
1100 int error;
1101
1102 PUFFS_VNREQ(remove);
1103
1104 remove_arg.pvnr_cookie_targ = VPTOPNC(ap->a_vp);
1105 puffs_makecn(&remove_arg.pvnr_cn, ap->a_cnp);
1106
1107 error = puffs_vntouser(MPTOPUFFSMP(ap->a_vp->v_mount), PUFFS_VN_REMOVE,
1108 &remove_arg, sizeof(remove_arg), VPTOPNC(ap->a_dvp),
1109 ap->a_dvp, ap->a_vp);
1110
1111 vput(ap->a_vp);
1112 if (ap->a_dvp == ap->a_vp)
1113 vrele(ap->a_dvp);
1114 else
1115 vput(ap->a_dvp);
1116
1117 return error;
1118 }
1119
1120 int
1121 puffs_mkdir(void *v)
1122 {
1123 struct vop_mkdir_args /* {
1124 const struct vnodeop_desc *a_desc;
1125 struct vnode *a_dvp;
1126 struct vnode **a_vpp;
1127 struct componentname *a_cnp;
1128 struct vattr *a_vap;
1129 } */ *ap = v;
1130 int error;
1131
1132 PUFFS_VNREQ(mkdir);
1133
1134 puffs_makecn(&mkdir_arg.pvnr_cn, ap->a_cnp);
1135 mkdir_arg.pvnr_va = *ap->a_vap;
1136
1137 /* XXX: wouldn't need to relock dvp, but that's life */
1138 error = puffs_vntouser(MPTOPUFFSMP(ap->a_dvp->v_mount), PUFFS_VN_MKDIR,
1139 &mkdir_arg, sizeof(mkdir_arg), VPTOPNC(ap->a_dvp), ap->a_dvp, NULL);
1140 if (error)
1141 goto out;
1142
1143 error = puffs_newnode(ap->a_dvp->v_mount, ap->a_dvp, ap->a_vpp,
1144 mkdir_arg.pvnr_newnode, ap->a_cnp, VDIR, 0);
1145
1146 out:
1147 if (error || (ap->a_cnp->cn_flags & SAVESTART) == 0)
1148 PNBUF_PUT(ap->a_cnp->cn_pnbuf);
1149 vput(ap->a_dvp);
1150 return error;
1151 }
1152
1153 int
1154 puffs_rmdir(void *v)
1155 {
1156 struct vop_rmdir_args /* {
1157 const struct vnodeop_desc *a_desc;
1158 struct vnode *a_dvp;
1159 struct vnode *a_vp;
1160 struct componentname *a_cnp;
1161 } */ *ap = v;
1162 int error;
1163
1164 PUFFS_VNREQ(rmdir);
1165
1166 rmdir_arg.pvnr_cookie_targ = VPTOPNC(ap->a_vp);
1167 puffs_makecn(&rmdir_arg.pvnr_cn, ap->a_cnp);
1168
1169 error = puffs_vntouser(MPTOPUFFSMP(ap->a_dvp->v_mount), PUFFS_VN_RMDIR,
1170 &rmdir_arg, sizeof(rmdir_arg), VPTOPNC(ap->a_dvp),
1171 ap->a_dvp, ap->a_vp);
1172
1173 /* XXX: some call cache_purge() *for both vnodes* here, investigate */
1174
1175 vput(ap->a_dvp);
1176 vput(ap->a_vp);
1177
1178 return error;
1179 }
1180
1181 int
1182 puffs_link(void *v)
1183 {
1184 struct vop_link_args /* {
1185 const struct vnodeop_desc *a_desc;
1186 struct vnode *a_dvp;
1187 struct vnode *a_vp;
1188 struct componentname *a_cnp;
1189 }*/ *ap = v;
1190 int error;
1191
1192 PUFFS_VNREQ(link);
1193
1194 link_arg.pvnr_cookie_targ = VPTOPNC(ap->a_vp);
1195 puffs_makecn(&link_arg.pvnr_cn, ap->a_cnp);
1196
1197 error = puffs_vntouser(MPTOPUFFSMP(ap->a_dvp->v_mount), PUFFS_VN_LINK,
1198 &link_arg, sizeof(link_arg), VPTOPNC(ap->a_dvp), ap->a_dvp, NULL);
1199
1200 /*
1201 * XXX: stay in touch with the cache. I don't like this, but
1202 * don't have a better solution either. See also puffs_rename().
1203 */
1204 if (error == 0)
1205 puffs_updatenode(ap->a_vp, PUFFS_UPDATECTIME);
1206
1207 vput(ap->a_dvp);
1208
1209 return error;
1210 }
1211
1212 int
1213 puffs_symlink(void *v)
1214 {
1215 struct vop_symlink_args /* {
1216 const struct vnodeop_desc *a_desc;
1217 struct vnode *a_dvp;
1218 struct vnode **a_vpp;
1219 struct componentname *a_cnp;
1220 struct vattr *a_vap;
1221 char *a_target;
1222 }*/ *ap = v;
1223 int error;
1224
1225 PUFFS_VNREQ(symlink); /* XXX: large structure */
1226
1227 *ap->a_vpp = NULL;
1228
1229 puffs_makecn(&symlink_arg.pvnr_cn, ap->a_cnp);
1230 symlink_arg.pvnr_va = *ap->a_vap;
1231 (void)strlcpy(symlink_arg.pvnr_link, ap->a_target,
1232 sizeof(symlink_arg.pvnr_link));
1233
1234 /* XXX: don't need to relock parent */
1235 error = puffs_vntouser(MPTOPUFFSMP(ap->a_dvp->v_mount),
1236 PUFFS_VN_SYMLINK, &symlink_arg, sizeof(symlink_arg),
1237 VPTOPNC(ap->a_dvp), ap->a_dvp, NULL);
1238 if (error)
1239 goto out;
1240
1241 error = puffs_newnode(ap->a_dvp->v_mount, ap->a_dvp, ap->a_vpp,
1242 symlink_arg.pvnr_newnode, ap->a_cnp, VLNK, 0);
1243
1244 out:
1245 if (error || (ap->a_cnp->cn_flags & SAVESTART) == 0)
1246 PNBUF_PUT(ap->a_cnp->cn_pnbuf);
1247 vput(ap->a_dvp);
1248 return error;
1249 }
1250
1251 int
1252 puffs_readlink(void *v)
1253 {
1254 struct vop_readlink_args /* {
1255 const struct vnodeop_desc *a_desc;
1256 struct vnode *a_vp;
1257 struct uio *a_uio;
1258 kauth_cred_t a_cred;
1259 } */ *ap = v;
1260 size_t linklen;
1261 int error;
1262
1263 PUFFS_VNREQ(readlink);
1264
1265 puffs_credcvt(&readlink_arg.pvnr_cred, ap->a_cred);
1266 linklen = sizeof(readlink_arg.pvnr_link);
1267 readlink_arg.pvnr_linklen = linklen;
1268
1269 error = puffs_vntouser(MPTOPUFFSMP(ap->a_vp->v_mount),
1270 PUFFS_VN_READLINK, &readlink_arg, sizeof(readlink_arg),
1271 VPTOPNC(ap->a_vp), ap->a_vp, NULL);
1272 if (error)
1273 return error;
1274
1275 /* bad bad user file server */
1276 if (readlink_arg.pvnr_linklen > linklen)
1277 return EINVAL;
1278
1279 return uiomove(&readlink_arg.pvnr_link, readlink_arg.pvnr_linklen,
1280 ap->a_uio);
1281 }
1282
1283 /* XXXXXXX: think about locking & userspace op delocking... */
1284 int
1285 puffs_rename(void *v)
1286 {
1287 struct vop_rename_args /* {
1288 const struct vnodeop_desc *a_desc;
1289 struct vnode *a_fdvp;
1290 struct vnode *a_fvp;
1291 struct componentname *a_fcnp;
1292 struct vnode *a_tdvp;
1293 struct vnode *a_tvp;
1294 struct componentname *a_tcnp;
1295 }*/ *ap = v;
1296 int error;
1297
1298 PUFFS_VNREQ(rename);
1299
1300 if (ap->a_fvp->v_mount != ap->a_tdvp->v_mount) {
1301 error = EXDEV;
1302 goto out;
1303 }
1304
1305 rename_arg.pvnr_cookie_src = VPTOPNC(ap->a_fvp);
1306 rename_arg.pvnr_cookie_targdir = VPTOPNC(ap->a_tdvp);
1307 if (ap->a_tvp)
1308 rename_arg.pvnr_cookie_targ = VPTOPNC(ap->a_tvp);
1309 else
1310 rename_arg.pvnr_cookie_targ = NULL;
1311 puffs_makecn(&rename_arg.pvnr_cn_src, ap->a_fcnp);
1312 puffs_makecn(&rename_arg.pvnr_cn_targ, ap->a_tcnp);
1313
1314 error = puffs_vntouser(MPTOPUFFSMP(ap->a_fdvp->v_mount),
1315 PUFFS_VN_RENAME, &rename_arg, sizeof(rename_arg),
1316 VPTOPNC(ap->a_fdvp), NULL, NULL);
1317
1318 /*
1319 * XXX: stay in touch with the cache. I don't like this, but
1320 * don't have a better solution either. See also puffs_link().
1321 */
1322 if (error == 0)
1323 puffs_updatenode(ap->a_fvp, PUFFS_UPDATECTIME);
1324
1325 out:
1326 if (ap->a_tvp != NULL)
1327 vput(ap->a_tvp);
1328 if (ap->a_tdvp == ap->a_tvp)
1329 vrele(ap->a_tdvp);
1330 else
1331 vput(ap->a_tdvp);
1332
1333 vrele(ap->a_fdvp);
1334 vrele(ap->a_fvp);
1335
1336 return error;
1337 }
1338
1339 int
1340 puffs_read(void *v)
1341 {
1342 struct vop_read_args /* {
1343 const struct vnodeop_desc *a_desc;
1344 struct vnode *a_vp;
1345 struct uio *a_uio;
1346 int a_ioflag;
1347 kauth_cred_t a_cred;
1348 } */ *ap = v;
1349 struct puffs_vnreq_read *read_argp;
1350 struct puffs_mount *pmp;
1351 struct vnode *vp;
1352 struct uio *uio;
1353 void *win;
1354 size_t tomove, argsize;
1355 vsize_t bytelen;
1356 int error, ubcflags;
1357
1358 uio = ap->a_uio;
1359 vp = ap->a_vp;
1360 read_argp = NULL;
1361 error = 0;
1362 pmp = MPTOPUFFSMP(vp->v_mount);
1363
1364 /* std sanity */
1365 if (uio->uio_resid == 0)
1366 return 0;
1367 if (uio->uio_offset < 0)
1368 return EINVAL;
1369
1370 if (vp->v_type == VREG && PUFFS_DOCACHE(pmp)) {
1371 const int advice = IO_ADV_DECODE(ap->a_ioflag);
1372
1373 ubcflags = 0;
1374 if (UBC_WANT_UNMAP(vp))
1375 ubcflags = UBC_UNMAP;
1376
1377 while (uio->uio_resid > 0) {
1378 bytelen = MIN(uio->uio_resid,
1379 vp->v_size - uio->uio_offset);
1380 if (bytelen == 0)
1381 break;
1382
1383 win = ubc_alloc(&vp->v_uobj, uio->uio_offset,
1384 &bytelen, advice, UBC_READ);
1385 error = uiomove(win, bytelen, uio);
1386 ubc_release(win, ubcflags);
1387 if (error)
1388 break;
1389 }
1390
1391 if ((vp->v_mount->mnt_flag & MNT_NOATIME) == 0)
1392 puffs_updatenode(vp, PUFFS_UPDATEATIME);
1393 } else {
1394 /*
1395 * in case it's not a regular file or we're operating
1396 * uncached, do read in the old-fashioned style,
1397 * i.e. explicit read operations
1398 */
1399
1400 tomove = PUFFS_TOMOVE(uio->uio_resid, pmp);
1401 argsize = sizeof(struct puffs_vnreq_read);
1402 read_argp = malloc(argsize + tomove,
1403 M_PUFFS, M_WAITOK | M_ZERO);
1404
1405 error = 0;
1406 while (uio->uio_resid > 0) {
1407 read_argp->pvnr_ioflag = ap->a_ioflag;
1408 read_argp->pvnr_resid = tomove;
1409 read_argp->pvnr_offset = uio->uio_offset;
1410 puffs_credcvt(&read_argp->pvnr_cred, ap->a_cred);
1411
1412 argsize = sizeof(struct puffs_vnreq_read);
1413 error = puffs_vntouser_delta(pmp, PUFFS_VN_READ,
1414 read_argp, argsize, tomove,
1415 VPTOPNC(ap->a_vp), ap->a_vp, NULL);
1416 if (error)
1417 break;
1418
1419 if (read_argp->pvnr_resid > tomove) {
1420 error = EINVAL;
1421 break;
1422 }
1423
1424 error = uiomove(read_argp->pvnr_data,
1425 tomove - read_argp->pvnr_resid, uio);
1426
1427 /*
1428 * in case the file is out of juice, resid from
1429 * userspace is != 0. and the error-case is
1430 * quite obvious
1431 */
1432 if (error || read_argp->pvnr_resid)
1433 break;
1434
1435 tomove = PUFFS_TOMOVE(uio->uio_resid, pmp);
1436 }
1437 }
1438
1439 if (read_argp)
1440 free(read_argp, M_PUFFS);
1441 return error;
1442 }
1443
1444 int
1445 puffs_write(void *v)
1446 {
1447 struct vop_write_args /* {
1448 const struct vnodeop_desc *a_desc;
1449 struct vnode *a_vp;
1450 struct uio *a_uio;
1451 int a_ioflag;
1452 kauth_cred_t a_cred;
1453 }*/ *ap = v;
1454 struct puffs_vnreq_write *write_argp;
1455 struct puffs_mount *pmp;
1456 struct uio *uio;
1457 struct vnode *vp;
1458 void *win;
1459 size_t tomove, argsize;
1460 off_t oldoff, newoff, origoff;
1461 vsize_t bytelen;
1462 int error, uflags;
1463 int ubcflags;
1464
1465 vp = ap->a_vp;
1466 uio = ap->a_uio;
1467 error = uflags = 0;
1468 write_argp = NULL;
1469 pmp = MPTOPUFFSMP(ap->a_vp->v_mount);
1470
1471 if (vp->v_type == VREG && PUFFS_DOCACHE(pmp)) {
1472 ubcflags = 0;
1473 if (UBC_WANT_UNMAP(vp))
1474 ubcflags = UBC_UNMAP;
1475
1476 /*
1477 * userspace *should* be allowed to control this,
1478 * but with UBC it's a bit unclear how to handle it
1479 */
1480 if (ap->a_ioflag & IO_APPEND)
1481 uio->uio_offset = vp->v_size;
1482
1483 origoff = uio->uio_offset;
1484 while (uio->uio_resid > 0) {
1485 uflags |= PUFFS_UPDATECTIME;
1486 uflags |= PUFFS_UPDATEMTIME;
1487 oldoff = uio->uio_offset;
1488 bytelen = uio->uio_resid;
1489
1490 win = ubc_alloc(&vp->v_uobj, oldoff, &bytelen,
1491 UVM_ADV_NORMAL, UBC_WRITE);
1492 error = uiomove(win, bytelen, uio);
1493
1494 /*
1495 * did we grow the file?
1496 * XXX: should probably ask userspace to extend
1497 * it's idea of the *first* before growing it
1498 * here. Or we need some mechanism to "rollback"
1499 * in case putpages fails.
1500 */
1501 newoff = oldoff + bytelen;
1502 if (vp->v_size < newoff) {
1503 uflags |= PUFFS_UPDATESIZE;
1504 uvm_vnp_setsize(vp, newoff);
1505
1506 /*
1507 * in case we couldn't copy data to the
1508 * window, zero it out so that we don't
1509 * have any random leftovers in there.
1510 */
1511 if (error)
1512 memset(win, 0, bytelen);
1513 }
1514
1515 ubc_release(win, ubcflags);
1516 if (error)
1517 break;
1518
1519 /*
1520 * If we're writing large files, flush to file server
1521 * every 64k. Otherwise we can very easily exhaust
1522 * kernel and user memory, as the file server cannot
1523 * really keep up with our writing speed.
1524 *
1525 * Note: this does *NOT* honor MNT_ASYNC, because
1526 * that gives userland too much say in the kernel.
1527 */
1528 if (oldoff >> 16 != uio->uio_offset >> 16) {
1529 simple_lock(&vp->v_interlock);
1530 error = VOP_PUTPAGES(vp, oldoff & ~0xffff,
1531 uio->uio_offset & ~0xffff,
1532 PGO_CLEANIT | PGO_SYNCIO);
1533 if (error)
1534 break;
1535 }
1536 }
1537
1538 if (error == 0 && ap->a_ioflag & IO_SYNC) {
1539 simple_lock(&vp->v_interlock);
1540 error = VOP_PUTPAGES(vp, trunc_page(origoff),
1541 round_page(uio->uio_offset),
1542 PGO_CLEANIT | PGO_SYNCIO);
1543 }
1544
1545 puffs_updatenode(vp, uflags);
1546 } else {
1547 /* tomove is non-increasing */
1548 tomove = PUFFS_TOMOVE(uio->uio_resid, pmp);
1549 argsize = sizeof(struct puffs_vnreq_write) + tomove;
1550 write_argp = malloc(argsize, M_PUFFS, M_WAITOK | M_ZERO);
1551
1552 while (uio->uio_resid > 0) {
1553 write_argp->pvnr_ioflag = ap->a_ioflag;
1554 write_argp->pvnr_resid = tomove;
1555 write_argp->pvnr_offset = uio->uio_offset;
1556 puffs_credcvt(&write_argp->pvnr_cred, ap->a_cred);
1557 error = uiomove(write_argp->pvnr_data, tomove, uio);
1558 if (error)
1559 break;
1560
1561 error = puffs_vntouser(MPTOPUFFSMP(ap->a_vp->v_mount),
1562 PUFFS_VN_WRITE, write_argp, argsize,
1563 VPTOPNC(ap->a_vp), ap->a_vp, NULL);
1564 if (error) {
1565 /* restore uiomove */
1566 uio->uio_resid += tomove;
1567 uio->uio_offset -= tomove;
1568 break;
1569 }
1570 if (write_argp->pvnr_resid > tomove) {
1571 /*
1572 * XXX: correct file size is a mystery,
1573 * we can only guess
1574 */
1575 error = EINVAL;
1576 break;
1577 }
1578
1579 /* adjust file size */
1580 if (vp->v_size < uio->uio_offset)
1581 uvm_vnp_setsize(vp, uio->uio_offset);
1582
1583 /* didn't move everything? bad userspace. bail */
1584 if (write_argp->pvnr_resid != 0) {
1585 uio->uio_resid += write_argp->pvnr_resid;
1586 uio->uio_offset -= write_argp->pvnr_resid;
1587 error = EIO;
1588 break;
1589 }
1590
1591 tomove = PUFFS_TOMOVE(uio->uio_resid, pmp);
1592 }
1593 }
1594
1595 if (write_argp)
1596 free(write_argp, M_PUFFS);
1597 return error;
1598 }
1599
1600 static int puffs_fcnioctl(struct vop_ioctl_args * /*XXX*/, int);
1601
1602 #define FCNIOCTL_ARG_MAX 1<<16
1603 int
1604 puffs_fcnioctl(struct vop_ioctl_args *ap, int puffsop)
1605 {
1606
1607 /* currently not supported */
1608 return EOPNOTSUPP;
1609 #if 0
1610 /* struct vop_ioctl_args {
1611 const struct vnodeop_desc *a_desc;
1612 struct vnode *a_vp;
1613 u_long a_command;
1614 void *a_data;
1615 int a_fflag;
1616 kauth_cred_t a_cred;
1617 struct lwp *a_l;
1618 }*ap = v; */
1619 struct puffs_mount *pmp;
1620 struct puffs_sizepark pspark;
1621 void *kernbuf;
1622 size_t copylen;
1623 int error;
1624
1625 PUFFS_VNREQ(fcnioctl);
1626
1627 /*
1628 * Since this op gives the filesystem (almost) complete control on
1629 * how much it is allowed to copy from the calling process
1630 * address space, do not enable it by default, since it would
1631 * be a whopping security hole.
1632 */
1633 pmp = MPTOPUFFSMP(ap->a_vp->v_mount);
1634 if ((pmp->pmp_flags & PUFFS_KFLAG_ALLOWCTL) == 0)
1635 return EINVAL; /* only shoe that fits */
1636
1637 /* fill in sizereq and store it */
1638 pspark.pkso_reqid = puffs_getreqid(pmp);
1639 pspark.pkso_reqtype = PUFFS_SIZEOPREQ_BUF_IN;
1640 pspark.pkso_copybuf = ap->a_data;
1641 pspark.pkso_bufsize = FCNIOCTL_ARG_MAX;
1642 TAILQ_INSERT_TAIL(&pmp->pmp_req_sizepark, &pspark, pkso_entries);
1643
1644 /* then fill in actual request and shoot it off */
1645 fcnioctl_arg.pvnr_command = ap->a_command;
1646 fcnioctl_arg.pvnr_fflag = ap->a_fflag;
1647 puffs_credcvt(&fcnioctl_arg.pvnr_cred, ap->a_cred);
1648 fcnioctl_arg.pvnr_pid = puffs_lwp2pid(ap->a_l);
1649
1650 error = puffs_vntouser_req(MPTOPUFFSMP(ap->a_vp->v_mount), puffsop,
1651 &fcnioctl_arg, sizeof(fcnioctl_arg), VPTOPNC(ap->a_vp),
1652 pspark.pkso_reqid, NULL, NULL);
1653
1654 /* if we don't need to copy data, we're done */
1655 if (error || !fcnioctl_arg.pvnr_copyback)
1656 return error;
1657
1658 copylen = MIN(FCNIOCTL_ARG_MAX, fcnioctl_arg.pvnr_datalen);
1659 kernbuf = malloc(copylen, M_PUFFS, M_WAITOK);
1660 error = copyin(fcnioctl_arg.pvnr_data, kernbuf, copylen);
1661 if (error)
1662 goto out;
1663 error = copyout(kernbuf, ap->a_data, copylen);
1664
1665 out:
1666 free(kernbuf, M_PUFFS);
1667 return error;
1668 #endif
1669 }
1670
1671 int
1672 puffs_ioctl(void *v)
1673 {
1674
1675 return puffs_fcnioctl(v, PUFFS_VN_IOCTL);
1676 }
1677
1678 int
1679 puffs_fcntl(void *v)
1680 {
1681
1682 return puffs_fcnioctl(v, PUFFS_VN_FCNTL);
1683 }
1684
1685 int
1686 puffs_print(void *v)
1687 {
1688 struct vop_print_args /* {
1689 struct vnode *a_vp;
1690 } */ *ap = v;
1691 struct puffs_mount *pmp;
1692 struct vnode *vp = ap->a_vp;
1693 struct puffs_node *pn = vp->v_data;
1694
1695 PUFFS_VNREQ(print);
1696
1697 pmp = MPTOPUFFSMP(vp->v_mount);
1698
1699 /* kernel portion */
1700 printf("tag VT_PUFFS, vnode %p, puffs node: %p,\n"
1701 " userspace cookie: %p\n", vp, pn, pn->pn_cookie);
1702 if (vp->v_type == VFIFO)
1703 fifo_printinfo(vp);
1704 lockmgr_printinfo(&vp->v_lock);
1705
1706 /* userspace portion */
1707 if (EXISTSOP(pmp, PRINT))
1708 puffs_vntouser(pmp, PUFFS_VN_PRINT,
1709 &print_arg, sizeof(print_arg), VPTOPNC(ap->a_vp),
1710 LOCKEDVP(ap->a_vp), NULL);
1711
1712 return 0;
1713 }
1714
1715 int
1716 puffs_pathconf(void *v)
1717 {
1718 struct vop_pathconf_args /* {
1719 const struct vnodeop_desc *a_desc;
1720 struct vnode *a_vp;
1721 int a_name;
1722 register_t *a_retval;
1723 } */ *ap = v;
1724 int error;
1725
1726 PUFFS_VNREQ(pathconf);
1727
1728 pathconf_arg.pvnr_name = ap->a_name;
1729
1730 error = puffs_vntouser(MPTOPUFFSMP(ap->a_vp->v_mount),
1731 PUFFS_VN_PATHCONF, &pathconf_arg, sizeof(pathconf_arg),
1732 VPTOPNC(ap->a_vp), ap->a_vp, NULL);
1733 if (error)
1734 return error;
1735
1736 *ap->a_retval = pathconf_arg.pvnr_retval;
1737
1738 return 0;
1739 }
1740
1741 int
1742 puffs_advlock(void *v)
1743 {
1744 struct vop_advlock_args /* {
1745 const struct vnodeop_desc *a_desc;
1746 struct vnode *a_vp;
1747 void *a_id;
1748 int a_op;
1749 struct flock *a_fl;
1750 int a_flags;
1751 } */ *ap = v;
1752 int error;
1753
1754 PUFFS_VNREQ(advlock);
1755
1756 error = copyin(ap->a_fl, &advlock_arg.pvnr_fl, sizeof(struct flock));
1757 if (error)
1758 return error;
1759 advlock_arg.pvnr_id = ap->a_id;
1760 advlock_arg.pvnr_op = ap->a_op;
1761 advlock_arg.pvnr_flags = ap->a_flags;
1762
1763 return puffs_vntouser(MPTOPUFFSMP(ap->a_vp->v_mount), PUFFS_VN_ADVLOCK,
1764 &advlock_arg, sizeof(advlock_arg), VPTOPNC(ap->a_vp), NULL, NULL);
1765 }
1766 /*
1767 * This maps itself to PUFFS_VN_READ/WRITE for data transfer.
1768 */
1769 int
1770 puffs_strategy(void *v)
1771 {
1772 struct vop_strategy_args /* {
1773 const struct vnodeop_desc *a_desc;
1774 struct vnode *a_vp;
1775 struct buf *a_bp;
1776 } */ *ap = v;
1777 struct puffs_mount *pmp;
1778 struct vnode *vp = ap->a_vp;
1779 struct puffs_node *pn;
1780 struct puffs_vnreq_read *read_argp = NULL;
1781 struct puffs_vnreq_write *write_argp = NULL;
1782 struct buf *bp;
1783 size_t argsize;
1784 size_t tomove, moved;
1785 int error, dowritefaf;
1786
1787 pmp = MPTOPUFFSMP(vp->v_mount);
1788 bp = ap->a_bp;
1789 error = 0;
1790 dowritefaf = 0;
1791 pn = VPTOPP(vp);
1792
1793 if (((bp->b_flags & B_READ) && !EXISTSOP(pmp, READ))
1794 || (((bp->b_flags & B_READ) == 0) && !EXISTSOP(pmp, WRITE))) {
1795 error = EOPNOTSUPP;
1796 goto out;
1797 }
1798
1799 /*
1800 * Short-circuit optimization: don't flush buffer in between
1801 * VOP_INACTIVE and VOP_RECLAIM in case the node has no references.
1802 */
1803 if (pn->pn_stat & PNODE_NOREFS) {
1804 bp->b_resid = 0;
1805 goto out;
1806 }
1807
1808 #ifdef DIAGNOSTIC
1809 if (bp->b_bcount > pmp->pmp_req_maxsize - PUFFS_REQSTRUCT_MAX)
1810 panic("puffs_strategy: wildly inappropriate buf bcount %d",
1811 bp->b_bcount);
1812 #endif
1813
1814 /*
1815 * See explanation for the necessity of a FAF in puffs_fsync.
1816 *
1817 * Also, do FAF in case we're suspending.
1818 * See puffs_vfsops.c:pageflush()
1819 *
1820 * XXgoddamnX: B_WRITE is a "pseudo flag"
1821 */
1822 if ((bp->b_flags & B_READ) == 0) {
1823 simple_lock(&vp->v_interlock);
1824 if (vp->v_flag & VXLOCK)
1825 dowritefaf = 1;
1826 if (pn->pn_stat & PNODE_SUSPEND)
1827 dowritefaf = 1;
1828 simple_unlock(&vp->v_interlock);
1829 }
1830
1831 if (bp->b_flags & B_ASYNC)
1832 dowritefaf = 1;
1833
1834 #ifdef DIAGNOSTIC
1835 if (curproc == uvm.pagedaemon_proc)
1836 KASSERT(dowritefaf);
1837 #endif
1838
1839 tomove = PUFFS_TOMOVE(bp->b_bcount, pmp);
1840
1841 if ((bp->b_flags & (B_READ | B_ASYNC)) == (B_READ | B_ASYNC)) {
1842 puffs_vntouser_bioread_async(pmp, VPTOPNC(vp), tomove,
1843 bp->b_blkno << DEV_BSHIFT, bp, LOCKEDVP(vp), NULL);
1844 } else if (bp->b_flags & B_READ) {
1845 argsize = sizeof(struct puffs_vnreq_read);
1846 read_argp = malloc(argsize + tomove,
1847 M_PUFFS, M_NOWAIT | M_ZERO);
1848 if (read_argp == NULL) {
1849 error = ENOMEM;
1850 goto out;
1851 }
1852
1853 read_argp->pvnr_ioflag = 0;
1854 read_argp->pvnr_resid = tomove;
1855 read_argp->pvnr_offset = bp->b_blkno << DEV_BSHIFT;
1856 puffs_credcvt(&read_argp->pvnr_cred, FSCRED);
1857
1858 error = puffs_vntouser_delta(pmp, PUFFS_VN_READ,
1859 read_argp, argsize, tomove,
1860 VPTOPNC(vp), LOCKEDVP(vp), NULL);
1861
1862 if (error)
1863 goto out;
1864
1865 if (read_argp->pvnr_resid > tomove) {
1866 error = EINVAL;
1867 goto out;
1868 }
1869
1870 moved = tomove - read_argp->pvnr_resid;
1871
1872 (void)memcpy(bp->b_data, read_argp->pvnr_data, moved);
1873 bp->b_resid = bp->b_bcount - moved;
1874 } else {
1875 /*
1876 * make pages read-only before we write them if we want
1877 * write caching info
1878 */
1879 if (PUFFS_WCACHEINFO(pmp)) {
1880 struct uvm_object *uobj = &vp->v_uobj;
1881 int npages = (bp->b_bcount + PAGE_SIZE-1) >> PAGE_SHIFT;
1882 struct vm_page *vmp;
1883 int i;
1884
1885 for (i = 0; i < npages; i++) {
1886 vmp= uvm_pageratop((vaddr_t)bp->b_data
1887 + (i << PAGE_SHIFT));
1888 DPRINTF(("puffs_strategy: write-protecting "
1889 "vp %p page %p, offset %" PRId64"\n",
1890 vp, vmp, vmp->offset));
1891 simple_lock(&uobj->vmobjlock);
1892 vmp->flags |= PG_RDONLY;
1893 pmap_page_protect(vmp, VM_PROT_READ);
1894 simple_unlock(&uobj->vmobjlock);
1895 }
1896 }
1897
1898 argsize = sizeof(struct puffs_vnreq_write) + bp->b_bcount;
1899 write_argp = malloc(argsize, M_PUFFS, M_NOWAIT | M_ZERO);
1900 if (write_argp == NULL) {
1901 error = ENOMEM;
1902 goto out;
1903 }
1904
1905 write_argp->pvnr_ioflag = 0;
1906 write_argp->pvnr_resid = tomove;
1907 write_argp->pvnr_offset = bp->b_blkno << DEV_BSHIFT;
1908 puffs_credcvt(&write_argp->pvnr_cred, FSCRED);
1909
1910 (void)memcpy(&write_argp->pvnr_data, bp->b_data, tomove);
1911
1912 if (dowritefaf) {
1913 /*
1914 * assume FAF moves everything. frankly, we don't
1915 * really have a choice.
1916 */
1917 puffs_vntouser_faf(MPTOPUFFSMP(vp->v_mount),
1918 PUFFS_VN_WRITE, write_argp, argsize, VPTOPNC(vp));
1919 bp->b_resid = bp->b_bcount - tomove;
1920 } else {
1921 error = puffs_vntouser(MPTOPUFFSMP(vp->v_mount),
1922 PUFFS_VN_WRITE, write_argp, argsize, VPTOPNC(vp),
1923 vp, NULL);
1924 if (error)
1925 goto out;
1926
1927 moved = tomove - write_argp->pvnr_resid;
1928 if (write_argp->pvnr_resid > tomove) {
1929 error = EINVAL;
1930 goto out;
1931 }
1932
1933 bp->b_resid = bp->b_bcount - moved;
1934 if (write_argp->pvnr_resid != 0)
1935 error = EIO;
1936 }
1937 }
1938
1939 out:
1940 if (read_argp)
1941 free(read_argp, M_PUFFS);
1942 if (write_argp && !dowritefaf)
1943 free(write_argp, M_PUFFS);
1944
1945 if (error) {
1946 bp->b_error = error;
1947 bp->b_flags |= B_ERROR;
1948 }
1949
1950 if ((bp->b_flags & (B_READ | B_ASYNC)) != (B_READ | B_ASYNC))
1951 biodone(bp);
1952 return error;
1953 }
1954
1955 int
1956 puffs_mmap(void *v)
1957 {
1958 struct vop_mmap_args /* {
1959 const struct vnodeop_desc *a_desc;
1960 struct vnode *a_vp;
1961 int a_fflags;
1962 kauth_cred_t a_cred;
1963 struct lwp *a_l;
1964 } */ *ap = v;
1965 struct puffs_mount *pmp;
1966 int error;
1967
1968 PUFFS_VNREQ(mmap);
1969
1970 pmp = MPTOPUFFSMP(ap->a_vp->v_mount);
1971
1972 if (!PUFFS_DOCACHE(pmp))
1973 return genfs_eopnotsupp(v);
1974
1975 if (EXISTSOP(pmp, MMAP)) {
1976 mmap_arg.pvnr_fflags = ap->a_fflags;
1977 puffs_credcvt(&mmap_arg.pvnr_cred, ap->a_cred);
1978 mmap_arg.pvnr_pid = puffs_lwp2pid(ap->a_l);
1979
1980 error = puffs_vntouser(pmp, PUFFS_VN_MMAP,
1981 &mmap_arg, sizeof(mmap_arg),
1982 VPTOPNC(ap->a_vp), NULL, NULL);
1983 } else {
1984 error = genfs_mmap(v);
1985 }
1986
1987 return error;
1988 }
1989
1990
1991 /*
1992 * The rest don't get a free trip to userspace and back, they
1993 * have to stay within the kernel.
1994 */
1995
1996 /*
1997 * bmap doesn't really make any sense for puffs, so just 1:1 map it.
1998 * well, maybe somehow, somewhere, some day ....
1999 */
2000 int
2001 puffs_bmap(void *v)
2002 {
2003 struct vop_bmap_args /* {
2004 const struct vnodeop_desc *a_desc;
2005 struct vnode *a_vp;
2006 daddr_t a_bn;
2007 struct vnode **a_vpp;
2008 daddr_t *a_bnp;
2009 int *a_runp;
2010 } */ *ap = v;
2011 struct puffs_mount *pmp;
2012
2013 pmp = MPTOPUFFSMP(ap->a_vp->v_mount);
2014
2015 if (ap->a_vpp)
2016 *ap->a_vpp = ap->a_vp;
2017 if (ap->a_bnp)
2018 *ap->a_bnp = ap->a_bn;
2019 if (ap->a_runp)
2020 *ap->a_runp
2021 = (PUFFS_TOMOVE(pmp->pmp_req_maxsize, pmp)>>DEV_BSHIFT) - 1;
2022
2023 return 0;
2024 }
2025
2026 /*
2027 * Handle getpages faults in puffs. We let genfs_getpages() do most
2028 * of the dirty work, but we come in this route to do accounting tasks.
2029 * If the user server has specified functions for cache notifications
2030 * about reads and/or writes, we record which type of operation we got,
2031 * for which page range, and proceed to issue a FAF notification to the
2032 * server about it.
2033 */
2034 int
2035 puffs_getpages(void *v)
2036 {
2037 struct vop_getpages_args /* {
2038 const struct vnodeop_desc *a_desc;
2039 struct vnode *a_vp;
2040 voff_t a_offset;
2041 struct vm_page **a_m;
2042 int *a_count;
2043 int a_centeridx;
2044 vm_prot_t a_access_type;
2045 int a_advice;
2046 int a_flags;
2047 } */ *ap = v;
2048 struct puffs_mount *pmp;
2049 struct vnode *vp;
2050 struct vm_page **pgs;
2051 struct puffs_cacheinfo *pcinfo = NULL;
2052 struct puffs_cacherun *pcrun;
2053 void *parkmem = NULL;
2054 size_t runsizes;
2055 int i, npages, si, streakon;
2056 int error, locked, write;
2057
2058 pmp = MPTOPUFFSMP(ap->a_vp->v_mount);
2059 npages = *ap->a_count;
2060 pgs = ap->a_m;
2061 vp = ap->a_vp;
2062 locked = (ap->a_flags & PGO_LOCKED) != 0;
2063 write = (ap->a_access_type & VM_PROT_WRITE) != 0;
2064
2065 /* ccg xnaht - gets Wuninitialized wrong */
2066 pcrun = NULL;
2067 runsizes = 0;
2068
2069 if (write && PUFFS_WCACHEINFO(pmp)) {
2070 /* allocate worst-case memory */
2071 runsizes = ((npages / 2) + 1) * sizeof(struct puffs_cacherun);
2072 pcinfo = malloc(sizeof(struct puffs_cacheinfo) + runsizes,
2073 M_PUFFS, M_ZERO | locked ? M_NOWAIT : M_WAITOK);
2074
2075 /*
2076 * can't block if we're locked and can't mess up caching
2077 * information for fs server. so come back later, please
2078 */
2079 if (pcinfo == NULL) {
2080 error = ENOMEM;
2081 goto out;
2082 }
2083
2084 parkmem = puffs_parkmem_alloc(locked == 0);
2085 if (parkmem == NULL) {
2086 error = ENOMEM;
2087 goto out;
2088 }
2089
2090 pcrun = pcinfo->pcache_runs;
2091 }
2092
2093 error = genfs_getpages(v);
2094 if (error)
2095 goto out;
2096
2097 if (PUFFS_WCACHEINFO(pmp) == 0)
2098 goto out;
2099
2100 /*
2101 * Let's see whose fault it was and inform the user server of
2102 * possibly read/written pages. Map pages from read faults
2103 * strictly read-only, since otherwise we might miss info on
2104 * when the page is actually write-faulted to.
2105 */
2106 if (!locked)
2107 simple_lock(&vp->v_uobj.vmobjlock);
2108 for (i = 0, si = 0, streakon = 0; i < npages; i++) {
2109 if (pgs[i] == NULL || pgs[i] == PGO_DONTCARE) {
2110 if (streakon && write) {
2111 streakon = 0;
2112 pcrun[si].pcache_runend
2113 = trunc_page(pgs[i]->offset) + PAGE_MASK;
2114 si++;
2115 }
2116 continue;
2117 }
2118 if (streakon == 0 && write) {
2119 streakon = 1;
2120 pcrun[si].pcache_runstart = pgs[i]->offset;
2121 }
2122
2123 if (!write)
2124 pgs[i]->flags |= PG_RDONLY;
2125 }
2126 /* was the last page part of our streak? */
2127 if (streakon) {
2128 pcrun[si].pcache_runend
2129 = trunc_page(pgs[i-1]->offset) + PAGE_MASK;
2130 si++;
2131 }
2132 if (!locked)
2133 simple_unlock(&vp->v_uobj.vmobjlock);
2134
2135 KASSERT(si <= (npages / 2) + 1);
2136
2137 /* send results to userspace */
2138 if (write)
2139 puffs_cacheop(pmp, parkmem, pcinfo,
2140 sizeof(struct puffs_cacheinfo) + runsizes, VPTOPNC(vp));
2141
2142 out:
2143 if (error) {
2144 if (pcinfo != NULL)
2145 free(pcinfo, M_PUFFS);
2146 if (parkmem != NULL)
2147 puffs_parkmem_free(parkmem);
2148 }
2149
2150 return error;
2151 }
2152
2153 int
2154 puffs_lock(void *v)
2155 {
2156 struct vop_lock_args /* {
2157 struct vnode *a_vp;
2158 int a_flags;
2159 }*/ *ap = v;
2160 struct vnode *vp = ap->a_vp;
2161 struct mount *mp = vp->v_mount;
2162
2163 #if 0
2164 DPRINTF(("puffs_lock: lock %p, args 0x%x\n", vp, ap->a_flags));
2165 #endif
2166
2167 /*
2168 * XXX: this avoids deadlocking when we're suspending.
2169 * e.g. some ops holding the vnode lock might be blocked for
2170 * the vfs transaction lock so we'd deadlock.
2171 *
2172 * Now once again this is skating on the thin ice of modern life,
2173 * since we are breaking the consistency guarantee provided
2174 * _to the user server_ by vnode locking. Hopefully this will
2175 * get fixed soon enough by getting rid of the dependency on
2176 * vnode locks alltogether.
2177 */
2178 if (fstrans_is_owner(mp) && fstrans_getstate(mp) == FSTRANS_SUSPENDING){
2179 if (ap->a_flags & LK_INTERLOCK)
2180 simple_unlock(&vp->v_interlock);
2181 return 0;
2182 }
2183
2184 return lockmgr(&vp->v_lock, ap->a_flags, &vp->v_interlock);
2185 }
2186
2187 int
2188 puffs_unlock(void *v)
2189 {
2190 struct vop_unlock_args /* {
2191 struct vnode *a_vp;
2192 int a_flags;
2193 } */ *ap = v;
2194 struct vnode *vp = ap->a_vp;
2195 struct mount *mp = vp->v_mount;
2196
2197 #if 0
2198 DPRINTF(("puffs_unlock: lock %p, args 0x%x\n", vp, ap->a_flags));
2199 #endif
2200
2201 /* XXX: see puffs_lock() */
2202 if (fstrans_is_owner(mp) && fstrans_getstate(mp) == FSTRANS_SUSPENDING){
2203 if (ap->a_flags & LK_INTERLOCK)
2204 simple_unlock(&vp->v_interlock);
2205 return 0;
2206 }
2207
2208 return lockmgr(&vp->v_lock, ap->a_flags | LK_RELEASE, &vp->v_interlock);
2209 }
2210
2211 int
2212 puffs_islocked(void *v)
2213 {
2214 struct vop_islocked_args *ap = v;
2215 int rv;
2216
2217 rv = lockstatus(&ap->a_vp->v_lock);
2218 return rv;
2219 }
2220
2221 int
2222 puffs_generic(void *v)
2223 {
2224 struct vop_generic_args *ap = v;
2225
2226 (void)ap;
2227 DPRINTF(("puffs_generic: ap->a_desc = %s\n", ap->a_desc->vdesc_name));
2228
2229 return EOPNOTSUPP;
2230 }
2231
2232
2233 /*
2234 * spec & fifo. These call the miscfs spec and fifo vectors, but issue
2235 * FAF update information for the puffs node first.
2236 */
2237 int
2238 puffs_spec_read(void *v)
2239 {
2240 struct vop_read_args /* {
2241 const struct vnodeop_desc *a_desc;
2242 struct vnode *a_vp;
2243 struct uio *a_uio;
2244 int a_ioflag;
2245 kauth_cred_t a_cred;
2246 } */ *ap = v;
2247
2248 puffs_updatenode(ap->a_vp, PUFFS_UPDATEATIME);
2249 return VOCALL(spec_vnodeop_p, VOFFSET(vop_read), v);
2250 }
2251
2252 int
2253 puffs_spec_write(void *v)
2254 {
2255 struct vop_write_args /* {
2256 const struct vnodeop_desc *a_desc;
2257 struct vnode *a_vp;
2258 struct uio *a_uio;
2259 int a_ioflag;
2260 kauth_cred_t a_cred;
2261 }*/ *ap = v;
2262
2263 puffs_updatenode(ap->a_vp, PUFFS_UPDATEMTIME);
2264 return VOCALL(spec_vnodeop_p, VOFFSET(vop_write), v);
2265 }
2266
2267 int
2268 puffs_fifo_read(void *v)
2269 {
2270 struct vop_read_args /* {
2271 const struct vnodeop_desc *a_desc;
2272 struct vnode *a_vp;
2273 struct uio *a_uio;
2274 int a_ioflag;
2275 kauth_cred_t a_cred;
2276 } */ *ap = v;
2277
2278 puffs_updatenode(ap->a_vp, PUFFS_UPDATEATIME);
2279 return VOCALL(fifo_vnodeop_p, VOFFSET(vop_read), v);
2280 }
2281
2282 int
2283 puffs_fifo_write(void *v)
2284 {
2285 struct vop_write_args /* {
2286 const struct vnodeop_desc *a_desc;
2287 struct vnode *a_vp;
2288 struct uio *a_uio;
2289 int a_ioflag;
2290 kauth_cred_t a_cred;
2291 }*/ *ap = v;
2292
2293 puffs_updatenode(ap->a_vp, PUFFS_UPDATEMTIME);
2294 return VOCALL(fifo_vnodeop_p, VOFFSET(vop_write), v);
2295 }
2296