Home | History | Annotate | Line # | Download | only in kern
vfs_vnops.c revision 1.169.2.4
      1  1.169.2.4  uebayasi /*	$NetBSD: vfs_vnops.c,v 1.169.2.4 2010/11/06 08:08:44 uebayasi 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.2.4  uebayasi __KERNEL_RCSID(0, "$NetBSD: vfs_vnops.c,v 1.169.2.4 2010/11/06 08:08:44 uebayasi 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.2.1  uebayasi #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.169.2.3  uebayasi 	if ((fmode & (O_CREAT | O_DIRECTORY)) == (O_CREAT | O_DIRECTORY))
    144  1.169.2.3  uebayasi 		return EINVAL;
    145  1.169.2.3  uebayasi 
    146      1.163     enami 	ndp->ni_cnd.cn_flags &= TRYEMULROOT | NOCHROOT;
    147      1.138       dsl 
    148       1.10       cgd 	if (fmode & O_CREAT) {
    149       1.11   mycroft 		ndp->ni_cnd.cn_nameiop = CREATE;
    150      1.138       dsl 		ndp->ni_cnd.cn_flags |= LOCKPARENT | LOCKLEAF;
    151       1.38    bouyer 		if ((fmode & O_EXCL) == 0 &&
    152       1.59  christos 		    ((fmode & O_NOFOLLOW) == 0))
    153       1.11   mycroft 			ndp->ni_cnd.cn_flags |= FOLLOW;
    154      1.130      elad 	} else {
    155      1.130      elad 		ndp->ni_cnd.cn_nameiop = LOOKUP;
    156      1.138       dsl 		ndp->ni_cnd.cn_flags |= LOCKLEAF;
    157      1.130      elad 		if ((fmode & O_NOFOLLOW) == 0)
    158      1.130      elad 			ndp->ni_cnd.cn_flags |= FOLLOW;
    159      1.130      elad 	}
    160      1.139  christos 
    161      1.139  christos 	VERIEXEC_PATH_GET(ndp->ni_dirp, ndp->ni_segflg, ndp->ni_dirp, path);
    162      1.139  christos 
    163      1.130      elad 	error = namei(ndp);
    164      1.130      elad 	if (error)
    165      1.139  christos 		goto out;
    166       1.91      elad 
    167      1.130      elad 	vp = ndp->ni_vp;
    168       1.91      elad 
    169      1.130      elad #if NVERIEXEC > 0
    170      1.130      elad 	error = veriexec_openchk(l, ndp->ni_vp, ndp->ni_dirp, fmode);
    171      1.130      elad 	if (error)
    172      1.130      elad 		goto bad;
    173      1.115      elad #endif /* NVERIEXEC > 0 */
    174       1.91      elad 
    175      1.130      elad 	if (fmode & O_CREAT) {
    176      1.130      elad 		if (ndp->ni_vp == NULL) {
    177      1.169     pooka 			vattr_null(&va);
    178       1.19   mycroft 			va.va_type = VREG;
    179       1.19   mycroft 			va.va_mode = cmode;
    180       1.28      fvdl 			if (fmode & O_EXCL)
    181       1.28      fvdl 				 va.va_vaflags |= VA_EXCLUSIVE;
    182       1.20  christos 			error = VOP_CREATE(ndp->ni_dvp, &ndp->ni_vp,
    183       1.20  christos 					   &ndp->ni_cnd, &va);
    184       1.20  christos 			if (error)
    185      1.139  christos 				goto out;
    186       1.10       cgd 			fmode &= ~O_TRUNC;
    187       1.10       cgd 			vp = ndp->ni_vp;
    188       1.10       cgd 		} else {
    189       1.11   mycroft 			VOP_ABORTOP(ndp->ni_dvp, &ndp->ni_cnd);
    190       1.10       cgd 			if (ndp->ni_dvp == ndp->ni_vp)
    191       1.10       cgd 				vrele(ndp->ni_dvp);
    192       1.10       cgd 			else
    193       1.10       cgd 				vput(ndp->ni_dvp);
    194       1.10       cgd 			ndp->ni_dvp = NULL;
    195       1.10       cgd 			vp = ndp->ni_vp;
    196       1.10       cgd 			if (fmode & O_EXCL) {
    197       1.10       cgd 				error = EEXIST;
    198       1.38    bouyer 				goto bad;
    199       1.38    bouyer 			}
    200       1.10       cgd 			fmode &= ~O_CREAT;
    201       1.10       cgd 		}
    202       1.10       cgd 	} else {
    203       1.10       cgd 		vp = ndp->ni_vp;
    204       1.10       cgd 	}
    205       1.10       cgd 	if (vp->v_type == VSOCK) {
    206       1.10       cgd 		error = EOPNOTSUPP;
    207       1.74        cb 		goto bad;
    208       1.74        cb 	}
    209       1.74        cb 	if (ndp->ni_vp->v_type == VLNK) {
    210       1.74        cb 		error = EFTYPE;
    211       1.10       cgd 		goto bad;
    212       1.10       cgd 	}
    213       1.58     blymn 
    214       1.10       cgd 	if ((fmode & O_CREAT) == 0) {
    215      1.146      yamt 		error = vn_openchk(vp, cred, fmode);
    216      1.146      yamt 		if (error != 0)
    217      1.146      yamt 			goto bad;
    218       1.10       cgd 	}
    219       1.87     blymn 
    220       1.10       cgd 	if (fmode & O_TRUNC) {
    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.149        ad 		mutex_enter(&vp->v_interlock);
    231       1.10       cgd 		vp->v_writecount++;
    232      1.149        ad 		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.169.2.3  uebayasi 	if ((fflags & O_DIRECTORY) != 0 && vp->v_type != VDIR)
    267  1.169.2.3  uebayasi 		return ENOTDIR;
    268  1.169.2.3  uebayasi 
    269      1.146      yamt 	if ((fflags & FREAD) != 0) {
    270      1.146      yamt 		permbits = VREAD;
    271      1.146      yamt 	}
    272      1.146      yamt 	if ((fflags & (FWRITE | O_TRUNC)) != 0) {
    273      1.146      yamt 		permbits |= VWRITE;
    274      1.146      yamt 		if (vp->v_type == VDIR) {
    275      1.146      yamt 			error = EISDIR;
    276      1.146      yamt 			goto bad;
    277      1.146      yamt 		}
    278      1.146      yamt 		error = vn_writechk(vp);
    279      1.146      yamt 		if (error != 0)
    280      1.146      yamt 			goto bad;
    281      1.146      yamt 	}
    282      1.146      yamt 	error = VOP_ACCESS(vp, permbits, cred);
    283      1.146      yamt bad:
    284      1.146      yamt 	return error;
    285      1.146      yamt }
    286      1.146      yamt 
    287       1.42       chs /*
    288       1.51   thorpej  * Mark a vnode as having executable mappings.
    289       1.42       chs  */
    290       1.42       chs void
    291       1.89   thorpej vn_markexec(struct vnode *vp)
    292       1.42       chs {
    293      1.143        ad 
    294      1.158        ad 	if ((vp->v_iflag & VI_EXECMAP) != 0) {
    295      1.158        ad 		/* Safe unlocked, as long as caller holds a reference. */
    296      1.158        ad 		return;
    297      1.158        ad 	}
    298      1.143        ad 
    299      1.158        ad 	mutex_enter(&vp->v_interlock);
    300      1.143        ad 	if ((vp->v_iflag & VI_EXECMAP) == 0) {
    301      1.145        ad 		atomic_add_int(&uvmexp.filepages, -vp->v_uobj.uo_npages);
    302      1.145        ad 		atomic_add_int(&uvmexp.execpages, vp->v_uobj.uo_npages);
    303      1.158        ad 		vp->v_iflag |= VI_EXECMAP;
    304       1.46       chs 	}
    305      1.158        ad 	mutex_exit(&vp->v_interlock);
    306       1.55       chs }
    307       1.55       chs 
    308       1.55       chs /*
    309       1.55       chs  * Mark a vnode as being the text of a process.
    310       1.55       chs  * Fail if the vnode is currently writable.
    311       1.55       chs  */
    312       1.55       chs int
    313       1.89   thorpej vn_marktext(struct vnode *vp)
    314       1.55       chs {
    315       1.55       chs 
    316      1.157        ad 	if ((vp->v_iflag & (VI_TEXT|VI_EXECMAP)) == (VI_TEXT|VI_EXECMAP)) {
    317      1.157        ad 		/* Safe unlocked, as long as caller holds a reference. */
    318      1.158        ad 		return (0);
    319      1.157        ad 	}
    320      1.157        ad 
    321      1.149        ad 	mutex_enter(&vp->v_interlock);
    322       1.55       chs 	if (vp->v_writecount != 0) {
    323      1.143        ad 		KASSERT((vp->v_iflag & VI_TEXT) == 0);
    324      1.149        ad 		mutex_exit(&vp->v_interlock);
    325       1.55       chs 		return (ETXTBSY);
    326       1.55       chs 	}
    327      1.158        ad 	if ((vp->v_iflag & VI_EXECMAP) == 0) {
    328      1.158        ad 		atomic_add_int(&uvmexp.filepages, -vp->v_uobj.uo_npages);
    329      1.158        ad 		atomic_add_int(&uvmexp.execpages, vp->v_uobj.uo_npages);
    330      1.158        ad 	}
    331      1.158        ad 	vp->v_iflag |= (VI_TEXT | VI_EXECMAP);
    332      1.149        ad 	mutex_exit(&vp->v_interlock);
    333       1.55       chs 	return (0);
    334       1.10       cgd }
    335       1.10       cgd 
    336       1.10       cgd /*
    337       1.10       cgd  * Vnode close call
    338       1.32  wrstuden  *
    339       1.32  wrstuden  * Note: takes an unlocked vnode, while VOP_CLOSE takes a locked node.
    340       1.10       cgd  */
    341       1.20  christos int
    342      1.155        ad vn_close(struct vnode *vp, int flags, kauth_cred_t cred)
    343       1.10       cgd {
    344       1.10       cgd 	int error;
    345       1.10       cgd 
    346      1.158        ad 	if (flags & FWRITE) {
    347      1.158        ad 		mutex_enter(&vp->v_interlock);
    348       1.10       cgd 		vp->v_writecount--;
    349      1.158        ad 		mutex_exit(&vp->v_interlock);
    350      1.158        ad 	}
    351      1.158        ad 	vn_lock(vp, LK_EXCLUSIVE | LK_RETRY);
    352      1.144     pooka 	error = VOP_CLOSE(vp, flags, cred);
    353       1.32  wrstuden 	vput(vp);
    354       1.10       cgd 	return (error);
    355       1.10       cgd }
    356       1.10       cgd 
    357  1.169.2.1  uebayasi static int
    358  1.169.2.1  uebayasi enforce_rlimit_fsize(struct vnode *vp, struct uio *uio, int ioflag)
    359  1.169.2.1  uebayasi {
    360  1.169.2.1  uebayasi 	struct lwp *l = curlwp;
    361  1.169.2.1  uebayasi 	off_t testoff;
    362  1.169.2.1  uebayasi 
    363  1.169.2.1  uebayasi 	if (uio->uio_rw != UIO_WRITE || vp->v_type != VREG)
    364  1.169.2.1  uebayasi 		return 0;
    365  1.169.2.1  uebayasi 
    366  1.169.2.1  uebayasi 	KASSERT(VOP_ISLOCKED(vp) == LK_EXCLUSIVE);
    367  1.169.2.1  uebayasi 	if (ioflag & IO_APPEND)
    368  1.169.2.1  uebayasi 		testoff = vp->v_size;
    369  1.169.2.1  uebayasi 	else
    370  1.169.2.1  uebayasi 		testoff = uio->uio_offset;
    371  1.169.2.1  uebayasi 
    372  1.169.2.1  uebayasi 	if (testoff + uio->uio_resid >
    373  1.169.2.1  uebayasi 	    l->l_proc->p_rlimit[RLIMIT_FSIZE].rlim_cur) {
    374  1.169.2.1  uebayasi 		mutex_enter(proc_lock);
    375  1.169.2.1  uebayasi 		psignal(l->l_proc, SIGXFSZ);
    376  1.169.2.1  uebayasi 		mutex_exit(proc_lock);
    377  1.169.2.1  uebayasi 		return EFBIG;
    378  1.169.2.1  uebayasi 	}
    379  1.169.2.1  uebayasi 
    380  1.169.2.1  uebayasi 	return 0;
    381  1.169.2.1  uebayasi }
    382  1.169.2.1  uebayasi 
    383       1.10       cgd /*
    384       1.10       cgd  * Package up an I/O request on a vnode into a uio and do it.
    385       1.10       cgd  */
    386       1.20  christos int
    387      1.134  christos vn_rdwr(enum uio_rw rw, struct vnode *vp, void *base, int len, off_t offset,
    388      1.111      elad     enum uio_seg segflg, int ioflg, kauth_cred_t cred, size_t *aresid,
    389      1.101  christos     struct lwp *l)
    390       1.10       cgd {
    391       1.10       cgd 	struct uio auio;
    392       1.10       cgd 	struct iovec aiov;
    393       1.10       cgd 	int error;
    394       1.10       cgd 
    395       1.50       chs 	if ((ioflg & IO_NODELOCKED) == 0) {
    396       1.50       chs 		if (rw == UIO_READ) {
    397       1.50       chs 			vn_lock(vp, LK_SHARED | LK_RETRY);
    398       1.75   hannken 		} else /* UIO_WRITE */ {
    399       1.50       chs 			vn_lock(vp, LK_EXCLUSIVE | LK_RETRY);
    400       1.50       chs 		}
    401       1.50       chs 	}
    402       1.10       cgd 	auio.uio_iov = &aiov;
    403       1.10       cgd 	auio.uio_iovcnt = 1;
    404       1.10       cgd 	aiov.iov_base = base;
    405       1.10       cgd 	aiov.iov_len = len;
    406       1.10       cgd 	auio.uio_resid = len;
    407       1.10       cgd 	auio.uio_offset = offset;
    408       1.10       cgd 	auio.uio_rw = rw;
    409      1.106      yamt 	if (segflg == UIO_SYSSPACE) {
    410      1.106      yamt 		UIO_SETUP_SYSSPACE(&auio);
    411      1.106      yamt 	} else {
    412      1.106      yamt 		auio.uio_vmspace = l->l_proc->p_vmspace;
    413      1.106      yamt 	}
    414  1.169.2.1  uebayasi 
    415  1.169.2.1  uebayasi 	if ((error = enforce_rlimit_fsize(vp, &auio, ioflg)) != 0)
    416  1.169.2.1  uebayasi 		goto out;
    417  1.169.2.1  uebayasi 
    418       1.11   mycroft 	if (rw == UIO_READ) {
    419       1.10       cgd 		error = VOP_READ(vp, &auio, ioflg, cred);
    420       1.11   mycroft 	} else {
    421       1.10       cgd 		error = VOP_WRITE(vp, &auio, ioflg, cred);
    422       1.11   mycroft 	}
    423  1.169.2.1  uebayasi 
    424       1.10       cgd 	if (aresid)
    425       1.10       cgd 		*aresid = auio.uio_resid;
    426       1.10       cgd 	else
    427       1.10       cgd 		if (auio.uio_resid && error == 0)
    428       1.10       cgd 			error = EIO;
    429  1.169.2.1  uebayasi 
    430  1.169.2.1  uebayasi  out:
    431       1.75   hannken 	if ((ioflg & IO_NODELOCKED) == 0) {
    432  1.169.2.2  uebayasi 		VOP_UNLOCK(vp);
    433       1.75   hannken 	}
    434       1.10       cgd 	return (error);
    435       1.23      fvdl }
    436       1.23      fvdl 
    437       1.23      fvdl int
    438      1.155        ad vn_readdir(file_t *fp, char *bf, int segflg, u_int count, int *done,
    439      1.101  christos     struct lwp *l, off_t **cookies, int *ncookies)
    440       1.23      fvdl {
    441       1.23      fvdl 	struct vnode *vp = (struct vnode *)fp->f_data;
    442       1.23      fvdl 	struct iovec aiov;
    443       1.23      fvdl 	struct uio auio;
    444       1.23      fvdl 	int error, eofflag;
    445       1.23      fvdl 
    446      1.112    simonb 	/* Limit the size on any kernel buffers used by VOP_READDIR */
    447      1.112    simonb 	count = min(MAXBSIZE, count);
    448      1.112    simonb 
    449       1.23      fvdl unionread:
    450       1.23      fvdl 	if (vp->v_type != VDIR)
    451       1.23      fvdl 		return (EINVAL);
    452       1.88  christos 	aiov.iov_base = bf;
    453       1.23      fvdl 	aiov.iov_len = count;
    454       1.23      fvdl 	auio.uio_iov = &aiov;
    455       1.23      fvdl 	auio.uio_iovcnt = 1;
    456       1.23      fvdl 	auio.uio_rw = UIO_READ;
    457      1.106      yamt 	if (segflg == UIO_SYSSPACE) {
    458      1.106      yamt 		UIO_SETUP_SYSSPACE(&auio);
    459      1.106      yamt 	} else {
    460      1.106      yamt 		KASSERT(l == curlwp);
    461      1.106      yamt 		auio.uio_vmspace = l->l_proc->p_vmspace;
    462      1.106      yamt 	}
    463       1.23      fvdl 	auio.uio_resid = count;
    464       1.50       chs 	vn_lock(vp, LK_SHARED | LK_RETRY);
    465       1.23      fvdl 	auio.uio_offset = fp->f_offset;
    466       1.28      fvdl 	error = VOP_READDIR(vp, &auio, fp->f_cred, &eofflag, cookies,
    467       1.23      fvdl 		    ncookies);
    468      1.166      yamt 	mutex_enter(&fp->f_lock);
    469       1.23      fvdl 	fp->f_offset = auio.uio_offset;
    470      1.166      yamt 	mutex_exit(&fp->f_lock);
    471  1.169.2.2  uebayasi 	VOP_UNLOCK(vp);
    472       1.23      fvdl 	if (error)
    473       1.23      fvdl 		return (error);
    474       1.23      fvdl 
    475       1.66  jdolecek 	if (count == auio.uio_resid && vn_union_readdir_hook) {
    476       1.66  jdolecek 		struct vnode *ovp = vp;
    477       1.23      fvdl 
    478      1.101  christos 		error = (*vn_union_readdir_hook)(&vp, fp, l);
    479       1.66  jdolecek 		if (error)
    480       1.66  jdolecek 			return (error);
    481       1.66  jdolecek 		if (vp != ovp)
    482       1.23      fvdl 			goto unionread;
    483       1.23      fvdl 	}
    484       1.23      fvdl 
    485      1.143        ad 	if (count == auio.uio_resid && (vp->v_vflag & VV_ROOT) &&
    486       1.23      fvdl 	    (vp->v_mount->mnt_flag & MNT_UNION)) {
    487       1.23      fvdl 		struct vnode *tvp = vp;
    488       1.23      fvdl 		vp = vp->v_mount->mnt_vnodecovered;
    489      1.169     pooka 		vref(vp);
    490      1.166      yamt 		mutex_enter(&fp->f_lock);
    491       1.68       dsl 		fp->f_data = vp;
    492       1.23      fvdl 		fp->f_offset = 0;
    493      1.166      yamt 		mutex_exit(&fp->f_lock);
    494       1.23      fvdl 		vrele(tvp);
    495       1.23      fvdl 		goto unionread;
    496       1.23      fvdl 	}
    497       1.23      fvdl 	*done = count - auio.uio_resid;
    498       1.23      fvdl 	return error;
    499       1.10       cgd }
    500       1.10       cgd 
    501       1.10       cgd /*
    502       1.10       cgd  * File table vnode read routine.
    503       1.10       cgd  */
    504       1.56  gmcgarry static int
    505      1.155        ad vn_read(file_t *fp, off_t *offset, struct uio *uio, kauth_cred_t cred,
    506       1.89   thorpej     int flags)
    507       1.10       cgd {
    508       1.28      fvdl 	struct vnode *vp = (struct vnode *)fp->f_data;
    509      1.155        ad 	int count, error, ioflag, fflag;
    510       1.10       cgd 
    511      1.100      yamt 	ioflag = IO_ADV_ENCODE(fp->f_advice);
    512      1.155        ad 	fflag = fp->f_flag;
    513      1.155        ad 	if (fflag & FNONBLOCK)
    514       1.31    kleink 		ioflag |= IO_NDELAY;
    515      1.155        ad 	if ((fflag & (FFSYNC | FRSYNC)) == (FFSYNC | FRSYNC))
    516       1.31    kleink 		ioflag |= IO_SYNC;
    517      1.155        ad 	if (fflag & FALTIO)
    518       1.37  wrstuden 		ioflag |= IO_ALTSEMANTICS;
    519      1.155        ad 	if (fflag & FDIRECT)
    520      1.125       chs 		ioflag |= IO_DIRECT;
    521       1.50       chs 	vn_lock(vp, LK_SHARED | LK_RETRY);
    522       1.29   thorpej 	uio->uio_offset = *offset;
    523       1.10       cgd 	count = uio->uio_resid;
    524       1.31    kleink 	error = VOP_READ(vp, uio, ioflag, cred);
    525       1.29   thorpej 	if (flags & FOF_UPDATE_OFFSET)
    526       1.29   thorpej 		*offset += count - uio->uio_resid;
    527  1.169.2.2  uebayasi 	VOP_UNLOCK(vp);
    528       1.10       cgd 	return (error);
    529       1.10       cgd }
    530       1.10       cgd 
    531       1.10       cgd /*
    532       1.10       cgd  * File table vnode write routine.
    533       1.10       cgd  */
    534       1.56  gmcgarry static int
    535      1.155        ad vn_write(file_t *fp, off_t *offset, struct uio *uio, kauth_cred_t cred,
    536       1.89   thorpej     int flags)
    537       1.10       cgd {
    538       1.28      fvdl 	struct vnode *vp = (struct vnode *)fp->f_data;
    539      1.155        ad 	int count, error, ioflag, fflag;
    540       1.10       cgd 
    541      1.151     pooka 	ioflag = IO_ADV_ENCODE(fp->f_advice) | IO_UNIT;
    542      1.155        ad 	fflag = fp->f_flag;
    543      1.155        ad 	if (vp->v_type == VREG && (fflag & O_APPEND))
    544       1.10       cgd 		ioflag |= IO_APPEND;
    545      1.155        ad 	if (fflag & FNONBLOCK)
    546       1.10       cgd 		ioflag |= IO_NDELAY;
    547      1.155        ad 	if (fflag & FFSYNC ||
    548       1.24   thorpej 	    (vp->v_mount && (vp->v_mount->mnt_flag & MNT_SYNCHRONOUS)))
    549       1.24   thorpej 		ioflag |= IO_SYNC;
    550      1.155        ad 	else if (fflag & FDSYNC)
    551       1.31    kleink 		ioflag |= IO_DSYNC;
    552      1.155        ad 	if (fflag & FALTIO)
    553       1.37  wrstuden 		ioflag |= IO_ALTSEMANTICS;
    554      1.155        ad 	if (fflag & FDIRECT)
    555      1.125       chs 		ioflag |= IO_DIRECT;
    556       1.28      fvdl 	vn_lock(vp, LK_EXCLUSIVE | LK_RETRY);
    557       1.29   thorpej 	uio->uio_offset = *offset;
    558       1.10       cgd 	count = uio->uio_resid;
    559  1.169.2.1  uebayasi 
    560  1.169.2.1  uebayasi 	if ((error = enforce_rlimit_fsize(vp, uio, ioflag)) != 0)
    561  1.169.2.1  uebayasi 		goto out;
    562  1.169.2.1  uebayasi 
    563       1.10       cgd 	error = VOP_WRITE(vp, uio, ioflag, cred);
    564  1.169.2.1  uebayasi 
    565       1.29   thorpej 	if (flags & FOF_UPDATE_OFFSET) {
    566      1.160  christos 		if (ioflag & IO_APPEND) {
    567      1.160  christos 			/*
    568      1.160  christos 			 * SUSv3 describes behaviour for count = 0 as following:
    569      1.160  christos 			 * "Before any action ... is taken, and if nbyte is zero
    570      1.160  christos 			 * and the file is a regular file, the write() function
    571      1.160  christos 			 * ... in the absence of errors ... shall return zero
    572      1.160  christos 			 * and have no other results."
    573      1.160  christos 			 */
    574      1.160  christos 			if (count)
    575      1.160  christos 				*offset = uio->uio_offset;
    576      1.160  christos 		} else
    577       1.29   thorpej 			*offset += count - uio->uio_resid;
    578       1.29   thorpej 	}
    579  1.169.2.1  uebayasi 
    580  1.169.2.1  uebayasi  out:
    581  1.169.2.2  uebayasi 	VOP_UNLOCK(vp);
    582       1.10       cgd 	return (error);
    583       1.10       cgd }
    584       1.10       cgd 
    585       1.10       cgd /*
    586       1.10       cgd  * File table vnode stat routine.
    587       1.10       cgd  */
    588       1.48  jdolecek static int
    589      1.155        ad vn_statfile(file_t *fp, struct stat *sb)
    590       1.48  jdolecek {
    591      1.165  christos 	struct vnode *vp = fp->f_data;
    592      1.165  christos 	int error;
    593       1.48  jdolecek 
    594      1.165  christos 	vn_lock(vp, LK_EXCLUSIVE | LK_RETRY);
    595      1.165  christos 	error = vn_stat(vp, sb);
    596  1.169.2.2  uebayasi 	VOP_UNLOCK(vp);
    597      1.165  christos 	return error;
    598       1.48  jdolecek }
    599       1.48  jdolecek 
    600       1.20  christos int
    601      1.155        ad vn_stat(struct vnode *vp, struct stat *sb)
    602       1.10       cgd {
    603       1.19   mycroft 	struct vattr va;
    604       1.10       cgd 	int error;
    605       1.35  wrstuden 	mode_t mode;
    606       1.10       cgd 
    607  1.169.2.2  uebayasi 	memset(&va, 0, sizeof(va));
    608      1.155        ad 	error = VOP_GETATTR(vp, &va, kauth_cred_get());
    609       1.10       cgd 	if (error)
    610       1.10       cgd 		return (error);
    611       1.10       cgd 	/*
    612       1.10       cgd 	 * Copy from vattr table
    613       1.10       cgd 	 */
    614  1.169.2.4  uebayasi 	memset(sb, 0, sizeof(*sb));
    615       1.19   mycroft 	sb->st_dev = va.va_fsid;
    616       1.19   mycroft 	sb->st_ino = va.va_fileid;
    617       1.19   mycroft 	mode = va.va_mode;
    618       1.10       cgd 	switch (vp->v_type) {
    619       1.10       cgd 	case VREG:
    620       1.10       cgd 		mode |= S_IFREG;
    621       1.10       cgd 		break;
    622       1.10       cgd 	case VDIR:
    623       1.10       cgd 		mode |= S_IFDIR;
    624       1.10       cgd 		break;
    625       1.10       cgd 	case VBLK:
    626       1.10       cgd 		mode |= S_IFBLK;
    627       1.10       cgd 		break;
    628       1.10       cgd 	case VCHR:
    629       1.10       cgd 		mode |= S_IFCHR;
    630       1.10       cgd 		break;
    631       1.10       cgd 	case VLNK:
    632       1.10       cgd 		mode |= S_IFLNK;
    633       1.10       cgd 		break;
    634       1.10       cgd 	case VSOCK:
    635       1.10       cgd 		mode |= S_IFSOCK;
    636       1.10       cgd 		break;
    637       1.10       cgd 	case VFIFO:
    638       1.10       cgd 		mode |= S_IFIFO;
    639       1.10       cgd 		break;
    640       1.10       cgd 	default:
    641       1.10       cgd 		return (EBADF);
    642       1.10       cgd 	};
    643       1.10       cgd 	sb->st_mode = mode;
    644       1.19   mycroft 	sb->st_nlink = va.va_nlink;
    645       1.19   mycroft 	sb->st_uid = va.va_uid;
    646       1.19   mycroft 	sb->st_gid = va.va_gid;
    647       1.19   mycroft 	sb->st_rdev = va.va_rdev;
    648       1.19   mycroft 	sb->st_size = va.va_size;
    649       1.19   mycroft 	sb->st_atimespec = va.va_atime;
    650       1.19   mycroft 	sb->st_mtimespec = va.va_mtime;
    651       1.19   mycroft 	sb->st_ctimespec = va.va_ctime;
    652       1.69      fvdl 	sb->st_birthtimespec = va.va_birthtime;
    653       1.19   mycroft 	sb->st_blksize = va.va_blocksize;
    654       1.19   mycroft 	sb->st_flags = va.va_flags;
    655       1.22   mycroft 	sb->st_gen = 0;
    656       1.19   mycroft 	sb->st_blocks = va.va_bytes / S_BLKSIZE;
    657       1.10       cgd 	return (0);
    658       1.37  wrstuden }
    659       1.37  wrstuden 
    660       1.37  wrstuden /*
    661       1.37  wrstuden  * File table vnode fcntl routine.
    662       1.37  wrstuden  */
    663       1.56  gmcgarry static int
    664      1.155        ad vn_fcntl(file_t *fp, u_int com, void *data)
    665       1.37  wrstuden {
    666      1.155        ad 	struct vnode *vp = fp->f_data;
    667       1.37  wrstuden 	int error;
    668       1.37  wrstuden 
    669      1.155        ad 	error = VOP_FCNTL(vp, com, data, fp->f_flag, kauth_cred_get());
    670       1.37  wrstuden 	return (error);
    671       1.10       cgd }
    672       1.10       cgd 
    673       1.10       cgd /*
    674       1.10       cgd  * File table vnode ioctl routine.
    675       1.10       cgd  */
    676       1.56  gmcgarry static int
    677      1.155        ad vn_ioctl(file_t *fp, u_long com, void *data)
    678       1.10       cgd {
    679      1.155        ad 	struct vnode *vp = fp->f_data, *ovp;
    680       1.10       cgd 	struct vattr vattr;
    681       1.10       cgd 	int error;
    682       1.10       cgd 
    683       1.10       cgd 	switch (vp->v_type) {
    684       1.10       cgd 
    685       1.10       cgd 	case VREG:
    686       1.10       cgd 	case VDIR:
    687       1.10       cgd 		if (com == FIONREAD) {
    688      1.155        ad 			error = VOP_GETATTR(vp, &vattr,
    689      1.155        ad 			    kauth_cred_get());
    690       1.20  christos 			if (error)
    691       1.10       cgd 				return (error);
    692       1.10       cgd 			*(int *)data = vattr.va_size - fp->f_offset;
    693       1.10       cgd 			return (0);
    694       1.60    atatat 		}
    695       1.82  christos 		if ((com == FIONWRITE) || (com == FIONSPACE)) {
    696       1.81  wrstuden 			/*
    697       1.81  wrstuden 			 * Files don't have send queues, so there never
    698       1.81  wrstuden 			 * are any bytes in them, nor is there any
    699       1.81  wrstuden 			 * open space in them.
    700       1.81  wrstuden 			 */
    701       1.81  wrstuden 			*(int *)data = 0;
    702       1.81  wrstuden 			return (0);
    703       1.81  wrstuden 		}
    704       1.60    atatat 		if (com == FIOGETBMAP) {
    705       1.60    atatat 			daddr_t *block;
    706       1.60    atatat 
    707       1.62    atatat 			if (*(daddr_t *)data < 0)
    708       1.62    atatat 				return (EINVAL);
    709       1.60    atatat 			block = (daddr_t *)data;
    710       1.60    atatat 			return (VOP_BMAP(vp, *block, NULL, block, NULL));
    711       1.61      fvdl 		}
    712       1.61      fvdl 		if (com == OFIOGETBMAP) {
    713       1.61      fvdl 			daddr_t ibn, obn;
    714       1.61      fvdl 
    715       1.62    atatat 			if (*(int32_t *)data < 0)
    716       1.62    atatat 				return (EINVAL);
    717       1.61      fvdl 			ibn = (daddr_t)*(int32_t *)data;
    718       1.61      fvdl 			error = VOP_BMAP(vp, ibn, NULL, &obn, NULL);
    719       1.61      fvdl 			*(int32_t *)data = (int32_t)obn;
    720       1.61      fvdl 			return error;
    721       1.10       cgd 		}
    722       1.10       cgd 		if (com == FIONBIO || com == FIOASYNC)	/* XXX */
    723       1.10       cgd 			return (0);			/* XXX */
    724       1.10       cgd 		/* fall into ... */
    725       1.10       cgd 	case VFIFO:
    726       1.10       cgd 	case VCHR:
    727       1.10       cgd 	case VBLK:
    728      1.155        ad 		error = VOP_IOCTL(vp, com, data, fp->f_flag,
    729      1.155        ad 		    kauth_cred_get());
    730       1.10       cgd 		if (error == 0 && com == TIOCSCTTY) {
    731      1.169     pooka 			vref(vp);
    732      1.156        ad 			mutex_enter(proc_lock);
    733      1.155        ad 			ovp = curproc->p_session->s_ttyvp;
    734      1.155        ad 			curproc->p_session->s_ttyvp = vp;
    735      1.156        ad 			mutex_exit(proc_lock);
    736      1.132        ad 			if (ovp != NULL)
    737      1.132        ad 				vrele(ovp);
    738       1.10       cgd 		}
    739       1.10       cgd 		return (error);
    740       1.63  perseant 
    741       1.63  perseant 	default:
    742       1.63  perseant 		return (EPASSTHROUGH);
    743       1.10       cgd 	}
    744       1.10       cgd }
    745       1.10       cgd 
    746       1.10       cgd /*
    747       1.21   mycroft  * File table vnode poll routine.
    748       1.10       cgd  */
    749       1.56  gmcgarry static int
    750      1.155        ad vn_poll(file_t *fp, int events)
    751       1.10       cgd {
    752       1.10       cgd 
    753      1.155        ad 	return (VOP_POLL(fp->f_data, events));
    754       1.57  jdolecek }
    755       1.57  jdolecek 
    756       1.57  jdolecek /*
    757       1.57  jdolecek  * File table vnode kqfilter routine.
    758       1.57  jdolecek  */
    759       1.57  jdolecek int
    760      1.155        ad vn_kqfilter(file_t *fp, struct knote *kn)
    761       1.57  jdolecek {
    762       1.57  jdolecek 
    763      1.155        ad 	return (VOP_KQFILTER(fp->f_data, kn));
    764       1.28      fvdl }
    765       1.28      fvdl 
    766       1.28      fvdl /*
    767       1.28      fvdl  * Check that the vnode is still valid, and if so
    768       1.28      fvdl  * acquire requested lock.
    769       1.28      fvdl  */
    770       1.28      fvdl int
    771       1.89   thorpej vn_lock(struct vnode *vp, int flags)
    772       1.28      fvdl {
    773       1.28      fvdl 	int error;
    774       1.34  sommerfe 
    775       1.84      yamt #if 0
    776  1.169.2.2  uebayasi 	KASSERT(vp->v_usecount > 0 || (vp->v_iflag & VI_ONWORKLST) != 0);
    777       1.84      yamt #endif
    778  1.169.2.2  uebayasi 	KASSERT((flags & ~(LK_SHARED|LK_EXCLUSIVE|LK_NOWAIT|LK_RETRY)) == 0);
    779  1.169.2.2  uebayasi 	KASSERT(!mutex_owned(&vp->v_interlock));
    780       1.80      yamt 
    781      1.159    simonb #ifdef DIAGNOSTIC
    782      1.159    simonb 	if (wapbl_vphaswapbl(vp))
    783      1.159    simonb 		WAPBL_JUNLOCK_ASSERT(wapbl_vptomp(vp));
    784      1.159    simonb #endif
    785      1.159    simonb 
    786       1.28      fvdl 	do {
    787      1.157        ad 		/*
    788      1.157        ad 		 * XXX PR 37706 forced unmount of file systems is unsafe.
    789      1.157        ad 		 * Race between vclean() and this the remaining problem.
    790      1.157        ad 		 */
    791  1.169.2.2  uebayasi 		mutex_enter(&vp->v_interlock);
    792      1.143        ad 		if (vp->v_iflag & VI_XLOCK) {
    793       1.49       chs 			if (flags & LK_NOWAIT) {
    794      1.149        ad 				mutex_exit(&vp->v_interlock);
    795       1.49       chs 				return EBUSY;
    796       1.49       chs 			}
    797      1.149        ad 			vwait(vp, VI_XLOCK);
    798      1.149        ad 			mutex_exit(&vp->v_interlock);
    799       1.28      fvdl 			error = ENOENT;
    800       1.28      fvdl 		} else {
    801  1.169.2.2  uebayasi 			mutex_exit(&vp->v_interlock);
    802      1.157        ad 			error = VOP_LOCK(vp, (flags & ~LK_RETRY));
    803       1.49       chs 			if (error == 0 || error == EDEADLK || error == EBUSY)
    804       1.28      fvdl 				return (error);
    805       1.28      fvdl 		}
    806       1.28      fvdl 	} while (flags & LK_RETRY);
    807       1.28      fvdl 	return (error);
    808       1.10       cgd }
    809       1.10       cgd 
    810       1.10       cgd /*
    811       1.10       cgd  * File table vnode close routine.
    812       1.10       cgd  */
    813       1.56  gmcgarry static int
    814      1.155        ad vn_closefile(file_t *fp)
    815       1.10       cgd {
    816       1.10       cgd 
    817      1.155        ad 	return vn_close(fp->f_data, fp->f_flag, fp->f_cred);
    818       1.39      fvdl }
    819       1.39      fvdl 
    820       1.39      fvdl /*
    821       1.85   thorpej  * Simplified in-kernel wrapper calls for extended attribute access.
    822       1.85   thorpej  * Both calls pass in a NULL credential, authorizing a "kernel" access.
    823       1.85   thorpej  * Set IO_NODELOCKED in ioflg if the vnode is already locked.
    824       1.85   thorpej  */
    825       1.85   thorpej int
    826       1.85   thorpej vn_extattr_get(struct vnode *vp, int ioflg, int attrnamespace,
    827      1.101  christos     const char *attrname, size_t *buflen, void *bf, struct lwp *l)
    828       1.85   thorpej {
    829       1.85   thorpej 	struct uio auio;
    830       1.85   thorpej 	struct iovec aiov;
    831       1.85   thorpej 	int error;
    832       1.85   thorpej 
    833       1.85   thorpej 	aiov.iov_len = *buflen;
    834       1.88  christos 	aiov.iov_base = bf;
    835       1.85   thorpej 
    836       1.85   thorpej 	auio.uio_iov = &aiov;
    837       1.85   thorpej 	auio.uio_iovcnt = 1;
    838       1.85   thorpej 	auio.uio_rw = UIO_READ;
    839       1.85   thorpej 	auio.uio_offset = 0;
    840       1.85   thorpej 	auio.uio_resid = *buflen;
    841      1.106      yamt 	UIO_SETUP_SYSSPACE(&auio);
    842       1.85   thorpej 
    843       1.85   thorpej 	if ((ioflg & IO_NODELOCKED) == 0)
    844       1.85   thorpej 		vn_lock(vp, LK_EXCLUSIVE | LK_RETRY);
    845       1.86     perry 
    846      1.144     pooka 	error = VOP_GETEXTATTR(vp, attrnamespace, attrname, &auio, NULL, NULL);
    847       1.86     perry 
    848       1.85   thorpej 	if ((ioflg & IO_NODELOCKED) == 0)
    849  1.169.2.2  uebayasi 		VOP_UNLOCK(vp);
    850       1.86     perry 
    851       1.85   thorpej 	if (error == 0)
    852       1.85   thorpej 		*buflen = *buflen - auio.uio_resid;
    853       1.86     perry 
    854       1.85   thorpej 	return (error);
    855       1.85   thorpej }
    856       1.85   thorpej 
    857       1.85   thorpej /*
    858       1.85   thorpej  * XXX Failure mode if partially written?
    859       1.85   thorpej  */
    860       1.85   thorpej int
    861       1.85   thorpej vn_extattr_set(struct vnode *vp, int ioflg, int attrnamespace,
    862      1.101  christos     const char *attrname, size_t buflen, const void *bf, struct lwp *l)
    863       1.85   thorpej {
    864       1.85   thorpej 	struct uio auio;
    865       1.85   thorpej 	struct iovec aiov;
    866       1.85   thorpej 	int error;
    867       1.85   thorpej 
    868       1.85   thorpej 	aiov.iov_len = buflen;
    869       1.88  christos 	aiov.iov_base = __UNCONST(bf);		/* XXXUNCONST kills const */
    870       1.85   thorpej 
    871       1.85   thorpej 	auio.uio_iov = &aiov;
    872       1.85   thorpej 	auio.uio_iovcnt = 1;
    873       1.85   thorpej 	auio.uio_rw = UIO_WRITE;
    874       1.85   thorpej 	auio.uio_offset = 0;
    875       1.85   thorpej 	auio.uio_resid = buflen;
    876      1.106      yamt 	UIO_SETUP_SYSSPACE(&auio);
    877       1.85   thorpej 
    878       1.85   thorpej 	if ((ioflg & IO_NODELOCKED) == 0) {
    879       1.85   thorpej 		vn_lock(vp, LK_EXCLUSIVE | LK_RETRY);
    880       1.85   thorpej 	}
    881       1.85   thorpej 
    882      1.144     pooka 	error = VOP_SETEXTATTR(vp, attrnamespace, attrname, &auio, NULL);
    883       1.85   thorpej 
    884       1.85   thorpej 	if ((ioflg & IO_NODELOCKED) == 0) {
    885  1.169.2.2  uebayasi 		VOP_UNLOCK(vp);
    886       1.85   thorpej 	}
    887       1.85   thorpej 
    888       1.85   thorpej 	return (error);
    889       1.85   thorpej }
    890       1.85   thorpej 
    891       1.85   thorpej int
    892       1.85   thorpej vn_extattr_rm(struct vnode *vp, int ioflg, int attrnamespace,
    893      1.101  christos     const char *attrname, struct lwp *l)
    894       1.85   thorpej {
    895       1.85   thorpej 	int error;
    896       1.85   thorpej 
    897       1.85   thorpej 	if ((ioflg & IO_NODELOCKED) == 0) {
    898       1.85   thorpej 		vn_lock(vp, LK_EXCLUSIVE | LK_RETRY);
    899       1.85   thorpej 	}
    900       1.85   thorpej 
    901      1.144     pooka 	error = VOP_DELETEEXTATTR(vp, attrnamespace, attrname, NULL);
    902       1.85   thorpej 	if (error == EOPNOTSUPP)
    903      1.144     pooka 		error = VOP_SETEXTATTR(vp, attrnamespace, attrname, NULL, NULL);
    904       1.86     perry 
    905       1.85   thorpej 	if ((ioflg & IO_NODELOCKED) == 0) {
    906  1.169.2.2  uebayasi 		VOP_UNLOCK(vp);
    907       1.85   thorpej 	}
    908       1.85   thorpej 
    909       1.85   thorpej 	return (error);
    910       1.85   thorpej }
    911       1.95      yamt 
    912      1.100      yamt void
    913      1.100      yamt vn_ra_allocctx(struct vnode *vp)
    914      1.100      yamt {
    915      1.100      yamt 	struct uvm_ractx *ra = NULL;
    916      1.100      yamt 
    917      1.149        ad 	KASSERT(mutex_owned(&vp->v_interlock));
    918      1.149        ad 
    919      1.100      yamt 	if (vp->v_type != VREG) {
    920      1.100      yamt 		return;
    921      1.100      yamt 	}
    922      1.100      yamt 	if (vp->v_ractx != NULL) {
    923      1.100      yamt 		return;
    924      1.100      yamt 	}
    925      1.100      yamt 	if (vp->v_ractx == NULL) {
    926      1.149        ad 		mutex_exit(&vp->v_interlock);
    927      1.100      yamt 		ra = uvm_ra_allocctx();
    928      1.149        ad 		mutex_enter(&vp->v_interlock);
    929      1.100      yamt 		if (ra != NULL && vp->v_ractx == NULL) {
    930      1.100      yamt 			vp->v_ractx = ra;
    931      1.100      yamt 			ra = NULL;
    932      1.100      yamt 		}
    933      1.100      yamt 	}
    934      1.100      yamt 	if (ra != NULL) {
    935      1.100      yamt 		uvm_ra_freectx(ra);
    936      1.100      yamt 	}
    937      1.100      yamt }
    938  1.169.2.1  uebayasi 
    939  1.169.2.1  uebayasi int
    940  1.169.2.1  uebayasi vn_fifo_bypass(void *v)
    941  1.169.2.1  uebayasi {
    942  1.169.2.1  uebayasi 	struct vop_generic_args *ap = v;
    943  1.169.2.1  uebayasi 
    944  1.169.2.1  uebayasi 	return VOCALL(fifo_vnodeop_p, ap->a_desc->vdesc_offset, v);
    945  1.169.2.1  uebayasi }
    946