Home | History | Annotate | Line # | Download | only in kern
vfs_vnode.c revision 1.37.2.2
      1  1.37.2.2       snj /*	$NetBSD: vfs_vnode.c,v 1.37.2.2 2016/01/26 23:43:34 snj Exp $	*/
      2       1.1     rmind 
      3       1.1     rmind /*-
      4       1.2     rmind  * Copyright (c) 1997-2011 The NetBSD Foundation, Inc.
      5       1.1     rmind  * All rights reserved.
      6       1.1     rmind  *
      7       1.1     rmind  * This code is derived from software contributed to The NetBSD Foundation
      8       1.1     rmind  * by Jason R. Thorpe of the Numerical Aerospace Simulation Facility,
      9       1.1     rmind  * NASA Ames Research Center, by Charles M. Hannum, and by Andrew Doran.
     10       1.1     rmind  *
     11       1.1     rmind  * Redistribution and use in source and binary forms, with or without
     12       1.1     rmind  * modification, are permitted provided that the following conditions
     13       1.1     rmind  * are met:
     14       1.1     rmind  * 1. Redistributions of source code must retain the above copyright
     15       1.1     rmind  *    notice, this list of conditions and the following disclaimer.
     16       1.1     rmind  * 2. Redistributions in binary form must reproduce the above copyright
     17       1.1     rmind  *    notice, this list of conditions and the following disclaimer in the
     18       1.1     rmind  *    documentation and/or other materials provided with the distribution.
     19       1.1     rmind  *
     20       1.1     rmind  * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
     21       1.1     rmind  * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
     22       1.1     rmind  * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
     23       1.1     rmind  * PURPOSE ARE DISCLAIMED.  IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
     24       1.1     rmind  * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
     25       1.1     rmind  * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
     26       1.1     rmind  * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
     27       1.1     rmind  * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
     28       1.1     rmind  * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
     29       1.1     rmind  * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
     30       1.1     rmind  * POSSIBILITY OF SUCH DAMAGE.
     31       1.1     rmind  */
     32       1.1     rmind 
     33       1.1     rmind /*
     34       1.1     rmind  * Copyright (c) 1989, 1993
     35       1.1     rmind  *	The Regents of the University of California.  All rights reserved.
     36       1.1     rmind  * (c) UNIX System Laboratories, Inc.
     37       1.1     rmind  * All or some portions of this file are derived from material licensed
     38       1.1     rmind  * to the University of California by American Telephone and Telegraph
     39       1.1     rmind  * Co. or Unix System Laboratories, Inc. and are reproduced herein with
     40       1.1     rmind  * the permission of UNIX System Laboratories, Inc.
     41       1.1     rmind  *
     42       1.1     rmind  * Redistribution and use in source and binary forms, with or without
     43       1.1     rmind  * modification, are permitted provided that the following conditions
     44       1.1     rmind  * are met:
     45       1.1     rmind  * 1. Redistributions of source code must retain the above copyright
     46       1.1     rmind  *    notice, this list of conditions and the following disclaimer.
     47       1.1     rmind  * 2. Redistributions in binary form must reproduce the above copyright
     48       1.1     rmind  *    notice, this list of conditions and the following disclaimer in the
     49       1.1     rmind  *    documentation and/or other materials provided with the distribution.
     50       1.1     rmind  * 3. Neither the name of the University nor the names of its contributors
     51       1.1     rmind  *    may be used to endorse or promote products derived from this software
     52       1.1     rmind  *    without specific prior written permission.
     53       1.1     rmind  *
     54       1.1     rmind  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
     55       1.1     rmind  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
     56       1.1     rmind  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
     57       1.1     rmind  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
     58       1.1     rmind  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
     59       1.1     rmind  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
     60       1.1     rmind  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
     61       1.1     rmind  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
     62       1.1     rmind  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
     63       1.1     rmind  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
     64       1.1     rmind  * SUCH DAMAGE.
     65       1.1     rmind  *
     66       1.1     rmind  *	@(#)vfs_subr.c	8.13 (Berkeley) 4/18/94
     67       1.1     rmind  */
     68       1.1     rmind 
     69       1.1     rmind /*
     70       1.8     rmind  * The vnode cache subsystem.
     71       1.1     rmind  *
     72       1.8     rmind  * Life-cycle
     73       1.1     rmind  *
     74       1.8     rmind  *	Normally, there are two points where new vnodes are created:
     75       1.8     rmind  *	VOP_CREATE(9) and VOP_LOOKUP(9).  The life-cycle of a vnode
     76       1.8     rmind  *	starts in one of the following ways:
     77       1.8     rmind  *
     78       1.8     rmind  *	- Allocation, via getnewvnode(9) and/or vnalloc(9).
     79       1.8     rmind  *	- Reclamation of inactive vnode, via vget(9).
     80       1.8     rmind  *
     81      1.16     rmind  *	Recycle from a free list, via getnewvnode(9) -> getcleanvnode(9)
     82      1.16     rmind  *	was another, traditional way.  Currently, only the draining thread
     83      1.16     rmind  *	recycles the vnodes.  This behaviour might be revisited.
     84      1.16     rmind  *
     85       1.8     rmind  *	The life-cycle ends when the last reference is dropped, usually
     86       1.8     rmind  *	in VOP_REMOVE(9).  In such case, VOP_INACTIVE(9) is called to inform
     87       1.8     rmind  *	the file system that vnode is inactive.  Via this call, file system
     88      1.16     rmind  *	indicates whether vnode can be recycled (usually, it checks its own
     89      1.16     rmind  *	references, e.g. count of links, whether the file was removed).
     90       1.8     rmind  *
     91       1.8     rmind  *	Depending on indication, vnode can be put into a free list (cache),
     92       1.8     rmind  *	or cleaned via vclean(9), which calls VOP_RECLAIM(9) to disassociate
     93       1.8     rmind  *	underlying file system from the vnode, and finally destroyed.
     94       1.8     rmind  *
     95       1.8     rmind  * Reference counting
     96       1.8     rmind  *
     97       1.8     rmind  *	Vnode is considered active, if reference count (vnode_t::v_usecount)
     98       1.8     rmind  *	is non-zero.  It is maintained using: vref(9) and vrele(9), as well
     99       1.8     rmind  *	as vput(9), routines.  Common points holding references are e.g.
    100       1.8     rmind  *	file openings, current working directory, mount points, etc.
    101       1.8     rmind  *
    102       1.8     rmind  * Note on v_usecount and its locking
    103       1.8     rmind  *
    104       1.8     rmind  *	At nearly all points it is known that v_usecount could be zero,
    105       1.8     rmind  *	the vnode_t::v_interlock will be held.  To change v_usecount away
    106       1.8     rmind  *	from zero, the interlock must be held.  To change from a non-zero
    107       1.8     rmind  *	value to zero, again the interlock must be held.
    108       1.8     rmind  *
    109      1.24   hannken  *	Changing the usecount from a non-zero value to a non-zero value can
    110      1.24   hannken  *	safely be done using atomic operations, without the interlock held.
    111       1.8     rmind  *
    112       1.8     rmind  *	Note: if VI_CLEAN is set, vnode_t::v_interlock will be released while
    113       1.8     rmind  *	mntvnode_lock is still held.
    114      1.20  dholland  *
    115      1.20  dholland  *	See PR 41374.
    116       1.1     rmind  */
    117       1.1     rmind 
    118       1.1     rmind #include <sys/cdefs.h>
    119  1.37.2.2       snj __KERNEL_RCSID(0, "$NetBSD: vfs_vnode.c,v 1.37.2.2 2016/01/26 23:43:34 snj Exp $");
    120      1.23   hannken 
    121      1.23   hannken #define _VFS_VNODE_PRIVATE
    122       1.1     rmind 
    123       1.1     rmind #include <sys/param.h>
    124       1.1     rmind #include <sys/kernel.h>
    125       1.1     rmind 
    126       1.1     rmind #include <sys/atomic.h>
    127       1.1     rmind #include <sys/buf.h>
    128       1.1     rmind #include <sys/conf.h>
    129       1.1     rmind #include <sys/device.h>
    130      1.36   hannken #include <sys/hash.h>
    131       1.1     rmind #include <sys/kauth.h>
    132       1.1     rmind #include <sys/kmem.h>
    133       1.1     rmind #include <sys/kthread.h>
    134       1.1     rmind #include <sys/module.h>
    135       1.1     rmind #include <sys/mount.h>
    136       1.1     rmind #include <sys/namei.h>
    137       1.1     rmind #include <sys/syscallargs.h>
    138       1.1     rmind #include <sys/sysctl.h>
    139       1.1     rmind #include <sys/systm.h>
    140       1.1     rmind #include <sys/vnode.h>
    141       1.1     rmind #include <sys/wapbl.h>
    142      1.24   hannken #include <sys/fstrans.h>
    143       1.1     rmind 
    144       1.1     rmind #include <uvm/uvm.h>
    145       1.1     rmind #include <uvm/uvm_readahead.h>
    146       1.1     rmind 
    147      1.23   hannken /* Flags to vrelel. */
    148      1.23   hannken #define	VRELEL_ASYNC_RELE	0x0001	/* Always defer to vrele thread. */
    149      1.29  christos #define	VRELEL_CHANGING_SET	0x0002	/* VI_CHANGING set by caller. */
    150      1.23   hannken 
    151      1.36   hannken struct vcache_key {
    152      1.36   hannken 	struct mount *vk_mount;
    153      1.36   hannken 	const void *vk_key;
    154      1.36   hannken 	size_t vk_key_len;
    155      1.36   hannken };
    156      1.36   hannken struct vcache_node {
    157      1.36   hannken 	SLIST_ENTRY(vcache_node) vn_hash;
    158      1.36   hannken 	struct vnode *vn_vnode;
    159      1.36   hannken 	struct vcache_key vn_key;
    160      1.36   hannken };
    161      1.36   hannken 
    162       1.6     rmind u_int			numvnodes		__cacheline_aligned;
    163       1.1     rmind 
    164       1.6     rmind static pool_cache_t	vnode_cache		__read_mostly;
    165      1.31   hannken static struct mount	*dead_mount;
    166      1.16     rmind 
    167      1.16     rmind /*
    168      1.16     rmind  * There are two free lists: one is for vnodes which have no buffer/page
    169      1.16     rmind  * references and one for those which do (i.e. v_holdcnt is non-zero).
    170      1.16     rmind  * Vnode recycling mechanism first attempts to look into the former list.
    171      1.16     rmind  */
    172       1.6     rmind static kmutex_t		vnode_free_list_lock	__cacheline_aligned;
    173       1.6     rmind static vnodelst_t	vnode_free_list		__cacheline_aligned;
    174       1.6     rmind static vnodelst_t	vnode_hold_list		__cacheline_aligned;
    175      1.16     rmind static kcondvar_t	vdrain_cv		__cacheline_aligned;
    176      1.16     rmind 
    177       1.6     rmind static vnodelst_t	vrele_list		__cacheline_aligned;
    178       1.6     rmind static kmutex_t		vrele_lock		__cacheline_aligned;
    179       1.6     rmind static kcondvar_t	vrele_cv		__cacheline_aligned;
    180       1.6     rmind static lwp_t *		vrele_lwp		__cacheline_aligned;
    181       1.6     rmind static int		vrele_pending		__cacheline_aligned;
    182       1.6     rmind static int		vrele_gen		__cacheline_aligned;
    183       1.1     rmind 
    184      1.36   hannken static struct {
    185      1.36   hannken 	kmutex_t	lock;
    186      1.36   hannken 	u_long		hashmask;
    187      1.36   hannken 	SLIST_HEAD(hashhead, vcache_node)	*hashtab;
    188      1.36   hannken 	pool_cache_t	pool;
    189      1.36   hannken }			vcache			__cacheline_aligned;
    190      1.36   hannken 
    191      1.12   hannken static int		cleanvnode(void);
    192      1.36   hannken static void		vcache_init(void);
    193      1.36   hannken static void		vcache_reinit(void);
    194      1.25   hannken static void		vclean(vnode_t *);
    195      1.23   hannken static void		vrelel(vnode_t *, int);
    196      1.12   hannken static void		vdrain_thread(void *);
    197       1.1     rmind static void		vrele_thread(void *);
    198      1.11  christos static void		vnpanic(vnode_t *, const char *, ...)
    199      1.18  christos     __printflike(2, 3);
    200      1.35   hannken static void		vwait(vnode_t *, int);
    201       1.1     rmind 
    202       1.1     rmind /* Routines having to do with the management of the vnode table. */
    203       1.1     rmind extern int		(**dead_vnodeop_p)(void *);
    204      1.31   hannken extern struct vfsops	dead_vfsops;
    205       1.1     rmind 
    206       1.1     rmind void
    207       1.1     rmind vfs_vnode_sysinit(void)
    208       1.1     rmind {
    209      1.22    martin 	int error __diagused;
    210       1.1     rmind 
    211       1.1     rmind 	vnode_cache = pool_cache_init(sizeof(vnode_t), 0, 0, 0, "vnodepl",
    212       1.1     rmind 	    NULL, IPL_NONE, NULL, NULL, NULL);
    213       1.1     rmind 	KASSERT(vnode_cache != NULL);
    214       1.1     rmind 
    215      1.31   hannken 	dead_mount = vfs_mountalloc(&dead_vfsops, NULL);
    216      1.31   hannken 	KASSERT(dead_mount != NULL);
    217      1.31   hannken 	dead_mount->mnt_iflag = IMNT_MPSAFE;
    218      1.31   hannken 
    219       1.1     rmind 	mutex_init(&vnode_free_list_lock, MUTEX_DEFAULT, IPL_NONE);
    220       1.1     rmind 	TAILQ_INIT(&vnode_free_list);
    221       1.1     rmind 	TAILQ_INIT(&vnode_hold_list);
    222       1.1     rmind 	TAILQ_INIT(&vrele_list);
    223       1.1     rmind 
    224      1.36   hannken 	vcache_init();
    225      1.36   hannken 
    226       1.1     rmind 	mutex_init(&vrele_lock, MUTEX_DEFAULT, IPL_NONE);
    227      1.12   hannken 	cv_init(&vdrain_cv, "vdrain");
    228       1.1     rmind 	cv_init(&vrele_cv, "vrele");
    229      1.12   hannken 	error = kthread_create(PRI_VM, KTHREAD_MPSAFE, NULL, vdrain_thread,
    230      1.12   hannken 	    NULL, NULL, "vdrain");
    231      1.12   hannken 	KASSERT(error == 0);
    232       1.1     rmind 	error = kthread_create(PRI_VM, KTHREAD_MPSAFE, NULL, vrele_thread,
    233       1.1     rmind 	    NULL, &vrele_lwp, "vrele");
    234       1.1     rmind 	KASSERT(error == 0);
    235       1.1     rmind }
    236       1.1     rmind 
    237       1.1     rmind /*
    238       1.1     rmind  * Allocate a new, uninitialized vnode.  If 'mp' is non-NULL, this is a
    239      1.13   hannken  * marker vnode.
    240       1.1     rmind  */
    241       1.1     rmind vnode_t *
    242       1.1     rmind vnalloc(struct mount *mp)
    243       1.1     rmind {
    244       1.1     rmind 	vnode_t *vp;
    245       1.1     rmind 
    246      1.13   hannken 	vp = pool_cache_get(vnode_cache, PR_WAITOK);
    247      1.13   hannken 	KASSERT(vp != NULL);
    248       1.1     rmind 
    249       1.1     rmind 	memset(vp, 0, sizeof(*vp));
    250       1.9     rmind 	uvm_obj_init(&vp->v_uobj, &uvm_vnodeops, true, 0);
    251       1.1     rmind 	cv_init(&vp->v_cv, "vnode");
    252       1.1     rmind 	/*
    253       1.1     rmind 	 * Done by memset() above.
    254       1.1     rmind 	 *	LIST_INIT(&vp->v_nclist);
    255       1.1     rmind 	 *	LIST_INIT(&vp->v_dnclist);
    256       1.1     rmind 	 */
    257       1.1     rmind 
    258       1.1     rmind 	if (mp != NULL) {
    259       1.1     rmind 		vp->v_mount = mp;
    260       1.1     rmind 		vp->v_type = VBAD;
    261       1.1     rmind 		vp->v_iflag = VI_MARKER;
    262      1.36   hannken 		return vp;
    263       1.1     rmind 	}
    264       1.1     rmind 
    265      1.36   hannken 	mutex_enter(&vnode_free_list_lock);
    266      1.36   hannken 	numvnodes++;
    267      1.36   hannken 	if (numvnodes > desiredvnodes + desiredvnodes / 10)
    268      1.36   hannken 		cv_signal(&vdrain_cv);
    269      1.36   hannken 	mutex_exit(&vnode_free_list_lock);
    270      1.36   hannken 
    271      1.36   hannken 	rw_init(&vp->v_lock);
    272      1.36   hannken 	vp->v_usecount = 1;
    273      1.36   hannken 	vp->v_type = VNON;
    274      1.36   hannken 	vp->v_size = vp->v_writesize = VSIZENOTSET;
    275      1.36   hannken 
    276       1.1     rmind 	return vp;
    277       1.1     rmind }
    278       1.1     rmind 
    279       1.1     rmind /*
    280       1.1     rmind  * Free an unused, unreferenced vnode.
    281       1.1     rmind  */
    282       1.1     rmind void
    283       1.1     rmind vnfree(vnode_t *vp)
    284       1.1     rmind {
    285       1.1     rmind 
    286       1.1     rmind 	KASSERT(vp->v_usecount == 0);
    287       1.1     rmind 
    288       1.1     rmind 	if ((vp->v_iflag & VI_MARKER) == 0) {
    289       1.1     rmind 		rw_destroy(&vp->v_lock);
    290       1.1     rmind 		mutex_enter(&vnode_free_list_lock);
    291       1.1     rmind 		numvnodes--;
    292       1.1     rmind 		mutex_exit(&vnode_free_list_lock);
    293       1.1     rmind 	}
    294       1.1     rmind 
    295       1.9     rmind 	/*
    296       1.9     rmind 	 * Note: the vnode interlock will either be freed, of reference
    297       1.9     rmind 	 * dropped (if VI_LOCKSHARE was in use).
    298       1.9     rmind 	 */
    299       1.9     rmind 	uvm_obj_destroy(&vp->v_uobj, true);
    300       1.1     rmind 	cv_destroy(&vp->v_cv);
    301       1.1     rmind 	pool_cache_put(vnode_cache, vp);
    302       1.1     rmind }
    303       1.1     rmind 
    304       1.1     rmind /*
    305      1.12   hannken  * cleanvnode: grab a vnode from freelist, clean and free it.
    306       1.5     rmind  *
    307       1.5     rmind  * => Releases vnode_free_list_lock.
    308       1.1     rmind  */
    309      1.12   hannken static int
    310      1.12   hannken cleanvnode(void)
    311       1.1     rmind {
    312       1.1     rmind 	vnode_t *vp;
    313       1.1     rmind 	vnodelst_t *listhd;
    314      1.24   hannken 	struct mount *mp;
    315       1.1     rmind 
    316       1.1     rmind 	KASSERT(mutex_owned(&vnode_free_list_lock));
    317      1.24   hannken 
    318       1.1     rmind 	listhd = &vnode_free_list;
    319       1.1     rmind try_nextlist:
    320       1.1     rmind 	TAILQ_FOREACH(vp, listhd, v_freelist) {
    321       1.1     rmind 		/*
    322       1.1     rmind 		 * It's safe to test v_usecount and v_iflag
    323       1.1     rmind 		 * without holding the interlock here, since
    324       1.1     rmind 		 * these vnodes should never appear on the
    325       1.1     rmind 		 * lists.
    326       1.1     rmind 		 */
    327       1.5     rmind 		KASSERT(vp->v_usecount == 0);
    328       1.5     rmind 		KASSERT((vp->v_iflag & VI_CLEAN) == 0);
    329       1.5     rmind 		KASSERT(vp->v_freelisthd == listhd);
    330       1.5     rmind 
    331  1.37.2.2       snj 		if (vn_lock(vp, LK_EXCLUSIVE | LK_NOWAIT) != 0)
    332       1.1     rmind 			continue;
    333  1.37.2.2       snj 		if (!mutex_tryenter(vp->v_interlock)) {
    334  1.37.2.2       snj 			VOP_UNLOCK(vp);
    335      1.24   hannken 			continue;
    336      1.24   hannken 		}
    337  1.37.2.2       snj 		KASSERT((vp->v_iflag & VI_XLOCK) == 0);
    338      1.24   hannken 		mp = vp->v_mount;
    339      1.24   hannken 		if (fstrans_start_nowait(mp, FSTRANS_SHARED) != 0) {
    340      1.24   hannken 			mutex_exit(vp->v_interlock);
    341  1.37.2.2       snj 			VOP_UNLOCK(vp);
    342      1.24   hannken 			continue;
    343      1.24   hannken 		}
    344      1.24   hannken 		break;
    345       1.1     rmind 	}
    346       1.1     rmind 
    347       1.1     rmind 	if (vp == NULL) {
    348       1.1     rmind 		if (listhd == &vnode_free_list) {
    349       1.1     rmind 			listhd = &vnode_hold_list;
    350       1.1     rmind 			goto try_nextlist;
    351       1.1     rmind 		}
    352       1.1     rmind 		mutex_exit(&vnode_free_list_lock);
    353      1.12   hannken 		return EBUSY;
    354       1.1     rmind 	}
    355       1.1     rmind 
    356       1.1     rmind 	/* Remove it from the freelist. */
    357       1.1     rmind 	TAILQ_REMOVE(listhd, vp, v_freelist);
    358       1.1     rmind 	vp->v_freelisthd = NULL;
    359       1.1     rmind 	mutex_exit(&vnode_free_list_lock);
    360       1.1     rmind 
    361       1.1     rmind 	KASSERT(vp->v_usecount == 0);
    362       1.1     rmind 
    363       1.1     rmind 	/*
    364       1.1     rmind 	 * The vnode is still associated with a file system, so we must
    365      1.12   hannken 	 * clean it out before freeing it.  We need to add a reference
    366      1.24   hannken 	 * before doing this.
    367       1.1     rmind 	 */
    368      1.24   hannken 	vp->v_usecount = 1;
    369      1.29  christos 	KASSERT((vp->v_iflag & VI_CHANGING) == 0);
    370      1.29  christos 	vp->v_iflag |= VI_CHANGING;
    371      1.25   hannken 	vclean(vp);
    372      1.29  christos 	vrelel(vp, VRELEL_CHANGING_SET);
    373      1.24   hannken 	fstrans_done(mp);
    374      1.12   hannken 
    375      1.12   hannken 	return 0;
    376       1.1     rmind }
    377       1.1     rmind 
    378       1.1     rmind /*
    379      1.12   hannken  * getnewvnode: return a fresh vnode.
    380       1.5     rmind  *
    381       1.5     rmind  * => Returns referenced vnode, moved into the mount queue.
    382       1.9     rmind  * => Shares the interlock specified by 'slock', if it is not NULL.
    383       1.1     rmind  */
    384       1.1     rmind int
    385       1.1     rmind getnewvnode(enum vtagtype tag, struct mount *mp, int (**vops)(void *),
    386       1.9     rmind     kmutex_t *slock, vnode_t **vpp)
    387       1.1     rmind {
    388      1.22    martin 	struct uvm_object *uobj __diagused;
    389       1.1     rmind 	vnode_t *vp;
    390      1.12   hannken 	int error = 0;
    391       1.1     rmind 
    392       1.1     rmind 	if (mp != NULL) {
    393       1.1     rmind 		/*
    394       1.4     rmind 		 * Mark filesystem busy while we are creating a vnode.
    395       1.4     rmind 		 * If unmount is in progress, this will fail.
    396       1.1     rmind 		 */
    397       1.1     rmind 		error = vfs_busy(mp, NULL);
    398       1.1     rmind 		if (error)
    399       1.1     rmind 			return error;
    400       1.1     rmind 	}
    401       1.1     rmind 
    402       1.1     rmind 	vp = NULL;
    403       1.1     rmind 
    404      1.12   hannken 	/* Allocate a new vnode. */
    405      1.14   hannken 	vp = vnalloc(NULL);
    406       1.1     rmind 
    407       1.1     rmind 	KASSERT(vp->v_freelisthd == NULL);
    408       1.1     rmind 	KASSERT(LIST_EMPTY(&vp->v_nclist));
    409       1.1     rmind 	KASSERT(LIST_EMPTY(&vp->v_dnclist));
    410      1.36   hannken 	KASSERT(vp->v_data == NULL);
    411       1.1     rmind 
    412       1.5     rmind 	/* Initialize vnode. */
    413       1.1     rmind 	vp->v_tag = tag;
    414       1.1     rmind 	vp->v_op = vops;
    415       1.1     rmind 
    416       1.1     rmind 	uobj = &vp->v_uobj;
    417       1.1     rmind 	KASSERT(uobj->pgops == &uvm_vnodeops);
    418       1.1     rmind 	KASSERT(uobj->uo_npages == 0);
    419       1.1     rmind 	KASSERT(TAILQ_FIRST(&uobj->memq) == NULL);
    420       1.1     rmind 
    421       1.9     rmind 	/* Share the vnode_t::v_interlock, if requested. */
    422       1.9     rmind 	if (slock) {
    423       1.9     rmind 		/* Set the interlock and mark that it is shared. */
    424       1.9     rmind 		KASSERT(vp->v_mount == NULL);
    425       1.9     rmind 		mutex_obj_hold(slock);
    426       1.9     rmind 		uvm_obj_setlock(&vp->v_uobj, slock);
    427       1.9     rmind 		KASSERT(vp->v_interlock == slock);
    428       1.9     rmind 		vp->v_iflag |= VI_LOCKSHARE;
    429       1.9     rmind 	}
    430       1.9     rmind 
    431       1.5     rmind 	/* Finally, move vnode into the mount queue. */
    432       1.5     rmind 	vfs_insmntque(vp, mp);
    433       1.5     rmind 
    434       1.1     rmind 	if (mp != NULL) {
    435       1.1     rmind 		if ((mp->mnt_iflag & IMNT_MPSAFE) != 0)
    436       1.1     rmind 			vp->v_vflag |= VV_MPSAFE;
    437       1.1     rmind 		vfs_unbusy(mp, true, NULL);
    438       1.1     rmind 	}
    439       1.1     rmind 
    440       1.5     rmind 	*vpp = vp;
    441       1.4     rmind 	return 0;
    442       1.1     rmind }
    443       1.1     rmind 
    444       1.1     rmind /*
    445       1.1     rmind  * This is really just the reverse of getnewvnode(). Needed for
    446       1.1     rmind  * VFS_VGET functions who may need to push back a vnode in case
    447       1.1     rmind  * of a locking race.
    448       1.1     rmind  */
    449       1.1     rmind void
    450       1.1     rmind ungetnewvnode(vnode_t *vp)
    451       1.1     rmind {
    452       1.1     rmind 
    453       1.1     rmind 	KASSERT(vp->v_usecount == 1);
    454       1.1     rmind 	KASSERT(vp->v_data == NULL);
    455       1.1     rmind 	KASSERT(vp->v_freelisthd == NULL);
    456       1.1     rmind 
    457       1.9     rmind 	mutex_enter(vp->v_interlock);
    458       1.1     rmind 	vp->v_iflag |= VI_CLEAN;
    459       1.1     rmind 	vrelel(vp, 0);
    460       1.1     rmind }
    461       1.1     rmind 
    462       1.1     rmind /*
    463      1.12   hannken  * Helper thread to keep the number of vnodes below desiredvnodes.
    464      1.12   hannken  */
    465      1.12   hannken static void
    466      1.12   hannken vdrain_thread(void *cookie)
    467      1.12   hannken {
    468      1.12   hannken 	int error;
    469      1.12   hannken 
    470      1.12   hannken 	mutex_enter(&vnode_free_list_lock);
    471      1.12   hannken 
    472      1.12   hannken 	for (;;) {
    473      1.12   hannken 		cv_timedwait(&vdrain_cv, &vnode_free_list_lock, hz);
    474      1.12   hannken 		while (numvnodes > desiredvnodes) {
    475      1.12   hannken 			error = cleanvnode();
    476      1.12   hannken 			if (error)
    477      1.12   hannken 				kpause("vndsbusy", false, hz, NULL);
    478      1.12   hannken 			mutex_enter(&vnode_free_list_lock);
    479      1.12   hannken 			if (error)
    480      1.12   hannken 				break;
    481      1.12   hannken 		}
    482      1.12   hannken 	}
    483      1.12   hannken }
    484      1.12   hannken 
    485      1.12   hannken /*
    486       1.1     rmind  * Remove a vnode from its freelist.
    487       1.1     rmind  */
    488       1.1     rmind void
    489       1.1     rmind vremfree(vnode_t *vp)
    490       1.1     rmind {
    491       1.1     rmind 
    492       1.9     rmind 	KASSERT(mutex_owned(vp->v_interlock));
    493       1.1     rmind 	KASSERT(vp->v_usecount == 0);
    494       1.1     rmind 
    495       1.1     rmind 	/*
    496       1.1     rmind 	 * Note that the reference count must not change until
    497       1.1     rmind 	 * the vnode is removed.
    498       1.1     rmind 	 */
    499       1.1     rmind 	mutex_enter(&vnode_free_list_lock);
    500       1.1     rmind 	if (vp->v_holdcnt > 0) {
    501       1.1     rmind 		KASSERT(vp->v_freelisthd == &vnode_hold_list);
    502       1.1     rmind 	} else {
    503       1.1     rmind 		KASSERT(vp->v_freelisthd == &vnode_free_list);
    504       1.1     rmind 	}
    505       1.1     rmind 	TAILQ_REMOVE(vp->v_freelisthd, vp, v_freelist);
    506       1.1     rmind 	vp->v_freelisthd = NULL;
    507       1.1     rmind 	mutex_exit(&vnode_free_list_lock);
    508       1.1     rmind }
    509       1.1     rmind 
    510       1.1     rmind /*
    511       1.4     rmind  * vget: get a particular vnode from the free list, increment its reference
    512       1.4     rmind  * count and lock it.
    513       1.4     rmind  *
    514       1.4     rmind  * => Should be called with v_interlock held.
    515       1.4     rmind  *
    516      1.29  christos  * If VI_CHANGING is set, the vnode may be eliminated in vgone()/vclean().
    517       1.4     rmind  * In that case, we cannot grab the vnode, so the process is awakened when
    518       1.4     rmind  * the transition is completed, and an error returned to indicate that the
    519      1.29  christos  * vnode is no longer usable.
    520       1.1     rmind  */
    521       1.1     rmind int
    522       1.1     rmind vget(vnode_t *vp, int flags)
    523       1.1     rmind {
    524       1.1     rmind 	int error = 0;
    525       1.1     rmind 
    526       1.1     rmind 	KASSERT((vp->v_iflag & VI_MARKER) == 0);
    527       1.9     rmind 	KASSERT(mutex_owned(vp->v_interlock));
    528       1.1     rmind 	KASSERT((flags & ~(LK_SHARED|LK_EXCLUSIVE|LK_NOWAIT)) == 0);
    529       1.1     rmind 
    530       1.1     rmind 	/*
    531       1.1     rmind 	 * Before adding a reference, we must remove the vnode
    532       1.1     rmind 	 * from its freelist.
    533       1.1     rmind 	 */
    534       1.1     rmind 	if (vp->v_usecount == 0) {
    535       1.1     rmind 		vremfree(vp);
    536       1.1     rmind 		vp->v_usecount = 1;
    537       1.1     rmind 	} else {
    538       1.1     rmind 		atomic_inc_uint(&vp->v_usecount);
    539       1.1     rmind 	}
    540       1.1     rmind 
    541       1.1     rmind 	/*
    542      1.29  christos 	 * If the vnode is in the process of changing state we wait
    543      1.29  christos 	 * for the change to complete and take care not to return
    544      1.29  christos 	 * a clean vnode.
    545       1.1     rmind 	 */
    546      1.29  christos 	if ((vp->v_iflag & VI_CHANGING) != 0) {
    547       1.1     rmind 		if ((flags & LK_NOWAIT) != 0) {
    548       1.1     rmind 			vrelel(vp, 0);
    549       1.1     rmind 			return EBUSY;
    550       1.1     rmind 		}
    551      1.29  christos 		vwait(vp, VI_CHANGING);
    552      1.17   hannken 		if ((vp->v_iflag & VI_CLEAN) != 0) {
    553      1.17   hannken 			vrelel(vp, 0);
    554      1.17   hannken 			return ENOENT;
    555      1.17   hannken 		}
    556      1.17   hannken 	}
    557      1.17   hannken 
    558       1.1     rmind 	/*
    559       1.1     rmind 	 * Ok, we got it in good shape.  Just locking left.
    560       1.1     rmind 	 */
    561       1.1     rmind 	KASSERT((vp->v_iflag & VI_CLEAN) == 0);
    562       1.9     rmind 	mutex_exit(vp->v_interlock);
    563       1.1     rmind 	if (flags & (LK_EXCLUSIVE | LK_SHARED)) {
    564       1.1     rmind 		error = vn_lock(vp, flags);
    565       1.1     rmind 		if (error != 0) {
    566       1.1     rmind 			vrele(vp);
    567       1.1     rmind 		}
    568       1.1     rmind 	}
    569       1.1     rmind 	return error;
    570       1.1     rmind }
    571       1.1     rmind 
    572       1.1     rmind /*
    573       1.4     rmind  * vput: unlock and release the reference.
    574       1.1     rmind  */
    575       1.1     rmind void
    576       1.1     rmind vput(vnode_t *vp)
    577       1.1     rmind {
    578       1.1     rmind 
    579       1.1     rmind 	KASSERT((vp->v_iflag & VI_MARKER) == 0);
    580       1.1     rmind 
    581       1.1     rmind 	VOP_UNLOCK(vp);
    582       1.1     rmind 	vrele(vp);
    583       1.1     rmind }
    584       1.1     rmind 
    585       1.1     rmind /*
    586       1.1     rmind  * Try to drop reference on a vnode.  Abort if we are releasing the
    587       1.1     rmind  * last reference.  Note: this _must_ succeed if not the last reference.
    588       1.1     rmind  */
    589       1.1     rmind static inline bool
    590       1.1     rmind vtryrele(vnode_t *vp)
    591       1.1     rmind {
    592       1.1     rmind 	u_int use, next;
    593       1.1     rmind 
    594       1.1     rmind 	for (use = vp->v_usecount;; use = next) {
    595       1.1     rmind 		if (use == 1) {
    596       1.1     rmind 			return false;
    597       1.1     rmind 		}
    598      1.24   hannken 		KASSERT(use > 1);
    599       1.1     rmind 		next = atomic_cas_uint(&vp->v_usecount, use, use - 1);
    600       1.1     rmind 		if (__predict_true(next == use)) {
    601       1.1     rmind 			return true;
    602       1.1     rmind 		}
    603       1.1     rmind 	}
    604       1.1     rmind }
    605       1.1     rmind 
    606       1.1     rmind /*
    607       1.1     rmind  * Vnode release.  If reference count drops to zero, call inactive
    608       1.1     rmind  * routine and either return to freelist or free to the pool.
    609       1.1     rmind  */
    610      1.23   hannken static void
    611       1.1     rmind vrelel(vnode_t *vp, int flags)
    612       1.1     rmind {
    613       1.1     rmind 	bool recycle, defer;
    614       1.1     rmind 	int error;
    615       1.1     rmind 
    616       1.9     rmind 	KASSERT(mutex_owned(vp->v_interlock));
    617       1.1     rmind 	KASSERT((vp->v_iflag & VI_MARKER) == 0);
    618       1.1     rmind 	KASSERT(vp->v_freelisthd == NULL);
    619       1.1     rmind 
    620       1.1     rmind 	if (__predict_false(vp->v_op == dead_vnodeop_p &&
    621       1.1     rmind 	    (vp->v_iflag & (VI_CLEAN|VI_XLOCK)) == 0)) {
    622      1.11  christos 		vnpanic(vp, "dead but not clean");
    623       1.1     rmind 	}
    624       1.1     rmind 
    625       1.1     rmind 	/*
    626       1.1     rmind 	 * If not the last reference, just drop the reference count
    627       1.1     rmind 	 * and unlock.
    628       1.1     rmind 	 */
    629       1.1     rmind 	if (vtryrele(vp)) {
    630      1.29  christos 		if ((flags & VRELEL_CHANGING_SET) != 0) {
    631      1.29  christos 			KASSERT((vp->v_iflag & VI_CHANGING) != 0);
    632      1.29  christos 			vp->v_iflag &= ~VI_CHANGING;
    633      1.29  christos 			cv_broadcast(&vp->v_cv);
    634      1.29  christos 		}
    635       1.9     rmind 		mutex_exit(vp->v_interlock);
    636       1.1     rmind 		return;
    637       1.1     rmind 	}
    638       1.1     rmind 	if (vp->v_usecount <= 0 || vp->v_writecount != 0) {
    639      1.11  christos 		vnpanic(vp, "%s: bad ref count", __func__);
    640       1.1     rmind 	}
    641       1.1     rmind 
    642       1.1     rmind 	KASSERT((vp->v_iflag & VI_XLOCK) == 0);
    643       1.1     rmind 
    644      1.15   hannken #ifdef DIAGNOSTIC
    645      1.15   hannken 	if ((vp->v_type == VBLK || vp->v_type == VCHR) &&
    646      1.15   hannken 	    vp->v_specnode != NULL && vp->v_specnode->sn_opencnt != 0) {
    647      1.15   hannken 		vprint("vrelel: missing VOP_CLOSE()", vp);
    648      1.15   hannken 	}
    649      1.15   hannken #endif
    650      1.15   hannken 
    651       1.1     rmind 	/*
    652       1.1     rmind 	 * If not clean, deactivate the vnode, but preserve
    653       1.1     rmind 	 * our reference across the call to VOP_INACTIVE().
    654       1.1     rmind 	 */
    655       1.1     rmind 	if ((vp->v_iflag & VI_CLEAN) == 0) {
    656       1.1     rmind 		recycle = false;
    657       1.1     rmind 
    658       1.1     rmind 		/*
    659       1.1     rmind 		 * XXX This ugly block can be largely eliminated if
    660       1.1     rmind 		 * locking is pushed down into the file systems.
    661       1.1     rmind 		 *
    662       1.1     rmind 		 * Defer vnode release to vrele_thread if caller
    663      1.30   hannken 		 * requests it explicitly or is the pagedaemon.
    664       1.1     rmind 		 */
    665       1.1     rmind 		if ((curlwp == uvm.pagedaemon_lwp) ||
    666       1.1     rmind 		    (flags & VRELEL_ASYNC_RELE) != 0) {
    667       1.1     rmind 			defer = true;
    668       1.1     rmind 		} else if (curlwp == vrele_lwp) {
    669      1.17   hannken 			/*
    670      1.29  christos 			 * We have to try harder.
    671      1.17   hannken 			 */
    672       1.9     rmind 			mutex_exit(vp->v_interlock);
    673      1.32   hannken 			error = vn_lock(vp, LK_EXCLUSIVE | LK_RETRY);
    674      1.30   hannken 			KASSERT(error == 0);
    675      1.17   hannken 			mutex_enter(vp->v_interlock);
    676       1.1     rmind 			defer = false;
    677       1.4     rmind 		} else {
    678       1.1     rmind 			/* If we can't acquire the lock, then defer. */
    679      1.32   hannken 			mutex_exit(vp->v_interlock);
    680      1.32   hannken 			error = vn_lock(vp,
    681      1.32   hannken 			    LK_EXCLUSIVE | LK_RETRY | LK_NOWAIT);
    682      1.30   hannken 			defer = (error != 0);
    683      1.32   hannken 			mutex_enter(vp->v_interlock);
    684       1.1     rmind 		}
    685       1.1     rmind 
    686      1.30   hannken 		KASSERT(mutex_owned(vp->v_interlock));
    687      1.30   hannken 		KASSERT(! (curlwp == vrele_lwp && defer));
    688      1.30   hannken 
    689       1.1     rmind 		if (defer) {
    690       1.1     rmind 			/*
    691       1.1     rmind 			 * Defer reclaim to the kthread; it's not safe to
    692       1.1     rmind 			 * clean it here.  We donate it our last reference.
    693       1.1     rmind 			 */
    694      1.29  christos 			if ((flags & VRELEL_CHANGING_SET) != 0) {
    695      1.29  christos 				KASSERT((vp->v_iflag & VI_CHANGING) != 0);
    696      1.29  christos 				vp->v_iflag &= ~VI_CHANGING;
    697      1.29  christos 				cv_broadcast(&vp->v_cv);
    698      1.29  christos 			}
    699       1.1     rmind 			mutex_enter(&vrele_lock);
    700       1.1     rmind 			TAILQ_INSERT_TAIL(&vrele_list, vp, v_freelist);
    701       1.1     rmind 			if (++vrele_pending > (desiredvnodes >> 8))
    702       1.1     rmind 				cv_signal(&vrele_cv);
    703       1.1     rmind 			mutex_exit(&vrele_lock);
    704       1.9     rmind 			mutex_exit(vp->v_interlock);
    705       1.1     rmind 			return;
    706       1.1     rmind 		}
    707       1.1     rmind 
    708      1.32   hannken 		/*
    709      1.32   hannken 		 * If the node got another reference while we
    710      1.32   hannken 		 * released the interlock, don't try to inactivate it yet.
    711      1.32   hannken 		 */
    712      1.32   hannken 		if (__predict_false(vtryrele(vp))) {
    713      1.32   hannken 			VOP_UNLOCK(vp);
    714      1.32   hannken 			if ((flags & VRELEL_CHANGING_SET) != 0) {
    715      1.32   hannken 				KASSERT((vp->v_iflag & VI_CHANGING) != 0);
    716      1.32   hannken 				vp->v_iflag &= ~VI_CHANGING;
    717      1.32   hannken 				cv_broadcast(&vp->v_cv);
    718      1.32   hannken 			}
    719      1.32   hannken 			mutex_exit(vp->v_interlock);
    720      1.32   hannken 			return;
    721      1.32   hannken 		}
    722      1.32   hannken 
    723      1.29  christos 		if ((flags & VRELEL_CHANGING_SET) == 0) {
    724      1.29  christos 			KASSERT((vp->v_iflag & VI_CHANGING) == 0);
    725      1.29  christos 			vp->v_iflag |= VI_CHANGING;
    726      1.29  christos 		}
    727      1.29  christos 		mutex_exit(vp->v_interlock);
    728      1.29  christos 
    729       1.1     rmind 		/*
    730       1.1     rmind 		 * The vnode can gain another reference while being
    731       1.1     rmind 		 * deactivated.  If VOP_INACTIVE() indicates that
    732       1.1     rmind 		 * the described file has been deleted, then recycle
    733       1.1     rmind 		 * the vnode irrespective of additional references.
    734       1.1     rmind 		 * Another thread may be waiting to re-use the on-disk
    735       1.1     rmind 		 * inode.
    736       1.1     rmind 		 *
    737       1.1     rmind 		 * Note that VOP_INACTIVE() will drop the vnode lock.
    738       1.1     rmind 		 */
    739       1.1     rmind 		VOP_INACTIVE(vp, &recycle);
    740  1.37.2.2       snj 		if (recycle) {
    741  1.37.2.2       snj 			/* vclean() below will drop the lock. */
    742  1.37.2.2       snj 			if (vn_lock(vp, LK_EXCLUSIVE) != 0)
    743  1.37.2.2       snj 				recycle = false;
    744  1.37.2.2       snj 		}
    745       1.9     rmind 		mutex_enter(vp->v_interlock);
    746       1.1     rmind 		if (!recycle) {
    747       1.1     rmind 			if (vtryrele(vp)) {
    748      1.29  christos 				KASSERT((vp->v_iflag & VI_CHANGING) != 0);
    749      1.29  christos 				vp->v_iflag &= ~VI_CHANGING;
    750      1.29  christos 				cv_broadcast(&vp->v_cv);
    751       1.9     rmind 				mutex_exit(vp->v_interlock);
    752       1.1     rmind 				return;
    753       1.1     rmind 			}
    754       1.1     rmind 		}
    755       1.1     rmind 
    756       1.1     rmind 		/* Take care of space accounting. */
    757       1.1     rmind 		if (vp->v_iflag & VI_EXECMAP) {
    758       1.1     rmind 			atomic_add_int(&uvmexp.execpages,
    759       1.1     rmind 			    -vp->v_uobj.uo_npages);
    760       1.1     rmind 			atomic_add_int(&uvmexp.filepages,
    761       1.1     rmind 			    vp->v_uobj.uo_npages);
    762       1.1     rmind 		}
    763       1.1     rmind 		vp->v_iflag &= ~(VI_TEXT|VI_EXECMAP|VI_WRMAP);
    764       1.1     rmind 		vp->v_vflag &= ~VV_MAPPED;
    765       1.1     rmind 
    766       1.1     rmind 		/*
    767       1.1     rmind 		 * Recycle the vnode if the file is now unused (unlinked),
    768       1.1     rmind 		 * otherwise just free it.
    769       1.1     rmind 		 */
    770       1.1     rmind 		if (recycle) {
    771      1.25   hannken 			vclean(vp);
    772       1.1     rmind 		}
    773       1.1     rmind 		KASSERT(vp->v_usecount > 0);
    774      1.29  christos 	} else { /* vnode was already clean */
    775      1.29  christos 		if ((flags & VRELEL_CHANGING_SET) == 0) {
    776      1.29  christos 			KASSERT((vp->v_iflag & VI_CHANGING) == 0);
    777      1.29  christos 			vp->v_iflag |= VI_CHANGING;
    778      1.29  christos 		}
    779       1.1     rmind 	}
    780       1.1     rmind 
    781       1.1     rmind 	if (atomic_dec_uint_nv(&vp->v_usecount) != 0) {
    782       1.1     rmind 		/* Gained another reference while being reclaimed. */
    783      1.29  christos 		KASSERT((vp->v_iflag & VI_CHANGING) != 0);
    784      1.29  christos 		vp->v_iflag &= ~VI_CHANGING;
    785      1.29  christos 		cv_broadcast(&vp->v_cv);
    786       1.9     rmind 		mutex_exit(vp->v_interlock);
    787       1.1     rmind 		return;
    788       1.1     rmind 	}
    789       1.1     rmind 
    790       1.1     rmind 	if ((vp->v_iflag & VI_CLEAN) != 0) {
    791       1.1     rmind 		/*
    792       1.1     rmind 		 * It's clean so destroy it.  It isn't referenced
    793       1.1     rmind 		 * anywhere since it has been reclaimed.
    794       1.1     rmind 		 */
    795       1.1     rmind 		KASSERT(vp->v_holdcnt == 0);
    796       1.1     rmind 		KASSERT(vp->v_writecount == 0);
    797       1.9     rmind 		mutex_exit(vp->v_interlock);
    798       1.1     rmind 		vfs_insmntque(vp, NULL);
    799       1.1     rmind 		if (vp->v_type == VBLK || vp->v_type == VCHR) {
    800       1.1     rmind 			spec_node_destroy(vp);
    801       1.1     rmind 		}
    802       1.1     rmind 		vnfree(vp);
    803       1.1     rmind 	} else {
    804       1.1     rmind 		/*
    805       1.1     rmind 		 * Otherwise, put it back onto the freelist.  It
    806       1.1     rmind 		 * can't be destroyed while still associated with
    807       1.1     rmind 		 * a file system.
    808       1.1     rmind 		 */
    809       1.1     rmind 		mutex_enter(&vnode_free_list_lock);
    810       1.1     rmind 		if (vp->v_holdcnt > 0) {
    811       1.1     rmind 			vp->v_freelisthd = &vnode_hold_list;
    812       1.1     rmind 		} else {
    813       1.1     rmind 			vp->v_freelisthd = &vnode_free_list;
    814       1.1     rmind 		}
    815       1.1     rmind 		TAILQ_INSERT_TAIL(vp->v_freelisthd, vp, v_freelist);
    816       1.1     rmind 		mutex_exit(&vnode_free_list_lock);
    817      1.29  christos 		KASSERT((vp->v_iflag & VI_CHANGING) != 0);
    818      1.29  christos 		vp->v_iflag &= ~VI_CHANGING;
    819      1.29  christos 		cv_broadcast(&vp->v_cv);
    820       1.9     rmind 		mutex_exit(vp->v_interlock);
    821       1.1     rmind 	}
    822       1.1     rmind }
    823       1.1     rmind 
    824       1.1     rmind void
    825       1.1     rmind vrele(vnode_t *vp)
    826       1.1     rmind {
    827       1.1     rmind 
    828       1.1     rmind 	KASSERT((vp->v_iflag & VI_MARKER) == 0);
    829       1.1     rmind 
    830      1.29  christos 	if (vtryrele(vp)) {
    831       1.1     rmind 		return;
    832       1.1     rmind 	}
    833       1.9     rmind 	mutex_enter(vp->v_interlock);
    834       1.1     rmind 	vrelel(vp, 0);
    835       1.1     rmind }
    836       1.1     rmind 
    837       1.1     rmind /*
    838       1.1     rmind  * Asynchronous vnode release, vnode is released in different context.
    839       1.1     rmind  */
    840       1.1     rmind void
    841       1.1     rmind vrele_async(vnode_t *vp)
    842       1.1     rmind {
    843       1.1     rmind 
    844       1.1     rmind 	KASSERT((vp->v_iflag & VI_MARKER) == 0);
    845       1.1     rmind 
    846      1.29  christos 	if (vtryrele(vp)) {
    847       1.1     rmind 		return;
    848       1.1     rmind 	}
    849       1.9     rmind 	mutex_enter(vp->v_interlock);
    850       1.1     rmind 	vrelel(vp, VRELEL_ASYNC_RELE);
    851       1.1     rmind }
    852       1.1     rmind 
    853       1.1     rmind static void
    854       1.1     rmind vrele_thread(void *cookie)
    855       1.1     rmind {
    856      1.34   hannken 	vnodelst_t skip_list;
    857       1.1     rmind 	vnode_t *vp;
    858      1.34   hannken 	struct mount *mp;
    859      1.34   hannken 
    860      1.34   hannken 	TAILQ_INIT(&skip_list);
    861       1.1     rmind 
    862      1.34   hannken 	mutex_enter(&vrele_lock);
    863       1.1     rmind 	for (;;) {
    864       1.1     rmind 		while (TAILQ_EMPTY(&vrele_list)) {
    865       1.1     rmind 			vrele_gen++;
    866       1.1     rmind 			cv_broadcast(&vrele_cv);
    867       1.1     rmind 			cv_timedwait(&vrele_cv, &vrele_lock, hz);
    868      1.34   hannken 			TAILQ_CONCAT(&vrele_list, &skip_list, v_freelist);
    869       1.1     rmind 		}
    870       1.1     rmind 		vp = TAILQ_FIRST(&vrele_list);
    871      1.34   hannken 		mp = vp->v_mount;
    872       1.1     rmind 		TAILQ_REMOVE(&vrele_list, vp, v_freelist);
    873      1.34   hannken 		if (fstrans_start_nowait(mp, FSTRANS_LAZY) != 0) {
    874      1.34   hannken 			TAILQ_INSERT_TAIL(&skip_list, vp, v_freelist);
    875      1.34   hannken 			continue;
    876      1.34   hannken 		}
    877       1.1     rmind 		vrele_pending--;
    878       1.1     rmind 		mutex_exit(&vrele_lock);
    879       1.1     rmind 
    880       1.1     rmind 		/*
    881       1.1     rmind 		 * If not the last reference, then ignore the vnode
    882       1.1     rmind 		 * and look for more work.
    883       1.1     rmind 		 */
    884       1.9     rmind 		mutex_enter(vp->v_interlock);
    885       1.1     rmind 		vrelel(vp, 0);
    886      1.34   hannken 		fstrans_done(mp);
    887      1.34   hannken 		mutex_enter(&vrele_lock);
    888       1.1     rmind 	}
    889       1.1     rmind }
    890       1.1     rmind 
    891       1.2     rmind void
    892       1.2     rmind vrele_flush(void)
    893       1.2     rmind {
    894       1.2     rmind 	int gen;
    895       1.2     rmind 
    896       1.2     rmind 	mutex_enter(&vrele_lock);
    897       1.2     rmind 	gen = vrele_gen;
    898       1.2     rmind 	while (vrele_pending && gen == vrele_gen) {
    899       1.2     rmind 		cv_broadcast(&vrele_cv);
    900       1.2     rmind 		cv_wait(&vrele_cv, &vrele_lock);
    901       1.2     rmind 	}
    902       1.2     rmind 	mutex_exit(&vrele_lock);
    903       1.2     rmind }
    904       1.2     rmind 
    905       1.1     rmind /*
    906       1.1     rmind  * Vnode reference, where a reference is already held by some other
    907       1.1     rmind  * object (for example, a file structure).
    908       1.1     rmind  */
    909       1.1     rmind void
    910       1.1     rmind vref(vnode_t *vp)
    911       1.1     rmind {
    912       1.1     rmind 
    913       1.1     rmind 	KASSERT((vp->v_iflag & VI_MARKER) == 0);
    914       1.1     rmind 	KASSERT(vp->v_usecount != 0);
    915       1.1     rmind 
    916       1.1     rmind 	atomic_inc_uint(&vp->v_usecount);
    917       1.1     rmind }
    918       1.1     rmind 
    919       1.1     rmind /*
    920       1.1     rmind  * Page or buffer structure gets a reference.
    921       1.1     rmind  * Called with v_interlock held.
    922       1.1     rmind  */
    923       1.1     rmind void
    924       1.1     rmind vholdl(vnode_t *vp)
    925       1.1     rmind {
    926       1.1     rmind 
    927       1.9     rmind 	KASSERT(mutex_owned(vp->v_interlock));
    928       1.1     rmind 	KASSERT((vp->v_iflag & VI_MARKER) == 0);
    929       1.1     rmind 
    930       1.1     rmind 	if (vp->v_holdcnt++ == 0 && vp->v_usecount == 0) {
    931       1.1     rmind 		mutex_enter(&vnode_free_list_lock);
    932       1.1     rmind 		KASSERT(vp->v_freelisthd == &vnode_free_list);
    933       1.1     rmind 		TAILQ_REMOVE(vp->v_freelisthd, vp, v_freelist);
    934       1.1     rmind 		vp->v_freelisthd = &vnode_hold_list;
    935       1.1     rmind 		TAILQ_INSERT_TAIL(vp->v_freelisthd, vp, v_freelist);
    936       1.1     rmind 		mutex_exit(&vnode_free_list_lock);
    937       1.1     rmind 	}
    938       1.1     rmind }
    939       1.1     rmind 
    940       1.1     rmind /*
    941       1.1     rmind  * Page or buffer structure frees a reference.
    942       1.1     rmind  * Called with v_interlock held.
    943       1.1     rmind  */
    944       1.1     rmind void
    945       1.1     rmind holdrelel(vnode_t *vp)
    946       1.1     rmind {
    947       1.1     rmind 
    948       1.9     rmind 	KASSERT(mutex_owned(vp->v_interlock));
    949       1.1     rmind 	KASSERT((vp->v_iflag & VI_MARKER) == 0);
    950       1.1     rmind 
    951       1.1     rmind 	if (vp->v_holdcnt <= 0) {
    952      1.11  christos 		vnpanic(vp, "%s: holdcnt vp %p", __func__, vp);
    953       1.1     rmind 	}
    954       1.1     rmind 
    955       1.1     rmind 	vp->v_holdcnt--;
    956       1.1     rmind 	if (vp->v_holdcnt == 0 && vp->v_usecount == 0) {
    957       1.1     rmind 		mutex_enter(&vnode_free_list_lock);
    958       1.1     rmind 		KASSERT(vp->v_freelisthd == &vnode_hold_list);
    959       1.1     rmind 		TAILQ_REMOVE(vp->v_freelisthd, vp, v_freelist);
    960       1.1     rmind 		vp->v_freelisthd = &vnode_free_list;
    961       1.1     rmind 		TAILQ_INSERT_TAIL(vp->v_freelisthd, vp, v_freelist);
    962       1.1     rmind 		mutex_exit(&vnode_free_list_lock);
    963       1.1     rmind 	}
    964       1.1     rmind }
    965       1.1     rmind 
    966       1.1     rmind /*
    967       1.1     rmind  * Disassociate the underlying file system from a vnode.
    968       1.1     rmind  *
    969  1.37.2.2       snj  * Must be called with vnode locked and will return unlocked.
    970       1.1     rmind  * Must be called with the interlock held, and will return with it held.
    971       1.1     rmind  */
    972      1.25   hannken static void
    973      1.25   hannken vclean(vnode_t *vp)
    974       1.1     rmind {
    975       1.1     rmind 	lwp_t *l = curlwp;
    976      1.25   hannken 	bool recycle, active, doclose;
    977       1.1     rmind 	int error;
    978       1.1     rmind 
    979  1.37.2.2       snj 	KASSERT((vp->v_vflag & VV_LOCKSWORK) == 0 ||
    980  1.37.2.2       snj 	    VOP_ISLOCKED(vp) == LK_EXCLUSIVE);
    981       1.9     rmind 	KASSERT(mutex_owned(vp->v_interlock));
    982       1.1     rmind 	KASSERT((vp->v_iflag & VI_MARKER) == 0);
    983  1.37.2.2       snj 	KASSERT((vp->v_iflag & (VI_XLOCK | VI_CLEAN)) == 0);
    984       1.1     rmind 	KASSERT(vp->v_usecount != 0);
    985       1.1     rmind 
    986      1.32   hannken 	active = (vp->v_usecount > 1);
    987      1.32   hannken 	doclose = ! (active && vp->v_type == VBLK &&
    988      1.32   hannken 	    spec_node_getmountedfs(vp) != NULL);
    989      1.32   hannken 
    990       1.1     rmind 	/*
    991       1.1     rmind 	 * Prevent the vnode from being recycled or brought into use
    992       1.1     rmind 	 * while we clean it out.
    993       1.1     rmind 	 */
    994       1.1     rmind 	vp->v_iflag |= VI_XLOCK;
    995       1.1     rmind 	if (vp->v_iflag & VI_EXECMAP) {
    996       1.1     rmind 		atomic_add_int(&uvmexp.execpages, -vp->v_uobj.uo_npages);
    997       1.1     rmind 		atomic_add_int(&uvmexp.filepages, vp->v_uobj.uo_npages);
    998       1.1     rmind 	}
    999       1.1     rmind 	vp->v_iflag &= ~(VI_TEXT|VI_EXECMAP);
   1000       1.9     rmind 	mutex_exit(vp->v_interlock);
   1001      1.23   hannken 
   1002       1.1     rmind 	/*
   1003       1.1     rmind 	 * Clean out any cached data associated with the vnode.
   1004       1.1     rmind 	 * If purging an active vnode, it must be closed and
   1005       1.1     rmind 	 * deactivated before being reclaimed. Note that the
   1006       1.1     rmind 	 * VOP_INACTIVE will unlock the vnode.
   1007       1.1     rmind 	 */
   1008      1.25   hannken 	if (doclose) {
   1009       1.1     rmind 		error = vinvalbuf(vp, V_SAVE, NOCRED, l, 0, 0);
   1010       1.1     rmind 		if (error != 0) {
   1011       1.1     rmind 			if (wapbl_vphaswapbl(vp))
   1012       1.1     rmind 				WAPBL_DISCARD(wapbl_vptomp(vp));
   1013       1.1     rmind 			error = vinvalbuf(vp, 0, NOCRED, l, 0, 0);
   1014       1.1     rmind 		}
   1015       1.1     rmind 		KASSERT(error == 0);
   1016       1.1     rmind 		KASSERT((vp->v_iflag & VI_ONWORKLST) == 0);
   1017       1.1     rmind 		if (active && (vp->v_type == VBLK || vp->v_type == VCHR)) {
   1018       1.1     rmind 			 spec_node_revoke(vp);
   1019       1.1     rmind 		}
   1020       1.1     rmind 	}
   1021       1.1     rmind 	if (active) {
   1022       1.1     rmind 		VOP_INACTIVE(vp, &recycle);
   1023       1.1     rmind 	} else {
   1024       1.1     rmind 		/*
   1025       1.1     rmind 		 * Any other processes trying to obtain this lock must first
   1026       1.1     rmind 		 * wait for VI_XLOCK to clear, then call the new lock operation.
   1027       1.1     rmind 		 */
   1028       1.1     rmind 		VOP_UNLOCK(vp);
   1029       1.1     rmind 	}
   1030       1.1     rmind 
   1031       1.1     rmind 	/* Disassociate the underlying file system from the vnode. */
   1032       1.1     rmind 	if (VOP_RECLAIM(vp)) {
   1033      1.11  christos 		vnpanic(vp, "%s: cannot reclaim", __func__);
   1034       1.1     rmind 	}
   1035       1.1     rmind 
   1036       1.7     rmind 	KASSERT(vp->v_data == NULL);
   1037       1.1     rmind 	KASSERT(vp->v_uobj.uo_npages == 0);
   1038       1.7     rmind 
   1039       1.1     rmind 	if (vp->v_type == VREG && vp->v_ractx != NULL) {
   1040       1.1     rmind 		uvm_ra_freectx(vp->v_ractx);
   1041       1.1     rmind 		vp->v_ractx = NULL;
   1042       1.1     rmind 	}
   1043       1.7     rmind 
   1044       1.7     rmind 	/* Purge name cache. */
   1045       1.1     rmind 	cache_purge(vp);
   1046       1.1     rmind 
   1047      1.31   hannken 	/* Move to dead mount. */
   1048      1.31   hannken 	vp->v_vflag &= ~VV_ROOT;
   1049      1.31   hannken 	atomic_inc_uint(&dead_mount->mnt_refcnt);
   1050      1.31   hannken 	vfs_insmntque(vp, dead_mount);
   1051      1.23   hannken 
   1052       1.1     rmind 	/* Done with purge, notify sleepers of the grim news. */
   1053       1.9     rmind 	mutex_enter(vp->v_interlock);
   1054      1.25   hannken 	if (doclose) {
   1055      1.25   hannken 		vp->v_op = dead_vnodeop_p;
   1056      1.25   hannken 		vp->v_vflag |= VV_LOCKSWORK;
   1057      1.25   hannken 		vp->v_iflag |= VI_CLEAN;
   1058      1.25   hannken 	} else {
   1059      1.23   hannken 		vp->v_op = spec_vnodeop_p;
   1060      1.25   hannken 		vp->v_vflag &= ~VV_LOCKSWORK;
   1061      1.23   hannken 	}
   1062       1.1     rmind 	vp->v_tag = VT_NON;
   1063       1.1     rmind 	KNOTE(&vp->v_klist, NOTE_REVOKE);
   1064       1.1     rmind 	vp->v_iflag &= ~VI_XLOCK;
   1065       1.1     rmind 	cv_broadcast(&vp->v_cv);
   1066       1.1     rmind 
   1067       1.1     rmind 	KASSERT((vp->v_iflag & VI_ONWORKLST) == 0);
   1068       1.1     rmind }
   1069       1.1     rmind 
   1070       1.1     rmind /*
   1071      1.33   hannken  * Recycle an unused vnode if caller holds the last reference.
   1072       1.1     rmind  */
   1073      1.33   hannken bool
   1074      1.33   hannken vrecycle(vnode_t *vp)
   1075       1.1     rmind {
   1076       1.1     rmind 
   1077  1.37.2.2       snj 	if (vn_lock(vp, LK_EXCLUSIVE) != 0)
   1078  1.37.2.2       snj 		return false;
   1079  1.37.2.2       snj 
   1080      1.33   hannken 	mutex_enter(vp->v_interlock);
   1081      1.33   hannken 
   1082       1.1     rmind 	KASSERT((vp->v_iflag & VI_MARKER) == 0);
   1083       1.1     rmind 
   1084      1.33   hannken 	if (vp->v_usecount != 1) {
   1085       1.9     rmind 		mutex_exit(vp->v_interlock);
   1086  1.37.2.2       snj 		VOP_UNLOCK(vp);
   1087      1.33   hannken 		return false;
   1088       1.1     rmind 	}
   1089      1.33   hannken 	if ((vp->v_iflag & VI_CHANGING) != 0)
   1090      1.33   hannken 		vwait(vp, VI_CHANGING);
   1091      1.33   hannken 	if (vp->v_usecount != 1) {
   1092      1.33   hannken 		mutex_exit(vp->v_interlock);
   1093  1.37.2.2       snj 		VOP_UNLOCK(vp);
   1094      1.33   hannken 		return false;
   1095       1.1     rmind 	}
   1096  1.37.2.2       snj 	KASSERT((vp->v_iflag & VI_CLEAN) == 0);
   1097      1.29  christos 	vp->v_iflag |= VI_CHANGING;
   1098      1.25   hannken 	vclean(vp);
   1099      1.29  christos 	vrelel(vp, VRELEL_CHANGING_SET);
   1100      1.33   hannken 	return true;
   1101       1.1     rmind }
   1102       1.1     rmind 
   1103       1.1     rmind /*
   1104       1.1     rmind  * Eliminate all activity associated with the requested vnode
   1105       1.1     rmind  * and with all vnodes aliased to the requested vnode.
   1106       1.1     rmind  */
   1107       1.1     rmind void
   1108       1.1     rmind vrevoke(vnode_t *vp)
   1109       1.1     rmind {
   1110      1.19   hannken 	vnode_t *vq;
   1111       1.1     rmind 	enum vtype type;
   1112       1.1     rmind 	dev_t dev;
   1113       1.1     rmind 
   1114       1.1     rmind 	KASSERT(vp->v_usecount > 0);
   1115       1.1     rmind 
   1116       1.9     rmind 	mutex_enter(vp->v_interlock);
   1117       1.1     rmind 	if ((vp->v_iflag & VI_CLEAN) != 0) {
   1118       1.9     rmind 		mutex_exit(vp->v_interlock);
   1119       1.1     rmind 		return;
   1120       1.1     rmind 	} else if (vp->v_type != VBLK && vp->v_type != VCHR) {
   1121       1.1     rmind 		atomic_inc_uint(&vp->v_usecount);
   1122      1.29  christos 		mutex_exit(vp->v_interlock);
   1123      1.29  christos 		vgone(vp);
   1124       1.1     rmind 		return;
   1125       1.1     rmind 	} else {
   1126       1.1     rmind 		dev = vp->v_rdev;
   1127       1.1     rmind 		type = vp->v_type;
   1128       1.9     rmind 		mutex_exit(vp->v_interlock);
   1129       1.1     rmind 	}
   1130       1.1     rmind 
   1131      1.19   hannken 	while (spec_node_lookup_by_dev(type, dev, &vq) == 0) {
   1132      1.29  christos 		vgone(vq);
   1133       1.1     rmind 	}
   1134       1.1     rmind }
   1135       1.1     rmind 
   1136       1.1     rmind /*
   1137       1.1     rmind  * Eliminate all activity associated with a vnode in preparation for
   1138       1.1     rmind  * reuse.  Drops a reference from the vnode.
   1139       1.1     rmind  */
   1140       1.1     rmind void
   1141       1.1     rmind vgone(vnode_t *vp)
   1142       1.1     rmind {
   1143       1.1     rmind 
   1144  1.37.2.2       snj 	if (vn_lock(vp, LK_EXCLUSIVE) != 0) {
   1145  1.37.2.2       snj 		KASSERT((vp->v_iflag & VI_CLEAN) != 0);
   1146  1.37.2.2       snj 		vrele(vp);
   1147  1.37.2.2       snj 	}
   1148  1.37.2.2       snj 
   1149       1.9     rmind 	mutex_enter(vp->v_interlock);
   1150      1.29  christos 	if ((vp->v_iflag & VI_CHANGING) != 0)
   1151      1.29  christos 		vwait(vp, VI_CHANGING);
   1152      1.29  christos 	vp->v_iflag |= VI_CHANGING;
   1153      1.25   hannken 	vclean(vp);
   1154      1.29  christos 	vrelel(vp, VRELEL_CHANGING_SET);
   1155       1.1     rmind }
   1156       1.1     rmind 
   1157      1.36   hannken static inline uint32_t
   1158      1.36   hannken vcache_hash(const struct vcache_key *key)
   1159      1.36   hannken {
   1160      1.36   hannken 	uint32_t hash = HASH32_BUF_INIT;
   1161      1.36   hannken 
   1162      1.36   hannken 	hash = hash32_buf(&key->vk_mount, sizeof(struct mount *), hash);
   1163      1.36   hannken 	hash = hash32_buf(key->vk_key, key->vk_key_len, hash);
   1164      1.36   hannken 	return hash;
   1165      1.36   hannken }
   1166      1.36   hannken 
   1167      1.36   hannken static void
   1168      1.36   hannken vcache_init(void)
   1169      1.36   hannken {
   1170      1.36   hannken 
   1171      1.36   hannken 	vcache.pool = pool_cache_init(sizeof(struct vcache_node), 0, 0, 0,
   1172      1.36   hannken 	    "vcachepl", NULL, IPL_NONE, NULL, NULL, NULL);
   1173      1.36   hannken 	KASSERT(vcache.pool != NULL);
   1174      1.36   hannken 	mutex_init(&vcache.lock, MUTEX_DEFAULT, IPL_NONE);
   1175      1.36   hannken 	vcache.hashtab = hashinit(desiredvnodes, HASH_SLIST, true,
   1176      1.36   hannken 	    &vcache.hashmask);
   1177      1.36   hannken }
   1178      1.36   hannken 
   1179      1.36   hannken static void
   1180      1.36   hannken vcache_reinit(void)
   1181      1.36   hannken {
   1182      1.36   hannken 	int i;
   1183      1.36   hannken 	uint32_t hash;
   1184      1.36   hannken 	u_long oldmask, newmask;
   1185      1.36   hannken 	struct hashhead *oldtab, *newtab;
   1186      1.36   hannken 	struct vcache_node *node;
   1187      1.36   hannken 
   1188      1.36   hannken 	newtab = hashinit(desiredvnodes, HASH_SLIST, true, &newmask);
   1189      1.36   hannken 	mutex_enter(&vcache.lock);
   1190      1.36   hannken 	oldtab = vcache.hashtab;
   1191      1.36   hannken 	oldmask = vcache.hashmask;
   1192      1.36   hannken 	vcache.hashtab = newtab;
   1193      1.36   hannken 	vcache.hashmask = newmask;
   1194      1.36   hannken 	for (i = 0; i <= oldmask; i++) {
   1195      1.36   hannken 		while ((node = SLIST_FIRST(&oldtab[i])) != NULL) {
   1196      1.36   hannken 			SLIST_REMOVE(&oldtab[i], node, vcache_node, vn_hash);
   1197      1.36   hannken 			hash = vcache_hash(&node->vn_key);
   1198      1.36   hannken 			SLIST_INSERT_HEAD(&newtab[hash & vcache.hashmask],
   1199      1.36   hannken 			    node, vn_hash);
   1200      1.36   hannken 		}
   1201      1.36   hannken 	}
   1202      1.36   hannken 	mutex_exit(&vcache.lock);
   1203      1.36   hannken 	hashdone(oldtab, HASH_SLIST, oldmask);
   1204      1.36   hannken }
   1205      1.36   hannken 
   1206      1.36   hannken static inline struct vcache_node *
   1207      1.36   hannken vcache_hash_lookup(const struct vcache_key *key, uint32_t hash)
   1208      1.36   hannken {
   1209      1.36   hannken 	struct hashhead *hashp;
   1210      1.36   hannken 	struct vcache_node *node;
   1211      1.36   hannken 
   1212      1.36   hannken 	KASSERT(mutex_owned(&vcache.lock));
   1213      1.36   hannken 
   1214      1.36   hannken 	hashp = &vcache.hashtab[hash & vcache.hashmask];
   1215      1.36   hannken 	SLIST_FOREACH(node, hashp, vn_hash) {
   1216      1.36   hannken 		if (key->vk_mount != node->vn_key.vk_mount)
   1217      1.36   hannken 			continue;
   1218      1.36   hannken 		if (key->vk_key_len != node->vn_key.vk_key_len)
   1219      1.36   hannken 			continue;
   1220      1.36   hannken 		if (memcmp(key->vk_key, node->vn_key.vk_key, key->vk_key_len))
   1221      1.36   hannken 			continue;
   1222      1.36   hannken 		return node;
   1223      1.36   hannken 	}
   1224      1.36   hannken 	return NULL;
   1225      1.36   hannken }
   1226      1.36   hannken 
   1227      1.36   hannken /*
   1228      1.36   hannken  * Get a vnode / fs node pair by key and return it referenced through vpp.
   1229      1.36   hannken  */
   1230      1.36   hannken int
   1231      1.36   hannken vcache_get(struct mount *mp, const void *key, size_t key_len,
   1232      1.36   hannken     struct vnode **vpp)
   1233      1.36   hannken {
   1234      1.36   hannken 	int error;
   1235      1.36   hannken 	uint32_t hash;
   1236      1.36   hannken 	const void *new_key;
   1237      1.36   hannken 	struct vnode *vp;
   1238      1.36   hannken 	struct vcache_key vcache_key;
   1239      1.36   hannken 	struct vcache_node *node, *new_node;
   1240      1.36   hannken 
   1241      1.36   hannken 	new_key = NULL;
   1242      1.36   hannken 	*vpp = NULL;
   1243      1.36   hannken 
   1244      1.36   hannken 	vcache_key.vk_mount = mp;
   1245      1.36   hannken 	vcache_key.vk_key = key;
   1246      1.36   hannken 	vcache_key.vk_key_len = key_len;
   1247      1.36   hannken 	hash = vcache_hash(&vcache_key);
   1248      1.36   hannken 
   1249      1.36   hannken again:
   1250      1.36   hannken 	mutex_enter(&vcache.lock);
   1251      1.36   hannken 	node = vcache_hash_lookup(&vcache_key, hash);
   1252      1.36   hannken 
   1253      1.36   hannken 	/* If found, take a reference or retry. */
   1254      1.36   hannken 	if (__predict_true(node != NULL && node->vn_vnode != NULL)) {
   1255      1.36   hannken 		vp = node->vn_vnode;
   1256      1.36   hannken 		mutex_enter(vp->v_interlock);
   1257      1.36   hannken 		mutex_exit(&vcache.lock);
   1258      1.36   hannken 		error = vget(vp, 0);
   1259      1.36   hannken 		if (error == ENOENT)
   1260      1.36   hannken 			goto again;
   1261      1.36   hannken 		if (error == 0)
   1262      1.36   hannken 			*vpp = vp;
   1263      1.36   hannken 		KASSERT((error != 0) == (*vpp == NULL));
   1264      1.36   hannken 		return error;
   1265      1.36   hannken 	}
   1266      1.36   hannken 
   1267      1.36   hannken 	/* If another thread loads this node, wait and retry. */
   1268      1.36   hannken 	if (node != NULL) {
   1269      1.36   hannken 		KASSERT(node->vn_vnode == NULL);
   1270      1.36   hannken 		mutex_exit(&vcache.lock);
   1271      1.36   hannken 		kpause("vcache", false, mstohz(20), NULL);
   1272      1.36   hannken 		goto again;
   1273      1.36   hannken 	}
   1274      1.36   hannken 	mutex_exit(&vcache.lock);
   1275      1.36   hannken 
   1276      1.36   hannken 	/* Allocate and initialize a new vcache / vnode pair. */
   1277      1.36   hannken 	error = vfs_busy(mp, NULL);
   1278      1.36   hannken 	if (error)
   1279      1.36   hannken 		return error;
   1280      1.36   hannken 	new_node = pool_cache_get(vcache.pool, PR_WAITOK);
   1281      1.36   hannken 	new_node->vn_vnode = NULL;
   1282      1.36   hannken 	new_node->vn_key = vcache_key;
   1283      1.36   hannken 	vp = vnalloc(NULL);
   1284      1.36   hannken 	mutex_enter(&vcache.lock);
   1285      1.36   hannken 	node = vcache_hash_lookup(&vcache_key, hash);
   1286      1.36   hannken 	if (node == NULL) {
   1287      1.36   hannken 		SLIST_INSERT_HEAD(&vcache.hashtab[hash & vcache.hashmask],
   1288      1.36   hannken 		    new_node, vn_hash);
   1289      1.36   hannken 		node = new_node;
   1290      1.36   hannken 	}
   1291      1.36   hannken 	mutex_exit(&vcache.lock);
   1292      1.36   hannken 
   1293      1.36   hannken 	/* If another thread beat us inserting this node, retry. */
   1294      1.36   hannken 	if (node != new_node) {
   1295      1.36   hannken 		pool_cache_put(vcache.pool, new_node);
   1296      1.36   hannken 		KASSERT(vp->v_usecount == 1);
   1297      1.36   hannken 		vp->v_usecount = 0;
   1298      1.36   hannken 		vnfree(vp);
   1299      1.36   hannken 		vfs_unbusy(mp, false, NULL);
   1300      1.36   hannken 		goto again;
   1301      1.36   hannken 	}
   1302      1.36   hannken 
   1303      1.36   hannken 	/* Load the fs node.  Exclusive as new_node->vn_vnode is NULL. */
   1304  1.37.2.1    martin 	vp->v_iflag |= VI_CHANGING;
   1305      1.36   hannken 	error = VFS_LOADVNODE(mp, vp, key, key_len, &new_key);
   1306      1.36   hannken 	if (error) {
   1307      1.36   hannken 		mutex_enter(&vcache.lock);
   1308      1.36   hannken 		SLIST_REMOVE(&vcache.hashtab[hash & vcache.hashmask],
   1309      1.36   hannken 		    new_node, vcache_node, vn_hash);
   1310      1.36   hannken 		mutex_exit(&vcache.lock);
   1311      1.36   hannken 		pool_cache_put(vcache.pool, new_node);
   1312      1.36   hannken 		KASSERT(vp->v_usecount == 1);
   1313      1.36   hannken 		vp->v_usecount = 0;
   1314      1.36   hannken 		vnfree(vp);
   1315      1.36   hannken 		vfs_unbusy(mp, false, NULL);
   1316      1.36   hannken 		KASSERT(*vpp == NULL);
   1317      1.36   hannken 		return error;
   1318      1.36   hannken 	}
   1319      1.36   hannken 	KASSERT(new_key != NULL);
   1320      1.36   hannken 	KASSERT(memcmp(key, new_key, key_len) == 0);
   1321      1.36   hannken 	KASSERT(vp->v_op != NULL);
   1322      1.36   hannken 	vfs_insmntque(vp, mp);
   1323      1.36   hannken 	if ((mp->mnt_iflag & IMNT_MPSAFE) != 0)
   1324      1.36   hannken 		vp->v_vflag |= VV_MPSAFE;
   1325      1.36   hannken 	vfs_unbusy(mp, true, NULL);
   1326      1.36   hannken 
   1327      1.36   hannken 	/* Finished loading, finalize node. */
   1328      1.36   hannken 	mutex_enter(&vcache.lock);
   1329      1.36   hannken 	new_node->vn_key.vk_key = new_key;
   1330      1.36   hannken 	new_node->vn_vnode = vp;
   1331      1.36   hannken 	mutex_exit(&vcache.lock);
   1332  1.37.2.1    martin 	mutex_enter(vp->v_interlock);
   1333  1.37.2.1    martin 	vp->v_iflag &= ~VI_CHANGING;
   1334  1.37.2.1    martin 	cv_broadcast(&vp->v_cv);
   1335  1.37.2.1    martin 	mutex_exit(vp->v_interlock);
   1336      1.36   hannken 	*vpp = vp;
   1337      1.36   hannken 	return 0;
   1338      1.36   hannken }
   1339      1.36   hannken 
   1340      1.36   hannken /*
   1341      1.37   hannken  * Prepare key change: lock old and new cache node.
   1342      1.37   hannken  * Return an error if the new node already exists.
   1343      1.37   hannken  */
   1344      1.37   hannken int
   1345      1.37   hannken vcache_rekey_enter(struct mount *mp, struct vnode *vp,
   1346      1.37   hannken     const void *old_key, size_t old_key_len,
   1347      1.37   hannken     const void *new_key, size_t new_key_len)
   1348      1.37   hannken {
   1349      1.37   hannken 	uint32_t old_hash, new_hash;
   1350      1.37   hannken 	struct vcache_key old_vcache_key, new_vcache_key;
   1351      1.37   hannken 	struct vcache_node *node, *new_node;
   1352      1.37   hannken 
   1353      1.37   hannken 	old_vcache_key.vk_mount = mp;
   1354      1.37   hannken 	old_vcache_key.vk_key = old_key;
   1355      1.37   hannken 	old_vcache_key.vk_key_len = old_key_len;
   1356      1.37   hannken 	old_hash = vcache_hash(&old_vcache_key);
   1357      1.37   hannken 
   1358      1.37   hannken 	new_vcache_key.vk_mount = mp;
   1359      1.37   hannken 	new_vcache_key.vk_key = new_key;
   1360      1.37   hannken 	new_vcache_key.vk_key_len = new_key_len;
   1361      1.37   hannken 	new_hash = vcache_hash(&new_vcache_key);
   1362      1.37   hannken 
   1363      1.37   hannken 	new_node = pool_cache_get(vcache.pool, PR_WAITOK);
   1364      1.37   hannken 	new_node->vn_vnode = NULL;
   1365      1.37   hannken 	new_node->vn_key = new_vcache_key;
   1366      1.37   hannken 
   1367      1.37   hannken 	mutex_enter(&vcache.lock);
   1368      1.37   hannken 	node = vcache_hash_lookup(&new_vcache_key, new_hash);
   1369      1.37   hannken 	if (node != NULL) {
   1370      1.37   hannken 		mutex_exit(&vcache.lock);
   1371      1.37   hannken 		pool_cache_put(vcache.pool, new_node);
   1372      1.37   hannken 		return EEXIST;
   1373      1.37   hannken 	}
   1374      1.37   hannken 	SLIST_INSERT_HEAD(&vcache.hashtab[new_hash & vcache.hashmask],
   1375      1.37   hannken 	    new_node, vn_hash);
   1376      1.37   hannken 	node = vcache_hash_lookup(&old_vcache_key, old_hash);
   1377      1.37   hannken 	KASSERT(node != NULL);
   1378      1.37   hannken 	KASSERT(node->vn_vnode == vp);
   1379      1.37   hannken 	node->vn_vnode = NULL;
   1380      1.37   hannken 	node->vn_key = old_vcache_key;
   1381      1.37   hannken 	mutex_exit(&vcache.lock);
   1382      1.37   hannken 	return 0;
   1383      1.37   hannken }
   1384      1.37   hannken 
   1385      1.37   hannken /*
   1386      1.37   hannken  * Key change complete: remove old node and unlock new node.
   1387      1.37   hannken  */
   1388      1.37   hannken void
   1389      1.37   hannken vcache_rekey_exit(struct mount *mp, struct vnode *vp,
   1390      1.37   hannken     const void *old_key, size_t old_key_len,
   1391      1.37   hannken     const void *new_key, size_t new_key_len)
   1392      1.37   hannken {
   1393      1.37   hannken 	uint32_t old_hash, new_hash;
   1394      1.37   hannken 	struct vcache_key old_vcache_key, new_vcache_key;
   1395      1.37   hannken 	struct vcache_node *node;
   1396      1.37   hannken 
   1397      1.37   hannken 	old_vcache_key.vk_mount = mp;
   1398      1.37   hannken 	old_vcache_key.vk_key = old_key;
   1399      1.37   hannken 	old_vcache_key.vk_key_len = old_key_len;
   1400      1.37   hannken 	old_hash = vcache_hash(&old_vcache_key);
   1401      1.37   hannken 
   1402      1.37   hannken 	new_vcache_key.vk_mount = mp;
   1403      1.37   hannken 	new_vcache_key.vk_key = new_key;
   1404      1.37   hannken 	new_vcache_key.vk_key_len = new_key_len;
   1405      1.37   hannken 	new_hash = vcache_hash(&new_vcache_key);
   1406      1.37   hannken 
   1407      1.37   hannken 	mutex_enter(&vcache.lock);
   1408      1.37   hannken 	node = vcache_hash_lookup(&new_vcache_key, new_hash);
   1409      1.37   hannken 	KASSERT(node != NULL && node->vn_vnode == NULL);
   1410      1.37   hannken 	KASSERT(node->vn_key.vk_key_len == new_key_len);
   1411      1.37   hannken 	node->vn_vnode = vp;
   1412      1.37   hannken 	node->vn_key = new_vcache_key;
   1413      1.37   hannken 	node = vcache_hash_lookup(&old_vcache_key, old_hash);
   1414      1.37   hannken 	KASSERT(node != NULL);
   1415      1.37   hannken 	KASSERT(node->vn_vnode == NULL);
   1416      1.37   hannken 	SLIST_REMOVE(&vcache.hashtab[old_hash & vcache.hashmask],
   1417      1.37   hannken 	    node, vcache_node, vn_hash);
   1418      1.37   hannken 	mutex_exit(&vcache.lock);
   1419      1.37   hannken 	pool_cache_put(vcache.pool, node);
   1420      1.37   hannken }
   1421      1.37   hannken 
   1422      1.37   hannken /*
   1423      1.36   hannken  * Remove a vnode / fs node pair from the cache.
   1424      1.36   hannken  */
   1425      1.36   hannken void
   1426      1.36   hannken vcache_remove(struct mount *mp, const void *key, size_t key_len)
   1427      1.36   hannken {
   1428      1.36   hannken 	uint32_t hash;
   1429      1.36   hannken 	struct vcache_key vcache_key;
   1430      1.36   hannken 	struct vcache_node *node;
   1431      1.36   hannken 
   1432      1.36   hannken 	vcache_key.vk_mount = mp;
   1433      1.36   hannken 	vcache_key.vk_key = key;
   1434      1.36   hannken 	vcache_key.vk_key_len = key_len;
   1435      1.36   hannken 	hash = vcache_hash(&vcache_key);
   1436      1.36   hannken 
   1437      1.36   hannken 	mutex_enter(&vcache.lock);
   1438      1.36   hannken 	node = vcache_hash_lookup(&vcache_key, hash);
   1439      1.36   hannken 	KASSERT(node != NULL);
   1440      1.36   hannken 	SLIST_REMOVE(&vcache.hashtab[hash & vcache.hashmask],
   1441      1.36   hannken 	    node, vcache_node, vn_hash);
   1442      1.36   hannken 	mutex_exit(&vcache.lock);
   1443      1.36   hannken 	pool_cache_put(vcache.pool, node);
   1444      1.36   hannken }
   1445      1.36   hannken 
   1446       1.1     rmind /*
   1447       1.1     rmind  * Update outstanding I/O count and do wakeup if requested.
   1448       1.1     rmind  */
   1449       1.1     rmind void
   1450       1.1     rmind vwakeup(struct buf *bp)
   1451       1.1     rmind {
   1452       1.1     rmind 	vnode_t *vp;
   1453       1.1     rmind 
   1454       1.1     rmind 	if ((vp = bp->b_vp) == NULL)
   1455       1.1     rmind 		return;
   1456       1.1     rmind 
   1457       1.9     rmind 	KASSERT(bp->b_objlock == vp->v_interlock);
   1458       1.1     rmind 	KASSERT(mutex_owned(bp->b_objlock));
   1459       1.1     rmind 
   1460       1.1     rmind 	if (--vp->v_numoutput < 0)
   1461      1.11  christos 		vnpanic(vp, "%s: neg numoutput, vp %p", __func__, vp);
   1462       1.1     rmind 	if (vp->v_numoutput == 0)
   1463       1.1     rmind 		cv_broadcast(&vp->v_cv);
   1464       1.1     rmind }
   1465       1.1     rmind 
   1466       1.1     rmind /*
   1467      1.35   hannken  * Test a vnode for being or becoming dead.  Returns one of:
   1468      1.35   hannken  * EBUSY:  vnode is becoming dead, with "flags == VDEAD_NOWAIT" only.
   1469      1.35   hannken  * ENOENT: vnode is dead.
   1470      1.35   hannken  * 0:      otherwise.
   1471      1.35   hannken  *
   1472      1.35   hannken  * Whenever this function returns a non-zero value all future
   1473      1.35   hannken  * calls will also return a non-zero value.
   1474      1.35   hannken  */
   1475      1.35   hannken int
   1476      1.35   hannken vdead_check(struct vnode *vp, int flags)
   1477      1.35   hannken {
   1478      1.35   hannken 
   1479      1.35   hannken 	KASSERT(mutex_owned(vp->v_interlock));
   1480      1.35   hannken 	if (ISSET(vp->v_iflag, VI_XLOCK)) {
   1481      1.35   hannken 		if (ISSET(flags, VDEAD_NOWAIT))
   1482      1.35   hannken 			return EBUSY;
   1483      1.35   hannken 		vwait(vp, VI_XLOCK);
   1484      1.35   hannken 		KASSERT(ISSET(vp->v_iflag, VI_CLEAN));
   1485      1.35   hannken 	}
   1486      1.35   hannken 	if (ISSET(vp->v_iflag, VI_CLEAN))
   1487      1.35   hannken 		return ENOENT;
   1488      1.35   hannken 	return 0;
   1489      1.35   hannken }
   1490      1.35   hannken 
   1491      1.35   hannken /*
   1492       1.1     rmind  * Wait for a vnode (typically with VI_XLOCK set) to be cleaned or
   1493       1.1     rmind  * recycled.
   1494       1.1     rmind  */
   1495      1.35   hannken static void
   1496       1.1     rmind vwait(vnode_t *vp, int flags)
   1497       1.1     rmind {
   1498       1.1     rmind 
   1499       1.9     rmind 	KASSERT(mutex_owned(vp->v_interlock));
   1500       1.1     rmind 	KASSERT(vp->v_usecount != 0);
   1501       1.1     rmind 
   1502       1.1     rmind 	while ((vp->v_iflag & flags) != 0)
   1503       1.9     rmind 		cv_wait(&vp->v_cv, vp->v_interlock);
   1504       1.1     rmind }
   1505       1.1     rmind 
   1506       1.1     rmind int
   1507       1.3     rmind vfs_drainvnodes(long target)
   1508       1.1     rmind {
   1509      1.12   hannken 	int error;
   1510      1.12   hannken 
   1511      1.12   hannken 	mutex_enter(&vnode_free_list_lock);
   1512       1.1     rmind 
   1513       1.1     rmind 	while (numvnodes > target) {
   1514      1.12   hannken 		error = cleanvnode();
   1515      1.12   hannken 		if (error != 0)
   1516      1.12   hannken 			return error;
   1517       1.1     rmind 		mutex_enter(&vnode_free_list_lock);
   1518       1.1     rmind 	}
   1519      1.12   hannken 
   1520      1.12   hannken 	mutex_exit(&vnode_free_list_lock);
   1521      1.12   hannken 
   1522      1.36   hannken 	vcache_reinit();
   1523      1.36   hannken 
   1524       1.1     rmind 	return 0;
   1525       1.1     rmind }
   1526       1.1     rmind 
   1527       1.1     rmind void
   1528      1.11  christos vnpanic(vnode_t *vp, const char *fmt, ...)
   1529       1.1     rmind {
   1530      1.11  christos 	va_list ap;
   1531      1.11  christos 
   1532       1.1     rmind #ifdef DIAGNOSTIC
   1533       1.1     rmind 	vprint(NULL, vp);
   1534       1.1     rmind #endif
   1535      1.11  christos 	va_start(ap, fmt);
   1536      1.11  christos 	vpanic(fmt, ap);
   1537      1.11  christos 	va_end(ap);
   1538       1.1     rmind }
   1539