Home | History | Annotate | Line # | Download | only in kern
vfs_vnode.c revision 1.37.2.1.2.1
      1  1.37.2.1.2.1       snj /*	$NetBSD: vfs_vnode.c,v 1.37.2.1.2.1 2016/01/26 23:44:11 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.1.2.1       snj __KERNEL_RCSID(0, "$NetBSD: vfs_vnode.c,v 1.37.2.1.2.1 2016/01/26 23:44:11 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.1.2.1       snj 		if (vn_lock(vp, LK_EXCLUSIVE | LK_NOWAIT) != 0)
    332           1.1     rmind 			continue;
    333  1.37.2.1.2.1       snj 		if (!mutex_tryenter(vp->v_interlock)) {
    334  1.37.2.1.2.1       snj 			VOP_UNLOCK(vp);
    335          1.24   hannken 			continue;
    336          1.24   hannken 		}
    337  1.37.2.1.2.1       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.1.2.1       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.1.2.1       snj 		if (recycle) {
    741  1.37.2.1.2.1       snj 			/* vclean() below will drop the lock. */
    742  1.37.2.1.2.1       snj 			if (vn_lock(vp, LK_EXCLUSIVE) != 0)
    743  1.37.2.1.2.1       snj 				recycle = false;
    744  1.37.2.1.2.1       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.1.2.1       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.1.2.1       snj 	KASSERT((vp->v_vflag & VV_LOCKSWORK) == 0 ||
    980  1.37.2.1.2.1       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.1.2.1       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.1.2.1       snj 	if (vn_lock(vp, LK_EXCLUSIVE) != 0)
   1078  1.37.2.1.2.1       snj 		return false;
   1079  1.37.2.1.2.1       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.1.2.1       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.1.2.1       snj 		VOP_UNLOCK(vp);
   1094          1.33   hannken 		return false;
   1095           1.1     rmind 	}
   1096  1.37.2.1.2.1       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.1.2.1       snj 	if (vn_lock(vp, LK_EXCLUSIVE) != 0) {
   1145  1.37.2.1.2.1       snj 		KASSERT((vp->v_iflag & VI_CLEAN) != 0);
   1146  1.37.2.1.2.1       snj 		vrele(vp);
   1147  1.37.2.1.2.1       snj 	}
   1148  1.37.2.1.2.1       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