Home | History | Annotate | Line # | Download | only in kern
vfs_vnops.c revision 1.169.4.2
      1  1.169.4.2     rmind /*	$NetBSD: vfs_vnops.c,v 1.169.4.2 2010/05/30 05:17:58 rmind Exp $	*/
      2      1.164        ad 
      3      1.164        ad /*-
      4      1.164        ad  * Copyright (c) 2009 The NetBSD Foundation, Inc.
      5      1.164        ad  * All rights reserved.
      6      1.164        ad  *
      7      1.164        ad  * This code is derived from software contributed to The NetBSD Foundation
      8      1.164        ad  * by Andrew Doran.
      9      1.164        ad  *
     10      1.164        ad  * Redistribution and use in source and binary forms, with or without
     11      1.164        ad  * modification, are permitted provided that the following conditions
     12      1.164        ad  * are met:
     13      1.164        ad  * 1. Redistributions of source code must retain the above copyright
     14      1.164        ad  *    notice, this list of conditions and the following disclaimer.
     15      1.164        ad  * 2. Redistributions in binary form must reproduce the above copyright
     16      1.164        ad  *    notice, this list of conditions and the following disclaimer in the
     17      1.164        ad  *    documentation and/or other materials provided with the distribution.
     18      1.164        ad  *
     19      1.164        ad  * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
     20      1.164        ad  * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
     21      1.164        ad  * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
     22      1.164        ad  * PURPOSE ARE DISCLAIMED.  IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
     23      1.164        ad  * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
     24      1.164        ad  * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
     25      1.164        ad  * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
     26      1.164        ad  * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
     27      1.164        ad  * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
     28      1.164        ad  * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
     29      1.164        ad  * POSSIBILITY OF SUCH DAMAGE.
     30      1.164        ad  */
     31       1.12       cgd 
     32       1.10       cgd /*
     33       1.11   mycroft  * Copyright (c) 1982, 1986, 1989, 1993
     34       1.11   mycroft  *	The Regents of the University of California.  All rights reserved.
     35       1.10       cgd  * (c) UNIX System Laboratories, Inc.
     36       1.10       cgd  * All or some portions of this file are derived from material licensed
     37       1.10       cgd  * to the University of California by American Telephone and Telegraph
     38       1.10       cgd  * Co. or Unix System Laboratories, Inc. and are reproduced herein with
     39       1.10       cgd  * the permission of UNIX System Laboratories, Inc.
     40       1.10       cgd  *
     41       1.10       cgd  * Redistribution and use in source and binary forms, with or without
     42       1.10       cgd  * modification, are permitted provided that the following conditions
     43       1.10       cgd  * are met:
     44       1.10       cgd  * 1. Redistributions of source code must retain the above copyright
     45       1.10       cgd  *    notice, this list of conditions and the following disclaimer.
     46       1.10       cgd  * 2. Redistributions in binary form must reproduce the above copyright
     47       1.10       cgd  *    notice, this list of conditions and the following disclaimer in the
     48       1.10       cgd  *    documentation and/or other materials provided with the distribution.
     49       1.73       agc  * 3. Neither the name of the University nor the names of its contributors
     50       1.10       cgd  *    may be used to endorse or promote products derived from this software
     51       1.10       cgd  *    without specific prior written permission.
     52       1.10       cgd  *
     53       1.10       cgd  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
     54       1.10       cgd  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
     55       1.10       cgd  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
     56       1.10       cgd  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
     57       1.10       cgd  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
     58       1.10       cgd  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
     59       1.10       cgd  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
     60       1.10       cgd  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
     61       1.10       cgd  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
     62       1.10       cgd  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
     63       1.10       cgd  * SUCH DAMAGE.
     64       1.10       cgd  *
     65       1.28      fvdl  *	@(#)vfs_vnops.c	8.14 (Berkeley) 6/15/95
     66       1.10       cgd  */
     67       1.52     lukem 
     68       1.52     lukem #include <sys/cdefs.h>
     69  1.169.4.2     rmind __KERNEL_RCSID(0, "$NetBSD: vfs_vnops.c,v 1.169.4.2 2010/05/30 05:17:58 rmind Exp $");
     70       1.26       mrg 
     71      1.122    dogcow #include "veriexec.h"
     72       1.10       cgd 
     73       1.10       cgd #include <sys/param.h>
     74       1.10       cgd #include <sys/systm.h>
     75       1.10       cgd #include <sys/kernel.h>
     76       1.10       cgd #include <sys/file.h>
     77       1.10       cgd #include <sys/stat.h>
     78       1.10       cgd #include <sys/buf.h>
     79       1.10       cgd #include <sys/proc.h>
     80       1.10       cgd #include <sys/mount.h>
     81       1.10       cgd #include <sys/namei.h>
     82       1.10       cgd #include <sys/vnode.h>
     83       1.10       cgd #include <sys/ioctl.h>
     84       1.10       cgd #include <sys/tty.h>
     85       1.21   mycroft #include <sys/poll.h>
     86      1.111      elad #include <sys/kauth.h>
     87      1.128      elad #include <sys/syslog.h>
     88      1.141   hannken #include <sys/fstrans.h>
     89      1.145        ad #include <sys/atomic.h>
     90      1.151     pooka #include <sys/filedesc.h>
     91      1.159    simonb #include <sys/wapbl.h>
     92       1.11   mycroft 
     93       1.77   hannken #include <miscfs/specfs/specdev.h>
     94  1.169.4.2     rmind #include <miscfs/fifofs/fifo.h>
     95       1.77   hannken 
     96       1.25       mrg #include <uvm/uvm_extern.h>
     97      1.100      yamt #include <uvm/uvm_readahead.h>
     98       1.25       mrg 
     99       1.28      fvdl #ifdef UNION
    100       1.65  jdolecek #include <fs/union/union.h>
    101       1.28      fvdl #endif
    102       1.64  jdolecek 
    103      1.101  christos int (*vn_union_readdir_hook) (struct vnode **, struct file *, struct lwp *);
    104       1.66  jdolecek 
    105       1.58     blymn #include <sys/verified_exec.h>
    106       1.28      fvdl 
    107      1.155        ad static int vn_read(file_t *fp, off_t *offset, struct uio *uio,
    108      1.111      elad 	    kauth_cred_t cred, int flags);
    109      1.155        ad static int vn_write(file_t *fp, off_t *offset, struct uio *uio,
    110      1.111      elad 	    kauth_cred_t cred, int flags);
    111      1.155        ad static int vn_closefile(file_t *fp);
    112      1.155        ad static int vn_poll(file_t *fp, int events);
    113      1.155        ad static int vn_fcntl(file_t *fp, u_int com, void *data);
    114      1.155        ad static int vn_statfile(file_t *fp, struct stat *sb);
    115      1.155        ad static int vn_ioctl(file_t *fp, u_long com, void *data);
    116       1.48  jdolecek 
    117       1.83  christos const struct fileops vnops = {
    118      1.164        ad 	.fo_read = vn_read,
    119      1.164        ad 	.fo_write = vn_write,
    120      1.164        ad 	.fo_ioctl = vn_ioctl,
    121      1.164        ad 	.fo_fcntl = vn_fcntl,
    122      1.164        ad 	.fo_poll = vn_poll,
    123      1.164        ad 	.fo_stat = vn_statfile,
    124      1.164        ad 	.fo_close = vn_closefile,
    125      1.164        ad 	.fo_kqfilter = vn_kqfilter,
    126      1.168       dsl 	.fo_restart = fnullop_restart,
    127       1.48  jdolecek };
    128       1.10       cgd 
    129       1.10       cgd /*
    130       1.10       cgd  * Common code for vnode open operations.
    131       1.10       cgd  * Check permissions, and call the VOP_OPEN or VOP_CREATE routine.
    132       1.10       cgd  */
    133       1.20  christos int
    134       1.89   thorpej vn_open(struct nameidata *ndp, int fmode, int cmode)
    135       1.10       cgd {
    136       1.94       erh 	struct vnode *vp;
    137      1.148     pooka 	struct lwp *l = curlwp;
    138      1.117        ad 	kauth_cred_t cred = l->l_cred;
    139       1.19   mycroft 	struct vattr va;
    140       1.10       cgd 	int error;
    141      1.139  christos 	char *path;
    142       1.75   hannken 
    143      1.163     enami 	ndp->ni_cnd.cn_flags &= TRYEMULROOT | NOCHROOT;
    144      1.138       dsl 
    145       1.10       cgd 	if (fmode & O_CREAT) {
    146       1.11   mycroft 		ndp->ni_cnd.cn_nameiop = CREATE;
    147      1.138       dsl 		ndp->ni_cnd.cn_flags |= LOCKPARENT | LOCKLEAF;
    148       1.38    bouyer 		if ((fmode & O_EXCL) == 0 &&
    149       1.59  christos 		    ((fmode & O_NOFOLLOW) == 0))
    150       1.11   mycroft 			ndp->ni_cnd.cn_flags |= FOLLOW;
    151      1.130      elad 	} else {
    152      1.130      elad 		ndp->ni_cnd.cn_nameiop = LOOKUP;
    153      1.138       dsl 		ndp->ni_cnd.cn_flags |= LOCKLEAF;
    154      1.130      elad 		if ((fmode & O_NOFOLLOW) == 0)
    155      1.130      elad 			ndp->ni_cnd.cn_flags |= FOLLOW;
    156      1.130      elad 	}
    157      1.139  christos 
    158      1.139  christos 	VERIEXEC_PATH_GET(ndp->ni_dirp, ndp->ni_segflg, ndp->ni_dirp, path);
    159      1.139  christos 
    160      1.130      elad 	error = namei(ndp);
    161      1.130      elad 	if (error)
    162      1.139  christos 		goto out;
    163       1.91      elad 
    164      1.130      elad 	vp = ndp->ni_vp;
    165       1.91      elad 
    166      1.130      elad #if NVERIEXEC > 0
    167      1.130      elad 	error = veriexec_openchk(l, ndp->ni_vp, ndp->ni_dirp, fmode);
    168      1.130      elad 	if (error)
    169      1.130      elad 		goto bad;
    170      1.115      elad #endif /* NVERIEXEC > 0 */
    171       1.91      elad 
    172      1.130      elad 	if (fmode & O_CREAT) {
    173      1.130      elad 		if (ndp->ni_vp == NULL) {
    174      1.169     pooka 			vattr_null(&va);
    175       1.19   mycroft 			va.va_type = VREG;
    176       1.19   mycroft 			va.va_mode = cmode;
    177       1.28      fvdl 			if (fmode & O_EXCL)
    178       1.28      fvdl 				 va.va_vaflags |= VA_EXCLUSIVE;
    179       1.20  christos 			error = VOP_CREATE(ndp->ni_dvp, &ndp->ni_vp,
    180       1.20  christos 					   &ndp->ni_cnd, &va);
    181       1.20  christos 			if (error)
    182      1.139  christos 				goto out;
    183       1.10       cgd 			fmode &= ~O_TRUNC;
    184       1.10       cgd 			vp = ndp->ni_vp;
    185       1.10       cgd 		} else {
    186       1.11   mycroft 			VOP_ABORTOP(ndp->ni_dvp, &ndp->ni_cnd);
    187       1.10       cgd 			if (ndp->ni_dvp == ndp->ni_vp)
    188       1.10       cgd 				vrele(ndp->ni_dvp);
    189       1.10       cgd 			else
    190       1.10       cgd 				vput(ndp->ni_dvp);
    191       1.10       cgd 			ndp->ni_dvp = NULL;
    192       1.10       cgd 			vp = ndp->ni_vp;
    193       1.10       cgd 			if (fmode & O_EXCL) {
    194       1.10       cgd 				error = EEXIST;
    195       1.38    bouyer 				goto bad;
    196       1.38    bouyer 			}
    197       1.10       cgd 			fmode &= ~O_CREAT;
    198       1.10       cgd 		}
    199       1.10       cgd 	} else {
    200       1.10       cgd 		vp = ndp->ni_vp;
    201       1.10       cgd 	}
    202       1.10       cgd 	if (vp->v_type == VSOCK) {
    203       1.10       cgd 		error = EOPNOTSUPP;
    204       1.74        cb 		goto bad;
    205       1.74        cb 	}
    206       1.74        cb 	if (ndp->ni_vp->v_type == VLNK) {
    207       1.74        cb 		error = EFTYPE;
    208       1.10       cgd 		goto bad;
    209       1.10       cgd 	}
    210       1.58     blymn 
    211       1.10       cgd 	if ((fmode & O_CREAT) == 0) {
    212      1.146      yamt 		error = vn_openchk(vp, cred, fmode);
    213      1.146      yamt 		if (error != 0)
    214      1.146      yamt 			goto bad;
    215       1.10       cgd 	}
    216       1.87     blymn 
    217       1.10       cgd 	if (fmode & O_TRUNC) {
    218       1.28      fvdl 		VOP_UNLOCK(vp, 0);			/* XXX */
    219      1.123     blymn 
    220       1.28      fvdl 		vn_lock(vp, LK_EXCLUSIVE | LK_RETRY);	/* XXX */
    221      1.169     pooka 		vattr_null(&va);
    222       1.19   mycroft 		va.va_size = 0;
    223      1.144     pooka 		error = VOP_SETATTR(vp, &va, cred);
    224       1.75   hannken 		if (error != 0)
    225       1.10       cgd 			goto bad;
    226       1.10       cgd 	}
    227      1.144     pooka 	if ((error = VOP_OPEN(vp, fmode, cred)) != 0)
    228       1.10       cgd 		goto bad;
    229      1.143        ad 	if (fmode & FWRITE) {
    230  1.169.4.1     rmind 		mutex_enter(vp->v_interlock);
    231       1.10       cgd 		vp->v_writecount++;
    232  1.169.4.1     rmind 		mutex_exit(vp->v_interlock);
    233      1.143        ad 	}
    234       1.45       chs 
    235       1.10       cgd bad:
    236      1.127      elad 	if (error)
    237      1.127      elad 		vput(vp);
    238      1.139  christos out:
    239      1.139  christos 	VERIEXEC_PATH_PUT(path);
    240       1.10       cgd 	return (error);
    241       1.10       cgd }
    242       1.10       cgd 
    243       1.10       cgd /*
    244       1.10       cgd  * Check for write permissions on the specified vnode.
    245       1.28      fvdl  * Prototype text segments cannot be written.
    246       1.10       cgd  */
    247       1.20  christos int
    248       1.89   thorpej vn_writechk(struct vnode *vp)
    249       1.10       cgd {
    250       1.10       cgd 
    251       1.10       cgd 	/*
    252       1.45       chs 	 * If the vnode is in use as a process's text,
    253       1.45       chs 	 * we can't allow writing.
    254       1.10       cgd 	 */
    255      1.143        ad 	if (vp->v_iflag & VI_TEXT)
    256       1.25       mrg 		return (ETXTBSY);
    257       1.10       cgd 	return (0);
    258       1.42       chs }
    259       1.42       chs 
    260      1.146      yamt int
    261      1.146      yamt vn_openchk(struct vnode *vp, kauth_cred_t cred, int fflags)
    262      1.146      yamt {
    263      1.146      yamt 	int permbits = 0;
    264      1.146      yamt 	int error;
    265      1.146      yamt 
    266      1.146      yamt 	if ((fflags & FREAD) != 0) {
    267      1.146      yamt 		permbits = VREAD;
    268      1.146      yamt 	}
    269      1.146      yamt 	if ((fflags & (FWRITE | O_TRUNC)) != 0) {
    270      1.146      yamt 		permbits |= VWRITE;
    271      1.146      yamt 		if (vp->v_type == VDIR) {
    272      1.146      yamt 			error = EISDIR;
    273      1.146      yamt 			goto bad;
    274      1.146      yamt 		}
    275      1.146      yamt 		error = vn_writechk(vp);
    276      1.146      yamt 		if (error != 0)
    277      1.146      yamt 			goto bad;
    278      1.146      yamt 	}
    279      1.146      yamt 	error = VOP_ACCESS(vp, permbits, cred);
    280      1.146      yamt bad:
    281      1.146      yamt 	return error;
    282      1.146      yamt }
    283      1.146      yamt 
    284       1.42       chs /*
    285       1.51   thorpej  * Mark a vnode as having executable mappings.
    286       1.42       chs  */
    287       1.42       chs void
    288       1.89   thorpej vn_markexec(struct vnode *vp)
    289       1.42       chs {
    290      1.143        ad 
    291      1.158        ad 	if ((vp->v_iflag & VI_EXECMAP) != 0) {
    292      1.158        ad 		/* Safe unlocked, as long as caller holds a reference. */
    293      1.158        ad 		return;
    294      1.158        ad 	}
    295      1.143        ad 
    296  1.169.4.1     rmind 	mutex_enter(vp->v_interlock);
    297      1.143        ad 	if ((vp->v_iflag & VI_EXECMAP) == 0) {
    298      1.145        ad 		atomic_add_int(&uvmexp.filepages, -vp->v_uobj.uo_npages);
    299      1.145        ad 		atomic_add_int(&uvmexp.execpages, vp->v_uobj.uo_npages);
    300      1.158        ad 		vp->v_iflag |= VI_EXECMAP;
    301       1.46       chs 	}
    302  1.169.4.1     rmind 	mutex_exit(vp->v_interlock);
    303       1.55       chs }
    304       1.55       chs 
    305       1.55       chs /*
    306       1.55       chs  * Mark a vnode as being the text of a process.
    307       1.55       chs  * Fail if the vnode is currently writable.
    308       1.55       chs  */
    309       1.55       chs int
    310       1.89   thorpej vn_marktext(struct vnode *vp)
    311       1.55       chs {
    312       1.55       chs 
    313      1.157        ad 	if ((vp->v_iflag & (VI_TEXT|VI_EXECMAP)) == (VI_TEXT|VI_EXECMAP)) {
    314      1.157        ad 		/* Safe unlocked, as long as caller holds a reference. */
    315      1.158        ad 		return (0);
    316      1.157        ad 	}
    317      1.157        ad 
    318  1.169.4.1     rmind 	mutex_enter(vp->v_interlock);
    319       1.55       chs 	if (vp->v_writecount != 0) {
    320      1.143        ad 		KASSERT((vp->v_iflag & VI_TEXT) == 0);
    321  1.169.4.1     rmind 		mutex_exit(vp->v_interlock);
    322       1.55       chs 		return (ETXTBSY);
    323       1.55       chs 	}
    324      1.158        ad 	if ((vp->v_iflag & VI_EXECMAP) == 0) {
    325      1.158        ad 		atomic_add_int(&uvmexp.filepages, -vp->v_uobj.uo_npages);
    326      1.158        ad 		atomic_add_int(&uvmexp.execpages, vp->v_uobj.uo_npages);
    327      1.158        ad 	}
    328      1.158        ad 	vp->v_iflag |= (VI_TEXT | VI_EXECMAP);
    329  1.169.4.1     rmind 	mutex_exit(vp->v_interlock);
    330       1.55       chs 	return (0);
    331       1.10       cgd }
    332       1.10       cgd 
    333       1.10       cgd /*
    334       1.10       cgd  * Vnode close call
    335       1.32  wrstuden  *
    336       1.32  wrstuden  * Note: takes an unlocked vnode, while VOP_CLOSE takes a locked node.
    337       1.10       cgd  */
    338       1.20  christos int
    339      1.155        ad vn_close(struct vnode *vp, int flags, kauth_cred_t cred)
    340       1.10       cgd {
    341       1.10       cgd 	int error;
    342       1.10       cgd 
    343      1.158        ad 	if (flags & FWRITE) {
    344  1.169.4.1     rmind 		mutex_enter(vp->v_interlock);
    345       1.10       cgd 		vp->v_writecount--;
    346  1.169.4.1     rmind 		mutex_exit(vp->v_interlock);
    347      1.158        ad 	}
    348      1.158        ad 	vn_lock(vp, LK_EXCLUSIVE | LK_RETRY);
    349      1.144     pooka 	error = VOP_CLOSE(vp, flags, cred);
    350       1.32  wrstuden 	vput(vp);
    351       1.10       cgd 	return (error);
    352       1.10       cgd }
    353       1.10       cgd 
    354  1.169.4.2     rmind static int
    355  1.169.4.2     rmind enforce_rlimit_fsize(struct vnode *vp, struct uio *uio, int ioflag)
    356  1.169.4.2     rmind {
    357  1.169.4.2     rmind 	struct lwp *l = curlwp;
    358  1.169.4.2     rmind 	off_t testoff;
    359  1.169.4.2     rmind 
    360  1.169.4.2     rmind 	if (uio->uio_rw != UIO_WRITE || vp->v_type != VREG)
    361  1.169.4.2     rmind 		return 0;
    362  1.169.4.2     rmind 
    363  1.169.4.2     rmind 	KASSERT(VOP_ISLOCKED(vp) == LK_EXCLUSIVE);
    364  1.169.4.2     rmind 	if (ioflag & IO_APPEND)
    365  1.169.4.2     rmind 		testoff = vp->v_size;
    366  1.169.4.2     rmind 	else
    367  1.169.4.2     rmind 		testoff = uio->uio_offset;
    368  1.169.4.2     rmind 
    369  1.169.4.2     rmind 	if (testoff + uio->uio_resid >
    370  1.169.4.2     rmind 	    l->l_proc->p_rlimit[RLIMIT_FSIZE].rlim_cur) {
    371  1.169.4.2     rmind 		mutex_enter(proc_lock);
    372  1.169.4.2     rmind 		psignal(l->l_proc, SIGXFSZ);
    373  1.169.4.2     rmind 		mutex_exit(proc_lock);
    374  1.169.4.2     rmind 		return EFBIG;
    375  1.169.4.2     rmind 	}
    376  1.169.4.2     rmind 
    377  1.169.4.2     rmind 	return 0;
    378  1.169.4.2     rmind }
    379  1.169.4.2     rmind 
    380       1.10       cgd /*
    381       1.10       cgd  * Package up an I/O request on a vnode into a uio and do it.
    382       1.10       cgd  */
    383       1.20  christos int
    384      1.134  christos vn_rdwr(enum uio_rw rw, struct vnode *vp, void *base, int len, off_t offset,
    385      1.111      elad     enum uio_seg segflg, int ioflg, kauth_cred_t cred, size_t *aresid,
    386      1.101  christos     struct lwp *l)
    387       1.10       cgd {
    388       1.10       cgd 	struct uio auio;
    389       1.10       cgd 	struct iovec aiov;
    390       1.10       cgd 	int error;
    391       1.10       cgd 
    392       1.50       chs 	if ((ioflg & IO_NODELOCKED) == 0) {
    393       1.50       chs 		if (rw == UIO_READ) {
    394       1.50       chs 			vn_lock(vp, LK_SHARED | LK_RETRY);
    395       1.75   hannken 		} else /* UIO_WRITE */ {
    396       1.50       chs 			vn_lock(vp, LK_EXCLUSIVE | LK_RETRY);
    397       1.50       chs 		}
    398       1.50       chs 	}
    399       1.10       cgd 	auio.uio_iov = &aiov;
    400       1.10       cgd 	auio.uio_iovcnt = 1;
    401       1.10       cgd 	aiov.iov_base = base;
    402       1.10       cgd 	aiov.iov_len = len;
    403       1.10       cgd 	auio.uio_resid = len;
    404       1.10       cgd 	auio.uio_offset = offset;
    405       1.10       cgd 	auio.uio_rw = rw;
    406      1.106      yamt 	if (segflg == UIO_SYSSPACE) {
    407      1.106      yamt 		UIO_SETUP_SYSSPACE(&auio);
    408      1.106      yamt 	} else {
    409      1.106      yamt 		auio.uio_vmspace = l->l_proc->p_vmspace;
    410      1.106      yamt 	}
    411  1.169.4.2     rmind 
    412  1.169.4.2     rmind 	if ((error = enforce_rlimit_fsize(vp, &auio, ioflg)) != 0)
    413  1.169.4.2     rmind 		goto out;
    414  1.169.4.2     rmind 
    415       1.11   mycroft 	if (rw == UIO_READ) {
    416       1.10       cgd 		error = VOP_READ(vp, &auio, ioflg, cred);
    417       1.11   mycroft 	} else {
    418       1.10       cgd 		error = VOP_WRITE(vp, &auio, ioflg, cred);
    419       1.11   mycroft 	}
    420  1.169.4.2     rmind 
    421       1.10       cgd 	if (aresid)
    422       1.10       cgd 		*aresid = auio.uio_resid;
    423       1.10       cgd 	else
    424       1.10       cgd 		if (auio.uio_resid && error == 0)
    425       1.10       cgd 			error = EIO;
    426  1.169.4.2     rmind 
    427  1.169.4.2     rmind  out:
    428       1.75   hannken 	if ((ioflg & IO_NODELOCKED) == 0) {
    429       1.28      fvdl 		VOP_UNLOCK(vp, 0);
    430       1.75   hannken 	}
    431       1.10       cgd 	return (error);
    432       1.23      fvdl }
    433       1.23      fvdl 
    434       1.23      fvdl int
    435      1.155        ad vn_readdir(file_t *fp, char *bf, int segflg, u_int count, int *done,
    436      1.101  christos     struct lwp *l, off_t **cookies, int *ncookies)
    437       1.23      fvdl {
    438       1.23      fvdl 	struct vnode *vp = (struct vnode *)fp->f_data;
    439       1.23      fvdl 	struct iovec aiov;
    440       1.23      fvdl 	struct uio auio;
    441       1.23      fvdl 	int error, eofflag;
    442       1.23      fvdl 
    443      1.112    simonb 	/* Limit the size on any kernel buffers used by VOP_READDIR */
    444      1.112    simonb 	count = min(MAXBSIZE, count);
    445      1.112    simonb 
    446       1.23      fvdl unionread:
    447       1.23      fvdl 	if (vp->v_type != VDIR)
    448       1.23      fvdl 		return (EINVAL);
    449       1.88  christos 	aiov.iov_base = bf;
    450       1.23      fvdl 	aiov.iov_len = count;
    451       1.23      fvdl 	auio.uio_iov = &aiov;
    452       1.23      fvdl 	auio.uio_iovcnt = 1;
    453       1.23      fvdl 	auio.uio_rw = UIO_READ;
    454      1.106      yamt 	if (segflg == UIO_SYSSPACE) {
    455      1.106      yamt 		UIO_SETUP_SYSSPACE(&auio);
    456      1.106      yamt 	} else {
    457      1.106      yamt 		KASSERT(l == curlwp);
    458      1.106      yamt 		auio.uio_vmspace = l->l_proc->p_vmspace;
    459      1.106      yamt 	}
    460       1.23      fvdl 	auio.uio_resid = count;
    461       1.50       chs 	vn_lock(vp, LK_SHARED | LK_RETRY);
    462       1.23      fvdl 	auio.uio_offset = fp->f_offset;
    463       1.28      fvdl 	error = VOP_READDIR(vp, &auio, fp->f_cred, &eofflag, cookies,
    464       1.23      fvdl 		    ncookies);
    465      1.166      yamt 	mutex_enter(&fp->f_lock);
    466       1.23      fvdl 	fp->f_offset = auio.uio_offset;
    467      1.166      yamt 	mutex_exit(&fp->f_lock);
    468       1.28      fvdl 	VOP_UNLOCK(vp, 0);
    469       1.23      fvdl 	if (error)
    470       1.23      fvdl 		return (error);
    471       1.23      fvdl 
    472       1.66  jdolecek 	if (count == auio.uio_resid && vn_union_readdir_hook) {
    473       1.66  jdolecek 		struct vnode *ovp = vp;
    474       1.23      fvdl 
    475      1.101  christos 		error = (*vn_union_readdir_hook)(&vp, fp, l);
    476       1.66  jdolecek 		if (error)
    477       1.66  jdolecek 			return (error);
    478       1.66  jdolecek 		if (vp != ovp)
    479       1.23      fvdl 			goto unionread;
    480       1.23      fvdl 	}
    481       1.23      fvdl 
    482      1.143        ad 	if (count == auio.uio_resid && (vp->v_vflag & VV_ROOT) &&
    483       1.23      fvdl 	    (vp->v_mount->mnt_flag & MNT_UNION)) {
    484       1.23      fvdl 		struct vnode *tvp = vp;
    485       1.23      fvdl 		vp = vp->v_mount->mnt_vnodecovered;
    486      1.169     pooka 		vref(vp);
    487      1.166      yamt 		mutex_enter(&fp->f_lock);
    488       1.68       dsl 		fp->f_data = vp;
    489       1.23      fvdl 		fp->f_offset = 0;
    490      1.166      yamt 		mutex_exit(&fp->f_lock);
    491       1.23      fvdl 		vrele(tvp);
    492       1.23      fvdl 		goto unionread;
    493       1.23      fvdl 	}
    494       1.23      fvdl 	*done = count - auio.uio_resid;
    495       1.23      fvdl 	return error;
    496       1.10       cgd }
    497       1.10       cgd 
    498       1.10       cgd /*
    499       1.10       cgd  * File table vnode read routine.
    500       1.10       cgd  */
    501       1.56  gmcgarry static int
    502      1.155        ad vn_read(file_t *fp, off_t *offset, struct uio *uio, kauth_cred_t cred,
    503       1.89   thorpej     int flags)
    504       1.10       cgd {
    505       1.28      fvdl 	struct vnode *vp = (struct vnode *)fp->f_data;
    506      1.155        ad 	int count, error, ioflag, fflag;
    507       1.10       cgd 
    508      1.100      yamt 	ioflag = IO_ADV_ENCODE(fp->f_advice);
    509      1.155        ad 	fflag = fp->f_flag;
    510      1.155        ad 	if (fflag & FNONBLOCK)
    511       1.31    kleink 		ioflag |= IO_NDELAY;
    512      1.155        ad 	if ((fflag & (FFSYNC | FRSYNC)) == (FFSYNC | FRSYNC))
    513       1.31    kleink 		ioflag |= IO_SYNC;
    514      1.155        ad 	if (fflag & FALTIO)
    515       1.37  wrstuden 		ioflag |= IO_ALTSEMANTICS;
    516      1.155        ad 	if (fflag & FDIRECT)
    517      1.125       chs 		ioflag |= IO_DIRECT;
    518       1.50       chs 	vn_lock(vp, LK_SHARED | LK_RETRY);
    519       1.29   thorpej 	uio->uio_offset = *offset;
    520       1.10       cgd 	count = uio->uio_resid;
    521       1.31    kleink 	error = VOP_READ(vp, uio, ioflag, cred);
    522       1.29   thorpej 	if (flags & FOF_UPDATE_OFFSET)
    523       1.29   thorpej 		*offset += count - uio->uio_resid;
    524       1.28      fvdl 	VOP_UNLOCK(vp, 0);
    525       1.10       cgd 	return (error);
    526       1.10       cgd }
    527       1.10       cgd 
    528       1.10       cgd /*
    529       1.10       cgd  * File table vnode write routine.
    530       1.10       cgd  */
    531       1.56  gmcgarry static int
    532      1.155        ad vn_write(file_t *fp, off_t *offset, struct uio *uio, kauth_cred_t cred,
    533       1.89   thorpej     int flags)
    534       1.10       cgd {
    535       1.28      fvdl 	struct vnode *vp = (struct vnode *)fp->f_data;
    536      1.155        ad 	int count, error, ioflag, fflag;
    537       1.10       cgd 
    538      1.151     pooka 	ioflag = IO_ADV_ENCODE(fp->f_advice) | IO_UNIT;
    539      1.155        ad 	fflag = fp->f_flag;
    540      1.155        ad 	if (vp->v_type == VREG && (fflag & O_APPEND))
    541       1.10       cgd 		ioflag |= IO_APPEND;
    542      1.155        ad 	if (fflag & FNONBLOCK)
    543       1.10       cgd 		ioflag |= IO_NDELAY;
    544      1.155        ad 	if (fflag & FFSYNC ||
    545       1.24   thorpej 	    (vp->v_mount && (vp->v_mount->mnt_flag & MNT_SYNCHRONOUS)))
    546       1.24   thorpej 		ioflag |= IO_SYNC;
    547      1.155        ad 	else if (fflag & FDSYNC)
    548       1.31    kleink 		ioflag |= IO_DSYNC;
    549      1.155        ad 	if (fflag & FALTIO)
    550       1.37  wrstuden 		ioflag |= IO_ALTSEMANTICS;
    551      1.155        ad 	if (fflag & FDIRECT)
    552      1.125       chs 		ioflag |= IO_DIRECT;
    553       1.28      fvdl 	vn_lock(vp, LK_EXCLUSIVE | LK_RETRY);
    554       1.29   thorpej 	uio->uio_offset = *offset;
    555       1.10       cgd 	count = uio->uio_resid;
    556  1.169.4.2     rmind 
    557  1.169.4.2     rmind 	if ((error = enforce_rlimit_fsize(vp, uio, ioflag)) != 0)
    558  1.169.4.2     rmind 		goto out;
    559  1.169.4.2     rmind 
    560       1.10       cgd 	error = VOP_WRITE(vp, uio, ioflag, cred);
    561  1.169.4.2     rmind 
    562       1.29   thorpej 	if (flags & FOF_UPDATE_OFFSET) {
    563      1.160  christos 		if (ioflag & IO_APPEND) {
    564      1.160  christos 			/*
    565      1.160  christos 			 * SUSv3 describes behaviour for count = 0 as following:
    566      1.160  christos 			 * "Before any action ... is taken, and if nbyte is zero
    567      1.160  christos 			 * and the file is a regular file, the write() function
    568      1.160  christos 			 * ... in the absence of errors ... shall return zero
    569      1.160  christos 			 * and have no other results."
    570      1.160  christos 			 */
    571      1.160  christos 			if (count)
    572      1.160  christos 				*offset = uio->uio_offset;
    573      1.160  christos 		} else
    574       1.29   thorpej 			*offset += count - uio->uio_resid;
    575       1.29   thorpej 	}
    576  1.169.4.2     rmind 
    577  1.169.4.2     rmind  out:
    578       1.28      fvdl 	VOP_UNLOCK(vp, 0);
    579       1.10       cgd 	return (error);
    580       1.10       cgd }
    581       1.10       cgd 
    582       1.10       cgd /*
    583       1.10       cgd  * File table vnode stat routine.
    584       1.10       cgd  */
    585       1.48  jdolecek static int
    586      1.155        ad vn_statfile(file_t *fp, struct stat *sb)
    587       1.48  jdolecek {
    588      1.165  christos 	struct vnode *vp = fp->f_data;
    589      1.165  christos 	int error;
    590       1.48  jdolecek 
    591      1.165  christos 	vn_lock(vp, LK_EXCLUSIVE | LK_RETRY);
    592      1.165  christos 	error = vn_stat(vp, sb);
    593      1.165  christos 	VOP_UNLOCK(vp, 0);
    594      1.165  christos 	return error;
    595       1.48  jdolecek }
    596       1.48  jdolecek 
    597       1.20  christos int
    598      1.155        ad vn_stat(struct vnode *vp, struct stat *sb)
    599       1.10       cgd {
    600       1.19   mycroft 	struct vattr va;
    601       1.10       cgd 	int error;
    602       1.35  wrstuden 	mode_t mode;
    603       1.10       cgd 
    604      1.155        ad 	error = VOP_GETATTR(vp, &va, kauth_cred_get());
    605       1.10       cgd 	if (error)
    606       1.10       cgd 		return (error);
    607       1.10       cgd 	/*
    608       1.10       cgd 	 * Copy from vattr table
    609       1.10       cgd 	 */
    610       1.19   mycroft 	sb->st_dev = va.va_fsid;
    611       1.19   mycroft 	sb->st_ino = va.va_fileid;
    612       1.19   mycroft 	mode = va.va_mode;
    613       1.10       cgd 	switch (vp->v_type) {
    614       1.10       cgd 	case VREG:
    615       1.10       cgd 		mode |= S_IFREG;
    616       1.10       cgd 		break;
    617       1.10       cgd 	case VDIR:
    618       1.10       cgd 		mode |= S_IFDIR;
    619       1.10       cgd 		break;
    620       1.10       cgd 	case VBLK:
    621       1.10       cgd 		mode |= S_IFBLK;
    622       1.10       cgd 		break;
    623       1.10       cgd 	case VCHR:
    624       1.10       cgd 		mode |= S_IFCHR;
    625       1.10       cgd 		break;
    626       1.10       cgd 	case VLNK:
    627       1.10       cgd 		mode |= S_IFLNK;
    628       1.10       cgd 		break;
    629       1.10       cgd 	case VSOCK:
    630       1.10       cgd 		mode |= S_IFSOCK;
    631       1.10       cgd 		break;
    632       1.10       cgd 	case VFIFO:
    633       1.10       cgd 		mode |= S_IFIFO;
    634       1.10       cgd 		break;
    635       1.10       cgd 	default:
    636       1.10       cgd 		return (EBADF);
    637       1.10       cgd 	};
    638       1.10       cgd 	sb->st_mode = mode;
    639       1.19   mycroft 	sb->st_nlink = va.va_nlink;
    640       1.19   mycroft 	sb->st_uid = va.va_uid;
    641       1.19   mycroft 	sb->st_gid = va.va_gid;
    642       1.19   mycroft 	sb->st_rdev = va.va_rdev;
    643       1.19   mycroft 	sb->st_size = va.va_size;
    644       1.19   mycroft 	sb->st_atimespec = va.va_atime;
    645       1.19   mycroft 	sb->st_mtimespec = va.va_mtime;
    646       1.19   mycroft 	sb->st_ctimespec = va.va_ctime;
    647       1.69      fvdl 	sb->st_birthtimespec = va.va_birthtime;
    648       1.19   mycroft 	sb->st_blksize = va.va_blocksize;
    649       1.19   mycroft 	sb->st_flags = va.va_flags;
    650       1.22   mycroft 	sb->st_gen = 0;
    651       1.19   mycroft 	sb->st_blocks = va.va_bytes / S_BLKSIZE;
    652       1.10       cgd 	return (0);
    653       1.37  wrstuden }
    654       1.37  wrstuden 
    655       1.37  wrstuden /*
    656       1.37  wrstuden  * File table vnode fcntl routine.
    657       1.37  wrstuden  */
    658       1.56  gmcgarry static int
    659      1.155        ad vn_fcntl(file_t *fp, u_int com, void *data)
    660       1.37  wrstuden {
    661      1.155        ad 	struct vnode *vp = fp->f_data;
    662       1.37  wrstuden 	int error;
    663       1.37  wrstuden 
    664      1.155        ad 	error = VOP_FCNTL(vp, com, data, fp->f_flag, kauth_cred_get());
    665       1.37  wrstuden 	return (error);
    666       1.10       cgd }
    667       1.10       cgd 
    668       1.10       cgd /*
    669       1.10       cgd  * File table vnode ioctl routine.
    670       1.10       cgd  */
    671       1.56  gmcgarry static int
    672      1.155        ad vn_ioctl(file_t *fp, u_long com, void *data)
    673       1.10       cgd {
    674      1.155        ad 	struct vnode *vp = fp->f_data, *ovp;
    675       1.10       cgd 	struct vattr vattr;
    676       1.10       cgd 	int error;
    677       1.10       cgd 
    678       1.10       cgd 	switch (vp->v_type) {
    679       1.10       cgd 
    680       1.10       cgd 	case VREG:
    681       1.10       cgd 	case VDIR:
    682       1.10       cgd 		if (com == FIONREAD) {
    683      1.155        ad 			error = VOP_GETATTR(vp, &vattr,
    684      1.155        ad 			    kauth_cred_get());
    685       1.20  christos 			if (error)
    686       1.10       cgd 				return (error);
    687       1.10       cgd 			*(int *)data = vattr.va_size - fp->f_offset;
    688       1.10       cgd 			return (0);
    689       1.60    atatat 		}
    690       1.82  christos 		if ((com == FIONWRITE) || (com == FIONSPACE)) {
    691       1.81  wrstuden 			/*
    692       1.81  wrstuden 			 * Files don't have send queues, so there never
    693       1.81  wrstuden 			 * are any bytes in them, nor is there any
    694       1.81  wrstuden 			 * open space in them.
    695       1.81  wrstuden 			 */
    696       1.81  wrstuden 			*(int *)data = 0;
    697       1.81  wrstuden 			return (0);
    698       1.81  wrstuden 		}
    699       1.60    atatat 		if (com == FIOGETBMAP) {
    700       1.60    atatat 			daddr_t *block;
    701       1.60    atatat 
    702       1.62    atatat 			if (*(daddr_t *)data < 0)
    703       1.62    atatat 				return (EINVAL);
    704       1.60    atatat 			block = (daddr_t *)data;
    705       1.60    atatat 			return (VOP_BMAP(vp, *block, NULL, block, NULL));
    706       1.61      fvdl 		}
    707       1.61      fvdl 		if (com == OFIOGETBMAP) {
    708       1.61      fvdl 			daddr_t ibn, obn;
    709       1.61      fvdl 
    710       1.62    atatat 			if (*(int32_t *)data < 0)
    711       1.62    atatat 				return (EINVAL);
    712       1.61      fvdl 			ibn = (daddr_t)*(int32_t *)data;
    713       1.61      fvdl 			error = VOP_BMAP(vp, ibn, NULL, &obn, NULL);
    714       1.61      fvdl 			*(int32_t *)data = (int32_t)obn;
    715       1.61      fvdl 			return error;
    716       1.10       cgd 		}
    717       1.10       cgd 		if (com == FIONBIO || com == FIOASYNC)	/* XXX */
    718       1.10       cgd 			return (0);			/* XXX */
    719       1.10       cgd 		/* fall into ... */
    720       1.10       cgd 	case VFIFO:
    721       1.10       cgd 	case VCHR:
    722       1.10       cgd 	case VBLK:
    723      1.155        ad 		error = VOP_IOCTL(vp, com, data, fp->f_flag,
    724      1.155        ad 		    kauth_cred_get());
    725       1.10       cgd 		if (error == 0 && com == TIOCSCTTY) {
    726      1.169     pooka 			vref(vp);
    727      1.156        ad 			mutex_enter(proc_lock);
    728      1.155        ad 			ovp = curproc->p_session->s_ttyvp;
    729      1.155        ad 			curproc->p_session->s_ttyvp = vp;
    730      1.156        ad 			mutex_exit(proc_lock);
    731      1.132        ad 			if (ovp != NULL)
    732      1.132        ad 				vrele(ovp);
    733       1.10       cgd 		}
    734       1.10       cgd 		return (error);
    735       1.63  perseant 
    736       1.63  perseant 	default:
    737       1.63  perseant 		return (EPASSTHROUGH);
    738       1.10       cgd 	}
    739       1.10       cgd }
    740       1.10       cgd 
    741       1.10       cgd /*
    742       1.21   mycroft  * File table vnode poll routine.
    743       1.10       cgd  */
    744       1.56  gmcgarry static int
    745      1.155        ad vn_poll(file_t *fp, int events)
    746       1.10       cgd {
    747       1.10       cgd 
    748      1.155        ad 	return (VOP_POLL(fp->f_data, events));
    749       1.57  jdolecek }
    750       1.57  jdolecek 
    751       1.57  jdolecek /*
    752       1.57  jdolecek  * File table vnode kqfilter routine.
    753       1.57  jdolecek  */
    754       1.57  jdolecek int
    755      1.155        ad vn_kqfilter(file_t *fp, struct knote *kn)
    756       1.57  jdolecek {
    757       1.57  jdolecek 
    758      1.155        ad 	return (VOP_KQFILTER(fp->f_data, kn));
    759       1.28      fvdl }
    760       1.28      fvdl 
    761       1.28      fvdl /*
    762       1.28      fvdl  * Check that the vnode is still valid, and if so
    763       1.28      fvdl  * acquire requested lock.
    764       1.28      fvdl  */
    765       1.28      fvdl int
    766       1.89   thorpej vn_lock(struct vnode *vp, int flags)
    767       1.28      fvdl {
    768       1.28      fvdl 	int error;
    769       1.34  sommerfe 
    770       1.84      yamt #if 0
    771       1.80      yamt 	KASSERT(vp->v_usecount > 0 || (flags & LK_INTERLOCK) != 0
    772      1.143        ad 	    || (vp->v_iflag & VI_ONWORKLST) != 0);
    773       1.84      yamt #endif
    774      1.103      yamt 	KASSERT((flags &
    775      1.149        ad 	    ~(LK_INTERLOCK|LK_SHARED|LK_EXCLUSIVE|LK_NOWAIT|LK_RETRY|
    776      1.149        ad 	    LK_CANRECURSE))
    777      1.103      yamt 	    == 0);
    778       1.80      yamt 
    779      1.159    simonb #ifdef DIAGNOSTIC
    780      1.159    simonb 	if (wapbl_vphaswapbl(vp))
    781      1.159    simonb 		WAPBL_JUNLOCK_ASSERT(wapbl_vptomp(vp));
    782      1.159    simonb #endif
    783      1.159    simonb 
    784       1.28      fvdl 	do {
    785      1.157        ad 		/*
    786      1.157        ad 		 * XXX PR 37706 forced unmount of file systems is unsafe.
    787      1.157        ad 		 * Race between vclean() and this the remaining problem.
    788      1.157        ad 		 */
    789      1.143        ad 		if (vp->v_iflag & VI_XLOCK) {
    790      1.157        ad 			if ((flags & LK_INTERLOCK) == 0) {
    791  1.169.4.1     rmind 				mutex_enter(vp->v_interlock);
    792      1.157        ad 			}
    793      1.157        ad 			flags &= ~LK_INTERLOCK;
    794       1.49       chs 			if (flags & LK_NOWAIT) {
    795  1.169.4.1     rmind 				mutex_exit(vp->v_interlock);
    796       1.49       chs 				return EBUSY;
    797       1.49       chs 			}
    798      1.149        ad 			vwait(vp, VI_XLOCK);
    799  1.169.4.1     rmind 			mutex_exit(vp->v_interlock);
    800       1.28      fvdl 			error = ENOENT;
    801       1.28      fvdl 		} else {
    802      1.157        ad 			if ((flags & LK_INTERLOCK) != 0) {
    803  1.169.4.1     rmind 				mutex_exit(vp->v_interlock);
    804      1.157        ad 			}
    805      1.157        ad 			flags &= ~LK_INTERLOCK;
    806      1.157        ad 			error = VOP_LOCK(vp, (flags & ~LK_RETRY));
    807       1.49       chs 			if (error == 0 || error == EDEADLK || error == EBUSY)
    808       1.28      fvdl 				return (error);
    809       1.28      fvdl 		}
    810       1.28      fvdl 	} while (flags & LK_RETRY);
    811       1.28      fvdl 	return (error);
    812       1.10       cgd }
    813       1.10       cgd 
    814       1.10       cgd /*
    815       1.10       cgd  * File table vnode close routine.
    816       1.10       cgd  */
    817       1.56  gmcgarry static int
    818      1.155        ad vn_closefile(file_t *fp)
    819       1.10       cgd {
    820       1.10       cgd 
    821      1.155        ad 	return vn_close(fp->f_data, fp->f_flag, fp->f_cred);
    822       1.39      fvdl }
    823       1.39      fvdl 
    824       1.39      fvdl /*
    825       1.39      fvdl  * Enable LK_CANRECURSE on lock. Return prior status.
    826       1.39      fvdl  */
    827       1.39      fvdl u_int
    828       1.89   thorpej vn_setrecurse(struct vnode *vp)
    829       1.39      fvdl {
    830      1.154        ad 	struct vnlock *lkp;
    831       1.39      fvdl 
    832      1.153        ad 	lkp = (vp->v_vnlock != NULL ? vp->v_vnlock : &vp->v_lock);
    833      1.154        ad 	atomic_inc_uint(&lkp->vl_canrecurse);
    834      1.153        ad 
    835      1.154        ad 	return 0;
    836       1.39      fvdl }
    837       1.39      fvdl 
    838       1.39      fvdl /*
    839       1.39      fvdl  * Called when done with locksetrecurse.
    840       1.39      fvdl  */
    841       1.39      fvdl void
    842       1.89   thorpej vn_restorerecurse(struct vnode *vp, u_int flags)
    843       1.39      fvdl {
    844      1.154        ad 	struct vnlock *lkp;
    845      1.153        ad 
    846      1.153        ad 	lkp = (vp->v_vnlock != NULL ? vp->v_vnlock : &vp->v_lock);
    847      1.154        ad 	atomic_dec_uint(&lkp->vl_canrecurse);
    848       1.75   hannken }
    849       1.77   hannken 
    850      1.141   hannken /*
    851       1.85   thorpej  * Simplified in-kernel wrapper calls for extended attribute access.
    852       1.85   thorpej  * Both calls pass in a NULL credential, authorizing a "kernel" access.
    853       1.85   thorpej  * Set IO_NODELOCKED in ioflg if the vnode is already locked.
    854       1.85   thorpej  */
    855       1.85   thorpej int
    856       1.85   thorpej vn_extattr_get(struct vnode *vp, int ioflg, int attrnamespace,
    857      1.101  christos     const char *attrname, size_t *buflen, void *bf, struct lwp *l)
    858       1.85   thorpej {
    859       1.85   thorpej 	struct uio auio;
    860       1.85   thorpej 	struct iovec aiov;
    861       1.85   thorpej 	int error;
    862       1.85   thorpej 
    863       1.85   thorpej 	aiov.iov_len = *buflen;
    864       1.88  christos 	aiov.iov_base = bf;
    865       1.85   thorpej 
    866       1.85   thorpej 	auio.uio_iov = &aiov;
    867       1.85   thorpej 	auio.uio_iovcnt = 1;
    868       1.85   thorpej 	auio.uio_rw = UIO_READ;
    869       1.85   thorpej 	auio.uio_offset = 0;
    870       1.85   thorpej 	auio.uio_resid = *buflen;
    871      1.106      yamt 	UIO_SETUP_SYSSPACE(&auio);
    872       1.85   thorpej 
    873       1.85   thorpej 	if ((ioflg & IO_NODELOCKED) == 0)
    874       1.85   thorpej 		vn_lock(vp, LK_EXCLUSIVE | LK_RETRY);
    875       1.86     perry 
    876      1.144     pooka 	error = VOP_GETEXTATTR(vp, attrnamespace, attrname, &auio, NULL, NULL);
    877       1.86     perry 
    878       1.85   thorpej 	if ((ioflg & IO_NODELOCKED) == 0)
    879       1.85   thorpej 		VOP_UNLOCK(vp, 0);
    880       1.86     perry 
    881       1.85   thorpej 	if (error == 0)
    882       1.85   thorpej 		*buflen = *buflen - auio.uio_resid;
    883       1.86     perry 
    884       1.85   thorpej 	return (error);
    885       1.85   thorpej }
    886       1.85   thorpej 
    887       1.85   thorpej /*
    888       1.85   thorpej  * XXX Failure mode if partially written?
    889       1.85   thorpej  */
    890       1.85   thorpej int
    891       1.85   thorpej vn_extattr_set(struct vnode *vp, int ioflg, int attrnamespace,
    892      1.101  christos     const char *attrname, size_t buflen, const void *bf, struct lwp *l)
    893       1.85   thorpej {
    894       1.85   thorpej 	struct uio auio;
    895       1.85   thorpej 	struct iovec aiov;
    896       1.85   thorpej 	int error;
    897       1.85   thorpej 
    898       1.85   thorpej 	aiov.iov_len = buflen;
    899       1.88  christos 	aiov.iov_base = __UNCONST(bf);		/* XXXUNCONST kills const */
    900       1.85   thorpej 
    901       1.85   thorpej 	auio.uio_iov = &aiov;
    902       1.85   thorpej 	auio.uio_iovcnt = 1;
    903       1.85   thorpej 	auio.uio_rw = UIO_WRITE;
    904       1.85   thorpej 	auio.uio_offset = 0;
    905       1.85   thorpej 	auio.uio_resid = buflen;
    906      1.106      yamt 	UIO_SETUP_SYSSPACE(&auio);
    907       1.85   thorpej 
    908       1.85   thorpej 	if ((ioflg & IO_NODELOCKED) == 0) {
    909       1.85   thorpej 		vn_lock(vp, LK_EXCLUSIVE | LK_RETRY);
    910       1.85   thorpej 	}
    911       1.85   thorpej 
    912      1.144     pooka 	error = VOP_SETEXTATTR(vp, attrnamespace, attrname, &auio, NULL);
    913       1.85   thorpej 
    914       1.85   thorpej 	if ((ioflg & IO_NODELOCKED) == 0) {
    915       1.85   thorpej 		VOP_UNLOCK(vp, 0);
    916       1.85   thorpej 	}
    917       1.85   thorpej 
    918       1.85   thorpej 	return (error);
    919       1.85   thorpej }
    920       1.85   thorpej 
    921       1.85   thorpej int
    922       1.85   thorpej vn_extattr_rm(struct vnode *vp, int ioflg, int attrnamespace,
    923      1.101  christos     const char *attrname, struct lwp *l)
    924       1.85   thorpej {
    925       1.85   thorpej 	int error;
    926       1.85   thorpej 
    927       1.85   thorpej 	if ((ioflg & IO_NODELOCKED) == 0) {
    928       1.85   thorpej 		vn_lock(vp, LK_EXCLUSIVE | LK_RETRY);
    929       1.85   thorpej 	}
    930       1.85   thorpej 
    931      1.144     pooka 	error = VOP_DELETEEXTATTR(vp, attrnamespace, attrname, NULL);
    932       1.85   thorpej 	if (error == EOPNOTSUPP)
    933      1.144     pooka 		error = VOP_SETEXTATTR(vp, attrnamespace, attrname, NULL, NULL);
    934       1.86     perry 
    935       1.85   thorpej 	if ((ioflg & IO_NODELOCKED) == 0) {
    936       1.85   thorpej 		VOP_UNLOCK(vp, 0);
    937       1.85   thorpej 	}
    938       1.85   thorpej 
    939       1.85   thorpej 	return (error);
    940       1.85   thorpej }
    941       1.95      yamt 
    942      1.100      yamt void
    943      1.100      yamt vn_ra_allocctx(struct vnode *vp)
    944      1.100      yamt {
    945      1.100      yamt 	struct uvm_ractx *ra = NULL;
    946      1.100      yamt 
    947  1.169.4.1     rmind 	KASSERT(mutex_owned(vp->v_interlock));
    948      1.149        ad 
    949      1.100      yamt 	if (vp->v_type != VREG) {
    950      1.100      yamt 		return;
    951      1.100      yamt 	}
    952      1.100      yamt 	if (vp->v_ractx != NULL) {
    953      1.100      yamt 		return;
    954      1.100      yamt 	}
    955      1.100      yamt 	if (vp->v_ractx == NULL) {
    956  1.169.4.1     rmind 		mutex_exit(vp->v_interlock);
    957      1.100      yamt 		ra = uvm_ra_allocctx();
    958  1.169.4.1     rmind 		mutex_enter(vp->v_interlock);
    959      1.100      yamt 		if (ra != NULL && vp->v_ractx == NULL) {
    960      1.100      yamt 			vp->v_ractx = ra;
    961      1.100      yamt 			ra = NULL;
    962      1.100      yamt 		}
    963      1.100      yamt 	}
    964      1.100      yamt 	if (ra != NULL) {
    965      1.100      yamt 		uvm_ra_freectx(ra);
    966      1.100      yamt 	}
    967      1.100      yamt }
    968  1.169.4.2     rmind 
    969  1.169.4.2     rmind int
    970  1.169.4.2     rmind vn_fifo_bypass(void *v)
    971  1.169.4.2     rmind {
    972  1.169.4.2     rmind 	struct vop_generic_args *ap = v;
    973  1.169.4.2     rmind 
    974  1.169.4.2     rmind 	return VOCALL(fifo_vnodeop_p, ap->a_desc->vdesc_offset, v);
    975  1.169.4.2     rmind }
    976