Home | History | Annotate | Line # | Download | only in kern
vfs_vnode.c revision 1.154
      1  1.154  riastrad /*	$NetBSD: vfs_vnode.c,v 1.154 2024/12/07 02:11:42 riastradh Exp $	*/
      2    1.1     rmind 
      3    1.1     rmind /*-
      4  1.111        ad  * Copyright (c) 1997-2011, 2019, 2020 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.45   hannken  *	- Allocation, via vcache_get(9) or vcache_new(9).
     79   1.66   hannken  *	- Reclamation of inactive vnode, via vcache_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.54   hannken  *	or cleaned via vcache_reclaim, which calls VOP_RECLAIM(9) to
     93   1.54   hannken  *	disassociate underlying file system from the vnode, and finally
     94   1.54   hannken  *	destroyed.
     95    1.8     rmind  *
     96   1.52   hannken  * Vnode state
     97   1.52   hannken  *
     98   1.52   hannken  *	Vnode is always in one of six states:
     99   1.52   hannken  *	- MARKER	This is a marker vnode to help list traversal.  It
    100   1.52   hannken  *			will never change its state.
    101   1.52   hannken  *	- LOADING	Vnode is associating underlying file system and not
    102   1.52   hannken  *			yet ready to use.
    103   1.94   hannken  *	- LOADED	Vnode has associated underlying file system and is
    104   1.52   hannken  *			ready to use.
    105   1.52   hannken  *	- BLOCKED	Vnode is active but cannot get new references.
    106   1.52   hannken  *	- RECLAIMING	Vnode is disassociating from the underlying file
    107   1.52   hannken  *			system.
    108   1.52   hannken  *	- RECLAIMED	Vnode has disassociated from underlying file system
    109   1.52   hannken  *			and is dead.
    110   1.52   hannken  *
    111   1.52   hannken  *	Valid state changes are:
    112   1.94   hannken  *	LOADING -> LOADED
    113   1.52   hannken  *			Vnode has been initialised in vcache_get() or
    114   1.52   hannken  *			vcache_new() and is ready to use.
    115  1.123        ad  *	BLOCKED -> RECLAIMING
    116   1.52   hannken  *			Vnode starts disassociation from underlying file
    117   1.54   hannken  *			system in vcache_reclaim().
    118   1.52   hannken  *	RECLAIMING -> RECLAIMED
    119   1.52   hannken  *			Vnode finished disassociation from underlying file
    120   1.54   hannken  *			system in vcache_reclaim().
    121   1.94   hannken  *	LOADED -> BLOCKED
    122   1.52   hannken  *			Either vcache_rekey*() is changing the vnode key or
    123   1.52   hannken  *			vrelel() is about to call VOP_INACTIVE().
    124   1.94   hannken  *	BLOCKED -> LOADED
    125   1.52   hannken  *			The block condition is over.
    126   1.52   hannken  *	LOADING -> RECLAIMED
    127   1.52   hannken  *			Either vcache_get() or vcache_new() failed to
    128   1.52   hannken  *			associate the underlying file system or vcache_rekey*()
    129   1.52   hannken  *			drops a vnode used as placeholder.
    130   1.52   hannken  *
    131   1.52   hannken  *	Of these states LOADING, BLOCKED and RECLAIMING are intermediate
    132   1.52   hannken  *	and it is possible to wait for state change.
    133   1.52   hannken  *
    134   1.52   hannken  *	State is protected with v_interlock with one exception:
    135   1.69   hannken  *	to change from LOADING both v_interlock and vcache_lock must be held
    136   1.52   hannken  *	so it is possible to check "state == LOADING" without holding
    137   1.52   hannken  *	v_interlock.  See vcache_get() for details.
    138   1.52   hannken  *
    139    1.8     rmind  * Reference counting
    140    1.8     rmind  *
    141    1.8     rmind  *	Vnode is considered active, if reference count (vnode_t::v_usecount)
    142    1.8     rmind  *	is non-zero.  It is maintained using: vref(9) and vrele(9), as well
    143    1.8     rmind  *	as vput(9), routines.  Common points holding references are e.g.
    144  1.146  riastrad  *	file openings, current working directory, mount points, etc.
    145    1.8     rmind  *
    146  1.123        ad  *	v_usecount is adjusted with atomic operations, however to change
    147  1.123        ad  *	from a non-zero value to zero the interlock must also be held.
    148    1.1     rmind  */
    149    1.1     rmind 
    150    1.1     rmind #include <sys/cdefs.h>
    151  1.154  riastrad __KERNEL_RCSID(0, "$NetBSD: vfs_vnode.c,v 1.154 2024/12/07 02:11:42 riastradh Exp $");
    152  1.108        ad 
    153  1.109        ad #ifdef _KERNEL_OPT
    154  1.108        ad #include "opt_pax.h"
    155  1.109        ad #endif
    156    1.1     rmind 
    157    1.1     rmind #include <sys/param.h>
    158  1.154  riastrad #include <sys/types.h>
    159    1.1     rmind 
    160    1.1     rmind #include <sys/atomic.h>
    161    1.1     rmind #include <sys/buf.h>
    162    1.1     rmind #include <sys/conf.h>
    163    1.1     rmind #include <sys/device.h>
    164  1.154  riastrad #include <sys/fstrans.h>
    165   1.36   hannken #include <sys/hash.h>
    166    1.1     rmind #include <sys/kauth.h>
    167  1.154  riastrad #include <sys/kernel.h>
    168    1.1     rmind #include <sys/kmem.h>
    169    1.1     rmind #include <sys/module.h>
    170    1.1     rmind #include <sys/mount.h>
    171    1.1     rmind #include <sys/namei.h>
    172  1.108        ad #include <sys/pax.h>
    173    1.1     rmind #include <sys/syscallargs.h>
    174    1.1     rmind #include <sys/sysctl.h>
    175    1.1     rmind #include <sys/systm.h>
    176  1.152   hannken #include <sys/threadpool.h>
    177   1.58   hannken #include <sys/vnode_impl.h>
    178    1.1     rmind #include <sys/wapbl.h>
    179    1.1     rmind 
    180  1.146  riastrad #include <miscfs/deadfs/deadfs.h>
    181  1.147  riastrad #include <miscfs/specfs/specdev.h>
    182  1.146  riastrad 
    183    1.1     rmind #include <uvm/uvm.h>
    184    1.1     rmind #include <uvm/uvm_readahead.h>
    185  1.104        ad #include <uvm/uvm_stat.h>
    186    1.1     rmind 
    187   1.23   hannken /* Flags to vrelel. */
    188  1.104        ad #define	VRELEL_ASYNC	0x0001	/* Always defer to vrele thread. */
    189  1.104        ad 
    190  1.104        ad #define	LRU_VRELE	0
    191  1.104        ad #define	LRU_FREE	1
    192  1.104        ad #define	LRU_HOLD	2
    193  1.104        ad #define	LRU_COUNT	3
    194    1.1     rmind 
    195   1.16     rmind /*
    196   1.63   hannken  * There are three lru lists: one holds vnodes waiting for async release,
    197  1.104        ad  * one is for vnodes which have no buffer/page references and one for those
    198  1.104        ad  * which do (i.e.  v_holdcnt is non-zero).  We put the lists into a single,
    199  1.104        ad  * private cache line as vnodes migrate between them while under the same
    200  1.104        ad  * lock (vdrain_lock).
    201   1.63   hannken  */
    202  1.152   hannken 
    203  1.152   hannken typedef struct {
    204  1.152   hannken 	vnode_impl_t *li_marker;
    205  1.152   hannken } lru_iter_t;
    206  1.152   hannken 
    207  1.104        ad u_int			numvnodes		__cacheline_aligned;
    208  1.104        ad static vnodelst_t	lru_list[LRU_COUNT]	__cacheline_aligned;
    209  1.152   hannken static struct threadpool *threadpool;
    210  1.152   hannken static struct threadpool_job vdrain_job;
    211  1.152   hannken static struct threadpool_job vrele_job;
    212   1.63   hannken static kmutex_t		vdrain_lock		__cacheline_aligned;
    213   1.57   hannken SLIST_HEAD(hashhead, vnode_impl);
    214   1.69   hannken static kmutex_t		vcache_lock		__cacheline_aligned;
    215  1.104        ad static kcondvar_t	vcache_cv;
    216   1.69   hannken static u_int		vcache_hashsize;
    217   1.69   hannken static u_long		vcache_hashmask;
    218  1.104        ad static struct hashhead	*vcache_hashtab;
    219   1.69   hannken static pool_cache_t	vcache_pool;
    220   1.63   hannken static void		lru_requeue(vnode_t *, vnodelst_t *);
    221   1.63   hannken static vnodelst_t *	lru_which(vnode_t *);
    222  1.152   hannken static vnode_impl_t *	lru_iter_first(int, lru_iter_t *);
    223  1.152   hannken static vnode_impl_t *	lru_iter_next(lru_iter_t *);
    224  1.152   hannken static void		lru_iter_release(lru_iter_t *);
    225   1.63   hannken static vnode_impl_t *	vcache_alloc(void);
    226   1.79   hannken static void		vcache_dealloc(vnode_impl_t *);
    227   1.57   hannken static void		vcache_free(vnode_impl_t *);
    228   1.36   hannken static void		vcache_init(void);
    229   1.36   hannken static void		vcache_reinit(void);
    230   1.54   hannken static void		vcache_reclaim(vnode_t *);
    231  1.152   hannken static void		vrele_deferred(vnode_impl_t *);
    232  1.107        ad static void		vrelel(vnode_t *, int, int);
    233   1.11  christos static void		vnpanic(vnode_t *, const char *, ...)
    234   1.18  christos     __printflike(2, 3);
    235  1.152   hannken static bool		vdrain_one(u_int);
    236  1.152   hannken static void		vdrain_task(struct threadpool_job *);
    237  1.152   hannken static void		vrele_task(struct threadpool_job *);
    238    1.1     rmind 
    239    1.1     rmind /* Routines having to do with the management of the vnode table. */
    240    1.1     rmind 
    241  1.120        ad /*
    242  1.123        ad  * The high bit of v_usecount is a gate for vcache_tryvget().  It's set
    243  1.123        ad  * only when the vnode state is LOADED.
    244  1.132   hannken  * The next bit of v_usecount is a flag for vrelel().  It's set
    245  1.132   hannken  * from vcache_vget() and vcache_tryvget() whenever the operation succeeds.
    246  1.123        ad  */
    247  1.132   hannken #define	VUSECOUNT_MASK	0x3fffffff
    248  1.123        ad #define	VUSECOUNT_GATE	0x80000000
    249  1.132   hannken #define	VUSECOUNT_VGET	0x40000000
    250  1.123        ad 
    251  1.123        ad /*
    252  1.120        ad  * Return the current usecount of a vnode.
    253  1.120        ad  */
    254  1.120        ad inline int
    255  1.120        ad vrefcnt(struct vnode *vp)
    256  1.120        ad {
    257  1.120        ad 
    258  1.123        ad 	return atomic_load_relaxed(&vp->v_usecount) & VUSECOUNT_MASK;
    259  1.120        ad }
    260  1.120        ad 
    261   1.51   hannken /* Vnode state operations and diagnostics. */
    262   1.51   hannken 
    263   1.51   hannken #if defined(DIAGNOSTIC)
    264   1.51   hannken 
    265   1.94   hannken #define VSTATE_VALID(state) \
    266   1.94   hannken 	((state) != VS_ACTIVE && (state) != VS_MARKER)
    267   1.51   hannken #define VSTATE_GET(vp) \
    268   1.51   hannken 	vstate_assert_get((vp), __func__, __LINE__)
    269   1.51   hannken #define VSTATE_CHANGE(vp, from, to) \
    270   1.51   hannken 	vstate_assert_change((vp), (from), (to), __func__, __LINE__)
    271   1.51   hannken #define VSTATE_WAIT_STABLE(vp) \
    272   1.51   hannken 	vstate_assert_wait_stable((vp), __func__, __LINE__)
    273   1.51   hannken 
    274   1.94   hannken void
    275   1.99     joerg _vstate_assert(vnode_t *vp, enum vnode_state state, const char *func, int line,
    276   1.99     joerg     bool has_lock)
    277   1.51   hannken {
    278   1.70   hannken 	vnode_impl_t *vip = VNODE_TO_VIMPL(vp);
    279  1.120        ad 	int refcnt = vrefcnt(vp);
    280   1.51   hannken 
    281   1.99     joerg 	if (!has_lock) {
    282  1.148  riastrad 		enum vnode_state vstate = atomic_load_relaxed(&vip->vi_state);
    283  1.148  riastrad 
    284  1.120        ad 		if (state == VS_ACTIVE && refcnt > 0 &&
    285  1.148  riastrad 		    (vstate == VS_LOADED || vstate == VS_BLOCKED))
    286   1.99     joerg 			return;
    287  1.148  riastrad 		if (vstate == state)
    288   1.99     joerg 			return;
    289   1.99     joerg 		mutex_enter((vp)->v_interlock);
    290   1.99     joerg 	}
    291   1.99     joerg 
    292   1.51   hannken 	KASSERTMSG(mutex_owned(vp->v_interlock), "at %s:%d", func, line);
    293   1.51   hannken 
    294  1.120        ad 	if ((state == VS_ACTIVE && refcnt > 0 &&
    295   1.99     joerg 	    (vip->vi_state == VS_LOADED || vip->vi_state == VS_BLOCKED)) ||
    296   1.99     joerg 	    vip->vi_state == state) {
    297   1.99     joerg 		if (!has_lock)
    298   1.99     joerg 			mutex_exit((vp)->v_interlock);
    299   1.94   hannken 		return;
    300   1.99     joerg 	}
    301   1.94   hannken 	vnpanic(vp, "state is %s, usecount %d, expected %s at %s:%d",
    302  1.120        ad 	    vstate_name(vip->vi_state), refcnt,
    303   1.94   hannken 	    vstate_name(state), func, line);
    304   1.51   hannken }
    305   1.51   hannken 
    306   1.57   hannken static enum vnode_state
    307   1.51   hannken vstate_assert_get(vnode_t *vp, const char *func, int line)
    308   1.51   hannken {
    309   1.70   hannken 	vnode_impl_t *vip = VNODE_TO_VIMPL(vp);
    310   1.51   hannken 
    311   1.51   hannken 	KASSERTMSG(mutex_owned(vp->v_interlock), "at %s:%d", func, line);
    312   1.94   hannken 	if (! VSTATE_VALID(vip->vi_state))
    313   1.51   hannken 		vnpanic(vp, "state is %s at %s:%d",
    314   1.70   hannken 		    vstate_name(vip->vi_state), func, line);
    315   1.51   hannken 
    316   1.70   hannken 	return vip->vi_state;
    317   1.51   hannken }
    318   1.51   hannken 
    319   1.52   hannken static void
    320   1.51   hannken vstate_assert_wait_stable(vnode_t *vp, const char *func, int line)
    321   1.51   hannken {
    322   1.70   hannken 	vnode_impl_t *vip = VNODE_TO_VIMPL(vp);
    323   1.51   hannken 
    324   1.51   hannken 	KASSERTMSG(mutex_owned(vp->v_interlock), "at %s:%d", func, line);
    325   1.94   hannken 	if (! VSTATE_VALID(vip->vi_state))
    326   1.51   hannken 		vnpanic(vp, "state is %s at %s:%d",
    327   1.70   hannken 		    vstate_name(vip->vi_state), func, line);
    328   1.51   hannken 
    329   1.94   hannken 	while (vip->vi_state != VS_LOADED && vip->vi_state != VS_RECLAIMED)
    330   1.51   hannken 		cv_wait(&vp->v_cv, vp->v_interlock);
    331   1.51   hannken 
    332   1.94   hannken 	if (! VSTATE_VALID(vip->vi_state))
    333   1.51   hannken 		vnpanic(vp, "state is %s at %s:%d",
    334   1.70   hannken 		    vstate_name(vip->vi_state), func, line);
    335   1.51   hannken }
    336   1.51   hannken 
    337   1.52   hannken static void
    338   1.57   hannken vstate_assert_change(vnode_t *vp, enum vnode_state from, enum vnode_state to,
    339   1.51   hannken     const char *func, int line)
    340   1.51   hannken {
    341  1.123        ad 	bool gated = (atomic_load_relaxed(&vp->v_usecount) & VUSECOUNT_GATE);
    342   1.70   hannken 	vnode_impl_t *vip = VNODE_TO_VIMPL(vp);
    343   1.51   hannken 
    344   1.51   hannken 	KASSERTMSG(mutex_owned(vp->v_interlock), "at %s:%d", func, line);
    345   1.57   hannken 	if (from == VS_LOADING)
    346   1.69   hannken 		KASSERTMSG(mutex_owned(&vcache_lock), "at %s:%d", func, line);
    347   1.51   hannken 
    348   1.94   hannken 	if (! VSTATE_VALID(from))
    349   1.51   hannken 		vnpanic(vp, "from is %s at %s:%d",
    350   1.51   hannken 		    vstate_name(from), func, line);
    351   1.94   hannken 	if (! VSTATE_VALID(to))
    352   1.51   hannken 		vnpanic(vp, "to is %s at %s:%d",
    353   1.51   hannken 		    vstate_name(to), func, line);
    354   1.70   hannken 	if (vip->vi_state != from)
    355   1.51   hannken 		vnpanic(vp, "from is %s, expected %s at %s:%d\n",
    356   1.70   hannken 		    vstate_name(vip->vi_state), vstate_name(from), func, line);
    357  1.123        ad 	if ((from == VS_LOADED) != gated)
    358  1.123        ad 		vnpanic(vp, "state is %s, gate %d does not match at %s:%d\n",
    359  1.123        ad 		    vstate_name(vip->vi_state), gated, func, line);
    360  1.123        ad 
    361  1.136  riastrad 	/* Open/close the gate for vcache_tryvget(). */
    362  1.136  riastrad 	if (to == VS_LOADED) {
    363  1.142  riastrad 		membar_release();
    364  1.123        ad 		atomic_or_uint(&vp->v_usecount, VUSECOUNT_GATE);
    365  1.136  riastrad 	} else {
    366  1.123        ad 		atomic_and_uint(&vp->v_usecount, ~VUSECOUNT_GATE);
    367  1.136  riastrad 	}
    368   1.51   hannken 
    369  1.148  riastrad 	atomic_store_relaxed(&vip->vi_state, to);
    370   1.57   hannken 	if (from == VS_LOADING)
    371   1.69   hannken 		cv_broadcast(&vcache_cv);
    372   1.94   hannken 	if (to == VS_LOADED || to == VS_RECLAIMED)
    373   1.51   hannken 		cv_broadcast(&vp->v_cv);
    374   1.51   hannken }
    375   1.51   hannken 
    376   1.51   hannken #else /* defined(DIAGNOSTIC) */
    377   1.51   hannken 
    378   1.51   hannken #define VSTATE_GET(vp) \
    379   1.57   hannken 	(VNODE_TO_VIMPL((vp))->vi_state)
    380   1.51   hannken #define VSTATE_CHANGE(vp, from, to) \
    381   1.51   hannken 	vstate_change((vp), (from), (to))
    382   1.51   hannken #define VSTATE_WAIT_STABLE(vp) \
    383   1.51   hannken 	vstate_wait_stable((vp))
    384   1.94   hannken void
    385  1.100     joerg _vstate_assert(vnode_t *vp, enum vnode_state state, const char *func, int line,
    386  1.100     joerg     bool has_lock)
    387   1.94   hannken {
    388   1.94   hannken 
    389   1.94   hannken }
    390   1.51   hannken 
    391   1.52   hannken static void
    392   1.51   hannken vstate_wait_stable(vnode_t *vp)
    393   1.51   hannken {
    394   1.70   hannken 	vnode_impl_t *vip = VNODE_TO_VIMPL(vp);
    395   1.51   hannken 
    396   1.94   hannken 	while (vip->vi_state != VS_LOADED && vip->vi_state != VS_RECLAIMED)
    397   1.51   hannken 		cv_wait(&vp->v_cv, vp->v_interlock);
    398   1.51   hannken }
    399   1.51   hannken 
    400   1.52   hannken static void
    401   1.57   hannken vstate_change(vnode_t *vp, enum vnode_state from, enum vnode_state to)
    402   1.51   hannken {
    403   1.70   hannken 	vnode_impl_t *vip = VNODE_TO_VIMPL(vp);
    404   1.51   hannken 
    405  1.142  riastrad 	/* Open/close the gate for vcache_tryvget(). */
    406  1.136  riastrad 	if (to == VS_LOADED) {
    407  1.142  riastrad 		membar_release();
    408  1.123        ad 		atomic_or_uint(&vp->v_usecount, VUSECOUNT_GATE);
    409  1.136  riastrad 	} else {
    410  1.123        ad 		atomic_and_uint(&vp->v_usecount, ~VUSECOUNT_GATE);
    411  1.136  riastrad 	}
    412  1.123        ad 
    413  1.148  riastrad 	atomic_store_relaxed(&vip->vi_state, to);
    414   1.57   hannken 	if (from == VS_LOADING)
    415   1.69   hannken 		cv_broadcast(&vcache_cv);
    416   1.94   hannken 	if (to == VS_LOADED || to == VS_RECLAIMED)
    417   1.51   hannken 		cv_broadcast(&vp->v_cv);
    418   1.51   hannken }
    419   1.51   hannken 
    420   1.51   hannken #endif /* defined(DIAGNOSTIC) */
    421   1.51   hannken 
    422    1.1     rmind void
    423    1.1     rmind vfs_vnode_sysinit(void)
    424    1.1     rmind {
    425  1.104        ad 	int error __diagused, i;
    426    1.1     rmind 
    427   1.44   hannken 	dead_rootmount = vfs_mountalloc(&dead_vfsops, NULL);
    428   1.44   hannken 	KASSERT(dead_rootmount != NULL);
    429  1.103   hannken 	dead_rootmount->mnt_iflag |= IMNT_MPSAFE;
    430   1.31   hannken 
    431   1.63   hannken 	mutex_init(&vdrain_lock, MUTEX_DEFAULT, IPL_NONE);
    432  1.104        ad 	for (i = 0; i < LRU_COUNT; i++) {
    433  1.104        ad 		TAILQ_INIT(&lru_list[i]);
    434  1.104        ad 	}
    435   1.36   hannken 	vcache_init();
    436   1.36   hannken 
    437  1.152   hannken 	error = threadpool_get(&threadpool, PRI_NONE);
    438  1.152   hannken 	KASSERTMSG((error == 0), "threadpool_get failed: %d", error);
    439  1.152   hannken 	threadpool_job_init(&vdrain_job, vdrain_task, &vdrain_lock, "vdrain");
    440  1.152   hannken 	threadpool_job_init(&vrele_job, vrele_task, &vdrain_lock, "vrele");
    441    1.1     rmind }
    442    1.1     rmind 
    443    1.1     rmind /*
    444   1.48   hannken  * Allocate a new marker vnode.
    445   1.48   hannken  */
    446   1.48   hannken vnode_t *
    447   1.48   hannken vnalloc_marker(struct mount *mp)
    448   1.48   hannken {
    449   1.70   hannken 	vnode_impl_t *vip;
    450   1.50   hannken 	vnode_t *vp;
    451   1.50   hannken 
    452   1.70   hannken 	vip = pool_cache_get(vcache_pool, PR_WAITOK);
    453   1.70   hannken 	memset(vip, 0, sizeof(*vip));
    454   1.70   hannken 	vp = VIMPL_TO_VNODE(vip);
    455  1.111        ad 	uvm_obj_init(&vp->v_uobj, &uvm_vnodeops, true, 1);
    456   1.50   hannken 	vp->v_mount = mp;
    457   1.50   hannken 	vp->v_type = VBAD;
    458  1.111        ad 	vp->v_interlock = mutex_obj_alloc(MUTEX_DEFAULT, IPL_NONE);
    459  1.144   thorpej 	klist_init(&vip->vi_klist.vk_klist);
    460  1.144   thorpej 	vp->v_klist = &vip->vi_klist;
    461   1.70   hannken 	vip->vi_state = VS_MARKER;
    462   1.48   hannken 
    463   1.50   hannken 	return vp;
    464   1.48   hannken }
    465   1.48   hannken 
    466   1.48   hannken /*
    467   1.48   hannken  * Free a marker vnode.
    468   1.48   hannken  */
    469   1.48   hannken void
    470   1.48   hannken vnfree_marker(vnode_t *vp)
    471   1.48   hannken {
    472   1.70   hannken 	vnode_impl_t *vip;
    473   1.48   hannken 
    474   1.70   hannken 	vip = VNODE_TO_VIMPL(vp);
    475   1.70   hannken 	KASSERT(vip->vi_state == VS_MARKER);
    476  1.111        ad 	mutex_obj_free(vp->v_interlock);
    477   1.50   hannken 	uvm_obj_destroy(&vp->v_uobj, true);
    478  1.144   thorpej 	klist_fini(&vip->vi_klist.vk_klist);
    479   1.70   hannken 	pool_cache_put(vcache_pool, vip);
    480   1.48   hannken }
    481   1.48   hannken 
    482   1.48   hannken /*
    483   1.48   hannken  * Test a vnode for being a marker vnode.
    484   1.48   hannken  */
    485   1.48   hannken bool
    486   1.48   hannken vnis_marker(vnode_t *vp)
    487   1.48   hannken {
    488   1.48   hannken 
    489   1.57   hannken 	return (VNODE_TO_VIMPL(vp)->vi_state == VS_MARKER);
    490   1.48   hannken }
    491   1.48   hannken 
    492   1.48   hannken /*
    493   1.63   hannken  * Return the lru list this node should be on.
    494   1.63   hannken  */
    495   1.63   hannken static vnodelst_t *
    496   1.63   hannken lru_which(vnode_t *vp)
    497   1.63   hannken {
    498   1.63   hannken 
    499   1.63   hannken 	KASSERT(mutex_owned(vp->v_interlock));
    500   1.63   hannken 
    501   1.63   hannken 	if (vp->v_holdcnt > 0)
    502  1.104        ad 		return &lru_list[LRU_HOLD];
    503   1.63   hannken 	else
    504  1.104        ad 		return &lru_list[LRU_FREE];
    505   1.63   hannken }
    506   1.63   hannken 
    507   1.63   hannken /*
    508   1.63   hannken  * Put vnode to end of given list.
    509   1.63   hannken  * Both the current and the new list may be NULL, used on vnode alloc/free.
    510   1.63   hannken  * Adjust numvnodes and signal vdrain thread if there is work.
    511   1.63   hannken  */
    512   1.63   hannken static void
    513   1.63   hannken lru_requeue(vnode_t *vp, vnodelst_t *listhd)
    514   1.63   hannken {
    515   1.70   hannken 	vnode_impl_t *vip;
    516  1.104        ad 	int d;
    517  1.104        ad 
    518  1.104        ad 	/*
    519  1.104        ad 	 * If the vnode is on the correct list, and was put there recently,
    520  1.104        ad 	 * then leave it be, thus avoiding huge cache and lock contention.
    521  1.104        ad 	 */
    522  1.104        ad 	vip = VNODE_TO_VIMPL(vp);
    523  1.104        ad 	if (listhd == vip->vi_lrulisthd &&
    524  1.119      maxv 	    (getticks() - vip->vi_lrulisttm) < hz) {
    525  1.104        ad 	    	return;
    526  1.104        ad 	}
    527   1.63   hannken 
    528   1.63   hannken 	mutex_enter(&vdrain_lock);
    529  1.104        ad 	d = 0;
    530   1.70   hannken 	if (vip->vi_lrulisthd != NULL)
    531   1.70   hannken 		TAILQ_REMOVE(vip->vi_lrulisthd, vip, vi_lrulist);
    532   1.63   hannken 	else
    533  1.104        ad 		d++;
    534   1.70   hannken 	vip->vi_lrulisthd = listhd;
    535  1.119      maxv 	vip->vi_lrulisttm = getticks();
    536   1.70   hannken 	if (vip->vi_lrulisthd != NULL)
    537   1.70   hannken 		TAILQ_INSERT_TAIL(vip->vi_lrulisthd, vip, vi_lrulist);
    538   1.63   hannken 	else
    539  1.104        ad 		d--;
    540  1.104        ad 	if (d != 0) {
    541  1.104        ad 		/*
    542  1.104        ad 		 * Looks strange?  This is not a bug.  Don't store
    543  1.104        ad 		 * numvnodes unless there is a change - avoid false
    544  1.104        ad 		 * sharing on MP.
    545  1.104        ad 		 */
    546  1.104        ad 		numvnodes += d;
    547  1.104        ad 	}
    548  1.152   hannken 	if (listhd == &lru_list[LRU_VRELE])
    549  1.152   hannken 		threadpool_schedule_job(threadpool, &vrele_job);
    550  1.152   hannken 	if (d > 0 && numvnodes > desiredvnodes)
    551  1.152   hannken 		threadpool_schedule_job(threadpool, &vdrain_job);
    552  1.150   hannken 	if (d > 0 && numvnodes > desiredvnodes + desiredvnodes / 16)
    553  1.151  riastrad 		kpause("vnfull", false, MAX(1, mstohz(10)), &vdrain_lock);
    554   1.63   hannken 	mutex_exit(&vdrain_lock);
    555   1.63   hannken }
    556   1.63   hannken 
    557   1.63   hannken /*
    558  1.152   hannken  * LRU list iterator.
    559  1.152   hannken  * Caller holds vdrain_lock.
    560   1.75   hannken  */
    561  1.152   hannken static vnode_impl_t *
    562  1.152   hannken lru_iter_first(int idx, lru_iter_t *iterp)
    563   1.75   hannken {
    564  1.152   hannken 	vnode_impl_t *marker;
    565   1.75   hannken 
    566  1.152   hannken 	KASSERT(mutex_owned(&vdrain_lock));
    567   1.75   hannken 
    568  1.152   hannken 	mutex_exit(&vdrain_lock);
    569   1.75   hannken 	marker = VNODE_TO_VIMPL(vnalloc_marker(NULL));
    570  1.152   hannken 	mutex_enter(&vdrain_lock);
    571  1.152   hannken 	marker->vi_lrulisthd = &lru_list[idx];
    572  1.152   hannken 	iterp->li_marker = marker;
    573  1.152   hannken 
    574  1.152   hannken 	TAILQ_INSERT_HEAD(marker->vi_lrulisthd, marker, vi_lrulist);
    575  1.152   hannken 
    576  1.152   hannken 	return lru_iter_next(iterp);
    577  1.152   hannken }
    578  1.152   hannken 
    579  1.152   hannken static vnode_impl_t *
    580  1.152   hannken lru_iter_next(lru_iter_t *iter)
    581  1.152   hannken {
    582  1.152   hannken 	vnode_impl_t *vip, *marker;
    583  1.152   hannken 	vnodelst_t *listhd;
    584   1.75   hannken 
    585  1.152   hannken 	KASSERT(mutex_owned(&vdrain_lock));
    586  1.152   hannken 
    587  1.152   hannken 	marker = iter->li_marker;
    588  1.152   hannken 	listhd = marker->vi_lrulisthd;
    589   1.75   hannken 
    590   1.75   hannken 	while ((vip = TAILQ_NEXT(marker, vi_lrulist))) {
    591  1.152   hannken 		TAILQ_REMOVE(listhd, marker, vi_lrulist);
    592  1.152   hannken 		TAILQ_INSERT_AFTER(listhd, vip, marker, vi_lrulist);
    593  1.152   hannken 		if (!vnis_marker(VIMPL_TO_VNODE(vip)))
    594  1.152   hannken 			break;
    595  1.152   hannken 	}
    596   1.75   hannken 
    597  1.152   hannken 	return vip;
    598  1.152   hannken }
    599   1.75   hannken 
    600  1.152   hannken static void
    601  1.152   hannken lru_iter_release(lru_iter_t *iter)
    602  1.152   hannken {
    603  1.152   hannken 	vnode_impl_t *marker;
    604   1.75   hannken 
    605  1.152   hannken 	KASSERT(mutex_owned(&vdrain_lock));
    606  1.122   hannken 
    607  1.152   hannken 	marker = iter->li_marker;
    608  1.152   hannken 	TAILQ_REMOVE(marker->vi_lrulisthd, marker, vi_lrulist);
    609   1.75   hannken 
    610   1.75   hannken 	mutex_exit(&vdrain_lock);
    611   1.75   hannken 	vnfree_marker(VIMPL_TO_VNODE(marker));
    612  1.152   hannken 	mutex_enter(&vdrain_lock);
    613   1.75   hannken }
    614   1.75   hannken 
    615   1.75   hannken /*
    616  1.152   hannken  * Release deferred vrele vnodes for this mount.
    617  1.152   hannken  * Called with file system suspended.
    618    1.1     rmind  */
    619  1.152   hannken void
    620  1.152   hannken vrele_flush(struct mount *mp)
    621    1.1     rmind {
    622  1.152   hannken 	lru_iter_t iter;
    623  1.152   hannken 	vnode_impl_t *vip;
    624    1.1     rmind 
    625  1.152   hannken 	KASSERT(fstrans_is_owner(mp));
    626   1.24   hannken 
    627  1.152   hannken 	mutex_enter(&vdrain_lock);
    628  1.152   hannken 	for (vip = lru_iter_first(LRU_VRELE, &iter); vip != NULL;
    629  1.152   hannken 	    vip = lru_iter_next(&iter)) {
    630  1.152   hannken 		if (VIMPL_TO_VNODE(vip)->v_mount != mp)
    631  1.152   hannken 			continue;
    632  1.152   hannken 		vrele_deferred(vip);
    633    1.1     rmind 	}
    634  1.152   hannken 	lru_iter_release(&iter);
    635   1.63   hannken 	mutex_exit(&vdrain_lock);
    636    1.1     rmind }
    637    1.1     rmind 
    638    1.1     rmind /*
    639  1.152   hannken  * One pass through the LRU lists to keep the number of allocated
    640  1.152   hannken  * vnodes below target.  Returns true if target met.
    641   1.12   hannken  */
    642  1.152   hannken static bool
    643  1.152   hannken vdrain_one(u_int target)
    644   1.12   hannken {
    645  1.152   hannken 	int ix, lists[] = { LRU_FREE, LRU_HOLD };
    646  1.152   hannken 	lru_iter_t iter;
    647  1.152   hannken 	vnode_impl_t *vip;
    648  1.152   hannken 	vnode_t *vp;
    649   1.63   hannken 	struct mount *mp;
    650   1.12   hannken 
    651   1.63   hannken 	KASSERT(mutex_owned(&vdrain_lock));
    652   1.12   hannken 
    653  1.152   hannken 	for (ix = 0; ix < __arraycount(lists); ix++) {
    654  1.152   hannken 		for (vip = lru_iter_first(lists[ix], &iter); vip != NULL;
    655  1.152   hannken 		    vip = lru_iter_next(&iter)) {
    656  1.152   hannken 			if (numvnodes < target) {
    657  1.152   hannken 				lru_iter_release(&iter);
    658  1.152   hannken 				return true;
    659  1.152   hannken 			}
    660  1.152   hannken 
    661  1.152   hannken 			vp = VIMPL_TO_VNODE(vip);
    662  1.152   hannken 
    663  1.152   hannken 			/* Probe usecount (unlocked). */
    664  1.152   hannken 			if (vrefcnt(vp) > 0)
    665  1.152   hannken 				continue;
    666  1.152   hannken 			/* Try v_interlock -- we lock the wrong direction! */
    667  1.152   hannken 			if (!mutex_tryenter(vp->v_interlock))
    668  1.152   hannken 				continue;
    669  1.152   hannken 			/* Probe usecount and state. */
    670  1.152   hannken 			if (vrefcnt(vp) > 0 || VSTATE_GET(vp) != VS_LOADED) {
    671  1.152   hannken 				mutex_exit(vp->v_interlock);
    672  1.152   hannken 				continue;
    673  1.152   hannken 			}
    674  1.152   hannken 			mutex_exit(&vdrain_lock);
    675   1.63   hannken 
    676  1.152   hannken 			mp = vp->v_mount;
    677  1.152   hannken 			if (fstrans_start_nowait(mp) != 0) {
    678  1.152   hannken 				mutex_exit(vp->v_interlock);
    679  1.152   hannken 				mutex_enter(&vdrain_lock);
    680  1.152   hannken 				continue;
    681  1.152   hannken 			}
    682   1.63   hannken 
    683  1.152   hannken 			if (vcache_vget(vp) == 0) {
    684  1.152   hannken 				if (!vrecycle(vp)) {
    685  1.152   hannken 					vn_lock(vp, LK_EXCLUSIVE | LK_RETRY);
    686  1.152   hannken 					mutex_enter(vp->v_interlock);
    687  1.152   hannken 					vrelel(vp, 0, LK_EXCLUSIVE);
    688  1.152   hannken 				}
    689  1.152   hannken 			}
    690  1.152   hannken 			fstrans_done(mp);
    691   1.63   hannken 
    692  1.152   hannken 			mutex_enter(&vdrain_lock);
    693  1.152   hannken 		}
    694  1.152   hannken 		lru_iter_release(&iter);
    695  1.152   hannken 	}
    696   1.63   hannken 
    697  1.152   hannken 	return false;
    698   1.12   hannken }
    699   1.12   hannken 
    700   1.12   hannken /*
    701  1.152   hannken  * threadpool task to keep the number of vnodes below desiredvnodes.
    702    1.1     rmind  */
    703   1.63   hannken static void
    704  1.152   hannken vdrain_task(struct threadpool_job *job)
    705    1.1     rmind {
    706   1.63   hannken 	u_int target;
    707   1.63   hannken 
    708  1.152   hannken 	target = desiredvnodes - desiredvnodes / 16;
    709   1.63   hannken 
    710   1.63   hannken 	mutex_enter(&vdrain_lock);
    711   1.63   hannken 
    712  1.152   hannken 	while (!vdrain_one(target))
    713  1.153   hannken 		kpause("vdrain", false, 1, &vdrain_lock);
    714  1.152   hannken 
    715  1.152   hannken 	threadpool_job_done(job);
    716  1.152   hannken 	mutex_exit(&vdrain_lock);
    717  1.152   hannken }
    718  1.152   hannken 
    719  1.152   hannken /*
    720  1.152   hannken  * threadpool task to process asynchronous vrele.
    721  1.152   hannken  */
    722  1.152   hannken static void
    723  1.152   hannken vrele_task(struct threadpool_job *job)
    724  1.152   hannken {
    725  1.152   hannken 	int skipped;
    726  1.152   hannken 	lru_iter_t iter;
    727  1.152   hannken 	vnode_impl_t *vip;
    728  1.152   hannken 	struct mount *mp;
    729  1.152   hannken 
    730  1.152   hannken 	mutex_enter(&vdrain_lock);
    731  1.152   hannken 	while ((vip = lru_iter_first(LRU_VRELE, &iter)) != NULL) {
    732  1.152   hannken 		for (skipped = 0; vip != NULL; vip = lru_iter_next(&iter)) {
    733  1.152   hannken 			mp = VIMPL_TO_VNODE(vip)->v_mount;
    734  1.152   hannken 			if (fstrans_start_nowait(mp) == 0) {
    735  1.152   hannken 				vrele_deferred(vip);
    736  1.152   hannken 				fstrans_done(mp);
    737  1.152   hannken 			} else {
    738  1.152   hannken 				skipped++;
    739   1.63   hannken 			}
    740   1.63   hannken 		}
    741    1.1     rmind 
    742  1.152   hannken 		lru_iter_release(&iter);
    743  1.154  riastrad 		if (skipped) {
    744  1.154  riastrad 			kpause("vrele", false, MAX(1, mstohz(10)),
    745  1.154  riastrad 			    &vdrain_lock);
    746  1.154  riastrad 		}
    747    1.1     rmind 	}
    748  1.152   hannken 
    749  1.152   hannken 	threadpool_job_done(job);
    750  1.152   hannken 	lru_iter_release(&iter);
    751  1.152   hannken 	mutex_exit(&vdrain_lock);
    752    1.1     rmind }
    753    1.1     rmind 
    754    1.1     rmind /*
    755  1.112        ad  * Try to drop reference on a vnode.  Abort if we are releasing the
    756  1.112        ad  * last reference.  Note: this _must_ succeed if not the last reference.
    757  1.112        ad  */
    758  1.112        ad static bool
    759  1.112        ad vtryrele(vnode_t *vp)
    760  1.112        ad {
    761  1.112        ad 	u_int use, next;
    762  1.112        ad 
    763  1.142  riastrad 	membar_release();
    764  1.112        ad 	for (use = atomic_load_relaxed(&vp->v_usecount);; use = next) {
    765  1.123        ad 		if (__predict_false((use & VUSECOUNT_MASK) == 1)) {
    766  1.112        ad 			return false;
    767  1.112        ad 		}
    768  1.123        ad 		KASSERT((use & VUSECOUNT_MASK) > 1);
    769  1.112        ad 		next = atomic_cas_uint(&vp->v_usecount, use, use - 1);
    770  1.112        ad 		if (__predict_true(next == use)) {
    771  1.112        ad 			return true;
    772  1.112        ad 		}
    773  1.112        ad 	}
    774  1.112        ad }
    775  1.112        ad 
    776  1.112        ad /*
    777    1.4     rmind  * vput: unlock and release the reference.
    778    1.1     rmind  */
    779    1.1     rmind void
    780    1.1     rmind vput(vnode_t *vp)
    781    1.1     rmind {
    782  1.107        ad 	int lktype;
    783    1.1     rmind 
    784  1.112        ad 	/*
    785  1.120        ad 	 * Do an unlocked check of the usecount.  If it looks like we're not
    786  1.112        ad 	 * about to drop the last reference, then unlock the vnode and try
    787  1.112        ad 	 * to drop the reference.  If it ends up being the last reference
    788  1.112        ad 	 * after all, vrelel() can fix it all up.  Most of the time this
    789  1.112        ad 	 * will all go to plan.
    790  1.112        ad 	 */
    791  1.120        ad 	if (vrefcnt(vp) > 1) {
    792  1.112        ad 		VOP_UNLOCK(vp);
    793  1.112        ad 		if (vtryrele(vp)) {
    794  1.112        ad 			return;
    795  1.112        ad 		}
    796  1.112        ad 		lktype = LK_NONE;
    797  1.107        ad 	} else {
    798  1.107        ad 		lktype = VOP_ISLOCKED(vp);
    799  1.107        ad 		KASSERT(lktype != LK_NONE);
    800  1.107        ad 	}
    801  1.107        ad 	mutex_enter(vp->v_interlock);
    802  1.107        ad 	vrelel(vp, 0, lktype);
    803    1.1     rmind }
    804    1.1     rmind 
    805    1.1     rmind /*
    806  1.152   hannken  * Release a vnode from the deferred list.
    807  1.152   hannken  */
    808  1.152   hannken static void
    809  1.152   hannken vrele_deferred(vnode_impl_t *vip)
    810  1.152   hannken {
    811  1.152   hannken 	vnode_t *vp;
    812  1.152   hannken 
    813  1.152   hannken 	KASSERT(mutex_owned(&vdrain_lock));
    814  1.152   hannken 	KASSERT(vip->vi_lrulisthd == &lru_list[LRU_VRELE]);
    815  1.152   hannken 
    816  1.152   hannken 	vp = VIMPL_TO_VNODE(vip);
    817  1.152   hannken 
    818  1.152   hannken 	/*
    819  1.152   hannken 	 * First remove the vnode from the vrele list.
    820  1.152   hannken 	 * Put it on the last lru list, the last vrele()
    821  1.152   hannken 	 * will put it back onto the right list before
    822  1.152   hannken 	 * its usecount reaches zero.
    823  1.152   hannken 	 */
    824  1.152   hannken 	TAILQ_REMOVE(vip->vi_lrulisthd, vip, vi_lrulist);
    825  1.152   hannken 	vip->vi_lrulisthd = &lru_list[LRU_HOLD];
    826  1.152   hannken 	vip->vi_lrulisttm = getticks();
    827  1.152   hannken 	TAILQ_INSERT_TAIL(vip->vi_lrulisthd, vip, vi_lrulist);
    828  1.152   hannken 
    829  1.152   hannken 	mutex_exit(&vdrain_lock);
    830  1.152   hannken 
    831  1.152   hannken 	vn_lock(vp, LK_EXCLUSIVE | LK_RETRY);
    832  1.152   hannken 	mutex_enter(vp->v_interlock);
    833  1.152   hannken 	vrelel(vp, 0, LK_EXCLUSIVE);
    834  1.152   hannken 
    835  1.152   hannken 	mutex_enter(&vdrain_lock);
    836  1.152   hannken }
    837  1.152   hannken 
    838  1.152   hannken /*
    839    1.1     rmind  * Vnode release.  If reference count drops to zero, call inactive
    840    1.1     rmind  * routine and either return to freelist or free to the pool.
    841    1.1     rmind  */
    842   1.23   hannken static void
    843  1.107        ad vrelel(vnode_t *vp, int flags, int lktype)
    844    1.1     rmind {
    845  1.104        ad 	const bool async = ((flags & VRELEL_ASYNC) != 0);
    846  1.133   hannken 	bool recycle, defer, objlock_held;
    847  1.132   hannken 	u_int use, next;
    848    1.1     rmind 	int error;
    849    1.1     rmind 
    850  1.133   hannken 	objlock_held = false;
    851  1.133   hannken 
    852  1.132   hannken retry:
    853    1.9     rmind 	KASSERT(mutex_owned(vp->v_interlock));
    854    1.1     rmind 
    855    1.1     rmind 	if (__predict_false(vp->v_op == dead_vnodeop_p &&
    856   1.57   hannken 	    VSTATE_GET(vp) != VS_RECLAIMED)) {
    857   1.11  christos 		vnpanic(vp, "dead but not clean");
    858    1.1     rmind 	}
    859    1.1     rmind 
    860    1.1     rmind 	/*
    861  1.132   hannken 	 * If not the last reference, just unlock and drop the reference count.
    862  1.132   hannken 	 *
    863  1.132   hannken 	 * Otherwise make sure we pass a point in time where we hold the
    864  1.132   hannken 	 * last reference with VGET flag unset.
    865    1.1     rmind 	 */
    866  1.132   hannken 	for (use = atomic_load_relaxed(&vp->v_usecount);; use = next) {
    867  1.132   hannken 		if (__predict_false((use & VUSECOUNT_MASK) > 1)) {
    868  1.134   hannken 			if (objlock_held) {
    869  1.134   hannken 				objlock_held = false;
    870  1.134   hannken 				rw_exit(vp->v_uobj.vmobjlock);
    871  1.134   hannken 			}
    872  1.132   hannken 			if (lktype != LK_NONE) {
    873  1.132   hannken 				mutex_exit(vp->v_interlock);
    874  1.132   hannken 				lktype = LK_NONE;
    875  1.132   hannken 				VOP_UNLOCK(vp);
    876  1.132   hannken 				mutex_enter(vp->v_interlock);
    877  1.132   hannken 			}
    878  1.132   hannken 			if (vtryrele(vp)) {
    879  1.132   hannken 				mutex_exit(vp->v_interlock);
    880  1.132   hannken 				return;
    881  1.132   hannken 			}
    882  1.132   hannken 			next = atomic_load_relaxed(&vp->v_usecount);
    883  1.132   hannken 			continue;
    884  1.132   hannken 		}
    885  1.132   hannken 		KASSERT((use & VUSECOUNT_MASK) == 1);
    886  1.132   hannken 		next = use & ~VUSECOUNT_VGET;
    887  1.132   hannken 		if (next != use) {
    888  1.132   hannken 			next = atomic_cas_uint(&vp->v_usecount, use, next);
    889  1.132   hannken 		}
    890  1.132   hannken 		if (__predict_true(next == use)) {
    891  1.132   hannken 			break;
    892  1.107        ad 		}
    893    1.1     rmind 	}
    894  1.142  riastrad 	membar_acquire();
    895  1.120        ad 	if (vrefcnt(vp) <= 0 || vp->v_writecount != 0) {
    896   1.11  christos 		vnpanic(vp, "%s: bad ref count", __func__);
    897    1.1     rmind 	}
    898    1.1     rmind 
    899   1.15   hannken #ifdef DIAGNOSTIC
    900   1.15   hannken 	if ((vp->v_type == VBLK || vp->v_type == VCHR) &&
    901   1.15   hannken 	    vp->v_specnode != NULL && vp->v_specnode->sn_opencnt != 0) {
    902   1.15   hannken 		vprint("vrelel: missing VOP_CLOSE()", vp);
    903   1.15   hannken 	}
    904   1.15   hannken #endif
    905   1.15   hannken 
    906    1.1     rmind 	/*
    907  1.131   hannken 	 * If already clean there is no need to lock, defer or
    908  1.131   hannken 	 * deactivate this node.
    909  1.131   hannken 	 */
    910  1.131   hannken 	if (VSTATE_GET(vp) == VS_RECLAIMED) {
    911  1.134   hannken 		if (objlock_held) {
    912  1.134   hannken 			objlock_held = false;
    913  1.134   hannken 			rw_exit(vp->v_uobj.vmobjlock);
    914  1.134   hannken 		}
    915  1.131   hannken 		if (lktype != LK_NONE) {
    916  1.131   hannken 			mutex_exit(vp->v_interlock);
    917  1.131   hannken 			lktype = LK_NONE;
    918  1.131   hannken 			VOP_UNLOCK(vp);
    919  1.131   hannken 			mutex_enter(vp->v_interlock);
    920  1.131   hannken 		}
    921  1.131   hannken 		goto out;
    922  1.131   hannken 	}
    923  1.131   hannken 
    924  1.131   hannken 	/*
    925   1.79   hannken 	 * First try to get the vnode locked for VOP_INACTIVE().
    926  1.152   hannken 	 * Defer vnode release to vrele task if caller requests
    927   1.79   hannken 	 * it explicitly, is the pagedaemon or the lock failed.
    928    1.1     rmind 	 */
    929  1.107        ad 	defer = false;
    930   1.79   hannken 	if ((curlwp == uvm.pagedaemon_lwp) || async) {
    931   1.79   hannken 		defer = true;
    932  1.107        ad 	} else if (lktype == LK_SHARED) {
    933  1.107        ad 		/* Excellent chance of getting, if the last ref. */
    934  1.131   hannken 		error = vn_lock(vp, LK_UPGRADE | LK_RETRY | LK_NOWAIT);
    935  1.107        ad 		if (error != 0) {
    936  1.107        ad 			defer = true;
    937  1.107        ad 		} else {
    938  1.107        ad 			lktype = LK_EXCLUSIVE;
    939  1.107        ad 		}
    940  1.107        ad 	} else if (lktype == LK_NONE) {
    941  1.107        ad 		/* Excellent chance of getting, if the last ref. */
    942  1.131   hannken 		error = vn_lock(vp, LK_EXCLUSIVE | LK_RETRY | LK_NOWAIT);
    943  1.107        ad 		if (error != 0) {
    944  1.107        ad 			defer = true;
    945  1.107        ad 		} else {
    946  1.107        ad 			lktype = LK_EXCLUSIVE;
    947  1.107        ad 		}
    948   1.79   hannken 	}
    949   1.79   hannken 	KASSERT(mutex_owned(vp->v_interlock));
    950   1.79   hannken 	if (defer) {
    951    1.1     rmind 		/*
    952  1.152   hannken 		 * Defer reclaim to the vrele task; it's not safe to
    953   1.79   hannken 		 * clean it here.  We donate it our last reference.
    954    1.1     rmind 		 */
    955  1.107        ad 		if (lktype != LK_NONE) {
    956  1.134   hannken 			mutex_exit(vp->v_interlock);
    957  1.107        ad 			VOP_UNLOCK(vp);
    958  1.134   hannken 			mutex_enter(vp->v_interlock);
    959  1.107        ad 		}
    960  1.104        ad 		lru_requeue(vp, &lru_list[LRU_VRELE]);
    961   1.79   hannken 		mutex_exit(vp->v_interlock);
    962   1.79   hannken 		return;
    963   1.79   hannken 	}
    964  1.107        ad 	KASSERT(lktype == LK_EXCLUSIVE);
    965   1.30   hannken 
    966  1.135   hannken 	/* If the node gained another reference, retry. */
    967  1.135   hannken 	use = atomic_load_relaxed(&vp->v_usecount);
    968  1.137   hannken 	if ((use & VUSECOUNT_VGET) != 0) {
    969  1.135   hannken 		goto retry;
    970  1.135   hannken 	}
    971  1.137   hannken 	KASSERT((use & VUSECOUNT_MASK) == 1);
    972  1.135   hannken 
    973  1.133   hannken 	if ((vp->v_iflag & (VI_TEXT|VI_EXECMAP|VI_WRMAP)) != 0 ||
    974  1.133   hannken 	    (vp->v_vflag & VV_MAPPED) != 0) {
    975  1.133   hannken 		/* Take care of space accounting. */
    976  1.133   hannken 		if (!objlock_held) {
    977  1.133   hannken 			objlock_held = true;
    978  1.133   hannken 			if (!rw_tryenter(vp->v_uobj.vmobjlock, RW_WRITER)) {
    979  1.133   hannken 				mutex_exit(vp->v_interlock);
    980  1.133   hannken 				rw_enter(vp->v_uobj.vmobjlock, RW_WRITER);
    981  1.133   hannken 				mutex_enter(vp->v_interlock);
    982  1.133   hannken 				goto retry;
    983  1.133   hannken 			}
    984  1.133   hannken 		}
    985  1.133   hannken 		if ((vp->v_iflag & VI_EXECMAP) != 0) {
    986  1.133   hannken 			cpu_count(CPU_COUNT_EXECPAGES, -vp->v_uobj.uo_npages);
    987  1.133   hannken 		}
    988  1.133   hannken 		vp->v_iflag &= ~(VI_TEXT|VI_EXECMAP|VI_WRMAP);
    989  1.133   hannken 		vp->v_vflag &= ~VV_MAPPED;
    990  1.133   hannken 	}
    991  1.133   hannken 	if (objlock_held) {
    992  1.133   hannken 		objlock_held = false;
    993  1.133   hannken 		rw_exit(vp->v_uobj.vmobjlock);
    994  1.133   hannken 	}
    995  1.133   hannken 
    996   1.79   hannken 	/*
    997  1.131   hannken 	 * Deactivate the vnode, but preserve our reference across
    998  1.131   hannken 	 * the call to VOP_INACTIVE().
    999  1.131   hannken 	 *
   1000  1.131   hannken 	 * If VOP_INACTIVE() indicates that the file has been
   1001  1.131   hannken 	 * deleted, then recycle the vnode.
   1002  1.131   hannken 	 *
   1003  1.131   hannken 	 * Note that VOP_INACTIVE() will not drop the vnode lock.
   1004   1.79   hannken 	 */
   1005  1.131   hannken 	mutex_exit(vp->v_interlock);
   1006  1.131   hannken 	recycle = false;
   1007  1.131   hannken 	VOP_INACTIVE(vp, &recycle);
   1008  1.133   hannken 	if (!recycle) {
   1009  1.133   hannken 		lktype = LK_NONE;
   1010  1.133   hannken 		VOP_UNLOCK(vp);
   1011  1.133   hannken 	}
   1012  1.131   hannken 	mutex_enter(vp->v_interlock);
   1013  1.131   hannken 
   1014  1.132   hannken 	/*
   1015  1.132   hannken 	 * Block new references then check again to see if a
   1016  1.132   hannken 	 * new reference was acquired in the meantime.  If
   1017  1.132   hannken 	 * it was, restore the vnode state and try again.
   1018  1.132   hannken 	 */
   1019  1.132   hannken 	if (recycle) {
   1020  1.132   hannken 		VSTATE_CHANGE(vp, VS_LOADED, VS_BLOCKED);
   1021  1.132   hannken 		use = atomic_load_relaxed(&vp->v_usecount);
   1022  1.137   hannken 		if ((use & VUSECOUNT_VGET) != 0) {
   1023  1.132   hannken 			VSTATE_CHANGE(vp, VS_BLOCKED, VS_LOADED);
   1024  1.132   hannken 			goto retry;
   1025  1.131   hannken 		}
   1026  1.137   hannken 		KASSERT((use & VUSECOUNT_MASK) == 1);
   1027  1.132   hannken 	}
   1028    1.1     rmind 
   1029  1.131   hannken 	/*
   1030  1.133   hannken 	 * Recycle the vnode if the file is now unused (unlinked).
   1031  1.131   hannken 	 */
   1032  1.131   hannken 	if (recycle) {
   1033  1.131   hannken 		VSTATE_ASSERT(vp, VS_BLOCKED);
   1034  1.133   hannken 		KASSERT(lktype == LK_EXCLUSIVE);
   1035  1.131   hannken 		/* vcache_reclaim drops the lock. */
   1036  1.132   hannken 		lktype = LK_NONE;
   1037  1.131   hannken 		vcache_reclaim(vp);
   1038    1.1     rmind 	}
   1039  1.131   hannken 	KASSERT(vrefcnt(vp) > 0);
   1040  1.133   hannken 	KASSERT(lktype == LK_NONE);
   1041    1.1     rmind 
   1042  1.131   hannken out:
   1043  1.132   hannken 	for (use = atomic_load_relaxed(&vp->v_usecount);; use = next) {
   1044  1.132   hannken 		if (__predict_false((use & VUSECOUNT_VGET) != 0 &&
   1045  1.132   hannken 		    (use & VUSECOUNT_MASK) == 1)) {
   1046  1.132   hannken 			/* Gained and released another reference, retry. */
   1047  1.132   hannken 			goto retry;
   1048  1.132   hannken 		}
   1049  1.132   hannken 		next = atomic_cas_uint(&vp->v_usecount, use, use - 1);
   1050  1.132   hannken 		if (__predict_true(next == use)) {
   1051  1.132   hannken 			if (__predict_false((use & VUSECOUNT_MASK) != 1)) {
   1052  1.132   hannken 				/* Gained another reference. */
   1053  1.132   hannken 				mutex_exit(vp->v_interlock);
   1054  1.132   hannken 				return;
   1055  1.132   hannken 			}
   1056  1.132   hannken 			break;
   1057  1.132   hannken 		}
   1058    1.1     rmind 	}
   1059  1.142  riastrad 	membar_acquire();
   1060    1.1     rmind 
   1061   1.67   hannken 	if (VSTATE_GET(vp) == VS_RECLAIMED && vp->v_holdcnt == 0) {
   1062    1.1     rmind 		/*
   1063    1.1     rmind 		 * It's clean so destroy it.  It isn't referenced
   1064    1.1     rmind 		 * anywhere since it has been reclaimed.
   1065    1.1     rmind 		 */
   1066   1.57   hannken 		vcache_free(VNODE_TO_VIMPL(vp));
   1067    1.1     rmind 	} else {
   1068    1.1     rmind 		/*
   1069    1.1     rmind 		 * Otherwise, put it back onto the freelist.  It
   1070    1.1     rmind 		 * can't be destroyed while still associated with
   1071    1.1     rmind 		 * a file system.
   1072    1.1     rmind 		 */
   1073   1.63   hannken 		lru_requeue(vp, lru_which(vp));
   1074    1.9     rmind 		mutex_exit(vp->v_interlock);
   1075    1.1     rmind 	}
   1076    1.1     rmind }
   1077    1.1     rmind 
   1078    1.1     rmind void
   1079    1.1     rmind vrele(vnode_t *vp)
   1080    1.1     rmind {
   1081    1.1     rmind 
   1082  1.112        ad 	if (vtryrele(vp)) {
   1083  1.112        ad 		return;
   1084  1.112        ad 	}
   1085    1.9     rmind 	mutex_enter(vp->v_interlock);
   1086  1.107        ad 	vrelel(vp, 0, LK_NONE);
   1087    1.1     rmind }
   1088    1.1     rmind 
   1089    1.1     rmind /*
   1090    1.1     rmind  * Asynchronous vnode release, vnode is released in different context.
   1091    1.1     rmind  */
   1092    1.1     rmind void
   1093    1.1     rmind vrele_async(vnode_t *vp)
   1094    1.1     rmind {
   1095    1.1     rmind 
   1096  1.112        ad 	if (vtryrele(vp)) {
   1097  1.112        ad 		return;
   1098  1.112        ad 	}
   1099    1.9     rmind 	mutex_enter(vp->v_interlock);
   1100  1.107        ad 	vrelel(vp, VRELEL_ASYNC, LK_NONE);
   1101    1.1     rmind }
   1102    1.1     rmind 
   1103    1.1     rmind /*
   1104    1.1     rmind  * Vnode reference, where a reference is already held by some other
   1105    1.1     rmind  * object (for example, a file structure).
   1106  1.112        ad  *
   1107  1.123        ad  * NB: lockless code sequences may rely on this not blocking.
   1108    1.1     rmind  */
   1109    1.1     rmind void
   1110    1.1     rmind vref(vnode_t *vp)
   1111    1.1     rmind {
   1112    1.1     rmind 
   1113  1.120        ad 	KASSERT(vrefcnt(vp) > 0);
   1114    1.1     rmind 
   1115  1.112        ad 	atomic_inc_uint(&vp->v_usecount);
   1116    1.1     rmind }
   1117    1.1     rmind 
   1118    1.1     rmind /*
   1119    1.1     rmind  * Page or buffer structure gets a reference.
   1120    1.1     rmind  * Called with v_interlock held.
   1121    1.1     rmind  */
   1122    1.1     rmind void
   1123    1.1     rmind vholdl(vnode_t *vp)
   1124    1.1     rmind {
   1125    1.1     rmind 
   1126    1.9     rmind 	KASSERT(mutex_owned(vp->v_interlock));
   1127    1.1     rmind 
   1128  1.120        ad 	if (vp->v_holdcnt++ == 0 && vrefcnt(vp) == 0)
   1129   1.63   hannken 		lru_requeue(vp, lru_which(vp));
   1130    1.1     rmind }
   1131    1.1     rmind 
   1132    1.1     rmind /*
   1133  1.112        ad  * Page or buffer structure gets a reference.
   1134  1.112        ad  */
   1135  1.112        ad void
   1136  1.112        ad vhold(vnode_t *vp)
   1137  1.112        ad {
   1138  1.112        ad 
   1139  1.112        ad 	mutex_enter(vp->v_interlock);
   1140  1.112        ad 	vholdl(vp);
   1141  1.112        ad 	mutex_exit(vp->v_interlock);
   1142  1.112        ad }
   1143  1.112        ad 
   1144  1.112        ad /*
   1145    1.1     rmind  * Page or buffer structure frees a reference.
   1146    1.1     rmind  * Called with v_interlock held.
   1147    1.1     rmind  */
   1148    1.1     rmind void
   1149    1.1     rmind holdrelel(vnode_t *vp)
   1150    1.1     rmind {
   1151    1.1     rmind 
   1152    1.9     rmind 	KASSERT(mutex_owned(vp->v_interlock));
   1153    1.1     rmind 
   1154    1.1     rmind 	if (vp->v_holdcnt <= 0) {
   1155   1.11  christos 		vnpanic(vp, "%s: holdcnt vp %p", __func__, vp);
   1156    1.1     rmind 	}
   1157    1.1     rmind 
   1158    1.1     rmind 	vp->v_holdcnt--;
   1159  1.120        ad 	if (vp->v_holdcnt == 0 && vrefcnt(vp) == 0)
   1160   1.63   hannken 		lru_requeue(vp, lru_which(vp));
   1161    1.1     rmind }
   1162    1.1     rmind 
   1163    1.1     rmind /*
   1164  1.112        ad  * Page or buffer structure frees a reference.
   1165  1.112        ad  */
   1166  1.112        ad void
   1167  1.112        ad holdrele(vnode_t *vp)
   1168  1.112        ad {
   1169  1.112        ad 
   1170  1.112        ad 	mutex_enter(vp->v_interlock);
   1171  1.112        ad 	holdrelel(vp);
   1172  1.112        ad 	mutex_exit(vp->v_interlock);
   1173  1.112        ad }
   1174  1.112        ad 
   1175  1.112        ad /*
   1176   1.33   hannken  * Recycle an unused vnode if caller holds the last reference.
   1177    1.1     rmind  */
   1178   1.33   hannken bool
   1179   1.33   hannken vrecycle(vnode_t *vp)
   1180    1.1     rmind {
   1181   1.60   hannken 	int error __diagused;
   1182   1.46   hannken 
   1183   1.33   hannken 	mutex_enter(vp->v_interlock);
   1184   1.33   hannken 
   1185  1.123        ad 	/* If the vnode is already clean we're done. */
   1186   1.60   hannken 	VSTATE_WAIT_STABLE(vp);
   1187   1.94   hannken 	if (VSTATE_GET(vp) != VS_LOADED) {
   1188   1.60   hannken 		VSTATE_ASSERT(vp, VS_RECLAIMED);
   1189  1.107        ad 		vrelel(vp, 0, LK_NONE);
   1190   1.60   hannken 		return true;
   1191   1.60   hannken 	}
   1192   1.60   hannken 
   1193   1.60   hannken 	/* Prevent further references until the vnode is locked. */
   1194   1.94   hannken 	VSTATE_CHANGE(vp, VS_LOADED, VS_BLOCKED);
   1195  1.123        ad 
   1196  1.123        ad 	/* Make sure we hold the last reference. */
   1197  1.123        ad 	if (vrefcnt(vp) != 1) {
   1198  1.123        ad 		VSTATE_CHANGE(vp, VS_BLOCKED, VS_LOADED);
   1199  1.123        ad 		mutex_exit(vp->v_interlock);
   1200  1.123        ad 		return false;
   1201  1.123        ad 	}
   1202  1.123        ad 
   1203   1.60   hannken 	mutex_exit(vp->v_interlock);
   1204   1.60   hannken 
   1205   1.73   hannken 	/*
   1206   1.73   hannken 	 * On a leaf file system this lock will always succeed as we hold
   1207   1.73   hannken 	 * the last reference and prevent further references.
   1208   1.73   hannken 	 * On layered file systems waiting for the lock would open a can of
   1209   1.73   hannken 	 * deadlocks as the lower vnodes may have other active references.
   1210   1.73   hannken 	 */
   1211   1.76   hannken 	error = vn_lock(vp, LK_EXCLUSIVE | LK_RETRY | LK_NOWAIT);
   1212   1.60   hannken 
   1213   1.60   hannken 	mutex_enter(vp->v_interlock);
   1214   1.73   hannken 	if (error) {
   1215  1.123        ad 		VSTATE_CHANGE(vp, VS_BLOCKED, VS_LOADED);
   1216   1.73   hannken 		mutex_exit(vp->v_interlock);
   1217   1.73   hannken 		return false;
   1218   1.73   hannken 	}
   1219   1.73   hannken 
   1220  1.120        ad 	KASSERT(vrefcnt(vp) == 1);
   1221   1.54   hannken 	vcache_reclaim(vp);
   1222  1.107        ad 	vrelel(vp, 0, LK_NONE);
   1223   1.60   hannken 
   1224   1.33   hannken 	return true;
   1225    1.1     rmind }
   1226    1.1     rmind 
   1227    1.1     rmind /*
   1228   1.92   hannken  * Helper for vrevoke() to propagate suspension from lastmp
   1229   1.92   hannken  * to thismp.  Both args may be NULL.
   1230   1.92   hannken  * Returns the currently suspended file system or NULL.
   1231   1.92   hannken  */
   1232   1.92   hannken static struct mount *
   1233   1.92   hannken vrevoke_suspend_next(struct mount *lastmp, struct mount *thismp)
   1234   1.92   hannken {
   1235   1.92   hannken 	int error;
   1236   1.92   hannken 
   1237   1.92   hannken 	if (lastmp == thismp)
   1238   1.92   hannken 		return thismp;
   1239   1.92   hannken 
   1240   1.92   hannken 	if (lastmp != NULL)
   1241   1.92   hannken 		vfs_resume(lastmp);
   1242   1.92   hannken 
   1243   1.92   hannken 	if (thismp == NULL)
   1244   1.92   hannken 		return NULL;
   1245   1.92   hannken 
   1246   1.92   hannken 	do {
   1247   1.92   hannken 		error = vfs_suspend(thismp, 0);
   1248   1.92   hannken 	} while (error == EINTR || error == ERESTART);
   1249   1.92   hannken 
   1250   1.92   hannken 	if (error == 0)
   1251   1.92   hannken 		return thismp;
   1252   1.92   hannken 
   1253  1.129   hannken 	KASSERT(error == EOPNOTSUPP || error == ENOENT);
   1254   1.92   hannken 	return NULL;
   1255   1.92   hannken }
   1256   1.92   hannken 
   1257   1.92   hannken /*
   1258    1.1     rmind  * Eliminate all activity associated with the requested vnode
   1259    1.1     rmind  * and with all vnodes aliased to the requested vnode.
   1260    1.1     rmind  */
   1261    1.1     rmind void
   1262    1.1     rmind vrevoke(vnode_t *vp)
   1263    1.1     rmind {
   1264   1.88   hannken 	struct mount *mp;
   1265   1.19   hannken 	vnode_t *vq;
   1266    1.1     rmind 	enum vtype type;
   1267    1.1     rmind 	dev_t dev;
   1268    1.1     rmind 
   1269  1.120        ad 	KASSERT(vrefcnt(vp) > 0);
   1270    1.1     rmind 
   1271   1.92   hannken 	mp = vrevoke_suspend_next(NULL, vp->v_mount);
   1272   1.88   hannken 
   1273    1.9     rmind 	mutex_enter(vp->v_interlock);
   1274   1.52   hannken 	VSTATE_WAIT_STABLE(vp);
   1275   1.57   hannken 	if (VSTATE_GET(vp) == VS_RECLAIMED) {
   1276    1.9     rmind 		mutex_exit(vp->v_interlock);
   1277    1.1     rmind 	} else if (vp->v_type != VBLK && vp->v_type != VCHR) {
   1278  1.112        ad 		atomic_inc_uint(&vp->v_usecount);
   1279   1.29  christos 		mutex_exit(vp->v_interlock);
   1280   1.29  christos 		vgone(vp);
   1281    1.1     rmind 	} else {
   1282    1.1     rmind 		dev = vp->v_rdev;
   1283    1.1     rmind 		type = vp->v_type;
   1284    1.9     rmind 		mutex_exit(vp->v_interlock);
   1285    1.1     rmind 
   1286  1.140  riastrad 		while (spec_node_lookup_by_dev(type, dev, VDEAD_NOWAIT, &vq)
   1287  1.140  riastrad 		    == 0) {
   1288   1.92   hannken 			mp = vrevoke_suspend_next(mp, vq->v_mount);
   1289   1.88   hannken 			vgone(vq);
   1290   1.88   hannken 		}
   1291    1.1     rmind 	}
   1292   1.92   hannken 	vrevoke_suspend_next(mp, NULL);
   1293    1.1     rmind }
   1294    1.1     rmind 
   1295    1.1     rmind /*
   1296    1.1     rmind  * Eliminate all activity associated with a vnode in preparation for
   1297    1.1     rmind  * reuse.  Drops a reference from the vnode.
   1298    1.1     rmind  */
   1299    1.1     rmind void
   1300    1.1     rmind vgone(vnode_t *vp)
   1301    1.1     rmind {
   1302  1.107        ad 	int lktype;
   1303    1.1     rmind 
   1304  1.154  riastrad 	KASSERT(vp->v_mount == dead_rootmount ||
   1305  1.154  riastrad 	    fstrans_is_owner(vp->v_mount));
   1306   1.93   hannken 
   1307   1.76   hannken 	vn_lock(vp, LK_EXCLUSIVE | LK_RETRY);
   1308  1.107        ad 	lktype = LK_EXCLUSIVE;
   1309    1.9     rmind 	mutex_enter(vp->v_interlock);
   1310   1.76   hannken 	VSTATE_WAIT_STABLE(vp);
   1311  1.146  riastrad 	if (VSTATE_GET(vp) == VS_LOADED) {
   1312  1.123        ad 		VSTATE_CHANGE(vp, VS_LOADED, VS_BLOCKED);
   1313   1.76   hannken 		vcache_reclaim(vp);
   1314  1.107        ad 		lktype = LK_NONE;
   1315  1.107        ad 	}
   1316   1.76   hannken 	VSTATE_ASSERT(vp, VS_RECLAIMED);
   1317  1.107        ad 	vrelel(vp, 0, lktype);
   1318    1.1     rmind }
   1319    1.1     rmind 
   1320   1.36   hannken static inline uint32_t
   1321   1.36   hannken vcache_hash(const struct vcache_key *key)
   1322   1.36   hannken {
   1323   1.36   hannken 	uint32_t hash = HASH32_BUF_INIT;
   1324   1.36   hannken 
   1325   1.97   hannken 	KASSERT(key->vk_key_len > 0);
   1326   1.97   hannken 
   1327   1.36   hannken 	hash = hash32_buf(&key->vk_mount, sizeof(struct mount *), hash);
   1328   1.36   hannken 	hash = hash32_buf(key->vk_key, key->vk_key_len, hash);
   1329   1.36   hannken 	return hash;
   1330   1.36   hannken }
   1331   1.36   hannken 
   1332  1.127    simonb static int
   1333  1.127    simonb vcache_stats(struct hashstat_sysctl *hs, bool fill)
   1334  1.127    simonb {
   1335  1.127    simonb 	vnode_impl_t *vip;
   1336  1.127    simonb 	uint64_t chain;
   1337  1.127    simonb 
   1338  1.127    simonb 	strlcpy(hs->hash_name, "vcache", sizeof(hs->hash_name));
   1339  1.127    simonb 	strlcpy(hs->hash_desc, "vnode cache hash", sizeof(hs->hash_desc));
   1340  1.127    simonb 	if (!fill)
   1341  1.127    simonb 		return 0;
   1342  1.127    simonb 
   1343  1.127    simonb 	hs->hash_size = vcache_hashmask + 1;
   1344  1.127    simonb 
   1345  1.127    simonb 	for (size_t i = 0; i < hs->hash_size; i++) {
   1346  1.127    simonb 		chain = 0;
   1347  1.127    simonb 		mutex_enter(&vcache_lock);
   1348  1.127    simonb 		SLIST_FOREACH(vip, &vcache_hashtab[i], vi_hash) {
   1349  1.127    simonb 			chain++;
   1350  1.127    simonb 		}
   1351  1.127    simonb 		mutex_exit(&vcache_lock);
   1352  1.127    simonb 		if (chain > 0) {
   1353  1.127    simonb 			hs->hash_used++;
   1354  1.127    simonb 			hs->hash_items += chain;
   1355  1.127    simonb 			if (chain > hs->hash_maxchain)
   1356  1.127    simonb 				hs->hash_maxchain = chain;
   1357  1.127    simonb 		}
   1358  1.127    simonb 		preempt_point();
   1359  1.127    simonb 	}
   1360  1.127    simonb 
   1361  1.127    simonb 	return 0;
   1362  1.127    simonb }
   1363  1.127    simonb 
   1364   1.36   hannken static void
   1365   1.36   hannken vcache_init(void)
   1366   1.36   hannken {
   1367   1.36   hannken 
   1368  1.112        ad 	vcache_pool = pool_cache_init(sizeof(vnode_impl_t), coherency_unit,
   1369  1.112        ad 	    0, 0, "vcachepl", NULL, IPL_NONE, NULL, NULL, NULL);
   1370   1.69   hannken 	KASSERT(vcache_pool != NULL);
   1371   1.69   hannken 	mutex_init(&vcache_lock, MUTEX_DEFAULT, IPL_NONE);
   1372   1.69   hannken 	cv_init(&vcache_cv, "vcache");
   1373   1.69   hannken 	vcache_hashsize = desiredvnodes;
   1374   1.69   hannken 	vcache_hashtab = hashinit(desiredvnodes, HASH_SLIST, true,
   1375   1.69   hannken 	    &vcache_hashmask);
   1376  1.127    simonb 	hashstat_register("vcache", vcache_stats);
   1377   1.36   hannken }
   1378   1.36   hannken 
   1379   1.36   hannken static void
   1380   1.36   hannken vcache_reinit(void)
   1381   1.36   hannken {
   1382   1.36   hannken 	int i;
   1383   1.36   hannken 	uint32_t hash;
   1384   1.36   hannken 	u_long oldmask, newmask;
   1385   1.36   hannken 	struct hashhead *oldtab, *newtab;
   1386   1.70   hannken 	vnode_impl_t *vip;
   1387   1.36   hannken 
   1388   1.36   hannken 	newtab = hashinit(desiredvnodes, HASH_SLIST, true, &newmask);
   1389   1.69   hannken 	mutex_enter(&vcache_lock);
   1390   1.69   hannken 	oldtab = vcache_hashtab;
   1391   1.69   hannken 	oldmask = vcache_hashmask;
   1392   1.69   hannken 	vcache_hashsize = desiredvnodes;
   1393   1.69   hannken 	vcache_hashtab = newtab;
   1394   1.69   hannken 	vcache_hashmask = newmask;
   1395   1.36   hannken 	for (i = 0; i <= oldmask; i++) {
   1396   1.70   hannken 		while ((vip = SLIST_FIRST(&oldtab[i])) != NULL) {
   1397   1.70   hannken 			SLIST_REMOVE(&oldtab[i], vip, vnode_impl, vi_hash);
   1398   1.70   hannken 			hash = vcache_hash(&vip->vi_key);
   1399   1.69   hannken 			SLIST_INSERT_HEAD(&newtab[hash & vcache_hashmask],
   1400   1.70   hannken 			    vip, vi_hash);
   1401   1.36   hannken 		}
   1402   1.36   hannken 	}
   1403   1.69   hannken 	mutex_exit(&vcache_lock);
   1404   1.36   hannken 	hashdone(oldtab, HASH_SLIST, oldmask);
   1405   1.36   hannken }
   1406   1.36   hannken 
   1407   1.57   hannken static inline vnode_impl_t *
   1408   1.36   hannken vcache_hash_lookup(const struct vcache_key *key, uint32_t hash)
   1409   1.36   hannken {
   1410   1.36   hannken 	struct hashhead *hashp;
   1411   1.70   hannken 	vnode_impl_t *vip;
   1412   1.36   hannken 
   1413   1.69   hannken 	KASSERT(mutex_owned(&vcache_lock));
   1414   1.36   hannken 
   1415   1.69   hannken 	hashp = &vcache_hashtab[hash & vcache_hashmask];
   1416   1.70   hannken 	SLIST_FOREACH(vip, hashp, vi_hash) {
   1417   1.70   hannken 		if (key->vk_mount != vip->vi_key.vk_mount)
   1418   1.36   hannken 			continue;
   1419   1.70   hannken 		if (key->vk_key_len != vip->vi_key.vk_key_len)
   1420   1.36   hannken 			continue;
   1421   1.70   hannken 		if (memcmp(key->vk_key, vip->vi_key.vk_key, key->vk_key_len))
   1422   1.36   hannken 			continue;
   1423   1.70   hannken 		return vip;
   1424   1.36   hannken 	}
   1425   1.36   hannken 	return NULL;
   1426   1.36   hannken }
   1427   1.36   hannken 
   1428   1.36   hannken /*
   1429   1.50   hannken  * Allocate a new, uninitialized vcache node.
   1430   1.50   hannken  */
   1431   1.57   hannken static vnode_impl_t *
   1432   1.50   hannken vcache_alloc(void)
   1433   1.50   hannken {
   1434   1.70   hannken 	vnode_impl_t *vip;
   1435   1.50   hannken 	vnode_t *vp;
   1436   1.50   hannken 
   1437   1.70   hannken 	vip = pool_cache_get(vcache_pool, PR_WAITOK);
   1438  1.111        ad 	vp = VIMPL_TO_VNODE(vip);
   1439   1.70   hannken 	memset(vip, 0, sizeof(*vip));
   1440   1.50   hannken 
   1441  1.112        ad 	rw_init(&vip->vi_lock);
   1442  1.111        ad 	vp->v_interlock = mutex_obj_alloc(MUTEX_DEFAULT, IPL_NONE);
   1443  1.111        ad 
   1444  1.111        ad 	uvm_obj_init(&vp->v_uobj, &uvm_vnodeops, true, 1);
   1445  1.144   thorpej 	klist_init(&vip->vi_klist.vk_klist);
   1446  1.144   thorpej 	vp->v_klist = &vip->vi_klist;
   1447   1.50   hannken 	cv_init(&vp->v_cv, "vnode");
   1448  1.114        ad 	cache_vnode_init(vp);
   1449   1.50   hannken 
   1450   1.50   hannken 	vp->v_usecount = 1;
   1451   1.50   hannken 	vp->v_type = VNON;
   1452   1.50   hannken 	vp->v_size = vp->v_writesize = VSIZENOTSET;
   1453   1.50   hannken 
   1454   1.70   hannken 	vip->vi_state = VS_LOADING;
   1455   1.51   hannken 
   1456  1.104        ad 	lru_requeue(vp, &lru_list[LRU_FREE]);
   1457   1.63   hannken 
   1458   1.70   hannken 	return vip;
   1459   1.50   hannken }
   1460   1.50   hannken 
   1461   1.50   hannken /*
   1462   1.79   hannken  * Deallocate a vcache node in state VS_LOADING.
   1463   1.79   hannken  *
   1464   1.79   hannken  * vcache_lock held on entry and released on return.
   1465   1.79   hannken  */
   1466   1.79   hannken static void
   1467   1.79   hannken vcache_dealloc(vnode_impl_t *vip)
   1468   1.79   hannken {
   1469   1.79   hannken 	vnode_t *vp;
   1470   1.79   hannken 
   1471   1.79   hannken 	KASSERT(mutex_owned(&vcache_lock));
   1472   1.79   hannken 
   1473   1.79   hannken 	vp = VIMPL_TO_VNODE(vip);
   1474  1.102   hannken 	vfs_ref(dead_rootmount);
   1475  1.102   hannken 	vfs_insmntque(vp, dead_rootmount);
   1476   1.79   hannken 	mutex_enter(vp->v_interlock);
   1477   1.79   hannken 	vp->v_op = dead_vnodeop_p;
   1478   1.79   hannken 	VSTATE_CHANGE(vp, VS_LOADING, VS_RECLAIMED);
   1479   1.79   hannken 	mutex_exit(&vcache_lock);
   1480  1.107        ad 	vrelel(vp, 0, LK_NONE);
   1481   1.79   hannken }
   1482   1.79   hannken 
   1483   1.79   hannken /*
   1484   1.50   hannken  * Free an unused, unreferenced vcache node.
   1485   1.67   hannken  * v_interlock locked on entry.
   1486   1.50   hannken  */
   1487   1.50   hannken static void
   1488   1.70   hannken vcache_free(vnode_impl_t *vip)
   1489   1.50   hannken {
   1490   1.50   hannken 	vnode_t *vp;
   1491   1.50   hannken 
   1492   1.70   hannken 	vp = VIMPL_TO_VNODE(vip);
   1493   1.67   hannken 	KASSERT(mutex_owned(vp->v_interlock));
   1494   1.50   hannken 
   1495  1.120        ad 	KASSERT(vrefcnt(vp) == 0);
   1496   1.67   hannken 	KASSERT(vp->v_holdcnt == 0);
   1497   1.67   hannken 	KASSERT(vp->v_writecount == 0);
   1498   1.67   hannken 	lru_requeue(vp, NULL);
   1499   1.67   hannken 	mutex_exit(vp->v_interlock);
   1500   1.67   hannken 
   1501   1.67   hannken 	vfs_insmntque(vp, NULL);
   1502   1.67   hannken 	if (vp->v_type == VBLK || vp->v_type == VCHR)
   1503   1.67   hannken 		spec_node_destroy(vp);
   1504   1.50   hannken 
   1505  1.111        ad 	mutex_obj_free(vp->v_interlock);
   1506  1.112        ad 	rw_destroy(&vip->vi_lock);
   1507   1.50   hannken 	uvm_obj_destroy(&vp->v_uobj, true);
   1508  1.145   thorpej 	KASSERT(vp->v_klist == &vip->vi_klist);
   1509  1.144   thorpej 	klist_fini(&vip->vi_klist.vk_klist);
   1510   1.50   hannken 	cv_destroy(&vp->v_cv);
   1511  1.114        ad 	cache_vnode_fini(vp);
   1512   1.70   hannken 	pool_cache_put(vcache_pool, vip);
   1513   1.50   hannken }
   1514   1.50   hannken 
   1515   1.50   hannken /*
   1516   1.66   hannken  * Try to get an initial reference on this cached vnode.
   1517  1.123        ad  * Returns zero on success or EBUSY if the vnode state is not LOADED.
   1518   1.66   hannken  *
   1519  1.123        ad  * NB: lockless code sequences may rely on this not blocking.
   1520   1.66   hannken  */
   1521   1.66   hannken int
   1522   1.66   hannken vcache_tryvget(vnode_t *vp)
   1523   1.66   hannken {
   1524  1.123        ad 	u_int use, next;
   1525   1.66   hannken 
   1526  1.123        ad 	for (use = atomic_load_relaxed(&vp->v_usecount);; use = next) {
   1527  1.123        ad 		if (__predict_false((use & VUSECOUNT_GATE) == 0)) {
   1528  1.123        ad 			return EBUSY;
   1529  1.123        ad 		}
   1530  1.132   hannken 		next = atomic_cas_uint(&vp->v_usecount,
   1531  1.132   hannken 		    use, (use + 1) | VUSECOUNT_VGET);
   1532  1.123        ad 		if (__predict_true(next == use)) {
   1533  1.142  riastrad 			membar_acquire();
   1534  1.123        ad 			return 0;
   1535  1.123        ad 		}
   1536  1.123        ad 	}
   1537   1.66   hannken }
   1538   1.66   hannken 
   1539   1.66   hannken /*
   1540   1.66   hannken  * Try to get an initial reference on this cached vnode.
   1541   1.66   hannken  * Returns zero on success and  ENOENT if the vnode has been reclaimed.
   1542   1.66   hannken  * Will wait for the vnode state to be stable.
   1543   1.66   hannken  *
   1544   1.66   hannken  * v_interlock locked on entry and unlocked on exit.
   1545   1.66   hannken  */
   1546   1.66   hannken int
   1547   1.66   hannken vcache_vget(vnode_t *vp)
   1548   1.66   hannken {
   1549  1.132   hannken 	int error;
   1550   1.66   hannken 
   1551   1.66   hannken 	KASSERT(mutex_owned(vp->v_interlock));
   1552   1.66   hannken 
   1553   1.67   hannken 	/* Increment hold count to prevent vnode from disappearing. */
   1554   1.67   hannken 	vp->v_holdcnt++;
   1555   1.67   hannken 	VSTATE_WAIT_STABLE(vp);
   1556   1.67   hannken 	vp->v_holdcnt--;
   1557   1.66   hannken 
   1558   1.67   hannken 	/* If this was the last reference to a reclaimed vnode free it now. */
   1559   1.67   hannken 	if (__predict_false(VSTATE_GET(vp) == VS_RECLAIMED)) {
   1560  1.120        ad 		if (vp->v_holdcnt == 0 && vrefcnt(vp) == 0)
   1561   1.67   hannken 			vcache_free(VNODE_TO_VIMPL(vp));
   1562   1.67   hannken 		else
   1563   1.67   hannken 			mutex_exit(vp->v_interlock);
   1564   1.66   hannken 		return ENOENT;
   1565   1.66   hannken 	}
   1566   1.94   hannken 	VSTATE_ASSERT(vp, VS_LOADED);
   1567  1.132   hannken 	error = vcache_tryvget(vp);
   1568  1.132   hannken 	KASSERT(error == 0);
   1569   1.66   hannken 	mutex_exit(vp->v_interlock);
   1570   1.66   hannken 
   1571   1.66   hannken 	return 0;
   1572   1.66   hannken }
   1573   1.66   hannken 
   1574   1.66   hannken /*
   1575   1.36   hannken  * Get a vnode / fs node pair by key and return it referenced through vpp.
   1576   1.36   hannken  */
   1577   1.36   hannken int
   1578   1.36   hannken vcache_get(struct mount *mp, const void *key, size_t key_len,
   1579   1.36   hannken     struct vnode **vpp)
   1580   1.36   hannken {
   1581   1.36   hannken 	int error;
   1582   1.36   hannken 	uint32_t hash;
   1583   1.36   hannken 	const void *new_key;
   1584   1.36   hannken 	struct vnode *vp;
   1585   1.36   hannken 	struct vcache_key vcache_key;
   1586   1.70   hannken 	vnode_impl_t *vip, *new_vip;
   1587   1.36   hannken 
   1588   1.36   hannken 	new_key = NULL;
   1589   1.36   hannken 	*vpp = NULL;
   1590   1.36   hannken 
   1591   1.36   hannken 	vcache_key.vk_mount = mp;
   1592   1.36   hannken 	vcache_key.vk_key = key;
   1593   1.36   hannken 	vcache_key.vk_key_len = key_len;
   1594   1.36   hannken 	hash = vcache_hash(&vcache_key);
   1595   1.36   hannken 
   1596   1.36   hannken again:
   1597   1.69   hannken 	mutex_enter(&vcache_lock);
   1598   1.70   hannken 	vip = vcache_hash_lookup(&vcache_key, hash);
   1599   1.36   hannken 
   1600   1.36   hannken 	/* If found, take a reference or retry. */
   1601   1.70   hannken 	if (__predict_true(vip != NULL)) {
   1602   1.52   hannken 		/*
   1603   1.52   hannken 		 * If the vnode is loading we cannot take the v_interlock
   1604   1.52   hannken 		 * here as it might change during load (see uvm_obj_setlock()).
   1605   1.69   hannken 		 * As changing state from VS_LOADING requires both vcache_lock
   1606   1.69   hannken 		 * and v_interlock it is safe to test with vcache_lock held.
   1607   1.52   hannken 		 *
   1608   1.57   hannken 		 * Wait for vnodes changing state from VS_LOADING and retry.
   1609   1.52   hannken 		 */
   1610   1.70   hannken 		if (__predict_false(vip->vi_state == VS_LOADING)) {
   1611   1.69   hannken 			cv_wait(&vcache_cv, &vcache_lock);
   1612   1.69   hannken 			mutex_exit(&vcache_lock);
   1613   1.52   hannken 			goto again;
   1614   1.52   hannken 		}
   1615   1.70   hannken 		vp = VIMPL_TO_VNODE(vip);
   1616   1.36   hannken 		mutex_enter(vp->v_interlock);
   1617   1.69   hannken 		mutex_exit(&vcache_lock);
   1618   1.66   hannken 		error = vcache_vget(vp);
   1619   1.36   hannken 		if (error == ENOENT)
   1620   1.36   hannken 			goto again;
   1621   1.36   hannken 		if (error == 0)
   1622   1.36   hannken 			*vpp = vp;
   1623   1.36   hannken 		KASSERT((error != 0) == (*vpp == NULL));
   1624   1.36   hannken 		return error;
   1625   1.36   hannken 	}
   1626   1.69   hannken 	mutex_exit(&vcache_lock);
   1627   1.36   hannken 
   1628   1.36   hannken 	/* Allocate and initialize a new vcache / vnode pair. */
   1629   1.87   hannken 	error = vfs_busy(mp);
   1630   1.36   hannken 	if (error)
   1631   1.36   hannken 		return error;
   1632   1.70   hannken 	new_vip = vcache_alloc();
   1633   1.70   hannken 	new_vip->vi_key = vcache_key;
   1634   1.70   hannken 	vp = VIMPL_TO_VNODE(new_vip);
   1635   1.69   hannken 	mutex_enter(&vcache_lock);
   1636   1.70   hannken 	vip = vcache_hash_lookup(&vcache_key, hash);
   1637   1.70   hannken 	if (vip == NULL) {
   1638   1.69   hannken 		SLIST_INSERT_HEAD(&vcache_hashtab[hash & vcache_hashmask],
   1639   1.70   hannken 		    new_vip, vi_hash);
   1640   1.70   hannken 		vip = new_vip;
   1641   1.36   hannken 	}
   1642   1.36   hannken 
   1643   1.36   hannken 	/* If another thread beat us inserting this node, retry. */
   1644   1.70   hannken 	if (vip != new_vip) {
   1645   1.79   hannken 		vcache_dealloc(new_vip);
   1646   1.87   hannken 		vfs_unbusy(mp);
   1647   1.36   hannken 		goto again;
   1648   1.36   hannken 	}
   1649   1.69   hannken 	mutex_exit(&vcache_lock);
   1650   1.36   hannken 
   1651   1.57   hannken 	/* Load the fs node.  Exclusive as new_node is VS_LOADING. */
   1652   1.36   hannken 	error = VFS_LOADVNODE(mp, vp, key, key_len, &new_key);
   1653   1.36   hannken 	if (error) {
   1654   1.69   hannken 		mutex_enter(&vcache_lock);
   1655   1.69   hannken 		SLIST_REMOVE(&vcache_hashtab[hash & vcache_hashmask],
   1656   1.70   hannken 		    new_vip, vnode_impl, vi_hash);
   1657   1.79   hannken 		vcache_dealloc(new_vip);
   1658   1.87   hannken 		vfs_unbusy(mp);
   1659   1.36   hannken 		KASSERT(*vpp == NULL);
   1660   1.36   hannken 		return error;
   1661   1.36   hannken 	}
   1662   1.36   hannken 	KASSERT(new_key != NULL);
   1663   1.36   hannken 	KASSERT(memcmp(key, new_key, key_len) == 0);
   1664   1.36   hannken 	KASSERT(vp->v_op != NULL);
   1665   1.36   hannken 	vfs_insmntque(vp, mp);
   1666   1.36   hannken 	if ((mp->mnt_iflag & IMNT_MPSAFE) != 0)
   1667   1.36   hannken 		vp->v_vflag |= VV_MPSAFE;
   1668   1.87   hannken 	vfs_ref(mp);
   1669   1.87   hannken 	vfs_unbusy(mp);
   1670   1.36   hannken 
   1671   1.36   hannken 	/* Finished loading, finalize node. */
   1672   1.69   hannken 	mutex_enter(&vcache_lock);
   1673   1.70   hannken 	new_vip->vi_key.vk_key = new_key;
   1674   1.39   hannken 	mutex_enter(vp->v_interlock);
   1675   1.94   hannken 	VSTATE_CHANGE(vp, VS_LOADING, VS_LOADED);
   1676   1.39   hannken 	mutex_exit(vp->v_interlock);
   1677   1.69   hannken 	mutex_exit(&vcache_lock);
   1678   1.36   hannken 	*vpp = vp;
   1679   1.36   hannken 	return 0;
   1680   1.36   hannken }
   1681   1.36   hannken 
   1682   1.36   hannken /*
   1683   1.40   hannken  * Create a new vnode / fs node pair and return it referenced through vpp.
   1684   1.40   hannken  */
   1685   1.40   hannken int
   1686   1.40   hannken vcache_new(struct mount *mp, struct vnode *dvp, struct vattr *vap,
   1687  1.101   hannken     kauth_cred_t cred, void *extra, struct vnode **vpp)
   1688   1.40   hannken {
   1689   1.40   hannken 	int error;
   1690   1.40   hannken 	uint32_t hash;
   1691   1.70   hannken 	struct vnode *vp, *ovp;
   1692   1.70   hannken 	vnode_impl_t *vip, *ovip;
   1693   1.40   hannken 
   1694   1.40   hannken 	*vpp = NULL;
   1695   1.40   hannken 
   1696   1.40   hannken 	/* Allocate and initialize a new vcache / vnode pair. */
   1697   1.87   hannken 	error = vfs_busy(mp);
   1698   1.40   hannken 	if (error)
   1699   1.40   hannken 		return error;
   1700   1.70   hannken 	vip = vcache_alloc();
   1701   1.70   hannken 	vip->vi_key.vk_mount = mp;
   1702   1.70   hannken 	vp = VIMPL_TO_VNODE(vip);
   1703   1.40   hannken 
   1704   1.40   hannken 	/* Create and load the fs node. */
   1705  1.101   hannken 	error = VFS_NEWVNODE(mp, dvp, vp, vap, cred, extra,
   1706   1.70   hannken 	    &vip->vi_key.vk_key_len, &vip->vi_key.vk_key);
   1707   1.40   hannken 	if (error) {
   1708   1.69   hannken 		mutex_enter(&vcache_lock);
   1709   1.79   hannken 		vcache_dealloc(vip);
   1710   1.87   hannken 		vfs_unbusy(mp);
   1711   1.40   hannken 		KASSERT(*vpp == NULL);
   1712   1.40   hannken 		return error;
   1713   1.40   hannken 	}
   1714   1.40   hannken 	KASSERT(vp->v_op != NULL);
   1715   1.97   hannken 	KASSERT((vip->vi_key.vk_key_len == 0) == (mp == dead_rootmount));
   1716   1.97   hannken 	if (vip->vi_key.vk_key_len > 0) {
   1717   1.97   hannken 		KASSERT(vip->vi_key.vk_key != NULL);
   1718   1.97   hannken 		hash = vcache_hash(&vip->vi_key);
   1719   1.40   hannken 
   1720   1.97   hannken 		/*
   1721   1.97   hannken 		 * Wait for previous instance to be reclaimed,
   1722   1.97   hannken 		 * then insert new node.
   1723   1.97   hannken 		 */
   1724   1.97   hannken 		mutex_enter(&vcache_lock);
   1725   1.97   hannken 		while ((ovip = vcache_hash_lookup(&vip->vi_key, hash))) {
   1726   1.97   hannken 			ovp = VIMPL_TO_VNODE(ovip);
   1727   1.97   hannken 			mutex_enter(ovp->v_interlock);
   1728   1.97   hannken 			mutex_exit(&vcache_lock);
   1729   1.97   hannken 			error = vcache_vget(ovp);
   1730   1.97   hannken 			KASSERT(error == ENOENT);
   1731   1.97   hannken 			mutex_enter(&vcache_lock);
   1732   1.97   hannken 		}
   1733   1.97   hannken 		SLIST_INSERT_HEAD(&vcache_hashtab[hash & vcache_hashmask],
   1734   1.97   hannken 		    vip, vi_hash);
   1735   1.69   hannken 		mutex_exit(&vcache_lock);
   1736   1.40   hannken 	}
   1737   1.40   hannken 	vfs_insmntque(vp, mp);
   1738   1.40   hannken 	if ((mp->mnt_iflag & IMNT_MPSAFE) != 0)
   1739   1.40   hannken 		vp->v_vflag |= VV_MPSAFE;
   1740   1.87   hannken 	vfs_ref(mp);
   1741   1.87   hannken 	vfs_unbusy(mp);
   1742   1.40   hannken 
   1743   1.40   hannken 	/* Finished loading, finalize node. */
   1744   1.69   hannken 	mutex_enter(&vcache_lock);
   1745   1.52   hannken 	mutex_enter(vp->v_interlock);
   1746   1.94   hannken 	VSTATE_CHANGE(vp, VS_LOADING, VS_LOADED);
   1747   1.69   hannken 	mutex_exit(&vcache_lock);
   1748   1.40   hannken 	mutex_exit(vp->v_interlock);
   1749   1.40   hannken 	*vpp = vp;
   1750   1.40   hannken 	return 0;
   1751   1.40   hannken }
   1752   1.40   hannken 
   1753   1.40   hannken /*
   1754   1.65   hannken  * Prepare key change: update old cache nodes key and lock new cache node.
   1755   1.37   hannken  * Return an error if the new node already exists.
   1756   1.37   hannken  */
   1757   1.37   hannken int
   1758   1.37   hannken vcache_rekey_enter(struct mount *mp, struct vnode *vp,
   1759   1.37   hannken     const void *old_key, size_t old_key_len,
   1760   1.37   hannken     const void *new_key, size_t new_key_len)
   1761   1.37   hannken {
   1762   1.37   hannken 	uint32_t old_hash, new_hash;
   1763   1.37   hannken 	struct vcache_key old_vcache_key, new_vcache_key;
   1764   1.70   hannken 	vnode_impl_t *vip, *new_vip;
   1765   1.37   hannken 
   1766   1.37   hannken 	old_vcache_key.vk_mount = mp;
   1767   1.37   hannken 	old_vcache_key.vk_key = old_key;
   1768   1.37   hannken 	old_vcache_key.vk_key_len = old_key_len;
   1769   1.37   hannken 	old_hash = vcache_hash(&old_vcache_key);
   1770   1.37   hannken 
   1771   1.37   hannken 	new_vcache_key.vk_mount = mp;
   1772   1.37   hannken 	new_vcache_key.vk_key = new_key;
   1773   1.37   hannken 	new_vcache_key.vk_key_len = new_key_len;
   1774   1.37   hannken 	new_hash = vcache_hash(&new_vcache_key);
   1775   1.37   hannken 
   1776   1.70   hannken 	new_vip = vcache_alloc();
   1777   1.70   hannken 	new_vip->vi_key = new_vcache_key;
   1778   1.37   hannken 
   1779   1.52   hannken 	/* Insert locked new node used as placeholder. */
   1780   1.69   hannken 	mutex_enter(&vcache_lock);
   1781   1.70   hannken 	vip = vcache_hash_lookup(&new_vcache_key, new_hash);
   1782   1.70   hannken 	if (vip != NULL) {
   1783   1.79   hannken 		vcache_dealloc(new_vip);
   1784   1.37   hannken 		return EEXIST;
   1785   1.37   hannken 	}
   1786   1.69   hannken 	SLIST_INSERT_HEAD(&vcache_hashtab[new_hash & vcache_hashmask],
   1787   1.70   hannken 	    new_vip, vi_hash);
   1788   1.49   hannken 
   1789   1.65   hannken 	/* Replace old nodes key with the temporary copy. */
   1790   1.70   hannken 	vip = vcache_hash_lookup(&old_vcache_key, old_hash);
   1791   1.70   hannken 	KASSERT(vip != NULL);
   1792   1.70   hannken 	KASSERT(VIMPL_TO_VNODE(vip) == vp);
   1793   1.70   hannken 	KASSERT(vip->vi_key.vk_key != old_vcache_key.vk_key);
   1794   1.70   hannken 	vip->vi_key = old_vcache_key;
   1795   1.69   hannken 	mutex_exit(&vcache_lock);
   1796   1.37   hannken 	return 0;
   1797   1.37   hannken }
   1798   1.37   hannken 
   1799   1.37   hannken /*
   1800   1.65   hannken  * Key change complete: update old node and remove placeholder.
   1801   1.37   hannken  */
   1802   1.37   hannken void
   1803   1.37   hannken vcache_rekey_exit(struct mount *mp, struct vnode *vp,
   1804   1.37   hannken     const void *old_key, size_t old_key_len,
   1805   1.37   hannken     const void *new_key, size_t new_key_len)
   1806   1.37   hannken {
   1807   1.37   hannken 	uint32_t old_hash, new_hash;
   1808   1.37   hannken 	struct vcache_key old_vcache_key, new_vcache_key;
   1809   1.70   hannken 	vnode_impl_t *vip, *new_vip;
   1810   1.70   hannken 	struct vnode *new_vp;
   1811   1.37   hannken 
   1812   1.37   hannken 	old_vcache_key.vk_mount = mp;
   1813   1.37   hannken 	old_vcache_key.vk_key = old_key;
   1814   1.37   hannken 	old_vcache_key.vk_key_len = old_key_len;
   1815   1.37   hannken 	old_hash = vcache_hash(&old_vcache_key);
   1816   1.37   hannken 
   1817   1.37   hannken 	new_vcache_key.vk_mount = mp;
   1818   1.37   hannken 	new_vcache_key.vk_key = new_key;
   1819   1.37   hannken 	new_vcache_key.vk_key_len = new_key_len;
   1820   1.37   hannken 	new_hash = vcache_hash(&new_vcache_key);
   1821   1.37   hannken 
   1822   1.69   hannken 	mutex_enter(&vcache_lock);
   1823   1.49   hannken 
   1824   1.49   hannken 	/* Lookup old and new node. */
   1825   1.70   hannken 	vip = vcache_hash_lookup(&old_vcache_key, old_hash);
   1826   1.70   hannken 	KASSERT(vip != NULL);
   1827   1.70   hannken 	KASSERT(VIMPL_TO_VNODE(vip) == vp);
   1828   1.70   hannken 
   1829   1.70   hannken 	new_vip = vcache_hash_lookup(&new_vcache_key, new_hash);
   1830   1.70   hannken 	KASSERT(new_vip != NULL);
   1831   1.70   hannken 	KASSERT(new_vip->vi_key.vk_key_len == new_key_len);
   1832   1.70   hannken 	new_vp = VIMPL_TO_VNODE(new_vip);
   1833   1.70   hannken 	mutex_enter(new_vp->v_interlock);
   1834   1.70   hannken 	VSTATE_ASSERT(VIMPL_TO_VNODE(new_vip), VS_LOADING);
   1835   1.79   hannken 	mutex_exit(new_vp->v_interlock);
   1836   1.49   hannken 
   1837   1.49   hannken 	/* Rekey old node and put it onto its new hashlist. */
   1838   1.70   hannken 	vip->vi_key = new_vcache_key;
   1839   1.49   hannken 	if (old_hash != new_hash) {
   1840   1.69   hannken 		SLIST_REMOVE(&vcache_hashtab[old_hash & vcache_hashmask],
   1841   1.70   hannken 		    vip, vnode_impl, vi_hash);
   1842   1.69   hannken 		SLIST_INSERT_HEAD(&vcache_hashtab[new_hash & vcache_hashmask],
   1843   1.70   hannken 		    vip, vi_hash);
   1844   1.49   hannken 	}
   1845   1.49   hannken 
   1846   1.49   hannken 	/* Remove new node used as placeholder. */
   1847   1.69   hannken 	SLIST_REMOVE(&vcache_hashtab[new_hash & vcache_hashmask],
   1848   1.70   hannken 	    new_vip, vnode_impl, vi_hash);
   1849   1.79   hannken 	vcache_dealloc(new_vip);
   1850   1.37   hannken }
   1851   1.37   hannken 
   1852   1.37   hannken /*
   1853   1.54   hannken  * Disassociate the underlying file system from a vnode.
   1854   1.54   hannken  *
   1855   1.54   hannken  * Must be called with vnode locked and will return unlocked.
   1856   1.54   hannken  * Must be called with the interlock held, and will return with it held.
   1857   1.54   hannken  */
   1858   1.54   hannken static void
   1859   1.54   hannken vcache_reclaim(vnode_t *vp)
   1860   1.54   hannken {
   1861   1.54   hannken 	lwp_t *l = curlwp;
   1862   1.70   hannken 	vnode_impl_t *vip = VNODE_TO_VIMPL(vp);
   1863   1.74   hannken 	struct mount *mp = vp->v_mount;
   1864   1.55   hannken 	uint32_t hash;
   1865   1.55   hannken 	uint8_t temp_buf[64], *temp_key;
   1866   1.55   hannken 	size_t temp_key_len;
   1867  1.141  riastrad 	bool recycle;
   1868   1.54   hannken 	int error;
   1869   1.54   hannken 
   1870  1.139   hannken 	KASSERT(VOP_ISLOCKED(vp) == LK_EXCLUSIVE);
   1871   1.54   hannken 	KASSERT(mutex_owned(vp->v_interlock));
   1872  1.120        ad 	KASSERT(vrefcnt(vp) != 0);
   1873   1.54   hannken 
   1874   1.70   hannken 	temp_key_len = vip->vi_key.vk_key_len;
   1875   1.54   hannken 	/*
   1876   1.54   hannken 	 * Prevent the vnode from being recycled or brought into use
   1877   1.54   hannken 	 * while we clean it out.
   1878   1.54   hannken 	 */
   1879  1.123        ad 	VSTATE_CHANGE(vp, VS_BLOCKED, VS_RECLAIMING);
   1880  1.145   thorpej 
   1881  1.145   thorpej 	/*
   1882  1.145   thorpej 	 * Send NOTE_REVOKE now, before we call VOP_RECLAIM(),
   1883  1.145   thorpej 	 * because VOP_RECLAIM() could cause vp->v_klist to
   1884  1.145   thorpej 	 * become invalid.  Don't check for interest in NOTE_REVOKE
   1885  1.145   thorpej 	 * here; it's always posted because it sets EV_EOF.
   1886  1.145   thorpej 	 *
   1887  1.145   thorpej 	 * Once it's been posted, reset vp->v_klist to point to
   1888  1.145   thorpej 	 * our own local storage, in case we were sharing with
   1889  1.145   thorpej 	 * someone else.
   1890  1.145   thorpej 	 */
   1891  1.145   thorpej 	KNOTE(&vp->v_klist->vk_klist, NOTE_REVOKE);
   1892  1.145   thorpej 	vp->v_klist = &vip->vi_klist;
   1893  1.111        ad 	mutex_exit(vp->v_interlock);
   1894  1.111        ad 
   1895  1.111        ad 	rw_enter(vp->v_uobj.vmobjlock, RW_WRITER);
   1896  1.111        ad 	mutex_enter(vp->v_interlock);
   1897  1.125        ad 	if ((vp->v_iflag & VI_EXECMAP) != 0) {
   1898  1.105        ad 		cpu_count(CPU_COUNT_EXECPAGES, -vp->v_uobj.uo_npages);
   1899   1.54   hannken 	}
   1900   1.54   hannken 	vp->v_iflag &= ~(VI_TEXT|VI_EXECMAP);
   1901  1.116        ad 	vp->v_iflag |= VI_DEADCHECK; /* for genfs_getpages() */
   1902   1.54   hannken 	mutex_exit(vp->v_interlock);
   1903  1.111        ad 	rw_exit(vp->v_uobj.vmobjlock);
   1904   1.54   hannken 
   1905  1.114        ad 	/*
   1906  1.114        ad 	 * With vnode state set to reclaiming, purge name cache immediately
   1907  1.114        ad 	 * to prevent new handles on vnode, and wait for existing threads
   1908  1.114        ad 	 * trying to get a handle to notice VS_RECLAIMED status and abort.
   1909  1.114        ad 	 */
   1910  1.114        ad 	cache_purge(vp);
   1911  1.114        ad 
   1912   1.55   hannken 	/* Replace the vnode key with a temporary copy. */
   1913   1.70   hannken 	if (vip->vi_key.vk_key_len > sizeof(temp_buf)) {
   1914   1.55   hannken 		temp_key = kmem_alloc(temp_key_len, KM_SLEEP);
   1915   1.55   hannken 	} else {
   1916   1.55   hannken 		temp_key = temp_buf;
   1917   1.55   hannken 	}
   1918   1.97   hannken 	if (vip->vi_key.vk_key_len > 0) {
   1919   1.97   hannken 		mutex_enter(&vcache_lock);
   1920   1.97   hannken 		memcpy(temp_key, vip->vi_key.vk_key, temp_key_len);
   1921   1.97   hannken 		vip->vi_key.vk_key = temp_key;
   1922   1.97   hannken 		mutex_exit(&vcache_lock);
   1923   1.97   hannken 	}
   1924   1.55   hannken 
   1925   1.96   hannken 	fstrans_start(mp);
   1926   1.74   hannken 
   1927   1.54   hannken 	/*
   1928   1.54   hannken 	 * Clean out any cached data associated with the vnode.
   1929   1.54   hannken 	 */
   1930   1.54   hannken 	error = vinvalbuf(vp, V_SAVE, NOCRED, l, 0, 0);
   1931   1.54   hannken 	if (error != 0) {
   1932   1.54   hannken 		if (wapbl_vphaswapbl(vp))
   1933   1.54   hannken 			WAPBL_DISCARD(wapbl_vptomp(vp));
   1934   1.54   hannken 		error = vinvalbuf(vp, 0, NOCRED, l, 0, 0);
   1935   1.54   hannken 	}
   1936   1.54   hannken 	KASSERTMSG((error == 0), "vinvalbuf failed: %d", error);
   1937   1.54   hannken 	KASSERT((vp->v_iflag & VI_ONWORKLST) == 0);
   1938  1.141  riastrad 	if (vp->v_type == VBLK || vp->v_type == VCHR) {
   1939   1.54   hannken 		 spec_node_revoke(vp);
   1940   1.54   hannken 	}
   1941   1.54   hannken 
   1942   1.60   hannken 	/*
   1943   1.60   hannken 	 * Disassociate the underlying file system from the vnode.
   1944   1.90  riastrad 	 * VOP_INACTIVE leaves the vnode locked; VOP_RECLAIM unlocks
   1945   1.90  riastrad 	 * the vnode, and may destroy the vnode so that VOP_UNLOCK
   1946   1.90  riastrad 	 * would no longer function.
   1947   1.60   hannken 	 */
   1948   1.60   hannken 	VOP_INACTIVE(vp, &recycle);
   1949  1.139   hannken 	KASSERT(VOP_ISLOCKED(vp) == LK_EXCLUSIVE);
   1950   1.54   hannken 	if (VOP_RECLAIM(vp)) {
   1951   1.54   hannken 		vnpanic(vp, "%s: cannot reclaim", __func__);
   1952   1.54   hannken 	}
   1953   1.54   hannken 
   1954   1.54   hannken 	KASSERT(vp->v_data == NULL);
   1955  1.113        ad 	KASSERT((vp->v_iflag & VI_PAGES) == 0);
   1956   1.54   hannken 
   1957   1.54   hannken 	if (vp->v_type == VREG && vp->v_ractx != NULL) {
   1958   1.54   hannken 		uvm_ra_freectx(vp->v_ractx);
   1959   1.54   hannken 		vp->v_ractx = NULL;
   1960   1.54   hannken 	}
   1961   1.54   hannken 
   1962   1.97   hannken 	if (vip->vi_key.vk_key_len > 0) {
   1963   1.55   hannken 	/* Remove from vnode cache. */
   1964   1.97   hannken 		hash = vcache_hash(&vip->vi_key);
   1965   1.97   hannken 		mutex_enter(&vcache_lock);
   1966   1.97   hannken 		KASSERT(vip == vcache_hash_lookup(&vip->vi_key, hash));
   1967   1.97   hannken 		SLIST_REMOVE(&vcache_hashtab[hash & vcache_hashmask],
   1968   1.97   hannken 		    vip, vnode_impl, vi_hash);
   1969   1.97   hannken 		mutex_exit(&vcache_lock);
   1970   1.97   hannken 	}
   1971   1.55   hannken 	if (temp_key != temp_buf)
   1972   1.55   hannken 		kmem_free(temp_key, temp_key_len);
   1973   1.55   hannken 
   1974   1.54   hannken 	/* Done with purge, notify sleepers of the grim news. */
   1975   1.54   hannken 	mutex_enter(vp->v_interlock);
   1976   1.54   hannken 	vp->v_op = dead_vnodeop_p;
   1977   1.57   hannken 	VSTATE_CHANGE(vp, VS_RECLAIMING, VS_RECLAIMED);
   1978   1.54   hannken 	vp->v_tag = VT_NON;
   1979   1.80   hannken 	mutex_exit(vp->v_interlock);
   1980   1.54   hannken 
   1981   1.80   hannken 	/*
   1982   1.80   hannken 	 * Move to dead mount.  Must be after changing the operations
   1983   1.80   hannken 	 * vector as vnode operations enter the mount before using the
   1984   1.80   hannken 	 * operations vector.  See sys/kern/vnode_if.c.
   1985   1.80   hannken 	 */
   1986   1.80   hannken 	vp->v_vflag &= ~VV_ROOT;
   1987   1.86   hannken 	vfs_ref(dead_rootmount);
   1988   1.80   hannken 	vfs_insmntque(vp, dead_rootmount);
   1989   1.80   hannken 
   1990  1.110        ad #ifdef PAX_SEGVGUARD
   1991  1.110        ad 	pax_segvguard_cleanup(vp);
   1992  1.110        ad #endif /* PAX_SEGVGUARD */
   1993  1.110        ad 
   1994   1.80   hannken 	mutex_enter(vp->v_interlock);
   1995   1.74   hannken 	fstrans_done(mp);
   1996   1.54   hannken 	KASSERT((vp->v_iflag & VI_ONWORKLST) == 0);
   1997   1.54   hannken }
   1998   1.54   hannken 
   1999   1.54   hannken /*
   2000   1.98   hannken  * Disassociate the underlying file system from an open device vnode
   2001   1.98   hannken  * and make it anonymous.
   2002   1.98   hannken  *
   2003   1.98   hannken  * Vnode unlocked on entry, drops a reference to the vnode.
   2004   1.98   hannken  */
   2005   1.98   hannken void
   2006   1.98   hannken vcache_make_anon(vnode_t *vp)
   2007   1.98   hannken {
   2008   1.98   hannken 	vnode_impl_t *vip = VNODE_TO_VIMPL(vp);
   2009   1.98   hannken 	uint32_t hash;
   2010   1.98   hannken 	bool recycle;
   2011   1.98   hannken 
   2012   1.98   hannken 	KASSERT(vp->v_type == VBLK || vp->v_type == VCHR);
   2013  1.154  riastrad 	KASSERT(vp->v_mount == dead_rootmount ||
   2014  1.154  riastrad 	    fstrans_is_owner(vp->v_mount));
   2015   1.98   hannken 	VSTATE_ASSERT_UNLOCKED(vp, VS_ACTIVE);
   2016   1.98   hannken 
   2017   1.98   hannken 	/* Remove from vnode cache. */
   2018   1.98   hannken 	hash = vcache_hash(&vip->vi_key);
   2019   1.98   hannken 	mutex_enter(&vcache_lock);
   2020   1.98   hannken 	KASSERT(vip == vcache_hash_lookup(&vip->vi_key, hash));
   2021   1.98   hannken 	SLIST_REMOVE(&vcache_hashtab[hash & vcache_hashmask],
   2022   1.98   hannken 	    vip, vnode_impl, vi_hash);
   2023   1.98   hannken 	vip->vi_key.vk_mount = dead_rootmount;
   2024   1.98   hannken 	vip->vi_key.vk_key_len = 0;
   2025   1.98   hannken 	vip->vi_key.vk_key = NULL;
   2026   1.98   hannken 	mutex_exit(&vcache_lock);
   2027   1.98   hannken 
   2028   1.98   hannken 	/*
   2029   1.98   hannken 	 * Disassociate the underlying file system from the vnode.
   2030   1.98   hannken 	 * VOP_INACTIVE leaves the vnode locked; VOP_RECLAIM unlocks
   2031   1.98   hannken 	 * the vnode, and may destroy the vnode so that VOP_UNLOCK
   2032   1.98   hannken 	 * would no longer function.
   2033   1.98   hannken 	 */
   2034   1.98   hannken 	if (vn_lock(vp, LK_EXCLUSIVE)) {
   2035   1.98   hannken 		vnpanic(vp, "%s: cannot lock", __func__);
   2036   1.98   hannken 	}
   2037   1.98   hannken 	VOP_INACTIVE(vp, &recycle);
   2038  1.139   hannken 	KASSERT(VOP_ISLOCKED(vp) == LK_EXCLUSIVE);
   2039   1.98   hannken 	if (VOP_RECLAIM(vp)) {
   2040   1.98   hannken 		vnpanic(vp, "%s: cannot reclaim", __func__);
   2041   1.98   hannken 	}
   2042   1.98   hannken 
   2043   1.98   hannken 	/* Purge name cache. */
   2044   1.98   hannken 	cache_purge(vp);
   2045   1.98   hannken 
   2046   1.98   hannken 	/* Done with purge, change operations vector. */
   2047   1.98   hannken 	mutex_enter(vp->v_interlock);
   2048   1.98   hannken 	vp->v_op = spec_vnodeop_p;
   2049  1.139   hannken 	vp->v_vflag |= VV_MPSAFE;
   2050   1.98   hannken 	mutex_exit(vp->v_interlock);
   2051   1.98   hannken 
   2052   1.98   hannken 	/*
   2053   1.98   hannken 	 * Move to dead mount.  Must be after changing the operations
   2054   1.98   hannken 	 * vector as vnode operations enter the mount before using the
   2055   1.98   hannken 	 * operations vector.  See sys/kern/vnode_if.c.
   2056   1.98   hannken 	 */
   2057   1.98   hannken 	vfs_ref(dead_rootmount);
   2058   1.98   hannken 	vfs_insmntque(vp, dead_rootmount);
   2059   1.98   hannken 
   2060   1.98   hannken 	vrele(vp);
   2061   1.98   hannken }
   2062   1.98   hannken 
   2063   1.98   hannken /*
   2064    1.1     rmind  * Update outstanding I/O count and do wakeup if requested.
   2065    1.1     rmind  */
   2066    1.1     rmind void
   2067    1.1     rmind vwakeup(struct buf *bp)
   2068    1.1     rmind {
   2069    1.1     rmind 	vnode_t *vp;
   2070    1.1     rmind 
   2071    1.1     rmind 	if ((vp = bp->b_vp) == NULL)
   2072    1.1     rmind 		return;
   2073    1.1     rmind 
   2074    1.9     rmind 	KASSERT(bp->b_objlock == vp->v_interlock);
   2075    1.1     rmind 	KASSERT(mutex_owned(bp->b_objlock));
   2076    1.1     rmind 
   2077    1.1     rmind 	if (--vp->v_numoutput < 0)
   2078   1.11  christos 		vnpanic(vp, "%s: neg numoutput, vp %p", __func__, vp);
   2079    1.1     rmind 	if (vp->v_numoutput == 0)
   2080    1.1     rmind 		cv_broadcast(&vp->v_cv);
   2081    1.1     rmind }
   2082    1.1     rmind 
   2083    1.1     rmind /*
   2084   1.35   hannken  * Test a vnode for being or becoming dead.  Returns one of:
   2085   1.35   hannken  * EBUSY:  vnode is becoming dead, with "flags == VDEAD_NOWAIT" only.
   2086   1.35   hannken  * ENOENT: vnode is dead.
   2087   1.35   hannken  * 0:      otherwise.
   2088   1.35   hannken  *
   2089   1.35   hannken  * Whenever this function returns a non-zero value all future
   2090   1.35   hannken  * calls will also return a non-zero value.
   2091   1.35   hannken  */
   2092   1.35   hannken int
   2093   1.35   hannken vdead_check(struct vnode *vp, int flags)
   2094   1.35   hannken {
   2095   1.35   hannken 
   2096   1.35   hannken 	KASSERT(mutex_owned(vp->v_interlock));
   2097   1.35   hannken 
   2098   1.52   hannken 	if (! ISSET(flags, VDEAD_NOWAIT))
   2099   1.52   hannken 		VSTATE_WAIT_STABLE(vp);
   2100    1.1     rmind 
   2101   1.57   hannken 	if (VSTATE_GET(vp) == VS_RECLAIMING) {
   2102   1.52   hannken 		KASSERT(ISSET(flags, VDEAD_NOWAIT));
   2103   1.52   hannken 		return EBUSY;
   2104   1.57   hannken 	} else if (VSTATE_GET(vp) == VS_RECLAIMED) {
   2105   1.52   hannken 		return ENOENT;
   2106   1.52   hannken 	}
   2107    1.1     rmind 
   2108   1.52   hannken 	return 0;
   2109    1.1     rmind }
   2110    1.1     rmind 
   2111    1.1     rmind int
   2112   1.61   hannken vfs_drainvnodes(void)
   2113    1.1     rmind {
   2114   1.61   hannken 
   2115   1.63   hannken 	mutex_enter(&vdrain_lock);
   2116  1.152   hannken 
   2117  1.152   hannken 	if (!vdrain_one(desiredvnodes)) {
   2118  1.152   hannken 		mutex_exit(&vdrain_lock);
   2119  1.152   hannken 		return EBUSY;
   2120   1.61   hannken 	}
   2121  1.152   hannken 
   2122   1.63   hannken 	mutex_exit(&vdrain_lock);
   2123   1.12   hannken 
   2124   1.69   hannken 	if (vcache_hashsize != desiredvnodes)
   2125   1.61   hannken 		vcache_reinit();
   2126   1.36   hannken 
   2127    1.1     rmind 	return 0;
   2128    1.1     rmind }
   2129    1.1     rmind 
   2130    1.1     rmind void
   2131   1.11  christos vnpanic(vnode_t *vp, const char *fmt, ...)
   2132    1.1     rmind {
   2133   1.11  christos 	va_list ap;
   2134   1.11  christos 
   2135    1.1     rmind #ifdef DIAGNOSTIC
   2136    1.1     rmind 	vprint(NULL, vp);
   2137    1.1     rmind #endif
   2138   1.11  christos 	va_start(ap, fmt);
   2139   1.11  christos 	vpanic(fmt, ap);
   2140   1.11  christos 	va_end(ap);
   2141    1.1     rmind }
   2142  1.111        ad 
   2143  1.111        ad void
   2144  1.111        ad vshareilock(vnode_t *tvp, vnode_t *fvp)
   2145  1.111        ad {
   2146  1.111        ad 	kmutex_t *oldlock;
   2147  1.111        ad 
   2148  1.111        ad 	oldlock = tvp->v_interlock;
   2149  1.111        ad 	mutex_obj_hold(fvp->v_interlock);
   2150  1.111        ad 	tvp->v_interlock = fvp->v_interlock;
   2151  1.111        ad 	mutex_obj_free(oldlock);
   2152  1.111        ad }
   2153  1.144   thorpej 
   2154  1.144   thorpej void
   2155  1.144   thorpej vshareklist(vnode_t *tvp, vnode_t *fvp)
   2156  1.144   thorpej {
   2157  1.144   thorpej 	/*
   2158  1.144   thorpej 	 * If two vnodes share klist state, they must also share
   2159  1.144   thorpej 	 * an interlock.
   2160  1.144   thorpej 	 */
   2161  1.144   thorpej 	KASSERT(tvp->v_interlock == fvp->v_interlock);
   2162  1.144   thorpej 
   2163  1.144   thorpej 	/*
   2164  1.144   thorpej 	 * We make the following assumptions:
   2165  1.144   thorpej 	 *
   2166  1.144   thorpej 	 * ==> Some other synchronization is happening outside of
   2167  1.144   thorpej 	 *     our view to make this safe.
   2168  1.144   thorpej 	 *
   2169  1.144   thorpej 	 * ==> That the "to" vnode will have the necessary references
   2170  1.144   thorpej 	 *     on the "from" vnode so that the storage for the klist
   2171  1.144   thorpej 	 *     won't be yanked out from beneath us (the vnode_impl).
   2172  1.144   thorpej 	 *
   2173  1.144   thorpej 	 * ==> If "from" is also sharing, we then assume that "from"
   2174  1.144   thorpej 	 *     has the necessary references, and so on.
   2175  1.144   thorpej 	 */
   2176  1.144   thorpej 	tvp->v_klist = fvp->v_klist;
   2177  1.144   thorpej }
   2178