Home | History | Annotate | Line # | Download | only in kern
vfs_cache.c revision 1.76
      1  1.76        ad /*	$NetBSD: vfs_cache.c,v 1.76 2008/05/05 17:11:17 ad Exp $	*/
      2  1.73        ad 
      3  1.73        ad /*-
      4  1.73        ad  * Copyright (c) 2008 The NetBSD Foundation, Inc.
      5  1.73        ad  * All rights reserved.
      6  1.73        ad  *
      7  1.73        ad  * Redistribution and use in source and binary forms, with or without
      8  1.73        ad  * modification, are permitted provided that the following conditions
      9  1.73        ad  * are met:
     10  1.73        ad  * 1. Redistributions of source code must retain the above copyright
     11  1.73        ad  *    notice, this list of conditions and the following disclaimer.
     12  1.73        ad  * 2. Redistributions in binary form must reproduce the above copyright
     13  1.73        ad  *    notice, this list of conditions and the following disclaimer in the
     14  1.73        ad  *    documentation and/or other materials provided with the distribution.
     15  1.73        ad  *
     16  1.73        ad  * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
     17  1.73        ad  * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
     18  1.73        ad  * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
     19  1.73        ad  * PURPOSE ARE DISCLAIMED.  IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
     20  1.73        ad  * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
     21  1.73        ad  * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
     22  1.73        ad  * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
     23  1.73        ad  * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
     24  1.73        ad  * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
     25  1.73        ad  * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
     26  1.73        ad  * POSSIBILITY OF SUCH DAMAGE.
     27  1.73        ad  */
     28   1.6       cgd 
     29   1.1       cgd /*
     30   1.5   mycroft  * Copyright (c) 1989, 1993
     31   1.5   mycroft  *	The Regents of the University of California.  All rights reserved.
     32   1.1       cgd  *
     33   1.1       cgd  * Redistribution and use in source and binary forms, with or without
     34   1.1       cgd  * modification, are permitted provided that the following conditions
     35   1.1       cgd  * are met:
     36   1.1       cgd  * 1. Redistributions of source code must retain the above copyright
     37   1.1       cgd  *    notice, this list of conditions and the following disclaimer.
     38   1.1       cgd  * 2. Redistributions in binary form must reproduce the above copyright
     39   1.1       cgd  *    notice, this list of conditions and the following disclaimer in the
     40   1.1       cgd  *    documentation and/or other materials provided with the distribution.
     41  1.51       agc  * 3. Neither the name of the University nor the names of its contributors
     42   1.1       cgd  *    may be used to endorse or promote products derived from this software
     43   1.1       cgd  *    without specific prior written permission.
     44   1.1       cgd  *
     45   1.1       cgd  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
     46   1.1       cgd  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
     47   1.1       cgd  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
     48   1.1       cgd  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
     49   1.1       cgd  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
     50   1.1       cgd  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
     51   1.1       cgd  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
     52   1.1       cgd  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
     53   1.1       cgd  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
     54   1.1       cgd  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
     55   1.1       cgd  * SUCH DAMAGE.
     56   1.1       cgd  *
     57  1.10   mycroft  *	@(#)vfs_cache.c	8.3 (Berkeley) 8/22/94
     58   1.1       cgd  */
     59  1.32     lukem 
     60  1.32     lukem #include <sys/cdefs.h>
     61  1.76        ad __KERNEL_RCSID(0, "$NetBSD: vfs_cache.c,v 1.76 2008/05/05 17:11:17 ad Exp $");
     62   1.1       cgd 
     63  1.28       chs #include "opt_ddb.h"
     64  1.29      fvdl #include "opt_revcache.h"
     65  1.28       chs 
     66   1.4   mycroft #include <sys/param.h>
     67   1.4   mycroft #include <sys/systm.h>
     68   1.4   mycroft #include <sys/time.h>
     69   1.4   mycroft #include <sys/mount.h>
     70   1.4   mycroft #include <sys/vnode.h>
     71   1.4   mycroft #include <sys/namei.h>
     72   1.4   mycroft #include <sys/errno.h>
     73  1.18   thorpej #include <sys/pool.h>
     74  1.68        ad #include <sys/mutex.h>
     75  1.73        ad #include <sys/atomic.h>
     76  1.73        ad #include <sys/kthread.h>
     77  1.73        ad #include <sys/kernel.h>
     78  1.73        ad #include <sys/cpu.h>
     79  1.73        ad #include <sys/evcnt.h>
     80   1.1       cgd 
     81  1.66  christos #define NAMECACHE_ENTER_REVERSE
     82   1.1       cgd /*
     83   1.1       cgd  * Name caching works as follows:
     84   1.1       cgd  *
     85   1.1       cgd  * Names found by directory scans are retained in a cache
     86   1.1       cgd  * for future reference.  It is managed LRU, so frequently
     87   1.1       cgd  * used names will hang around.  Cache is indexed by hash value
     88  1.20  jdolecek  * obtained from (dvp, name) where dvp refers to the directory
     89   1.1       cgd  * containing name.
     90   1.1       cgd  *
     91   1.1       cgd  * For simplicity (and economy of storage), names longer than
     92   1.1       cgd  * a maximum length of NCHNAMLEN are not cached; they occur
     93   1.1       cgd  * infrequently in any case, and are almost never of interest.
     94   1.1       cgd  *
     95   1.1       cgd  * Upon reaching the last segment of a path, if the reference
     96   1.1       cgd  * is for DELETE, or NOCACHE is set (rewrite), and the
     97   1.1       cgd  * name is located in the cache, it will be dropped.
     98  1.20  jdolecek  * The entry is dropped also when it was not possible to lock
     99  1.20  jdolecek  * the cached vnode, either because vget() failed or the generation
    100  1.20  jdolecek  * number has changed while waiting for the lock.
    101   1.1       cgd  */
    102   1.1       cgd 
    103   1.1       cgd /*
    104   1.1       cgd  * Structures associated with name cacheing.
    105   1.1       cgd  */
    106   1.9   mycroft LIST_HEAD(nchashhead, namecache) *nchashtbl;
    107   1.1       cgd u_long	nchash;				/* size of hash table - 1 */
    108  1.49      yamt #define	NCHASH(cnp, dvp)	\
    109  1.49      yamt 	(((cnp)->cn_hash ^ ((uintptr_t)(dvp) >> 3)) & nchash)
    110  1.19  sommerfe 
    111  1.19  sommerfe LIST_HEAD(ncvhashhead, namecache) *ncvhashtbl;
    112  1.19  sommerfe u_long	ncvhash;			/* size of hash table - 1 */
    113  1.48      yamt #define	NCVHASH(vp)		(((uintptr_t)(vp) >> 3) & ncvhash)
    114  1.19  sommerfe 
    115  1.73        ad long	numcache;			/* number of cache entries allocated */
    116  1.73        ad static u_int	cache_gcpend;		/* number of entries pending GC */
    117  1.73        ad static void	*cache_gcqueue;		/* garbage collection queue */
    118  1.73        ad 
    119  1.72      matt TAILQ_HEAD(, namecache) nclruhead =		/* LRU chain */
    120  1.72      matt 	TAILQ_HEAD_INITIALIZER(nclruhead);
    121  1.73        ad #define	COUNT(x)	nchstats.x++
    122   1.1       cgd struct	nchstats nchstats;		/* cache effectiveness statistics */
    123   1.1       cgd 
    124  1.71        ad static pool_cache_t namecache_cache;
    125  1.38   thorpej 
    126  1.38   thorpej MALLOC_DEFINE(M_CACHE, "namecache", "Dynamically allocated cache entries");
    127  1.18   thorpej 
    128  1.73        ad int cache_lowat = 95;
    129  1.73        ad int cache_hiwat = 98;
    130  1.73        ad int cache_hottime = 5;			/* number of seconds */
    131   1.7    chopps int doingcache = 1;			/* 1 => enable the cache */
    132   1.1       cgd 
    133  1.73        ad static struct evcnt cache_ev_scan;
    134  1.73        ad static struct evcnt cache_ev_gc;
    135  1.73        ad static struct evcnt cache_ev_over;
    136  1.73        ad static struct evcnt cache_ev_under;
    137  1.73        ad static struct evcnt cache_ev_forced;
    138  1.73        ad 
    139  1.73        ad /* A single lock to serialize modifications. */
    140  1.73        ad static kmutex_t *namecache_lock;
    141  1.39        pk 
    142  1.73        ad static void cache_invalidate(struct namecache *);
    143  1.63     perry static inline struct namecache *cache_lookup_entry(
    144  1.55      yamt     const struct vnode *, const struct componentname *);
    145  1.73        ad static void cache_thread(void *);
    146  1.73        ad static void cache_invalidate(struct namecache *);
    147  1.73        ad static void cache_disassociate(struct namecache *);
    148  1.73        ad static void cache_reclaim(void);
    149  1.73        ad static int cache_ctor(void *, void *, int);
    150  1.73        ad static void cache_dtor(void *, void *);
    151  1.46      yamt 
    152  1.73        ad /*
    153  1.73        ad  * Invalidate a cache entry and enqueue it for garbage collection.
    154  1.73        ad  */
    155  1.46      yamt static void
    156  1.73        ad cache_invalidate(struct namecache *ncp)
    157  1.46      yamt {
    158  1.73        ad 	void *head;
    159  1.46      yamt 
    160  1.73        ad 	KASSERT(mutex_owned(&ncp->nc_lock));
    161  1.46      yamt 
    162  1.73        ad 	if (ncp->nc_dvp != NULL) {
    163  1.73        ad 		ncp->nc_vp = NULL;
    164  1.73        ad 		ncp->nc_dvp = NULL;
    165  1.73        ad 		do {
    166  1.73        ad 			head = cache_gcqueue;
    167  1.73        ad 			ncp->nc_gcqueue = head;
    168  1.73        ad 		} while (atomic_cas_ptr(&cache_gcqueue, head, ncp) != head);
    169  1.73        ad 		atomic_inc_uint(&cache_gcpend);
    170  1.73        ad 	}
    171  1.73        ad }
    172  1.46      yamt 
    173  1.73        ad /*
    174  1.73        ad  * Disassociate a namecache entry from any vnodes it is attached to,
    175  1.73        ad  * and remove from the global LRU list.
    176  1.73        ad  */
    177  1.73        ad static void
    178  1.73        ad cache_disassociate(struct namecache *ncp)
    179  1.73        ad {
    180  1.73        ad 
    181  1.73        ad 	KASSERT(mutex_owned(namecache_lock));
    182  1.73        ad 	KASSERT(ncp->nc_dvp == NULL);
    183  1.73        ad 
    184  1.73        ad 	if (ncp->nc_lru.tqe_prev != NULL) {
    185  1.73        ad 		TAILQ_REMOVE(&nclruhead, ncp, nc_lru);
    186  1.73        ad 		ncp->nc_lru.tqe_prev = NULL;
    187  1.46      yamt 	}
    188  1.46      yamt 	if (ncp->nc_vhash.le_prev != NULL) {
    189  1.46      yamt 		LIST_REMOVE(ncp, nc_vhash);
    190  1.46      yamt 		ncp->nc_vhash.le_prev = NULL;
    191  1.46      yamt 	}
    192  1.46      yamt 	if (ncp->nc_vlist.le_prev != NULL) {
    193  1.46      yamt 		LIST_REMOVE(ncp, nc_vlist);
    194  1.46      yamt 		ncp->nc_vlist.le_prev = NULL;
    195  1.46      yamt 	}
    196  1.46      yamt 	if (ncp->nc_dvlist.le_prev != NULL) {
    197  1.46      yamt 		LIST_REMOVE(ncp, nc_dvlist);
    198  1.46      yamt 		ncp->nc_dvlist.le_prev = NULL;
    199  1.46      yamt 	}
    200  1.46      yamt }
    201  1.46      yamt 
    202  1.73        ad /*
    203  1.73        ad  * Lock all CPUs to prevent any cache lookup activity.  Conceptually,
    204  1.73        ad  * this locks out all "readers".
    205  1.73        ad  */
    206  1.46      yamt static void
    207  1.73        ad cache_lock_cpus(void)
    208  1.46      yamt {
    209  1.73        ad 	CPU_INFO_ITERATOR cii;
    210  1.73        ad 	struct cpu_info *ci;
    211  1.46      yamt 
    212  1.73        ad 	for (CPU_INFO_FOREACH(cii, ci)) {
    213  1.73        ad 		mutex_enter(ci->ci_data.cpu_cachelock);
    214  1.73        ad 	}
    215  1.46      yamt }
    216  1.46      yamt 
    217  1.73        ad /*
    218  1.73        ad  * Release all CPU locks.
    219  1.73        ad  */
    220  1.73        ad static void
    221  1.73        ad cache_unlock_cpus(void)
    222  1.73        ad {
    223  1.73        ad 	CPU_INFO_ITERATOR cii;
    224  1.73        ad 	struct cpu_info *ci;
    225  1.73        ad 
    226  1.73        ad 	for (CPU_INFO_FOREACH(cii, ci)) {
    227  1.73        ad 		mutex_exit(ci->ci_data.cpu_cachelock);
    228  1.73        ad 	}
    229  1.73        ad }
    230  1.73        ad 
    231  1.73        ad /*
    232  1.73        ad  * Find a single cache entry and return it locked.  'namecache_lock' or
    233  1.73        ad  * at least one of the per-CPU locks must be held.
    234  1.73        ad  */
    235  1.73        ad static struct namecache *
    236  1.55      yamt cache_lookup_entry(const struct vnode *dvp, const struct componentname *cnp)
    237  1.55      yamt {
    238  1.55      yamt 	struct nchashhead *ncpp;
    239  1.55      yamt 	struct namecache *ncp;
    240  1.55      yamt 
    241  1.55      yamt 	ncpp = &nchashtbl[NCHASH(cnp, dvp)];
    242  1.55      yamt 
    243  1.55      yamt 	LIST_FOREACH(ncp, ncpp, nc_hash) {
    244  1.73        ad 		if (ncp->nc_dvp != dvp ||
    245  1.73        ad 		    ncp->nc_nlen != cnp->cn_namelen ||
    246  1.73        ad 		    memcmp(ncp->nc_name, cnp->cn_nameptr, (u_int)ncp->nc_nlen))
    247  1.73        ad 		    	continue;
    248  1.73        ad 	    	mutex_enter(&ncp->nc_lock);
    249  1.73        ad 		if (ncp->nc_dvp == dvp) {
    250  1.73        ad 			ncp->nc_hittime = hardclock_ticks;
    251  1.73        ad 			return ncp;
    252  1.73        ad 		}
    253  1.73        ad 		/* Raced: entry has been nullified. */
    254  1.73        ad 		mutex_exit(&ncp->nc_lock);
    255  1.55      yamt 	}
    256  1.55      yamt 
    257  1.73        ad 	return NULL;
    258  1.55      yamt }
    259  1.55      yamt 
    260   1.1       cgd /*
    261   1.1       cgd  * Look for a the name in the cache. We don't do this
    262   1.1       cgd  * if the segment name is long, simply so the cache can avoid
    263   1.1       cgd  * holding long names (which would either waste space, or
    264   1.1       cgd  * add greatly to the complexity).
    265   1.1       cgd  *
    266   1.1       cgd  * Lookup is called with ni_dvp pointing to the directory to search,
    267   1.1       cgd  * ni_ptr pointing to the name of the entry being sought, ni_namelen
    268   1.1       cgd  * tells the length of the name, and ni_hash contains a hash of
    269  1.20  jdolecek  * the name. If the lookup succeeds, the vnode is locked, stored in ni_vp
    270  1.20  jdolecek  * and a status of zero is returned. If the locking fails for whatever
    271  1.20  jdolecek  * reason, the vnode is unlocked and the error is returned to caller.
    272  1.20  jdolecek  * If the lookup determines that the name does not exist (negative cacheing),
    273  1.20  jdolecek  * a status of ENOENT is returned. If the lookup fails, a status of -1
    274  1.20  jdolecek  * is returned.
    275   1.1       cgd  */
    276   1.5   mycroft int
    277  1.34     enami cache_lookup(struct vnode *dvp, struct vnode **vpp, struct componentname *cnp)
    278   1.1       cgd {
    279  1.23  augustss 	struct namecache *ncp;
    280  1.20  jdolecek 	struct vnode *vp;
    281  1.73        ad 	kmutex_t *cpulock;
    282  1.36   thorpej 	int error;
    283   1.1       cgd 
    284   1.8       cgd 	if (!doingcache) {
    285   1.8       cgd 		cnp->cn_flags &= ~MAKEENTRY;
    286  1.34     enami 		*vpp = NULL;
    287  1.20  jdolecek 		return (-1);
    288   1.8       cgd 	}
    289  1.39        pk 
    290   1.5   mycroft 	if (cnp->cn_namelen > NCHNAMLEN) {
    291  1.70        ad 		/* Unlocked, but only for stats. */
    292  1.73        ad 		COUNT(ncs_long);
    293   1.5   mycroft 		cnp->cn_flags &= ~MAKEENTRY;
    294  1.53      yamt 		goto fail;
    295   1.1       cgd 	}
    296  1.73        ad 	cpulock = curcpu()->ci_data.cpu_cachelock;
    297  1.73        ad 	mutex_enter(cpulock);
    298  1.55      yamt 	ncp = cache_lookup_entry(dvp, cnp);
    299  1.55      yamt 	if (ncp == NULL) {
    300  1.73        ad 		COUNT(ncs_miss);
    301  1.39        pk 		goto fail_wlock;
    302   1.1       cgd 	}
    303   1.9   mycroft 	if ((cnp->cn_flags & MAKEENTRY) == 0) {
    304  1.73        ad 		COUNT(ncs_badhits);
    305  1.20  jdolecek 		goto remove;
    306   1.1       cgd 	} else if (ncp->nc_vp == NULL) {
    307  1.11   mycroft 		/*
    308  1.11   mycroft 		 * Restore the ISWHITEOUT flag saved earlier.
    309  1.11   mycroft 		 */
    310  1.50      yamt 		cnp->cn_flags |= ncp->nc_flags;
    311  1.21   mycroft 		if (cnp->cn_nameiop != CREATE ||
    312  1.21   mycroft 		    (cnp->cn_flags & ISLASTCN) == 0) {
    313  1.73        ad 			COUNT(ncs_neghits);
    314  1.73        ad 			mutex_exit(&ncp->nc_lock);
    315  1.73        ad 			mutex_exit(cpulock);
    316   1.1       cgd 			return (ENOENT);
    317  1.20  jdolecek 		} else {
    318  1.73        ad 			COUNT(ncs_badhits);
    319  1.20  jdolecek 			goto remove;
    320  1.20  jdolecek 		}
    321  1.20  jdolecek 	}
    322  1.20  jdolecek 
    323  1.20  jdolecek 	vp = ncp->nc_vp;
    324  1.73        ad 	mutex_enter(&vp->v_interlock);
    325  1.73        ad 	mutex_exit(&ncp->nc_lock);
    326  1.73        ad 	mutex_exit(cpulock);
    327  1.73        ad 	error = vget(vp, LK_NOWAIT | LK_INTERLOCK);
    328  1.39        pk 
    329  1.52      yamt #ifdef DEBUG
    330  1.52      yamt 	/*
    331  1.73        ad 	 * since we released nb->nb_lock,
    332  1.52      yamt 	 * we can't use this pointer any more.
    333  1.52      yamt 	 */
    334  1.52      yamt 	ncp = NULL;
    335  1.52      yamt #endif /* DEBUG */
    336  1.52      yamt 
    337  1.60      yamt 	if (error) {
    338  1.60      yamt 		KASSERT(error == EBUSY);
    339  1.53      yamt 		/*
    340  1.53      yamt 		 * this vnode is being cleaned out.
    341  1.53      yamt 		 */
    342  1.73        ad 		COUNT(ncs_falsehits); /* XXX badhits? */
    343  1.53      yamt 		goto fail;
    344  1.53      yamt 	}
    345  1.53      yamt 
    346  1.20  jdolecek 	if (vp == dvp) {	/* lookup on "." */
    347  1.20  jdolecek 		error = 0;
    348  1.20  jdolecek 	} else if (cnp->cn_flags & ISDOTDOT) {
    349  1.20  jdolecek 		VOP_UNLOCK(dvp, 0);
    350  1.60      yamt 		error = vn_lock(vp, LK_EXCLUSIVE);
    351  1.67       chs 		vn_lock(dvp, LK_EXCLUSIVE | LK_RETRY);
    352   1.1       cgd 	} else {
    353  1.60      yamt 		error = vn_lock(vp, LK_EXCLUSIVE);
    354  1.20  jdolecek 	}
    355  1.20  jdolecek 
    356  1.20  jdolecek 	/*
    357  1.54      yamt 	 * Check that the lock succeeded.
    358  1.20  jdolecek 	 */
    359  1.47      yamt 	if (error) {
    360  1.70        ad 		/* Unlocked, but only for stats. */
    361  1.73        ad 		COUNT(ncs_badhits);
    362  1.31       chs 		*vpp = NULL;
    363  1.31       chs 		return (-1);
    364  1.20  jdolecek 	}
    365  1.20  jdolecek 
    366  1.70        ad 	/* Unlocked, but only for stats. */
    367  1.73        ad 	COUNT(ncs_goodhits);
    368  1.20  jdolecek 	*vpp = vp;
    369  1.20  jdolecek 	return (0);
    370   1.1       cgd 
    371  1.20  jdolecek remove:
    372   1.1       cgd 	/*
    373   1.1       cgd 	 * Last component and we are renaming or deleting,
    374   1.1       cgd 	 * the cache entry is invalid, or otherwise don't
    375   1.1       cgd 	 * want cache entry to exist.
    376   1.1       cgd 	 */
    377  1.73        ad 	cache_invalidate(ncp);
    378  1.73        ad 	mutex_exit(&ncp->nc_lock);
    379  1.39        pk fail_wlock:
    380  1.73        ad 	mutex_exit(cpulock);
    381  1.53      yamt fail:
    382  1.34     enami 	*vpp = NULL;
    383  1.20  jdolecek 	return (-1);
    384   1.1       cgd }
    385   1.1       cgd 
    386  1.61      yamt int
    387  1.61      yamt cache_lookup_raw(struct vnode *dvp, struct vnode **vpp,
    388  1.61      yamt     struct componentname *cnp)
    389  1.61      yamt {
    390  1.61      yamt 	struct namecache *ncp;
    391  1.61      yamt 	struct vnode *vp;
    392  1.73        ad 	kmutex_t *cpulock;
    393  1.61      yamt 	int error;
    394  1.61      yamt 
    395  1.61      yamt 	if (!doingcache) {
    396  1.61      yamt 		cnp->cn_flags &= ~MAKEENTRY;
    397  1.61      yamt 		*vpp = NULL;
    398  1.61      yamt 		return (-1);
    399  1.61      yamt 	}
    400  1.61      yamt 
    401  1.61      yamt 	if (cnp->cn_namelen > NCHNAMLEN) {
    402  1.70        ad 		/* Unlocked, but only for stats. */
    403  1.73        ad 		COUNT(ncs_long);
    404  1.61      yamt 		cnp->cn_flags &= ~MAKEENTRY;
    405  1.61      yamt 		goto fail;
    406  1.61      yamt 	}
    407  1.73        ad 	cpulock = curcpu()->ci_data.cpu_cachelock;
    408  1.73        ad 	mutex_enter(cpulock);
    409  1.61      yamt 	ncp = cache_lookup_entry(dvp, cnp);
    410  1.61      yamt 	if (ncp == NULL) {
    411  1.73        ad 		COUNT(ncs_miss);
    412  1.61      yamt 		goto fail_wlock;
    413  1.61      yamt 	}
    414  1.61      yamt 	vp = ncp->nc_vp;
    415  1.61      yamt 	if (vp == NULL) {
    416  1.61      yamt 		/*
    417  1.61      yamt 		 * Restore the ISWHITEOUT flag saved earlier.
    418  1.61      yamt 		 */
    419  1.61      yamt 		cnp->cn_flags |= ncp->nc_flags;
    420  1.73        ad 		COUNT(ncs_neghits);
    421  1.73        ad 		mutex_exit(&ncp->nc_lock);
    422  1.73        ad 		mutex_exit(cpulock);
    423  1.61      yamt 		return (ENOENT);
    424  1.61      yamt 	}
    425  1.73        ad 	mutex_enter(&vp->v_interlock);
    426  1.73        ad 	mutex_exit(&ncp->nc_lock);
    427  1.73        ad 	mutex_exit(cpulock);
    428  1.73        ad 	error = vget(vp, LK_NOWAIT | LK_INTERLOCK);
    429  1.61      yamt 
    430  1.61      yamt 	if (error) {
    431  1.61      yamt 		KASSERT(error == EBUSY);
    432  1.61      yamt 		/*
    433  1.61      yamt 		 * this vnode is being cleaned out.
    434  1.61      yamt 		 */
    435  1.73        ad 		COUNT(ncs_falsehits); /* XXX badhits? */
    436  1.61      yamt 		goto fail;
    437  1.61      yamt 	}
    438  1.61      yamt 
    439  1.61      yamt 	*vpp = vp;
    440  1.61      yamt 
    441  1.61      yamt 	return 0;
    442  1.61      yamt 
    443  1.61      yamt fail_wlock:
    444  1.73        ad 	mutex_exit(cpulock);
    445  1.61      yamt fail:
    446  1.61      yamt 	*vpp = NULL;
    447  1.61      yamt 	return -1;
    448  1.61      yamt }
    449  1.61      yamt 
    450   1.1       cgd /*
    451  1.19  sommerfe  * Scan cache looking for name of directory entry pointing at vp.
    452  1.19  sommerfe  *
    453  1.19  sommerfe  * Fill in dvpp.
    454  1.19  sommerfe  *
    455  1.19  sommerfe  * If bufp is non-NULL, also place the name in the buffer which starts
    456  1.19  sommerfe  * at bufp, immediately before *bpp, and move bpp backwards to point
    457  1.19  sommerfe  * at the start of it.  (Yes, this is a little baroque, but it's done
    458  1.19  sommerfe  * this way to cater to the whims of getcwd).
    459  1.19  sommerfe  *
    460  1.19  sommerfe  * Returns 0 on success, -1 on cache miss, positive errno on failure.
    461  1.19  sommerfe  */
    462  1.19  sommerfe int
    463  1.34     enami cache_revlookup(struct vnode *vp, struct vnode **dvpp, char **bpp, char *bufp)
    464  1.19  sommerfe {
    465  1.19  sommerfe 	struct namecache *ncp;
    466  1.19  sommerfe 	struct vnode *dvp;
    467  1.19  sommerfe 	struct ncvhashhead *nvcpp;
    468  1.34     enami 	char *bp;
    469  1.34     enami 
    470  1.19  sommerfe 	if (!doingcache)
    471  1.19  sommerfe 		goto out;
    472  1.19  sommerfe 
    473  1.30       chs 	nvcpp = &ncvhashtbl[NCVHASH(vp)];
    474  1.19  sommerfe 
    475  1.73        ad 	mutex_enter(namecache_lock);
    476  1.27       chs 	LIST_FOREACH(ncp, nvcpp, nc_vhash) {
    477  1.73        ad 		mutex_enter(&ncp->nc_lock);
    478  1.34     enami 		if (ncp->nc_vp == vp &&
    479  1.34     enami 		    (dvp = ncp->nc_dvp) != NULL &&
    480  1.47      yamt 		    dvp != vp) { 		/* avoid pesky . entries.. */
    481  1.34     enami 
    482  1.19  sommerfe #ifdef DIAGNOSTIC
    483  1.34     enami 			if (ncp->nc_nlen == 1 &&
    484  1.34     enami 			    ncp->nc_name[0] == '.')
    485  1.19  sommerfe 				panic("cache_revlookup: found entry for .");
    486  1.19  sommerfe 
    487  1.34     enami 			if (ncp->nc_nlen == 2 &&
    488  1.34     enami 			    ncp->nc_name[0] == '.' &&
    489  1.34     enami 			    ncp->nc_name[1] == '.')
    490  1.19  sommerfe 				panic("cache_revlookup: found entry for ..");
    491  1.19  sommerfe #endif
    492  1.73        ad 			COUNT(ncs_revhits);
    493  1.19  sommerfe 
    494  1.19  sommerfe 			if (bufp) {
    495  1.19  sommerfe 				bp = *bpp;
    496  1.19  sommerfe 				bp -= ncp->nc_nlen;
    497  1.19  sommerfe 				if (bp <= bufp) {
    498  1.34     enami 					*dvpp = NULL;
    499  1.73        ad 					mutex_exit(&ncp->nc_lock);
    500  1.73        ad 					mutex_exit(namecache_lock);
    501  1.34     enami 					return (ERANGE);
    502  1.19  sommerfe 				}
    503  1.19  sommerfe 				memcpy(bp, ncp->nc_name, ncp->nc_nlen);
    504  1.19  sommerfe 				*bpp = bp;
    505  1.19  sommerfe 			}
    506  1.34     enami 
    507  1.19  sommerfe 			/* XXX MP: how do we know dvp won't evaporate? */
    508  1.19  sommerfe 			*dvpp = dvp;
    509  1.73        ad 			mutex_exit(&ncp->nc_lock);
    510  1.73        ad 			mutex_exit(namecache_lock);
    511  1.34     enami 			return (0);
    512  1.19  sommerfe 		}
    513  1.73        ad 		mutex_exit(&ncp->nc_lock);
    514  1.19  sommerfe 	}
    515  1.73        ad 	COUNT(ncs_revmiss);
    516  1.73        ad 	mutex_exit(namecache_lock);
    517  1.19  sommerfe  out:
    518  1.34     enami 	*dvpp = NULL;
    519  1.34     enami 	return (-1);
    520  1.19  sommerfe }
    521  1.19  sommerfe 
    522  1.19  sommerfe /*
    523   1.1       cgd  * Add an entry to the cache
    524   1.1       cgd  */
    525  1.13  christos void
    526  1.34     enami cache_enter(struct vnode *dvp, struct vnode *vp, struct componentname *cnp)
    527   1.1       cgd {
    528  1.23  augustss 	struct namecache *ncp;
    529  1.59      yamt 	struct namecache *oncp;
    530  1.23  augustss 	struct nchashhead *ncpp;
    531  1.23  augustss 	struct ncvhashhead *nvcpp;
    532   1.1       cgd 
    533   1.5   mycroft #ifdef DIAGNOSTIC
    534   1.5   mycroft 	if (cnp->cn_namelen > NCHNAMLEN)
    535   1.5   mycroft 		panic("cache_enter: name too long");
    536   1.5   mycroft #endif
    537   1.1       cgd 	if (!doingcache)
    538   1.1       cgd 		return;
    539  1.58      yamt 
    540  1.73        ad 	if (numcache > desiredvnodes) {
    541  1.73        ad 		mutex_enter(namecache_lock);
    542  1.73        ad 		cache_ev_forced.ev_count++;
    543  1.73        ad 		cache_reclaim();
    544  1.73        ad 		mutex_exit(namecache_lock);
    545  1.39        pk 	}
    546  1.57        pk 
    547  1.73        ad 	ncp = pool_cache_get(namecache_cache, PR_WAITOK);
    548  1.73        ad 	mutex_enter(namecache_lock);
    549  1.73        ad 	numcache++;
    550  1.73        ad 
    551  1.59      yamt 	/*
    552  1.59      yamt 	 * Concurrent lookups in the same directory may race for a
    553  1.59      yamt 	 * cache entry.  if there's a duplicated entry, free it.
    554  1.59      yamt 	 */
    555  1.59      yamt 	oncp = cache_lookup_entry(dvp, cnp);
    556  1.59      yamt 	if (oncp) {
    557  1.73        ad 		cache_invalidate(oncp);
    558  1.73        ad 		mutex_exit(&oncp->nc_lock);
    559  1.59      yamt 	}
    560  1.59      yamt 
    561  1.34     enami 	/* Grab the vnode we just found. */
    562  1.73        ad 	mutex_enter(&ncp->nc_lock);
    563   1.5   mycroft 	ncp->nc_vp = vp;
    564  1.73        ad 	ncp->nc_flags = 0;
    565  1.73        ad 	ncp->nc_hittime = 0;
    566  1.73        ad 	ncp->nc_gcqueue = NULL;
    567  1.47      yamt 	if (vp == NULL) {
    568  1.11   mycroft 		/*
    569  1.11   mycroft 		 * For negative hits, save the ISWHITEOUT flag so we can
    570  1.11   mycroft 		 * restore it later when the cache entry is used again.
    571  1.11   mycroft 		 */
    572  1.50      yamt 		ncp->nc_flags = cnp->cn_flags & ISWHITEOUT;
    573  1.11   mycroft 	}
    574  1.34     enami 	/* Fill in cache info. */
    575   1.5   mycroft 	ncp->nc_dvp = dvp;
    576  1.46      yamt 	LIST_INSERT_HEAD(&dvp->v_dnclist, ncp, nc_dvlist);
    577  1.46      yamt 	if (vp)
    578  1.46      yamt 		LIST_INSERT_HEAD(&vp->v_nclist, ncp, nc_vlist);
    579  1.73        ad 	else {
    580  1.73        ad 		ncp->nc_vlist.le_prev = NULL;
    581  1.73        ad 		ncp->nc_vlist.le_next = NULL;
    582  1.73        ad 	}
    583   1.5   mycroft 	ncp->nc_nlen = cnp->cn_namelen;
    584  1.73        ad 	TAILQ_INSERT_TAIL(&nclruhead, ncp, nc_lru);
    585  1.17     perry 	memcpy(ncp->nc_name, cnp->cn_nameptr, (unsigned)ncp->nc_nlen);
    586  1.30       chs 	ncpp = &nchashtbl[NCHASH(cnp, dvp)];
    587  1.73        ad 
    588  1.73        ad 	/*
    589  1.73        ad 	 * Flush updates before making visible in table.  No need for a
    590  1.73        ad 	 * memory barrier on the other side: to see modifications the
    591  1.73        ad 	 * list must be followed, meaning a dependent pointer load.
    592  1.74        ad 	 * The below is LIST_INSERT_HEAD() inlined, with the memory
    593  1.74        ad 	 * barrier included in the correct place.
    594  1.73        ad 	 */
    595  1.74        ad 	if ((ncp->nc_hash.le_next = ncpp->lh_first) != NULL)
    596  1.74        ad 		ncpp->lh_first->nc_hash.le_prev = &ncp->nc_hash.le_next;
    597  1.74        ad 	ncp->nc_hash.le_prev = &ncpp->lh_first;
    598  1.73        ad 	membar_producer();
    599  1.74        ad 	ncpp->lh_first = ncp;
    600  1.19  sommerfe 
    601  1.34     enami 	ncp->nc_vhash.le_prev = NULL;
    602  1.34     enami 	ncp->nc_vhash.le_next = NULL;
    603  1.34     enami 
    604  1.19  sommerfe 	/*
    605  1.19  sommerfe 	 * Create reverse-cache entries (used in getcwd) for directories.
    606  1.66  christos 	 * (and in linux procfs exe node)
    607  1.19  sommerfe 	 */
    608  1.33     enami 	if (vp != NULL &&
    609  1.33     enami 	    vp != dvp &&
    610  1.29      fvdl #ifndef NAMECACHE_ENTER_REVERSE
    611  1.33     enami 	    vp->v_type == VDIR &&
    612  1.29      fvdl #endif
    613  1.33     enami 	    (ncp->nc_nlen > 2 ||
    614  1.33     enami 	    (ncp->nc_nlen > 1 && ncp->nc_name[1] != '.') ||
    615  1.33     enami 	    (/* ncp->nc_nlen > 0 && */ ncp->nc_name[0] != '.'))) {
    616  1.30       chs 		nvcpp = &ncvhashtbl[NCVHASH(vp)];
    617  1.19  sommerfe 		LIST_INSERT_HEAD(nvcpp, ncp, nc_vhash);
    618  1.19  sommerfe 	}
    619  1.73        ad 	mutex_exit(&ncp->nc_lock);
    620  1.73        ad 	mutex_exit(namecache_lock);
    621   1.1       cgd }
    622   1.1       cgd 
    623   1.1       cgd /*
    624   1.1       cgd  * Name cache initialization, from vfs_init() when we are booting
    625   1.1       cgd  */
    626  1.13  christos void
    627  1.34     enami nchinit(void)
    628   1.1       cgd {
    629  1.73        ad 	int error;
    630   1.1       cgd 
    631  1.73        ad 	namecache_cache = pool_cache_init(sizeof(struct namecache),
    632  1.73        ad 	    coherency_unit, 0, 0, "ncache", NULL, IPL_NONE, cache_ctor,
    633  1.73        ad 	    cache_dtor, NULL);
    634  1.71        ad 	KASSERT(namecache_cache != NULL);
    635  1.71        ad 
    636  1.73        ad 	namecache_lock = mutex_obj_alloc(MUTEX_DEFAULT, IPL_NONE);
    637  1.73        ad 
    638  1.76        ad 	nchashtbl = hashinit(desiredvnodes, HASH_LIST, true, &nchash);
    639  1.26        ad 	ncvhashtbl =
    640  1.29      fvdl #ifdef NAMECACHE_ENTER_REVERSE
    641  1.76        ad 	    hashinit(desiredvnodes, HASH_LIST, true, &ncvhash);
    642  1.29      fvdl #else
    643  1.76        ad 	    hashinit(desiredvnodes/8, HASH_LIST, true, &ncvhash);
    644  1.29      fvdl #endif
    645  1.73        ad 
    646  1.73        ad 	error = kthread_create(PRI_VM, KTHREAD_MPSAFE, NULL, cache_thread,
    647  1.73        ad 	    NULL, NULL, "cachegc");
    648  1.73        ad 	if (error != 0)
    649  1.73        ad 		panic("nchinit %d", error);
    650  1.73        ad 
    651  1.73        ad 	evcnt_attach_dynamic(&cache_ev_scan, EVCNT_TYPE_MISC, NULL,
    652  1.73        ad 	   "namecache", "entries scanned");
    653  1.73        ad 	evcnt_attach_dynamic(&cache_ev_gc, EVCNT_TYPE_MISC, NULL,
    654  1.73        ad 	   "namecache", "entries collected");
    655  1.73        ad 	evcnt_attach_dynamic(&cache_ev_over, EVCNT_TYPE_MISC, NULL,
    656  1.73        ad 	   "namecache", "over scan target");
    657  1.73        ad 	evcnt_attach_dynamic(&cache_ev_under, EVCNT_TYPE_MISC, NULL,
    658  1.73        ad 	   "namecache", "under scan target");
    659  1.73        ad 	evcnt_attach_dynamic(&cache_ev_forced, EVCNT_TYPE_MISC, NULL,
    660  1.73        ad 	   "namecache", "forced reclaims");
    661  1.73        ad }
    662  1.73        ad 
    663  1.73        ad static int
    664  1.73        ad cache_ctor(void *arg, void *obj, int flag)
    665  1.73        ad {
    666  1.73        ad 	struct namecache *ncp;
    667  1.73        ad 
    668  1.73        ad 	ncp = obj;
    669  1.73        ad 	mutex_init(&ncp->nc_lock, MUTEX_DEFAULT, IPL_NONE);
    670  1.73        ad 
    671  1.73        ad 	return 0;
    672  1.73        ad }
    673  1.73        ad 
    674  1.73        ad static void
    675  1.73        ad cache_dtor(void *arg, void *obj)
    676  1.73        ad {
    677  1.73        ad 	struct namecache *ncp;
    678  1.73        ad 
    679  1.73        ad 	ncp = obj;
    680  1.73        ad 	mutex_destroy(&ncp->nc_lock);
    681  1.73        ad }
    682  1.73        ad 
    683  1.73        ad /*
    684  1.73        ad  * Called once for each CPU in the system as attached.
    685  1.73        ad  */
    686  1.73        ad void
    687  1.73        ad cache_cpu_init(struct cpu_info *ci)
    688  1.73        ad {
    689  1.73        ad 
    690  1.73        ad 	ci->ci_data.cpu_cachelock = mutex_obj_alloc(MUTEX_DEFAULT, IPL_NONE);
    691  1.30       chs }
    692  1.30       chs 
    693  1.30       chs /*
    694  1.30       chs  * Name cache reinitialization, for when the maximum number of vnodes increases.
    695  1.30       chs  */
    696  1.30       chs void
    697  1.34     enami nchreinit(void)
    698  1.30       chs {
    699  1.30       chs 	struct namecache *ncp;
    700  1.30       chs 	struct nchashhead *oldhash1, *hash1;
    701  1.30       chs 	struct ncvhashhead *oldhash2, *hash2;
    702  1.36   thorpej 	u_long i, oldmask1, oldmask2, mask1, mask2;
    703  1.30       chs 
    704  1.76        ad 	hash1 = hashinit(desiredvnodes, HASH_LIST, true, &mask1);
    705  1.30       chs 	hash2 =
    706  1.30       chs #ifdef NAMECACHE_ENTER_REVERSE
    707  1.76        ad 	    hashinit(desiredvnodes, HASH_LIST, true, &mask2);
    708  1.30       chs #else
    709  1.76        ad 	    hashinit(desiredvnodes/8, HASH_LIST, true, &mask2);
    710  1.30       chs #endif
    711  1.73        ad 	mutex_enter(namecache_lock);
    712  1.73        ad 	cache_lock_cpus();
    713  1.30       chs 	oldhash1 = nchashtbl;
    714  1.30       chs 	oldmask1 = nchash;
    715  1.30       chs 	nchashtbl = hash1;
    716  1.30       chs 	nchash = mask1;
    717  1.30       chs 	oldhash2 = ncvhashtbl;
    718  1.30       chs 	oldmask2 = ncvhash;
    719  1.30       chs 	ncvhashtbl = hash2;
    720  1.30       chs 	ncvhash = mask2;
    721  1.30       chs 	for (i = 0; i <= oldmask1; i++) {
    722  1.30       chs 		while ((ncp = LIST_FIRST(&oldhash1[i])) != NULL) {
    723  1.30       chs 			LIST_REMOVE(ncp, nc_hash);
    724  1.30       chs 			ncp->nc_hash.le_prev = NULL;
    725  1.30       chs 		}
    726  1.30       chs 	}
    727  1.30       chs 	for (i = 0; i <= oldmask2; i++) {
    728  1.30       chs 		while ((ncp = LIST_FIRST(&oldhash2[i])) != NULL) {
    729  1.30       chs 			LIST_REMOVE(ncp, nc_vhash);
    730  1.30       chs 			ncp->nc_vhash.le_prev = NULL;
    731  1.30       chs 		}
    732  1.30       chs 	}
    733  1.73        ad 	cache_unlock_cpus();
    734  1.73        ad 	mutex_exit(namecache_lock);
    735  1.76        ad 	hashdone(oldhash1, HASH_LIST, oldmask1);
    736  1.76        ad 	hashdone(oldhash2, HASH_LIST, oldmask2);
    737   1.1       cgd }
    738   1.1       cgd 
    739   1.1       cgd /*
    740   1.1       cgd  * Cache flush, a particular vnode; called when a vnode is renamed to
    741   1.1       cgd  * hide entries that would now be invalid
    742   1.1       cgd  */
    743  1.13  christos void
    744  1.55      yamt cache_purge1(struct vnode *vp, const struct componentname *cnp, int flags)
    745   1.1       cgd {
    746  1.46      yamt 	struct namecache *ncp, *ncnext;
    747   1.1       cgd 
    748  1.73        ad 	mutex_enter(namecache_lock);
    749  1.55      yamt 	if (flags & PURGE_PARENTS) {
    750  1.55      yamt 		for (ncp = LIST_FIRST(&vp->v_nclist); ncp != NULL;
    751  1.55      yamt 		    ncp = ncnext) {
    752  1.55      yamt 			ncnext = LIST_NEXT(ncp, nc_vlist);
    753  1.73        ad 			mutex_enter(&ncp->nc_lock);
    754  1.73        ad 			cache_invalidate(ncp);
    755  1.73        ad 			mutex_exit(&ncp->nc_lock);
    756  1.73        ad 			cache_disassociate(ncp);
    757  1.55      yamt 		}
    758  1.55      yamt 	}
    759  1.55      yamt 	if (flags & PURGE_CHILDREN) {
    760  1.55      yamt 		for (ncp = LIST_FIRST(&vp->v_dnclist); ncp != NULL;
    761  1.55      yamt 		    ncp = ncnext) {
    762  1.55      yamt 			ncnext = LIST_NEXT(ncp, nc_dvlist);
    763  1.73        ad 			mutex_enter(&ncp->nc_lock);
    764  1.73        ad 			cache_invalidate(ncp);
    765  1.73        ad 			mutex_exit(&ncp->nc_lock);
    766  1.73        ad 			cache_disassociate(ncp);
    767  1.55      yamt 		}
    768  1.46      yamt 	}
    769  1.55      yamt 	if (cnp != NULL) {
    770  1.55      yamt 		ncp = cache_lookup_entry(vp, cnp);
    771  1.55      yamt 		if (ncp) {
    772  1.73        ad 			cache_invalidate(ncp);
    773  1.73        ad 			cache_disassociate(ncp);
    774  1.73        ad 			mutex_exit(&ncp->nc_lock);
    775  1.55      yamt 		}
    776  1.46      yamt 	}
    777  1.73        ad 	mutex_exit(namecache_lock);
    778   1.1       cgd }
    779   1.1       cgd 
    780   1.1       cgd /*
    781   1.1       cgd  * Cache flush, a whole filesystem; called when filesys is umounted to
    782  1.27       chs  * remove entries that would now be invalid.
    783   1.1       cgd  */
    784  1.13  christos void
    785  1.34     enami cache_purgevfs(struct mount *mp)
    786   1.1       cgd {
    787  1.23  augustss 	struct namecache *ncp, *nxtcp;
    788   1.1       cgd 
    789  1.73        ad 	mutex_enter(namecache_lock);
    790  1.73        ad 	for (ncp = TAILQ_FIRST(&nclruhead); ncp != NULL; ncp = nxtcp) {
    791  1.73        ad 		nxtcp = TAILQ_NEXT(ncp, nc_lru);
    792  1.73        ad 		mutex_enter(&ncp->nc_lock);
    793  1.73        ad 		if (ncp->nc_dvp != NULL && ncp->nc_dvp->v_mount == mp) {
    794  1.73        ad 			/* Free the resources we had. */
    795  1.73        ad 			cache_invalidate(ncp);
    796  1.73        ad 			cache_disassociate(ncp);
    797  1.73        ad 		}
    798  1.73        ad 		mutex_exit(&ncp->nc_lock);
    799  1.73        ad 	}
    800  1.73        ad 	cache_reclaim();
    801  1.73        ad 	mutex_exit(namecache_lock);
    802  1.73        ad }
    803  1.73        ad 
    804  1.73        ad /*
    805  1.73        ad  * Scan global list invalidating entries until we meet a preset target.
    806  1.73        ad  * Prefer to invalidate entries that have not scored a hit within
    807  1.73        ad  * cache_hottime seconds.  We sort the LRU list only for this routine's
    808  1.73        ad  * benefit.
    809  1.73        ad  */
    810  1.73        ad static void
    811  1.73        ad cache_prune(int incache, int target)
    812  1.73        ad {
    813  1.73        ad 	struct namecache *ncp, *nxtcp, *sentinel;
    814  1.73        ad 	int items, recent, tryharder;
    815  1.73        ad 
    816  1.73        ad 	KASSERT(mutex_owned(namecache_lock));
    817  1.73        ad 
    818  1.73        ad 	items = 0;
    819  1.73        ad 	tryharder = 0;
    820  1.73        ad 	recent = hardclock_ticks - hz * cache_hottime;
    821  1.73        ad 	sentinel = NULL;
    822  1.27       chs 	for (ncp = TAILQ_FIRST(&nclruhead); ncp != NULL; ncp = nxtcp) {
    823  1.73        ad 		if (incache <= target)
    824  1.73        ad 			break;
    825  1.73        ad 		items++;
    826  1.27       chs 		nxtcp = TAILQ_NEXT(ncp, nc_lru);
    827  1.73        ad 		if (ncp->nc_dvp == NULL)
    828   1.1       cgd 			continue;
    829  1.73        ad 		if (ncp == sentinel) {
    830  1.73        ad 			/*
    831  1.73        ad 			 * If we looped back on ourself, then ignore
    832  1.73        ad 			 * recent entries and purge whatever we find.
    833  1.73        ad 			 */
    834  1.73        ad 			tryharder = 1;
    835   1.5   mycroft 		}
    836  1.73        ad 		if (!tryharder && ncp->nc_hittime > recent) {
    837  1.73        ad 			if (sentinel == NULL)
    838  1.73        ad 				sentinel = ncp;
    839  1.73        ad 			TAILQ_REMOVE(&nclruhead, ncp, nc_lru);
    840  1.73        ad 			TAILQ_INSERT_TAIL(&nclruhead, ncp, nc_lru);
    841  1.73        ad 			continue;
    842  1.73        ad 		}
    843  1.73        ad 		mutex_enter(&ncp->nc_lock);
    844  1.73        ad 		if (ncp->nc_dvp != NULL) {
    845  1.73        ad 			cache_invalidate(ncp);
    846  1.73        ad 			cache_disassociate(ncp);
    847  1.73        ad 			incache--;
    848  1.73        ad 		}
    849  1.73        ad 		mutex_exit(&ncp->nc_lock);
    850  1.73        ad 	}
    851  1.73        ad 	cache_ev_scan.ev_count += items;
    852  1.73        ad }
    853  1.73        ad 
    854  1.73        ad /*
    855  1.73        ad  * Collect dead cache entries from all CPUs and garbage collect.
    856  1.73        ad  */
    857  1.73        ad static void
    858  1.73        ad cache_reclaim(void)
    859  1.73        ad {
    860  1.73        ad 	struct namecache *ncp, *next;
    861  1.73        ad 	int items;
    862  1.73        ad 
    863  1.73        ad 	KASSERT(mutex_owned(namecache_lock));
    864  1.73        ad 
    865  1.73        ad 	/*
    866  1.73        ad 	 * If the number of extant entries not awaiting garbage collection
    867  1.73        ad 	 * exceeds the high water mark, then reclaim stale entries until we
    868  1.73        ad 	 * reach our low water mark.
    869  1.73        ad 	 */
    870  1.73        ad 	items = numcache - cache_gcpend;
    871  1.73        ad 	if (items > (uint64_t)desiredvnodes * cache_hiwat / 100) {
    872  1.73        ad 		cache_prune(items, (int)((uint64_t)desiredvnodes *
    873  1.73        ad 		    cache_lowat / 100));
    874  1.73        ad 		cache_ev_over.ev_count++;
    875  1.73        ad 	} else
    876  1.73        ad 		cache_ev_under.ev_count++;
    877  1.73        ad 
    878  1.73        ad 	/*
    879  1.73        ad 	 * Stop forward lookup activity on all CPUs and garbage collect dead
    880  1.73        ad 	 * entries.
    881  1.73        ad 	 */
    882  1.73        ad 	cache_lock_cpus();
    883  1.73        ad 	ncp = cache_gcqueue;
    884  1.73        ad 	cache_gcqueue = NULL;
    885  1.73        ad 	items = cache_gcpend;
    886  1.73        ad 	cache_gcpend = 0;
    887  1.73        ad 	while (ncp != NULL) {
    888  1.73        ad 		next = ncp->nc_gcqueue;
    889  1.73        ad 		cache_disassociate(ncp);
    890  1.73        ad 		KASSERT(ncp->nc_dvp == NULL);
    891  1.73        ad 		if (ncp->nc_hash.le_prev != NULL) {
    892  1.73        ad 			LIST_REMOVE(ncp, nc_hash);
    893  1.73        ad 			ncp->nc_hash.le_prev = NULL;
    894  1.73        ad 		}
    895  1.73        ad 		pool_cache_put(namecache_cache, ncp);
    896  1.73        ad 		ncp = next;
    897  1.73        ad 	}
    898  1.73        ad 	cache_unlock_cpus();
    899  1.73        ad 	numcache -= items;
    900  1.73        ad 	cache_ev_gc.ev_count += items;
    901  1.73        ad }
    902  1.73        ad 
    903  1.73        ad /*
    904  1.73        ad  * Cache maintainence thread, awakening once per second to:
    905  1.73        ad  *
    906  1.73        ad  * => keep number of entries below the high water mark
    907  1.73        ad  * => sort pseudo-LRU list
    908  1.73        ad  * => garbage collect dead entries
    909  1.73        ad  */
    910  1.73        ad static void
    911  1.73        ad cache_thread(void *arg)
    912  1.73        ad {
    913  1.73        ad 
    914  1.73        ad 	mutex_enter(namecache_lock);
    915  1.73        ad 	for (;;) {
    916  1.73        ad 		cache_reclaim();
    917  1.73        ad 		kpause("cachegc", false, hz, namecache_lock);
    918   1.1       cgd 	}
    919   1.1       cgd }
    920  1.19  sommerfe 
    921  1.28       chs #ifdef DDB
    922  1.28       chs void
    923  1.28       chs namecache_print(struct vnode *vp, void (*pr)(const char *, ...))
    924  1.28       chs {
    925  1.28       chs 	struct vnode *dvp = NULL;
    926  1.28       chs 	struct namecache *ncp;
    927  1.28       chs 
    928  1.28       chs 	TAILQ_FOREACH(ncp, &nclruhead, nc_lru) {
    929  1.73        ad 		if (ncp->nc_vp == vp && ncp->nc_dvp != NULL) {
    930  1.28       chs 			(*pr)("name %.*s\n", ncp->nc_nlen, ncp->nc_name);
    931  1.28       chs 			dvp = ncp->nc_dvp;
    932  1.28       chs 		}
    933  1.28       chs 	}
    934  1.28       chs 	if (dvp == NULL) {
    935  1.28       chs 		(*pr)("name not found\n");
    936  1.28       chs 		return;
    937  1.28       chs 	}
    938  1.28       chs 	vp = dvp;
    939  1.28       chs 	TAILQ_FOREACH(ncp, &nclruhead, nc_lru) {
    940  1.47      yamt 		if (ncp->nc_vp == vp) {
    941  1.28       chs 			(*pr)("parent %.*s\n", ncp->nc_nlen, ncp->nc_name);
    942  1.28       chs 		}
    943  1.28       chs 	}
    944  1.28       chs }
    945  1.28       chs #endif
    946