udf_vnops.c revision 1.90 1 /* $NetBSD: udf_vnops.c,v 1.90 2014/02/07 15:29:22 hannken Exp $ */
2
3 /*
4 * Copyright (c) 2006, 2008 Reinoud Zandijk
5 * All rights reserved.
6 *
7 * Redistribution and use in source and binary forms, with or without
8 * modification, are permitted provided that the following conditions
9 * are met:
10 * 1. Redistributions of source code must retain the above copyright
11 * notice, this list of conditions and the following disclaimer.
12 * 2. Redistributions in binary form must reproduce the above copyright
13 * notice, this list of conditions and the following disclaimer in the
14 * documentation and/or other materials provided with the distribution.
15 *
16 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
17 * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
18 * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
19 * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
20 * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
21 * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
22 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
23 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
24 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
25 * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
26 *
27 * Generic parts are derived from software contributed to The NetBSD Foundation
28 * by Julio M. Merino Vidal, developed as part of Google's Summer of Code
29 * 2005 program.
30 *
31 */
32
33 #include <sys/cdefs.h>
34 #ifndef lint
35 __KERNEL_RCSID(0, "$NetBSD: udf_vnops.c,v 1.90 2014/02/07 15:29:22 hannken Exp $");
36 #endif /* not lint */
37
38
39 #include <sys/param.h>
40 #include <sys/systm.h>
41 #include <sys/namei.h>
42 #include <sys/resourcevar.h> /* defines plimit structure in proc struct */
43 #include <sys/kernel.h>
44 #include <sys/file.h> /* define FWRITE ... */
45 #include <sys/stat.h>
46 #include <sys/buf.h>
47 #include <sys/proc.h>
48 #include <sys/mount.h>
49 #include <sys/vnode.h>
50 #include <sys/signalvar.h>
51 #include <sys/malloc.h>
52 #include <sys/dirent.h>
53 #include <sys/lockf.h>
54 #include <sys/kauth.h>
55
56 #include <miscfs/genfs/genfs.h>
57 #include <uvm/uvm_extern.h>
58
59 #include <fs/udf/ecma167-udf.h>
60 #include <fs/udf/udf_mount.h>
61 #include <sys/dirhash.h>
62
63 #include "udf.h"
64 #include "udf_subr.h"
65 #include "udf_bswap.h"
66
67
68 #define VTOI(vnode) ((struct udf_node *) (vnode)->v_data)
69
70
71 /* externs */
72 extern int prtactive;
73
74 /* implementations of vnode functions; table follows at end */
75 /* --------------------------------------------------------------------- */
76
77 int
78 udf_inactive(void *v)
79 {
80 struct vop_inactive_args /* {
81 struct vnode *a_vp;
82 bool *a_recycle;
83 } */ *ap = v;
84 struct vnode *vp = ap->a_vp;
85 struct udf_node *udf_node = VTOI(vp);
86 int refcnt;
87
88 DPRINTF(NODE, ("udf_inactive called for udf_node %p\n", VTOI(vp)));
89
90 if (udf_node == NULL) {
91 DPRINTF(NODE, ("udf_inactive: inactive NULL UDF node\n"));
92 VOP_UNLOCK(vp);
93 return 0;
94 }
95
96 /*
97 * Optionally flush metadata to disc. If the file has not been
98 * referenced anymore in a directory we ought to free up the resources
99 * on disc if applicable.
100 */
101 if (udf_node->fe) {
102 refcnt = udf_rw16(udf_node->fe->link_cnt);
103 } else {
104 assert(udf_node->efe);
105 refcnt = udf_rw16(udf_node->efe->link_cnt);
106 }
107
108 if ((refcnt == 0) && (vp->v_vflag & VV_SYSTEM)) {
109 DPRINTF(VOLUMES, ("UDF_INACTIVE deleting VV_SYSTEM\n"));
110 /* system nodes are not writen out on inactive, so flush */
111 udf_node->i_flags = 0;
112 }
113
114 *ap->a_recycle = false;
115 if ((refcnt == 0) && ((vp->v_vflag & VV_SYSTEM) == 0)) {
116 /* remove this file's allocation */
117 DPRINTF(NODE, ("udf_inactive deleting unlinked file\n"));
118 *ap->a_recycle = true;
119 udf_delete_node(udf_node);
120 VOP_UNLOCK(vp);
121 return 0;
122 }
123
124 /* write out its node */
125 if (udf_node->i_flags & (IN_CHANGE | IN_UPDATE | IN_MODIFIED))
126 udf_update(vp, NULL, NULL, NULL, 0);
127 VOP_UNLOCK(vp);
128
129 return 0;
130 }
131
132 /* --------------------------------------------------------------------- */
133
134 int udf_sync(struct mount *mp, int waitfor, kauth_cred_t cred, struct lwp *lwp);
135
136 int
137 udf_reclaim(void *v)
138 {
139 struct vop_reclaim_args /* {
140 struct vnode *a_vp;
141 } */ *ap = v;
142 struct vnode *vp = ap->a_vp;
143 struct udf_node *udf_node = VTOI(vp);
144
145 DPRINTF(NODE, ("udf_reclaim called for node %p\n", udf_node));
146 if (prtactive && vp->v_usecount > 1)
147 vprint("udf_reclaim(): pushing active", vp);
148
149 if (udf_node == NULL) {
150 DPRINTF(NODE, ("udf_reclaim(): null udfnode\n"));
151 return 0;
152 }
153
154 /* update note for closure */
155 udf_update(vp, NULL, NULL, NULL, UPDATE_CLOSE);
156
157 /* async check to see if all node descriptors are written out */
158 while ((volatile int) udf_node->outstanding_nodedscr > 0) {
159 vprint("udf_reclaim(): waiting for writeout\n", vp);
160 tsleep(&udf_node->outstanding_nodedscr, PRIBIO, "recl wait", hz/8);
161 }
162
163 /* dispose all node knowledge */
164 udf_dispose_node(udf_node);
165
166 return 0;
167 }
168
169 /* --------------------------------------------------------------------- */
170
171 int
172 udf_read(void *v)
173 {
174 struct vop_read_args /* {
175 struct vnode *a_vp;
176 struct uio *a_uio;
177 int a_ioflag;
178 kauth_cred_t a_cred;
179 } */ *ap = v;
180 struct vnode *vp = ap->a_vp;
181 struct uio *uio = ap->a_uio;
182 int ioflag = ap->a_ioflag;
183 int advice = IO_ADV_DECODE(ap->a_ioflag);
184 struct uvm_object *uobj;
185 struct udf_node *udf_node = VTOI(vp);
186 struct file_entry *fe;
187 struct extfile_entry *efe;
188 uint64_t file_size;
189 vsize_t len;
190 int error;
191
192 /*
193 * XXX reading from extended attributes not yet implemented. FreeBSD
194 * has it in mind to forward the IO_EXT read call to the
195 * VOP_READEXTATTR().
196 */
197
198 DPRINTF(READ, ("udf_read called\n"));
199
200 /* can this happen? some filingsystems have this check */
201 if (uio->uio_offset < 0)
202 return EINVAL;
203 if (uio->uio_resid == 0)
204 return 0;
205
206 /* protect against rogue programs reading raw directories and links */
207 if ((ioflag & IO_ALTSEMANTICS) == 0) {
208 if (vp->v_type == VDIR)
209 return EISDIR;
210 /* all but regular files just give EINVAL */
211 if (vp->v_type != VREG)
212 return EINVAL;
213 }
214
215 assert(udf_node);
216 assert(udf_node->fe || udf_node->efe);
217
218 /* get file/directory filesize */
219 if (udf_node->fe) {
220 fe = udf_node->fe;
221 file_size = udf_rw64(fe->inf_len);
222 } else {
223 assert(udf_node->efe);
224 efe = udf_node->efe;
225 file_size = udf_rw64(efe->inf_len);
226 }
227
228 /* read contents using buffercache */
229 uobj = &vp->v_uobj;
230 error = 0;
231 while (uio->uio_resid > 0) {
232 /* reached end? */
233 if (file_size <= uio->uio_offset)
234 break;
235
236 /* maximise length to file extremity */
237 len = MIN(file_size - uio->uio_offset, uio->uio_resid);
238 if (len == 0)
239 break;
240
241 /* ubc, here we come, prepare to trap */
242 error = ubc_uiomove(uobj, uio, len, advice,
243 UBC_READ | UBC_PARTIALOK | UBC_UNMAP_FLAG(vp));
244 if (error)
245 break;
246 }
247
248 /* note access time unless not requested */
249 if (!(vp->v_mount->mnt_flag & MNT_NOATIME)) {
250 udf_node->i_flags |= IN_ACCESS;
251 if ((ioflag & IO_SYNC) == IO_SYNC)
252 error = udf_update(vp, NULL, NULL, NULL, UPDATE_WAIT);
253 }
254
255 return error;
256 }
257
258 /* --------------------------------------------------------------------- */
259
260 int
261 udf_write(void *v)
262 {
263 struct vop_write_args /* {
264 struct vnode *a_vp;
265 struct uio *a_uio;
266 int a_ioflag;
267 kauth_cred_t a_cred;
268 } */ *ap = v;
269 struct vnode *vp = ap->a_vp;
270 struct uio *uio = ap->a_uio;
271 int ioflag = ap->a_ioflag;
272 kauth_cred_t cred = ap->a_cred;
273 int advice = IO_ADV_DECODE(ap->a_ioflag);
274 struct uvm_object *uobj;
275 struct udf_node *udf_node = VTOI(vp);
276 struct file_entry *fe;
277 struct extfile_entry *efe;
278 uint64_t file_size, old_size, old_offset;
279 vsize_t len;
280 int aflag = ioflag & IO_SYNC ? B_SYNC : 0;
281 int error;
282 int resid, extended;
283
284 /*
285 * XXX writing to extended attributes not yet implemented. FreeBSD has
286 * it in mind to forward the IO_EXT read call to the
287 * VOP_READEXTATTR().
288 */
289
290 DPRINTF(WRITE, ("udf_write called\n"));
291
292 /* can this happen? some filingsystems have this check */
293 if (uio->uio_offset < 0)
294 return EINVAL;
295 if (uio->uio_resid == 0)
296 return 0;
297
298 /* protect against rogue programs writing raw directories or links */
299 if ((ioflag & IO_ALTSEMANTICS) == 0) {
300 if (vp->v_type == VDIR)
301 return EISDIR;
302 /* all but regular files just give EINVAL for now */
303 if (vp->v_type != VREG)
304 return EINVAL;
305 }
306
307 assert(udf_node);
308 assert(udf_node->fe || udf_node->efe);
309
310 /* get file/directory filesize */
311 if (udf_node->fe) {
312 fe = udf_node->fe;
313 file_size = udf_rw64(fe->inf_len);
314 } else {
315 assert(udf_node->efe);
316 efe = udf_node->efe;
317 file_size = udf_rw64(efe->inf_len);
318 }
319 old_size = file_size;
320
321 /* if explicitly asked to append, uio_offset can be wrong? */
322 if (ioflag & IO_APPEND)
323 uio->uio_offset = file_size;
324
325 extended = (uio->uio_offset + uio->uio_resid > file_size);
326 if (extended) {
327 DPRINTF(WRITE, ("extending file from %"PRIu64" to %"PRIu64"\n",
328 file_size, uio->uio_offset + uio->uio_resid));
329 error = udf_grow_node(udf_node, uio->uio_offset + uio->uio_resid);
330 if (error)
331 return error;
332 file_size = uio->uio_offset + uio->uio_resid;
333 }
334
335 /* write contents using buffercache */
336 uobj = &vp->v_uobj;
337 resid = uio->uio_resid;
338 error = 0;
339
340 uvm_vnp_setwritesize(vp, file_size);
341 old_offset = uio->uio_offset;
342 while (uio->uio_resid > 0) {
343 /* maximise length to file extremity */
344 len = MIN(file_size - uio->uio_offset, uio->uio_resid);
345 if (len == 0)
346 break;
347
348 genfs_node_wrlock(vp);
349 error = GOP_ALLOC(vp, uio->uio_offset, len, aflag, cred);
350 genfs_node_unlock(vp);
351 if (error)
352 break;
353
354 /* ubc, here we come, prepare to trap */
355 error = ubc_uiomove(uobj, uio, len, advice,
356 UBC_WRITE | UBC_UNMAP_FLAG(vp));
357 if (error)
358 break;
359
360 /*
361 * flush what we just wrote if necessary.
362 * XXXUBC simplistic async flushing.
363 *
364 * Directories are excluded since its file data that we want
365 * to purge.
366 */
367 if ((vp->v_type != VDIR) &&
368 (old_offset >> 16 != uio->uio_offset >> 16)) {
369 mutex_enter(vp->v_interlock);
370 error = VOP_PUTPAGES(vp, (old_offset >> 16) << 16,
371 (uio->uio_offset >> 16) << 16,
372 PGO_CLEANIT | PGO_LAZY);
373 old_offset = uio->uio_offset;
374 }
375 }
376 uvm_vnp_setsize(vp, file_size);
377
378 /* mark node changed and request update */
379 udf_node->i_flags |= IN_CHANGE | IN_UPDATE;
380 if (vp->v_mount->mnt_flag & MNT_RELATIME)
381 udf_node->i_flags |= IN_ACCESS;
382
383 /*
384 * XXX TODO FFS has code here to reset setuid & setgid when we're not
385 * the superuser as a precaution against tampering.
386 */
387
388 /* if we wrote a thing, note write action on vnode */
389 if (resid > uio->uio_resid)
390 VN_KNOTE(vp, NOTE_WRITE | (extended ? NOTE_EXTEND : 0));
391
392 if (error) {
393 /* bring back file size to its former size */
394 /* take notice of its errors? */
395 (void) udf_chsize(vp, (u_quad_t) old_size, cred);
396
397 /* roll back uio */
398 uio->uio_offset -= resid - uio->uio_resid;
399 uio->uio_resid = resid;
400 } else {
401 /* if we write and we're synchronous, update node */
402 if ((resid > uio->uio_resid) && ((ioflag & IO_SYNC) == IO_SYNC))
403 error = udf_update(vp, NULL, NULL, NULL, UPDATE_WAIT);
404 }
405
406 return error;
407 }
408
409
410 /* --------------------------------------------------------------------- */
411
412 /*
413 * `Special' bmap functionality that translates all incomming requests to
414 * translate to vop_strategy() calls with the same blocknumbers effectively
415 * not translating at all.
416 */
417
418 int
419 udf_trivial_bmap(void *v)
420 {
421 struct vop_bmap_args /* {
422 struct vnode *a_vp;
423 daddr_t a_bn;
424 struct vnode **a_vpp;
425 daddr_t *a_bnp;
426 int *a_runp;
427 } */ *ap = v;
428 struct vnode *vp = ap->a_vp; /* our node */
429 struct vnode **vpp = ap->a_vpp; /* return node */
430 daddr_t *bnp = ap->a_bnp; /* translated */
431 daddr_t bn = ap->a_bn; /* origional */
432 int *runp = ap->a_runp;
433 struct udf_node *udf_node = VTOI(vp);
434 uint32_t lb_size;
435
436 /* get logical block size */
437 lb_size = udf_rw32(udf_node->ump->logical_vol->lb_size);
438
439 /* could return `-1' to indicate holes/zeros */
440 /* translate 1:1 */
441 *bnp = bn;
442
443 /* set the vnode to read the data from with strategy on itself */
444 if (vpp)
445 *vpp = vp;
446
447 /* set runlength of maximum block size */
448 if (runp)
449 *runp = MAXPHYS / lb_size; /* or with -1 ? */
450
451 /* return success */
452 return 0;
453 }
454
455 /* --------------------------------------------------------------------- */
456
457 int
458 udf_vfsstrategy(void *v)
459 {
460 struct vop_strategy_args /* {
461 struct vnode *a_vp;
462 struct buf *a_bp;
463 } */ *ap = v;
464 struct vnode *vp = ap->a_vp;
465 struct buf *bp = ap->a_bp;
466 struct udf_node *udf_node = VTOI(vp);
467 uint32_t lb_size, sectors;
468
469 DPRINTF(STRATEGY, ("udf_strategy called\n"));
470
471 /* check if we ought to be here */
472 if (vp->v_type == VBLK || vp->v_type == VCHR)
473 panic("udf_strategy: spec");
474
475 /* only filebuffers ought to be read/write by this, no descriptors */
476 assert(bp->b_blkno >= 0);
477
478 /* get sector size */
479 lb_size = udf_rw32(udf_node->ump->logical_vol->lb_size);
480
481 /* calculate length to fetch/store in sectors */
482 sectors = bp->b_bcount / lb_size;
483 assert(bp->b_bcount > 0);
484
485 /* NEVER assume later that this buffer is already translated */
486 /* bp->b_lblkno = bp->b_blkno; */
487
488 /* check assertions: we OUGHT to always get multiples of this */
489 assert(sectors * lb_size == bp->b_bcount);
490
491 /* issue buffer */
492 if (bp->b_flags & B_READ) {
493 DPRINTF(STRATEGY, ("\tread vp %p buf %p (blk no %"PRIu64")"
494 ", for %d sectors\n",
495 vp, bp, bp->b_blkno, sectors));
496
497 /* read buffer from the udf_node, translate vtop on the way*/
498 udf_read_filebuf(udf_node, bp);
499 } else {
500 DPRINTF(STRATEGY, ("\twrite vp %p buf %p (blk no %"PRIu64")"
501 ", for %d sectors\n",
502 vp, bp, bp->b_blkno, sectors));
503
504 /* write buffer to the udf_node, translate vtop on the way*/
505 udf_write_filebuf(udf_node, bp);
506 }
507
508 return bp->b_error;
509 }
510
511 /* --------------------------------------------------------------------- */
512
513 int
514 udf_readdir(void *v)
515 {
516 struct vop_readdir_args /* {
517 struct vnode *a_vp;
518 struct uio *a_uio;
519 kauth_cred_t a_cred;
520 int *a_eofflag;
521 off_t **a_cookies;
522 int *a_ncookies;
523 } */ *ap = v;
524 struct uio *uio = ap->a_uio;
525 struct vnode *vp = ap->a_vp;
526 struct udf_node *udf_node = VTOI(vp);
527 struct file_entry *fe;
528 struct extfile_entry *efe;
529 struct fileid_desc *fid;
530 struct dirent *dirent;
531 uint64_t file_size, diroffset, transoffset;
532 uint32_t lb_size;
533 int error;
534
535 DPRINTF(READDIR, ("udf_readdir called\n"));
536
537 /* This operation only makes sense on directory nodes. */
538 if (vp->v_type != VDIR)
539 return ENOTDIR;
540
541 /* get directory filesize */
542 if (udf_node->fe) {
543 fe = udf_node->fe;
544 file_size = udf_rw64(fe->inf_len);
545 } else {
546 assert(udf_node->efe);
547 efe = udf_node->efe;
548 file_size = udf_rw64(efe->inf_len);
549 }
550
551 dirent = malloc(sizeof(struct dirent), M_UDFTEMP, M_WAITOK | M_ZERO);
552
553 /*
554 * Add `.' pseudo entry if at offset zero since its not in the fid
555 * stream
556 */
557 if (uio->uio_offset == 0) {
558 DPRINTF(READDIR, ("\t'.' inserted\n"));
559 strcpy(dirent->d_name, ".");
560 dirent->d_fileno = udf_get_node_id(&udf_node->loc);
561 dirent->d_type = DT_DIR;
562 dirent->d_namlen = strlen(dirent->d_name);
563 dirent->d_reclen = _DIRENT_SIZE(dirent);
564 uiomove(dirent, _DIRENT_SIZE(dirent), uio);
565
566 /* mark with magic value that we have done the dummy */
567 uio->uio_offset = UDF_DIRCOOKIE_DOT;
568 }
569
570 /* we are called just as long as we keep on pushing data in */
571 error = 0;
572 if (uio->uio_offset < file_size) {
573 /* allocate temporary space for fid */
574 lb_size = udf_rw32(udf_node->ump->logical_vol->lb_size);
575 fid = malloc(lb_size, M_UDFTEMP, M_WAITOK);
576
577 if (uio->uio_offset == UDF_DIRCOOKIE_DOT)
578 uio->uio_offset = 0;
579
580 diroffset = uio->uio_offset;
581 transoffset = diroffset;
582 while (diroffset < file_size) {
583 DPRINTF(READDIR, ("\tread in fid stream\n"));
584 /* transfer a new fid/dirent */
585 error = udf_read_fid_stream(vp, &diroffset, fid, dirent);
586 DPRINTFIF(READDIR, error, ("read error in read fid "
587 "stream : %d\n", error));
588 if (error)
589 break;
590
591 /*
592 * If there isn't enough space in the uio to return a
593 * whole dirent, break off read
594 */
595 if (uio->uio_resid < _DIRENT_SIZE(dirent))
596 break;
597
598 /* remember the last entry we transfered */
599 transoffset = diroffset;
600
601 /* skip deleted entries */
602 if (fid->file_char & UDF_FILE_CHAR_DEL)
603 continue;
604
605 /* skip not visible files */
606 if (fid->file_char & UDF_FILE_CHAR_VIS)
607 continue;
608
609 /* copy dirent to the caller */
610 DPRINTF(READDIR, ("\tread dirent `%s', type %d\n",
611 dirent->d_name, dirent->d_type));
612 uiomove(dirent, _DIRENT_SIZE(dirent), uio);
613 }
614
615 /* pass on last transfered offset */
616 uio->uio_offset = transoffset;
617 free(fid, M_UDFTEMP);
618 }
619
620 if (ap->a_eofflag)
621 *ap->a_eofflag = (uio->uio_offset >= file_size);
622
623 #ifdef DEBUG
624 if (udf_verbose & UDF_DEBUG_READDIR) {
625 printf("returning offset %d\n", (uint32_t) uio->uio_offset);
626 if (ap->a_eofflag)
627 printf("returning EOF ? %d\n", *ap->a_eofflag);
628 if (error)
629 printf("readdir returning error %d\n", error);
630 }
631 #endif
632
633 free(dirent, M_UDFTEMP);
634 return error;
635 }
636
637 /* --------------------------------------------------------------------- */
638
639 int
640 udf_lookup(void *v)
641 {
642 struct vop_lookup_v2_args /* {
643 struct vnode *a_dvp;
644 struct vnode **a_vpp;
645 struct componentname *a_cnp;
646 } */ *ap = v;
647 struct vnode *dvp = ap->a_dvp;
648 struct vnode **vpp = ap->a_vpp;
649 struct componentname *cnp = ap->a_cnp;
650 struct udf_node *dir_node, *res_node;
651 struct udf_mount *ump;
652 struct long_ad icb_loc;
653 mode_t mode;
654 uid_t d_uid;
655 gid_t d_gid;
656 const char *name;
657 int namelen, nameiop, islastcn, mounted_ro;
658 int error, found;
659
660 dir_node = VTOI(dvp);
661 ump = dir_node->ump;
662 *vpp = NULL;
663
664 DPRINTF(LOOKUP, ("udf_lookup called, lookup `%s`\n",
665 cnp->cn_nameptr));
666
667 /* simplify/clarification flags */
668 nameiop = cnp->cn_nameiop;
669 islastcn = cnp->cn_flags & ISLASTCN;
670 mounted_ro = dvp->v_mount->mnt_flag & MNT_RDONLY;
671
672 /* check exec/dirread permissions first */
673 error = VOP_ACCESS(dvp, VEXEC, cnp->cn_cred);
674 if (error)
675 return error;
676
677 DPRINTF(LOOKUP, ("\taccess ok\n"));
678
679 /*
680 * If requesting a modify on the last path element on a read-only
681 * filingsystem, reject lookup; XXX why is this repeated in every FS ?
682 */
683 if (islastcn && mounted_ro && (nameiop == DELETE || nameiop == RENAME))
684 return EROFS;
685
686 DPRINTF(LOOKUP, ("\tlooking up cnp->cn_nameptr '%s'\n",
687 cnp->cn_nameptr));
688 /* look in the namecache */
689 if (cache_lookup(dvp, cnp->cn_nameptr, cnp->cn_namelen,
690 cnp->cn_nameiop, cnp->cn_flags, NULL, vpp)) {
691 return *vpp == NULLVP ? ENOENT : 0;
692 }
693
694 DPRINTF(LOOKUP, ("\tNOT found in cache\n"));
695
696 /*
697 * Obviously, the file is not (anymore) in the namecache, we have to
698 * search for it. There are three basic cases: '.', '..' and others.
699 *
700 * Following the guidelines of VOP_LOOKUP manpage and tmpfs.
701 */
702 error = 0;
703 if ((cnp->cn_namelen == 1) && (cnp->cn_nameptr[0] == '.')) {
704 DPRINTF(LOOKUP, ("\tlookup '.'\n"));
705 /* special case 1 '.' */
706 if (islastcn && cnp->cn_nameiop == RENAME) {
707 error = EISDIR;
708 goto out;
709 }
710 vref(dvp);
711 *vpp = dvp;
712 /* done */
713 goto done;
714 } else if (cnp->cn_flags & ISDOTDOT) {
715 /* special case 2 '..' */
716 DPRINTF(LOOKUP, ("\tlookup '..'\n"));
717
718 if (islastcn && cnp->cn_nameiop == RENAME) {
719 error = EINVAL;
720 goto out;
721 }
722
723 /* get our node */
724 name = "..";
725 namelen = 2;
726 error = udf_lookup_name_in_dir(dvp, name, namelen,
727 &icb_loc, &found);
728 if (error)
729 goto out;
730 if (!found)
731 error = ENOENT;
732
733 /* first unlock parent */
734 VOP_UNLOCK(dvp);
735
736 if (error == 0) {
737 DPRINTF(LOOKUP, ("\tfound '..'\n"));
738 /* try to create/reuse the node */
739 error = udf_get_node(ump, &icb_loc, &res_node);
740
741 if (!error) {
742 DPRINTF(LOOKUP,
743 ("\tnode retrieved/created OK\n"));
744 *vpp = res_node->vnode;
745 }
746 }
747
748 /* try to relock parent */
749 vn_lock(dvp, LK_EXCLUSIVE | LK_RETRY);
750 goto out;
751 }
752
753 /* all other files */
754 DPRINTF(LOOKUP, ("\tlookup file/dir in directory\n"));
755
756 /* lookup filename in the directory; location icb_loc */
757 name = cnp->cn_nameptr;
758 namelen = cnp->cn_namelen;
759 error = udf_lookup_name_in_dir(dvp, name, namelen,
760 &icb_loc, &found);
761 if (error)
762 goto out;
763 if (!found) {
764 DPRINTF(LOOKUP, ("\tNOT found\n"));
765 /*
766 * The entry was not found in the directory. This is
767 * valid if we are creating or renaming an entry and
768 * are working on the last component of the path name.
769 */
770 if (islastcn && (cnp->cn_nameiop == CREATE ||
771 cnp->cn_nameiop == RENAME)) {
772 error = VOP_ACCESS(dvp, VWRITE, cnp->cn_cred);
773 if (error) {
774 goto out;
775 }
776 error = EJUSTRETURN;
777 } else {
778 error = ENOENT;
779 }
780 /* done */
781 goto done;
782 }
783
784 /*
785 * XXX NOTE tmpfs has a test here that tests that intermediate
786 * components i.e. not the last one ought to be either a directory or
787 * a link. It seems to function well without this code.
788 */
789
790 /* try to create/reuse the node */
791 error = udf_get_node(ump, &icb_loc, &res_node);
792 if (error)
793 goto out;
794
795 /* check permissions */
796 if (islastcn && (cnp->cn_nameiop == DELETE ||
797 cnp->cn_nameiop == RENAME) ) {
798 error = VOP_ACCESS(dvp, VWRITE, cnp->cn_cred);
799 if (error) {
800 vput(res_node->vnode);
801 goto out;
802 }
803
804 /*
805 * Check if the directory has its sticky bit set. If so, ask
806 * for clearance since only the owner of a file or directory
807 * can remove/rename from taht directory.
808 */
809 mode = udf_getaccessmode(dir_node);
810 if ((mode & S_ISTXT) != 0) {
811 udf_getownership(dir_node, &d_uid, &d_gid);
812 error = kauth_authorize_vnode(cnp->cn_cred,
813 KAUTH_VNODE_DELETE, res_node->vnode,
814 dir_node->vnode, genfs_can_sticky(cnp->cn_cred,
815 d_uid, d_uid));
816 if (error) {
817 error = EPERM;
818 vput(res_node->vnode);
819 goto out;
820 }
821 }
822 }
823
824 *vpp = res_node->vnode;
825
826 done:
827 /*
828 * Store result in the cache if requested. If we are creating a file,
829 * the file might not be found and thus putting it into the namecache
830 * might be seen as negative caching.
831 */
832 if (nameiop != CREATE)
833 cache_enter(dvp, *vpp, cnp->cn_nameptr, cnp->cn_namelen,
834 cnp->cn_flags);
835
836 out:
837 if (error == 0 && *vpp != dvp)
838 VOP_UNLOCK(*vpp);
839 DPRINTFIF(LOOKUP, error, ("udf_lookup returing error %d\n", error));
840
841 return error;
842 }
843
844 /* --------------------------------------------------------------------- */
845
846 int
847 udf_getattr(void *v)
848 {
849 struct vop_getattr_args /* {
850 struct vnode *a_vp;
851 struct vattr *a_vap;
852 kauth_cred_t a_cred;
853 struct lwp *a_l;
854 } */ *ap = v;
855 struct vnode *vp = ap->a_vp;
856 struct udf_node *udf_node = VTOI(vp);
857 struct udf_mount *ump = udf_node->ump;
858 struct file_entry *fe = udf_node->fe;
859 struct extfile_entry *efe = udf_node->efe;
860 struct filetimes_extattr_entry *ft_extattr;
861 struct device_extattr_entry *devattr;
862 struct vattr *vap = ap->a_vap;
863 struct timestamp *atime, *mtime, *attrtime, *creatime;
864 uint64_t filesize, blkssize;
865 uint32_t nlink;
866 uint32_t offset, a_l;
867 uint8_t *filedata;
868 uid_t uid;
869 gid_t gid;
870 int error;
871
872 DPRINTF(CALL, ("udf_getattr called\n"));
873
874 /* update times before we returning values */
875 udf_itimes(udf_node, NULL, NULL, NULL);
876
877 /* get descriptor information */
878 if (fe) {
879 nlink = udf_rw16(fe->link_cnt);
880 uid = (uid_t)udf_rw32(fe->uid);
881 gid = (gid_t)udf_rw32(fe->gid);
882 filesize = udf_rw64(fe->inf_len);
883 blkssize = udf_rw64(fe->logblks_rec);
884 atime = &fe->atime;
885 mtime = &fe->mtime;
886 attrtime = &fe->attrtime;
887 filedata = fe->data;
888
889 /* initial guess */
890 creatime = mtime;
891
892 /* check our extended attribute if present */
893 error = udf_extattr_search_intern(udf_node,
894 UDF_FILETIMES_ATTR_NO, "", &offset, &a_l);
895 if (!error) {
896 ft_extattr = (struct filetimes_extattr_entry *)
897 (filedata + offset);
898 if (ft_extattr->existence & UDF_FILETIMES_FILE_CREATION)
899 creatime = &ft_extattr->times[0];
900 }
901 } else {
902 assert(udf_node->efe);
903 nlink = udf_rw16(efe->link_cnt);
904 uid = (uid_t)udf_rw32(efe->uid);
905 gid = (gid_t)udf_rw32(efe->gid);
906 filesize = udf_rw64(efe->inf_len); /* XXX or obj_size? */
907 blkssize = udf_rw64(efe->logblks_rec);
908 atime = &efe->atime;
909 mtime = &efe->mtime;
910 attrtime = &efe->attrtime;
911 creatime = &efe->ctime;
912 filedata = efe->data;
913 }
914
915 /* do the uid/gid translation game */
916 if (uid == (uid_t) -1)
917 uid = ump->mount_args.anon_uid;
918 if (gid == (gid_t) -1)
919 gid = ump->mount_args.anon_gid;
920
921 /* fill in struct vattr with values from the node */
922 vattr_null(vap);
923 vap->va_type = vp->v_type;
924 vap->va_mode = udf_getaccessmode(udf_node);
925 vap->va_nlink = nlink;
926 vap->va_uid = uid;
927 vap->va_gid = gid;
928 vap->va_fsid = vp->v_mount->mnt_stat.f_fsidx.__fsid_val[0];
929 vap->va_fileid = udf_get_node_id(&udf_node->loc); /* inode hash XXX */
930 vap->va_size = filesize;
931 vap->va_blocksize = udf_node->ump->discinfo.sector_size; /* wise? */
932
933 /*
934 * BUG-ALERT: UDF doesn't count '.' as an entry, so we'll have to add
935 * 1 to the link count if its a directory we're requested attributes
936 * of.
937 */
938 if (vap->va_type == VDIR)
939 vap->va_nlink++;
940
941 /* access times */
942 udf_timestamp_to_timespec(ump, atime, &vap->va_atime);
943 udf_timestamp_to_timespec(ump, mtime, &vap->va_mtime);
944 udf_timestamp_to_timespec(ump, attrtime, &vap->va_ctime);
945 udf_timestamp_to_timespec(ump, creatime, &vap->va_birthtime);
946
947 vap->va_gen = 1; /* no multiple generations yes (!?) */
948 vap->va_flags = 0; /* no flags */
949 vap->va_bytes = blkssize * udf_node->ump->discinfo.sector_size;
950 vap->va_filerev = 1; /* TODO file revision numbers? */
951 vap->va_vaflags = 0;
952 /* TODO get vaflags from the extended attributes? */
953
954 if ((vap->va_type == VBLK) || (vap->va_type == VCHR)) {
955 error = udf_extattr_search_intern(udf_node,
956 UDF_DEVICESPEC_ATTR_NO, "",
957 &offset, &a_l);
958 /* if error, deny access */
959 if (error || (filedata == NULL)) {
960 vap->va_mode = 0; /* or v_type = VNON? */
961 } else {
962 devattr = (struct device_extattr_entry *)
963 filedata + offset;
964 vap->va_rdev = makedev(
965 udf_rw32(devattr->major),
966 udf_rw32(devattr->minor)
967 );
968 /* TODO we could check the implementator */
969 }
970 }
971
972 return 0;
973 }
974
975 /* --------------------------------------------------------------------- */
976
977 static int
978 udf_chown(struct vnode *vp, uid_t new_uid, gid_t new_gid,
979 kauth_cred_t cred)
980 {
981 struct udf_node *udf_node = VTOI(vp);
982 uid_t uid;
983 gid_t gid;
984 int error;
985
986 #ifdef notyet
987 /* TODO get vaflags from the extended attributes? */
988 /* Immutable or append-only files cannot be modified, either. */
989 if (udf_node->flags & (IMMUTABLE | APPEND))
990 return EPERM;
991 #endif
992
993 if (vp->v_mount->mnt_flag & MNT_RDONLY)
994 return EROFS;
995
996 /* retrieve old values */
997 udf_getownership(udf_node, &uid, &gid);
998
999 /* only one could be specified */
1000 if (new_uid == VNOVAL)
1001 new_uid = uid;
1002 if (new_gid == VNOVAL)
1003 new_gid = gid;
1004
1005 /* check if we can fit it in an 32 bits */
1006 if ((uid_t) ((uint32_t) new_uid) != new_uid)
1007 return EINVAL;
1008 if ((gid_t) ((uint32_t) new_gid) != new_gid)
1009 return EINVAL;
1010
1011 /* check permissions */
1012 error = kauth_authorize_vnode(cred, KAUTH_VNODE_CHANGE_OWNERSHIP,
1013 vp, NULL, genfs_can_chown(cred, uid, gid, new_uid, new_gid));
1014 if (error)
1015 return (error);
1016
1017 /* change the ownership */
1018 udf_setownership(udf_node, new_uid, new_gid);
1019
1020 /* mark node changed */
1021 udf_node->i_flags |= IN_CHANGE;
1022 if (vp->v_mount->mnt_flag & MNT_RELATIME)
1023 udf_node->i_flags |= IN_ACCESS;
1024
1025 return 0;
1026 }
1027
1028
1029 static int
1030 udf_chmod(struct vnode *vp, mode_t mode, kauth_cred_t cred)
1031 {
1032 struct udf_node *udf_node = VTOI(vp);
1033 uid_t uid;
1034 gid_t gid;
1035 int error;
1036
1037 #ifdef notyet
1038 /* TODO get vaflags from the extended attributes? */
1039 /* Immutable or append-only files cannot be modified, either. */
1040 if (udf_node->flags & (IMMUTABLE | APPEND))
1041 return EPERM;
1042 #endif
1043
1044 if (vp->v_mount->mnt_flag & MNT_RDONLY)
1045 return EROFS;
1046
1047 /* retrieve uid/gid values */
1048 udf_getownership(udf_node, &uid, &gid);
1049
1050 /* check permissions */
1051 error = kauth_authorize_vnode(cred, KAUTH_VNODE_WRITE_SECURITY, vp,
1052 NULL, genfs_can_chmod(vp->v_type, cred, uid, gid, mode));
1053 if (error)
1054 return (error);
1055
1056 /* change mode */
1057 udf_setaccessmode(udf_node, mode);
1058
1059 /* mark node changed */
1060 udf_node->i_flags |= IN_CHANGE;
1061 if (vp->v_mount->mnt_flag & MNT_RELATIME)
1062 udf_node->i_flags |= IN_ACCESS;
1063
1064 return 0;
1065 }
1066
1067
1068 /* exported */
1069 int
1070 udf_chsize(struct vnode *vp, u_quad_t newsize, kauth_cred_t cred)
1071 {
1072 struct udf_node *udf_node = VTOI(vp);
1073 int error, extended;
1074
1075 if (vp->v_mount->mnt_flag & MNT_RDONLY)
1076 return EROFS;
1077
1078 /* Decide whether this is a valid operation based on the file type. */
1079 switch (vp->v_type) {
1080 case VDIR:
1081 return EISDIR;
1082 case VREG:
1083 if (vp->v_mount->mnt_flag & MNT_RDONLY)
1084 return EROFS;
1085 break;
1086 case VBLK:
1087 /* FALLTHROUGH */
1088 case VCHR:
1089 /* FALLTHROUGH */
1090 case VFIFO:
1091 /* Allow modifications of special files even if in the file
1092 * system is mounted read-only (we are not modifying the
1093 * files themselves, but the objects they represent). */
1094 return 0;
1095 default:
1096 /* Anything else is unsupported. */
1097 return EOPNOTSUPP;
1098 }
1099
1100 #if notyet
1101 /* TODO get vaflags from the extended attributes? */
1102 /* Immutable or append-only files cannot be modified, either. */
1103 if (node->flags & (IMMUTABLE | APPEND))
1104 return EPERM;
1105 #endif
1106
1107 /* resize file to the requested size */
1108 error = udf_resize_node(udf_node, newsize, &extended);
1109
1110 if (error == 0) {
1111 /* mark change */
1112 udf_node->i_flags |= IN_CHANGE | IN_MODIFY;
1113 if (vp->v_mount->mnt_flag & MNT_RELATIME)
1114 udf_node->i_flags |= IN_ACCESS;
1115 VN_KNOTE(vp, NOTE_ATTRIB | (extended ? NOTE_EXTEND : 0));
1116 udf_update(vp, NULL, NULL, NULL, 0);
1117 }
1118
1119 return error;
1120 }
1121
1122
1123 static int
1124 udf_chflags(struct vnode *vp, mode_t mode, kauth_cred_t cred)
1125 {
1126 if (vp->v_mount->mnt_flag & MNT_RDONLY)
1127 return EROFS;
1128
1129 /*
1130 * XXX we can't do this yet, as its not described in the standard yet
1131 */
1132
1133 return EOPNOTSUPP;
1134 }
1135
1136
1137 static int
1138 udf_chtimes(struct vnode *vp,
1139 struct timespec *atime, struct timespec *mtime,
1140 struct timespec *birthtime, int setattrflags,
1141 kauth_cred_t cred)
1142 {
1143 struct udf_node *udf_node = VTOI(vp);
1144 uid_t uid;
1145 gid_t gid;
1146 int error;
1147
1148 #ifdef notyet
1149 /* TODO get vaflags from the extended attributes? */
1150 /* Immutable or append-only files cannot be modified, either. */
1151 if (udf_node->flags & (IMMUTABLE | APPEND))
1152 return EPERM;
1153 #endif
1154
1155 if (vp->v_mount->mnt_flag & MNT_RDONLY)
1156 return EROFS;
1157
1158 /* retrieve uid/gid values */
1159 udf_getownership(udf_node, &uid, &gid);
1160
1161 /* check permissions */
1162 error = kauth_authorize_vnode(cred, KAUTH_VNODE_WRITE_TIMES, vp,
1163 NULL, genfs_can_chtimes(vp, setattrflags, uid, cred));
1164 if (error)
1165 return (error);
1166
1167 /* update node flags depending on what times are passed */
1168 if (atime->tv_sec != VNOVAL)
1169 if (!(vp->v_mount->mnt_flag & MNT_NOATIME))
1170 udf_node->i_flags |= IN_ACCESS;
1171 if ((mtime->tv_sec != VNOVAL) || (birthtime->tv_sec != VNOVAL)) {
1172 udf_node->i_flags |= IN_CHANGE | IN_UPDATE;
1173 if (vp->v_mount->mnt_flag & MNT_RELATIME)
1174 udf_node->i_flags |= IN_ACCESS;
1175 }
1176
1177 return udf_update(vp, atime, mtime, birthtime, 0);
1178 }
1179
1180
1181 int
1182 udf_setattr(void *v)
1183 {
1184 struct vop_setattr_args /* {
1185 struct vnode *a_vp;
1186 struct vattr *a_vap;
1187 kauth_cred_t a_cred;
1188 struct lwp *a_l;
1189 } */ *ap = v;
1190 struct vnode *vp = ap->a_vp;
1191 /* struct udf_node *udf_node = VTOI(vp); */
1192 /* struct udf_mount *ump = udf_node->ump; */
1193 kauth_cred_t cred = ap->a_cred;
1194 struct vattr *vap = ap->a_vap;
1195 int error;
1196
1197 DPRINTF(CALL, ("udf_setattr called\n"));
1198
1199 /* Abort if any unsettable attribute is given. */
1200 error = 0;
1201 if (vap->va_type != VNON ||
1202 vap->va_nlink != VNOVAL ||
1203 vap->va_fsid != VNOVAL ||
1204 vap->va_fileid != VNOVAL ||
1205 vap->va_blocksize != VNOVAL ||
1206 #ifdef notyet
1207 /* checks are debated */
1208 vap->va_ctime.tv_sec != VNOVAL ||
1209 vap->va_ctime.tv_nsec != VNOVAL ||
1210 vap->va_birthtime.tv_sec != VNOVAL ||
1211 vap->va_birthtime.tv_nsec != VNOVAL ||
1212 #endif
1213 vap->va_gen != VNOVAL ||
1214 vap->va_rdev != VNOVAL ||
1215 vap->va_bytes != VNOVAL)
1216 error = EINVAL;
1217
1218 DPRINTF(ATTR, ("setattr changing:\n"));
1219 if (error == 0 && (vap->va_flags != VNOVAL)) {
1220 DPRINTF(ATTR, ("\tchflags\n"));
1221 error = udf_chflags(vp, vap->va_flags, cred);
1222 }
1223
1224 if (error == 0 && (vap->va_size != VNOVAL)) {
1225 DPRINTF(ATTR, ("\tchsize\n"));
1226 error = udf_chsize(vp, vap->va_size, cred);
1227 }
1228
1229 if (error == 0 && (vap->va_uid != VNOVAL || vap->va_gid != VNOVAL)) {
1230 DPRINTF(ATTR, ("\tchown\n"));
1231 error = udf_chown(vp, vap->va_uid, vap->va_gid, cred);
1232 }
1233
1234 if (error == 0 && (vap->va_mode != VNOVAL)) {
1235 DPRINTF(ATTR, ("\tchmod\n"));
1236 error = udf_chmod(vp, vap->va_mode, cred);
1237 }
1238
1239 if (error == 0 &&
1240 ((vap->va_atime.tv_sec != VNOVAL &&
1241 vap->va_atime.tv_nsec != VNOVAL) ||
1242 (vap->va_mtime.tv_sec != VNOVAL &&
1243 vap->va_mtime.tv_nsec != VNOVAL))
1244 ) {
1245 DPRINTF(ATTR, ("\tchtimes\n"));
1246 error = udf_chtimes(vp, &vap->va_atime, &vap->va_mtime,
1247 &vap->va_birthtime, vap->va_vaflags, cred);
1248 }
1249 VN_KNOTE(vp, NOTE_ATTRIB);
1250
1251 return error;
1252 }
1253
1254 /* --------------------------------------------------------------------- */
1255
1256 /*
1257 * Return POSIX pathconf information for UDF file systems.
1258 */
1259 int
1260 udf_pathconf(void *v)
1261 {
1262 struct vop_pathconf_args /* {
1263 struct vnode *a_vp;
1264 int a_name;
1265 register_t *a_retval;
1266 } */ *ap = v;
1267 uint32_t bits;
1268
1269 DPRINTF(CALL, ("udf_pathconf called\n"));
1270
1271 switch (ap->a_name) {
1272 case _PC_LINK_MAX:
1273 *ap->a_retval = (1<<16)-1; /* 16 bits */
1274 return 0;
1275 case _PC_NAME_MAX:
1276 *ap->a_retval = UDF_MAXNAMLEN;
1277 return 0;
1278 case _PC_PATH_MAX:
1279 *ap->a_retval = PATH_MAX;
1280 return 0;
1281 case _PC_PIPE_BUF:
1282 *ap->a_retval = PIPE_BUF;
1283 return 0;
1284 case _PC_CHOWN_RESTRICTED:
1285 *ap->a_retval = 1;
1286 return 0;
1287 case _PC_NO_TRUNC:
1288 *ap->a_retval = 1;
1289 return 0;
1290 case _PC_SYNC_IO:
1291 *ap->a_retval = 0; /* synchronised is off for performance */
1292 return 0;
1293 case _PC_FILESIZEBITS:
1294 /* 64 bit file offsets -> 2+floor(2log(2^64-1)) = 2 + 63 = 65 */
1295 bits = 64; /* XXX ought to deliver 65 */
1296 #if 0
1297 if (udf_node)
1298 bits = 64 * vp->v_mount->mnt_dev_bshift;
1299 #endif
1300 *ap->a_retval = bits;
1301 return 0;
1302 }
1303
1304 return EINVAL;
1305 }
1306
1307
1308 /* --------------------------------------------------------------------- */
1309
1310 int
1311 udf_open(void *v)
1312 {
1313 struct vop_open_args /* {
1314 struct vnode *a_vp;
1315 int a_mode;
1316 kauth_cred_t a_cred;
1317 struct proc *a_p;
1318 } */ *ap = v;
1319 int flags;
1320
1321 DPRINTF(CALL, ("udf_open called\n"));
1322
1323 /*
1324 * Files marked append-only must be opened for appending.
1325 * TODO: get chflags(2) flags from extened attribute.
1326 */
1327 flags = 0;
1328 if ((flags & APPEND) && (ap->a_mode & (FWRITE | O_APPEND)) == FWRITE)
1329 return (EPERM);
1330
1331 return 0;
1332 }
1333
1334
1335 /* --------------------------------------------------------------------- */
1336
1337 int
1338 udf_close(void *v)
1339 {
1340 struct vop_close_args /* {
1341 struct vnode *a_vp;
1342 int a_fflag;
1343 kauth_cred_t a_cred;
1344 struct proc *a_p;
1345 } */ *ap = v;
1346 struct vnode *vp = ap->a_vp;
1347 struct udf_node *udf_node = VTOI(vp);
1348 int async = vp->v_mount->mnt_flag & MNT_ASYNC;
1349 int error;
1350
1351 DPRINTF(CALL, ("udf_close called\n"));
1352 udf_node = udf_node; /* shut up gcc */
1353
1354 if (!async && (vp->v_type != VDIR)) {
1355 mutex_enter(vp->v_interlock);
1356 error = VOP_PUTPAGES(vp, 0, 0, PGO_CLEANIT);
1357 if (error)
1358 return error;
1359 }
1360
1361 mutex_enter(vp->v_interlock);
1362 if (vp->v_usecount > 1)
1363 udf_itimes(udf_node, NULL, NULL, NULL);
1364 mutex_exit(vp->v_interlock);
1365
1366 return 0;
1367 }
1368
1369
1370 /* --------------------------------------------------------------------- */
1371
1372 static int
1373 udf_check_possible(struct vnode *vp, struct vattr *vap, mode_t mode)
1374 {
1375 int flags;
1376
1377 /* check if we are allowed to write */
1378 switch (vap->va_type) {
1379 case VDIR:
1380 case VLNK:
1381 case VREG:
1382 /*
1383 * normal nodes: check if we're on a read-only mounted
1384 * filingsystem and bomb out if we're trying to write.
1385 */
1386 if ((mode & VWRITE) && (vp->v_mount->mnt_flag & MNT_RDONLY))
1387 return EROFS;
1388 break;
1389 case VBLK:
1390 case VCHR:
1391 case VSOCK:
1392 case VFIFO:
1393 /*
1394 * special nodes: even on read-only mounted filingsystems
1395 * these are allowed to be written to if permissions allow.
1396 */
1397 break;
1398 default:
1399 /* no idea what this is */
1400 return EINVAL;
1401 }
1402
1403 /* noone may write immutable files */
1404 /* TODO: get chflags(2) flags from extened attribute. */
1405 flags = 0;
1406 if ((mode & VWRITE) && (flags & IMMUTABLE))
1407 return EPERM;
1408
1409 return 0;
1410 }
1411
1412 static int
1413 udf_check_permitted(struct vnode *vp, struct vattr *vap, mode_t mode,
1414 kauth_cred_t cred)
1415 {
1416 /* ask the generic genfs_can_access to advice on security */
1417 return kauth_authorize_vnode(cred, KAUTH_ACCESS_ACTION(mode,
1418 vp->v_type, vap->va_mode), vp, NULL, genfs_can_access(vp->v_type,
1419 vap->va_mode, vap->va_uid, vap->va_gid, mode, cred));
1420 }
1421
1422 int
1423 udf_access(void *v)
1424 {
1425 struct vop_access_args /* {
1426 struct vnode *a_vp;
1427 int a_mode;
1428 kauth_cred_t a_cred;
1429 struct proc *a_p;
1430 } */ *ap = v;
1431 struct vnode *vp = ap->a_vp;
1432 mode_t mode = ap->a_mode;
1433 kauth_cred_t cred = ap->a_cred;
1434 /* struct udf_node *udf_node = VTOI(vp); */
1435 struct vattr vap;
1436 int error;
1437
1438 DPRINTF(CALL, ("udf_access called\n"));
1439
1440 error = VOP_GETATTR(vp, &vap, NULL);
1441 if (error)
1442 return error;
1443
1444 error = udf_check_possible(vp, &vap, mode);
1445 if (error)
1446 return error;
1447
1448 error = udf_check_permitted(vp, &vap, mode, cred);
1449
1450 return error;
1451 }
1452
1453 /* --------------------------------------------------------------------- */
1454
1455 int
1456 udf_create(void *v)
1457 {
1458 struct vop_create_v3_args /* {
1459 struct vnode *a_dvp;
1460 struct vnode **a_vpp;
1461 struct componentname *a_cnp;
1462 struct vattr *a_vap;
1463 } */ *ap = v;
1464 struct vnode *dvp = ap->a_dvp;
1465 struct vnode **vpp = ap->a_vpp;
1466 struct vattr *vap = ap->a_vap;
1467 struct componentname *cnp = ap->a_cnp;
1468 int error;
1469
1470 DPRINTF(CALL, ("udf_create called\n"));
1471 error = udf_create_node(dvp, vpp, vap, cnp);
1472
1473 return error;
1474 }
1475
1476 /* --------------------------------------------------------------------- */
1477
1478 int
1479 udf_mknod(void *v)
1480 {
1481 struct vop_mknod_v3_args /* {
1482 struct vnode *a_dvp;
1483 struct vnode **a_vpp;
1484 struct componentname *a_cnp;
1485 struct vattr *a_vap;
1486 } */ *ap = v;
1487 struct vnode *dvp = ap->a_dvp;
1488 struct vnode **vpp = ap->a_vpp;
1489 struct vattr *vap = ap->a_vap;
1490 struct componentname *cnp = ap->a_cnp;
1491 int error;
1492
1493 DPRINTF(CALL, ("udf_mknod called\n"));
1494 error = udf_create_node(dvp, vpp, vap, cnp);
1495
1496 return error;
1497 }
1498
1499 /* --------------------------------------------------------------------- */
1500
1501 int
1502 udf_mkdir(void *v)
1503 {
1504 struct vop_mkdir_v3_args /* {
1505 struct vnode *a_dvp;
1506 struct vnode **a_vpp;
1507 struct componentname *a_cnp;
1508 struct vattr *a_vap;
1509 } */ *ap = v;
1510 struct vnode *dvp = ap->a_dvp;
1511 struct vnode **vpp = ap->a_vpp;
1512 struct vattr *vap = ap->a_vap;
1513 struct componentname *cnp = ap->a_cnp;
1514 int error;
1515
1516 DPRINTF(CALL, ("udf_mkdir called\n"));
1517 error = udf_create_node(dvp, vpp, vap, cnp);
1518
1519 return error;
1520 }
1521
1522 /* --------------------------------------------------------------------- */
1523
1524 static int
1525 udf_do_link(struct vnode *dvp, struct vnode *vp, struct componentname *cnp)
1526 {
1527 struct udf_node *udf_node, *dir_node;
1528 struct vattr vap;
1529 int error;
1530
1531 DPRINTF(CALL, ("udf_link called\n"));
1532 KASSERT(dvp != vp);
1533 KASSERT(vp->v_type != VDIR);
1534 KASSERT(dvp->v_mount == vp->v_mount);
1535
1536 /* get attributes */
1537 dir_node = VTOI(dvp);
1538 udf_node = VTOI(vp);
1539
1540 error = VOP_GETATTR(vp, &vap, FSCRED);
1541 if (error) {
1542 VOP_UNLOCK(vp);
1543 return error;
1544 }
1545
1546 /* check link count overflow */
1547 if (vap.va_nlink >= (1<<16)-1) { /* uint16_t */
1548 VOP_UNLOCK(vp);
1549 return EMLINK;
1550 }
1551
1552 error = udf_dir_attach(dir_node->ump, dir_node, udf_node, &vap, cnp);
1553 if (error)
1554 VOP_UNLOCK(vp);
1555 return error;
1556 }
1557
1558 int
1559 udf_link(void *v)
1560 {
1561 struct vop_link_args /* {
1562 struct vnode *a_dvp;
1563 struct vnode *a_vp;
1564 struct componentname *a_cnp;
1565 } */ *ap = v;
1566 struct vnode *dvp = ap->a_dvp;
1567 struct vnode *vp = ap->a_vp;
1568 struct componentname *cnp = ap->a_cnp;
1569 int error;
1570
1571 error = udf_do_link(dvp, vp, cnp);
1572 if (error)
1573 VOP_ABORTOP(dvp, cnp);
1574
1575 VN_KNOTE(vp, NOTE_LINK);
1576 VN_KNOTE(dvp, NOTE_WRITE);
1577 vput(dvp);
1578
1579 return error;
1580 }
1581
1582 /* --------------------------------------------------------------------- */
1583
1584 static int
1585 udf_do_symlink(struct udf_node *udf_node, char *target)
1586 {
1587 struct pathcomp pathcomp;
1588 uint8_t *pathbuf, *pathpos, *compnamepos;
1589 char *mntonname;
1590 int pathlen, len, compnamelen, mntonnamelen;
1591 int error;
1592
1593 /* process `target' to an UDF structure */
1594 pathbuf = malloc(UDF_SYMLINKBUFLEN, M_UDFTEMP, M_WAITOK);
1595 pathpos = pathbuf;
1596 pathlen = 0;
1597
1598 if (*target == '/') {
1599 /* symlink starts from the root */
1600 len = UDF_PATH_COMP_SIZE;
1601 memset(&pathcomp, 0, len);
1602 pathcomp.type = UDF_PATH_COMP_ROOT;
1603
1604 /* check if its mount-point relative! */
1605 mntonname = udf_node->ump->vfs_mountp->mnt_stat.f_mntonname;
1606 mntonnamelen = strlen(mntonname);
1607 if (strlen(target) >= mntonnamelen) {
1608 if (strncmp(target, mntonname, mntonnamelen) == 0) {
1609 pathcomp.type = UDF_PATH_COMP_MOUNTROOT;
1610 target += mntonnamelen;
1611 }
1612 } else {
1613 target++;
1614 }
1615
1616 memcpy(pathpos, &pathcomp, len);
1617 pathpos += len;
1618 pathlen += len;
1619 }
1620
1621 error = 0;
1622 while (*target) {
1623 /* ignore multiple '/' */
1624 while (*target == '/') {
1625 target++;
1626 }
1627 if (!*target)
1628 break;
1629
1630 /* extract component name */
1631 compnamelen = 0;
1632 compnamepos = target;
1633 while ((*target) && (*target != '/')) {
1634 target++;
1635 compnamelen++;
1636 }
1637
1638 /* just trunc if too long ?? (security issue) */
1639 if (compnamelen >= 127) {
1640 error = ENAMETOOLONG;
1641 break;
1642 }
1643
1644 /* convert unix name to UDF name */
1645 len = sizeof(struct pathcomp);
1646 memset(&pathcomp, 0, len);
1647 pathcomp.type = UDF_PATH_COMP_NAME;
1648 len = UDF_PATH_COMP_SIZE;
1649
1650 if ((compnamelen == 2) && (strncmp(compnamepos, "..", 2) == 0))
1651 pathcomp.type = UDF_PATH_COMP_PARENTDIR;
1652 if ((compnamelen == 1) && (*compnamepos == '.'))
1653 pathcomp.type = UDF_PATH_COMP_CURDIR;
1654
1655 if (pathcomp.type == UDF_PATH_COMP_NAME) {
1656 unix_to_udf_name(
1657 (char *) &pathcomp.ident, &pathcomp.l_ci,
1658 compnamepos, compnamelen,
1659 &udf_node->ump->logical_vol->desc_charset);
1660 len = UDF_PATH_COMP_SIZE + pathcomp.l_ci;
1661 }
1662
1663 if (pathlen + len >= UDF_SYMLINKBUFLEN) {
1664 error = ENAMETOOLONG;
1665 break;
1666 }
1667
1668 memcpy(pathpos, &pathcomp, len);
1669 pathpos += len;
1670 pathlen += len;
1671 }
1672
1673 if (error) {
1674 /* aparently too big */
1675 free(pathbuf, M_UDFTEMP);
1676 return error;
1677 }
1678
1679 error = udf_grow_node(udf_node, pathlen);
1680 if (error) {
1681 /* failed to pregrow node */
1682 free(pathbuf, M_UDFTEMP);
1683 return error;
1684 }
1685
1686 /* write out structure on the new file */
1687 error = vn_rdwr(UIO_WRITE, udf_node->vnode,
1688 pathbuf, pathlen, 0,
1689 UIO_SYSSPACE, IO_NODELOCKED | IO_ALTSEMANTICS,
1690 FSCRED, NULL, NULL);
1691
1692 /* return status of symlink contents writeout */
1693 free(pathbuf, M_UDFTEMP);
1694 return error;
1695 }
1696
1697
1698 int
1699 udf_symlink(void *v)
1700 {
1701 struct vop_symlink_v3_args /* {
1702 struct vnode *a_dvp;
1703 struct vnode **a_vpp;
1704 struct componentname *a_cnp;
1705 struct vattr *a_vap;
1706 char *a_target;
1707 } */ *ap = v;
1708 struct vnode *dvp = ap->a_dvp;
1709 struct vnode **vpp = ap->a_vpp;
1710 struct vattr *vap = ap->a_vap;
1711 struct componentname *cnp = ap->a_cnp;
1712 struct udf_node *dir_node;
1713 struct udf_node *udf_node;
1714 int error;
1715
1716 DPRINTF(CALL, ("udf_symlink called\n"));
1717 DPRINTF(CALL, ("\tlinking to `%s`\n", ap->a_target));
1718 error = udf_create_node(dvp, vpp, vap, cnp);
1719 KASSERT(((error == 0) && (*vpp != NULL)) || ((error && (*vpp == NULL))));
1720 if (!error) {
1721 dir_node = VTOI(dvp);
1722 udf_node = VTOI(*vpp);
1723 KASSERT(udf_node);
1724 error = udf_do_symlink(udf_node, ap->a_target);
1725 if (error) {
1726 /* remove node */
1727 udf_shrink_node(udf_node, 0);
1728 udf_dir_detach(udf_node->ump, dir_node, udf_node, cnp);
1729 }
1730 }
1731 return error;
1732 }
1733
1734 /* --------------------------------------------------------------------- */
1735
1736 int
1737 udf_readlink(void *v)
1738 {
1739 struct vop_readlink_args /* {
1740 struct vnode *a_vp;
1741 struct uio *a_uio;
1742 kauth_cred_t a_cred;
1743 } */ *ap = v;
1744 struct vnode *vp = ap->a_vp;
1745 struct uio *uio = ap->a_uio;
1746 kauth_cred_t cred = ap->a_cred;
1747 struct udf_node *udf_node;
1748 struct pathcomp pathcomp;
1749 struct vattr vattr;
1750 uint8_t *pathbuf, *targetbuf, *tmpname;
1751 uint8_t *pathpos, *targetpos;
1752 char *mntonname;
1753 int pathlen, targetlen, namelen, mntonnamelen, len, l_ci;
1754 int first, error;
1755
1756 DPRINTF(CALL, ("udf_readlink called\n"));
1757
1758 udf_node = VTOI(vp);
1759 error = VOP_GETATTR(vp, &vattr, cred);
1760 if (error)
1761 return error;
1762
1763 /* claim temporary buffers for translation */
1764 pathbuf = malloc(UDF_SYMLINKBUFLEN, M_UDFTEMP, M_WAITOK);
1765 targetbuf = malloc(PATH_MAX+1, M_UDFTEMP, M_WAITOK);
1766 tmpname = malloc(PATH_MAX+1, M_UDFTEMP, M_WAITOK);
1767 memset(pathbuf, 0, UDF_SYMLINKBUFLEN);
1768 memset(targetbuf, 0, PATH_MAX);
1769
1770 /* read contents of file in our temporary buffer */
1771 error = vn_rdwr(UIO_READ, udf_node->vnode,
1772 pathbuf, vattr.va_size, 0,
1773 UIO_SYSSPACE, IO_NODELOCKED | IO_ALTSEMANTICS,
1774 FSCRED, NULL, NULL);
1775 if (error) {
1776 /* failed to read in symlink contents */
1777 free(pathbuf, M_UDFTEMP);
1778 free(targetbuf, M_UDFTEMP);
1779 free(tmpname, M_UDFTEMP);
1780 return error;
1781 }
1782
1783 /* convert to a unix path */
1784 pathpos = pathbuf;
1785 pathlen = 0;
1786 targetpos = targetbuf;
1787 targetlen = PATH_MAX;
1788 mntonname = udf_node->ump->vfs_mountp->mnt_stat.f_mntonname;
1789 mntonnamelen = strlen(mntonname);
1790
1791 error = 0;
1792 first = 1;
1793 while (vattr.va_size - pathlen >= UDF_PATH_COMP_SIZE) {
1794 len = UDF_PATH_COMP_SIZE;
1795 memcpy(&pathcomp, pathpos, len);
1796 l_ci = pathcomp.l_ci;
1797 switch (pathcomp.type) {
1798 case UDF_PATH_COMP_ROOT :
1799 /* XXX should check for l_ci; bugcompatible now */
1800 if ((targetlen < 1) || !first) {
1801 error = EINVAL;
1802 break;
1803 }
1804 *targetpos++ = '/'; targetlen--;
1805 break;
1806 case UDF_PATH_COMP_MOUNTROOT :
1807 /* XXX what should it be if l_ci > 0 ? [4/48.16.1.2] */
1808 if (l_ci || (targetlen < mntonnamelen+1) || !first) {
1809 error = EINVAL;
1810 break;
1811 }
1812 memcpy(targetpos, mntonname, mntonnamelen);
1813 targetpos += mntonnamelen; targetlen -= mntonnamelen;
1814 if (vattr.va_size-pathlen > UDF_PATH_COMP_SIZE+l_ci) {
1815 /* more follows, so must be directory */
1816 *targetpos++ = '/'; targetlen--;
1817 }
1818 break;
1819 case UDF_PATH_COMP_PARENTDIR :
1820 /* XXX should check for l_ci; bugcompatible now */
1821 if (targetlen < 3) {
1822 error = EINVAL;
1823 break;
1824 }
1825 *targetpos++ = '.'; targetlen--;
1826 *targetpos++ = '.'; targetlen--;
1827 *targetpos++ = '/'; targetlen--;
1828 break;
1829 case UDF_PATH_COMP_CURDIR :
1830 /* XXX should check for l_ci; bugcompatible now */
1831 if (targetlen < 2) {
1832 error = EINVAL;
1833 break;
1834 }
1835 *targetpos++ = '.'; targetlen--;
1836 *targetpos++ = '/'; targetlen--;
1837 break;
1838 case UDF_PATH_COMP_NAME :
1839 if (l_ci == 0) {
1840 error = EINVAL;
1841 break;
1842 }
1843 memset(tmpname, 0, PATH_MAX);
1844 memcpy(&pathcomp, pathpos, len + l_ci);
1845 udf_to_unix_name(tmpname, MAXPATHLEN,
1846 pathcomp.ident, l_ci,
1847 &udf_node->ump->logical_vol->desc_charset);
1848 namelen = strlen(tmpname);
1849 if (targetlen < namelen + 1) {
1850 error = EINVAL;
1851 break;
1852 }
1853 memcpy(targetpos, tmpname, namelen);
1854 targetpos += namelen; targetlen -= namelen;
1855 if (vattr.va_size-pathlen > UDF_PATH_COMP_SIZE+l_ci) {
1856 /* more follows, so must be directory */
1857 *targetpos++ = '/'; targetlen--;
1858 }
1859 break;
1860 default :
1861 error = EINVAL;
1862 break;
1863 }
1864 first = 0;
1865 if (error)
1866 break;
1867 pathpos += UDF_PATH_COMP_SIZE + l_ci;
1868 pathlen += UDF_PATH_COMP_SIZE + l_ci;
1869
1870 }
1871 /* all processed? */
1872 if (vattr.va_size - pathlen > 0)
1873 error = EINVAL;
1874
1875 /* uiomove() to destination */
1876 if (!error)
1877 uiomove(targetbuf, PATH_MAX - targetlen, uio);
1878
1879 free(pathbuf, M_UDFTEMP);
1880 free(targetbuf, M_UDFTEMP);
1881 free(tmpname, M_UDFTEMP);
1882
1883 return error;
1884 }
1885
1886 /* --------------------------------------------------------------------- */
1887
1888 /*
1889 * udf_rename() moved to udf_rename.c
1890 */
1891
1892 /* --------------------------------------------------------------------- */
1893
1894 int
1895 udf_remove(void *v)
1896 {
1897 struct vop_remove_args /* {
1898 struct vnode *a_dvp;
1899 struct vnode *a_vp;
1900 struct componentname *a_cnp;
1901 } */ *ap = v;
1902 struct vnode *dvp = ap->a_dvp;
1903 struct vnode *vp = ap->a_vp;
1904 struct componentname *cnp = ap->a_cnp;
1905 struct udf_node *dir_node = VTOI(dvp);
1906 struct udf_node *udf_node = VTOI(vp);
1907 struct udf_mount *ump = dir_node->ump;
1908 int error;
1909
1910 DPRINTF(CALL, ("udf_remove called\n"));
1911 if (vp->v_type != VDIR) {
1912 error = udf_dir_detach(ump, dir_node, udf_node, cnp);
1913 DPRINTFIF(NODE, error, ("\tgot error removing file\n"));
1914 } else {
1915 DPRINTF(NODE, ("\tis a directory: perm. denied\n"));
1916 error = EPERM;
1917 }
1918
1919 if (error == 0) {
1920 VN_KNOTE(vp, NOTE_DELETE);
1921 VN_KNOTE(dvp, NOTE_WRITE);
1922 }
1923
1924 if (dvp == vp)
1925 vrele(vp);
1926 else
1927 vput(vp);
1928 vput(dvp);
1929
1930 return error;
1931 }
1932
1933 /* --------------------------------------------------------------------- */
1934
1935 int
1936 udf_rmdir(void *v)
1937 {
1938 struct vop_rmdir_args /* {
1939 struct vnode *a_dvp;
1940 struct vnode *a_vp;
1941 struct componentname *a_cnp;
1942 } */ *ap = v;
1943 struct vnode *vp = ap->a_vp;
1944 struct vnode *dvp = ap->a_dvp;
1945 struct componentname *cnp = ap->a_cnp;
1946 struct udf_node *dir_node = VTOI(dvp);
1947 struct udf_node *udf_node = VTOI(vp);
1948 struct udf_mount *ump = dir_node->ump;
1949 int error, isempty;
1950
1951 DPRINTF(NOTIMPL, ("udf_rmdir '%s' called\n", cnp->cn_nameptr));
1952
1953 /* don't allow '.' to be deleted */
1954 if (dir_node == udf_node) {
1955 vrele(dvp);
1956 vput(vp);
1957 return EINVAL;
1958 }
1959
1960 /* make sure our `leaf' node's hash is populated */
1961 dirhash_get(&udf_node->dir_hash);
1962 error = udf_dirhash_fill(udf_node);
1963 if (error) {
1964 dirhash_put(udf_node->dir_hash);
1965 return error;
1966 }
1967
1968 /* check to see if the directory is empty */
1969 isempty = dirhash_dir_isempty(udf_node->dir_hash);
1970 dirhash_put(udf_node->dir_hash);
1971
1972 if (!isempty) {
1973 vput(dvp);
1974 vput(vp);
1975 return ENOTEMPTY;
1976 }
1977
1978 /* detach the node from the directory, udf_node is an empty dir here */
1979 error = udf_dir_detach(ump, dir_node, udf_node, cnp);
1980 if (error == 0) {
1981 cache_purge(vp);
1982 // cache_purge(dvp); /* XXX from msdosfs, why? */
1983 /*
1984 * Bug alert: we need to remove '..' from the detaching
1985 * udf_node so further lookups of this are not possible. This
1986 * prevents a process in a deleted directory from going to its
1987 * deleted parent. Since `udf_node' is garanteed to be empty
1988 * here, trunc it so no fids are there.
1989 */
1990 dirhash_purge(&udf_node->dir_hash);
1991 udf_shrink_node(udf_node, 0);
1992 VN_KNOTE(vp, NOTE_DELETE);
1993 }
1994 DPRINTFIF(NODE, error, ("\tgot error removing dir\n"));
1995
1996 /* unput the nodes and exit */
1997 vput(dvp);
1998 vput(vp);
1999
2000 return error;
2001 }
2002
2003 /* --------------------------------------------------------------------- */
2004
2005 int
2006 udf_fsync(void *v)
2007 {
2008 struct vop_fsync_args /* {
2009 struct vnode *a_vp;
2010 kauth_cred_t a_cred;
2011 int a_flags;
2012 off_t offlo;
2013 off_t offhi;
2014 struct proc *a_p;
2015 } */ *ap = v;
2016 struct vnode *vp = ap->a_vp;
2017 struct udf_node *udf_node = VTOI(vp);
2018 int error, flags, wait;
2019
2020 DPRINTF(SYNC, ("udf_fsync called on %p : %s, %s\n",
2021 udf_node,
2022 (ap->a_flags & FSYNC_WAIT) ? "wait":"no wait",
2023 (ap->a_flags & FSYNC_DATAONLY) ? "data_only":"complete"));
2024
2025 /* flush data and wait for it when requested */
2026 wait = (ap->a_flags & FSYNC_WAIT) ? UPDATE_WAIT : 0;
2027 error = vflushbuf(vp, ap->a_flags);
2028 if (error)
2029 return error;
2030
2031 if (udf_node == NULL) {
2032 printf("udf_fsync() called on NULL udf_node!\n");
2033 return 0;
2034 }
2035 if (vp->v_tag != VT_UDF) {
2036 printf("udf_fsync() called on node not tagged as UDF node!\n");
2037 return 0;
2038 }
2039
2040 /* set our times */
2041 udf_itimes(udf_node, NULL, NULL, NULL);
2042
2043 /* if called when mounted readonly, never write back */
2044 if (vp->v_mount->mnt_flag & MNT_RDONLY)
2045 return 0;
2046
2047 /* if only data is requested, return */
2048 if (ap->a_flags & FSYNC_DATAONLY)
2049 return 0;
2050
2051 /* check if the node is dirty 'enough'*/
2052 flags = udf_node->i_flags & (IN_MODIFIED | IN_ACCESSED);
2053 if (flags == 0)
2054 return 0;
2055
2056 /* if we don't have to wait, check for IO pending */
2057 if (!wait) {
2058 if (vp->v_numoutput > 0) {
2059 DPRINTF(SYNC, ("udf_fsync %p, rejecting on v_numoutput\n", udf_node));
2060 return 0;
2061 }
2062 if (udf_node->outstanding_bufs > 0) {
2063 DPRINTF(SYNC, ("udf_fsync %p, rejecting on outstanding_bufs\n", udf_node));
2064 return 0;
2065 }
2066 if (udf_node->outstanding_nodedscr > 0) {
2067 DPRINTF(SYNC, ("udf_fsync %p, rejecting on outstanding_nodedscr\n", udf_node));
2068 return 0;
2069 }
2070 }
2071
2072 /* wait until vp->v_numoutput reaches zero i.e. is finished */
2073 if (wait) {
2074 DPRINTF(SYNC, ("udf_fsync %p, waiting\n", udf_node));
2075 mutex_enter(vp->v_interlock);
2076 while (vp->v_numoutput) {
2077 DPRINTF(SYNC, ("udf_fsync %p, v_numoutput %d\n", udf_node, vp->v_numoutput));
2078 cv_timedwait(&vp->v_cv, vp->v_interlock, hz/8);
2079 }
2080 mutex_exit(vp->v_interlock);
2081 DPRINTF(SYNC, ("udf_fsync %p, fin wait\n", udf_node));
2082 }
2083
2084 /* write out node and wait for it if requested */
2085 DPRINTF(SYNC, ("udf_fsync %p, writeout node\n", udf_node));
2086 error = udf_writeout_node(udf_node, wait);
2087 if (error)
2088 return error;
2089
2090 /* TODO/XXX if ap->a_flags & FSYNC_CACHE, we ought to do a disc sync */
2091
2092 return 0;
2093 }
2094
2095 /* --------------------------------------------------------------------- */
2096
2097 int
2098 udf_advlock(void *v)
2099 {
2100 struct vop_advlock_args /* {
2101 struct vnode *a_vp;
2102 void *a_id;
2103 int a_op;
2104 struct flock *a_fl;
2105 int a_flags;
2106 } */ *ap = v;
2107 struct vnode *vp = ap->a_vp;
2108 struct udf_node *udf_node = VTOI(vp);
2109 struct file_entry *fe;
2110 struct extfile_entry *efe;
2111 uint64_t file_size;
2112
2113 DPRINTF(LOCKING, ("udf_advlock called\n"));
2114
2115 /* get directory filesize */
2116 if (udf_node->fe) {
2117 fe = udf_node->fe;
2118 file_size = udf_rw64(fe->inf_len);
2119 } else {
2120 assert(udf_node->efe);
2121 efe = udf_node->efe;
2122 file_size = udf_rw64(efe->inf_len);
2123 }
2124
2125 return lf_advlock(ap, &udf_node->lockf, file_size);
2126 }
2127
2128 /* --------------------------------------------------------------------- */
2129
2130 /* Global vfs vnode data structures for udfs */
2131 int (**udf_vnodeop_p)(void *);
2132
2133 const struct vnodeopv_entry_desc udf_vnodeop_entries[] = {
2134 { &vop_default_desc, vn_default_error },
2135 { &vop_lookup_desc, udf_lookup }, /* lookup */
2136 { &vop_create_desc, udf_create }, /* create */
2137 { &vop_mknod_desc, udf_mknod }, /* mknod */ /* TODO */
2138 { &vop_open_desc, udf_open }, /* open */
2139 { &vop_close_desc, udf_close }, /* close */
2140 { &vop_access_desc, udf_access }, /* access */
2141 { &vop_getattr_desc, udf_getattr }, /* getattr */
2142 { &vop_setattr_desc, udf_setattr }, /* setattr */ /* TODO chflags */
2143 { &vop_read_desc, udf_read }, /* read */
2144 { &vop_write_desc, udf_write }, /* write */ /* WRITE */
2145 { &vop_fcntl_desc, genfs_fcntl }, /* fcntl */ /* TODO? */
2146 { &vop_ioctl_desc, genfs_enoioctl }, /* ioctl */ /* TODO? */
2147 { &vop_poll_desc, genfs_poll }, /* poll */ /* TODO/OK? */
2148 { &vop_kqfilter_desc, genfs_kqfilter }, /* kqfilter */ /* ? */
2149 { &vop_revoke_desc, genfs_revoke }, /* revoke */ /* TODO? */
2150 { &vop_mmap_desc, genfs_mmap }, /* mmap */ /* OK? */
2151 { &vop_fsync_desc, udf_fsync }, /* fsync */
2152 { &vop_seek_desc, genfs_seek }, /* seek */
2153 { &vop_remove_desc, udf_remove }, /* remove */
2154 { &vop_link_desc, udf_link }, /* link */ /* TODO */
2155 { &vop_rename_desc, udf_rename }, /* rename */ /* TODO */
2156 { &vop_mkdir_desc, udf_mkdir }, /* mkdir */
2157 { &vop_rmdir_desc, udf_rmdir }, /* rmdir */
2158 { &vop_symlink_desc, udf_symlink }, /* symlink */ /* TODO */
2159 { &vop_readdir_desc, udf_readdir }, /* readdir */
2160 { &vop_readlink_desc, udf_readlink }, /* readlink */ /* TEST ME */
2161 { &vop_abortop_desc, genfs_abortop }, /* abortop */ /* TODO/OK? */
2162 { &vop_inactive_desc, udf_inactive }, /* inactive */
2163 { &vop_reclaim_desc, udf_reclaim }, /* reclaim */
2164 { &vop_lock_desc, genfs_lock }, /* lock */
2165 { &vop_unlock_desc, genfs_unlock }, /* unlock */
2166 { &vop_bmap_desc, udf_trivial_bmap }, /* bmap */ /* 1:1 bmap */
2167 { &vop_strategy_desc, udf_vfsstrategy },/* strategy */
2168 /* { &vop_print_desc, udf_print }, */ /* print */
2169 { &vop_islocked_desc, genfs_islocked }, /* islocked */
2170 { &vop_pathconf_desc, udf_pathconf }, /* pathconf */
2171 { &vop_advlock_desc, udf_advlock }, /* advlock */ /* TEST ME */
2172 { &vop_bwrite_desc, vn_bwrite }, /* bwrite */ /* ->strategy */
2173 { &vop_getpages_desc, genfs_getpages }, /* getpages */
2174 { &vop_putpages_desc, genfs_putpages }, /* putpages */
2175 { NULL, NULL }
2176 };
2177
2178
2179 const struct vnodeopv_desc udf_vnodeop_opv_desc = {
2180 &udf_vnodeop_p, udf_vnodeop_entries
2181 };
2182