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