Home | History | Annotate | Line # | Download | only in kern
vfs_cache.c revision 1.111
      1  1.111   hannken /*	$NetBSD: vfs_cache.c,v 1.111 2017/01/02 10:33:28 hannken 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.111   hannken __KERNEL_RCSID(0, "$NetBSD: vfs_cache.c,v 1.111 2017/01/02 10:33:28 hannken Exp $");
     62    1.1       cgd 
     63  1.107     pooka #ifdef _KERNEL_OPT
     64   1.28       chs #include "opt_ddb.h"
     65   1.29      fvdl #include "opt_revcache.h"
     66  1.108  christos #include "opt_dtrace.h"
     67  1.107     pooka #endif
     68   1.28       chs 
     69    1.4   mycroft #include <sys/param.h>
     70    1.4   mycroft #include <sys/systm.h>
     71   1.97     joerg #include <sys/sysctl.h>
     72    1.4   mycroft #include <sys/time.h>
     73    1.4   mycroft #include <sys/mount.h>
     74  1.111   hannken #include <sys/vnode_impl.h>
     75    1.4   mycroft #include <sys/namei.h>
     76    1.4   mycroft #include <sys/errno.h>
     77   1.18   thorpej #include <sys/pool.h>
     78   1.68        ad #include <sys/mutex.h>
     79   1.73        ad #include <sys/atomic.h>
     80   1.73        ad #include <sys/kthread.h>
     81   1.73        ad #include <sys/kernel.h>
     82   1.73        ad #include <sys/cpu.h>
     83   1.73        ad #include <sys/evcnt.h>
     84  1.108  christos #include <sys/sdt.h>
     85    1.1       cgd 
     86   1.66  christos #define NAMECACHE_ENTER_REVERSE
     87    1.1       cgd /*
     88    1.1       cgd  * Name caching works as follows:
     89    1.1       cgd  *
     90    1.1       cgd  * Names found by directory scans are retained in a cache
     91    1.1       cgd  * for future reference.  It is managed LRU, so frequently
     92    1.1       cgd  * used names will hang around.  Cache is indexed by hash value
     93   1.20  jdolecek  * obtained from (dvp, name) where dvp refers to the directory
     94    1.1       cgd  * containing name.
     95    1.1       cgd  *
     96    1.1       cgd  * For simplicity (and economy of storage), names longer than
     97    1.1       cgd  * a maximum length of NCHNAMLEN are not cached; they occur
     98    1.1       cgd  * infrequently in any case, and are almost never of interest.
     99    1.1       cgd  *
    100    1.1       cgd  * Upon reaching the last segment of a path, if the reference
    101    1.1       cgd  * is for DELETE, or NOCACHE is set (rewrite), and the
    102    1.1       cgd  * name is located in the cache, it will be dropped.
    103   1.20  jdolecek  * The entry is dropped also when it was not possible to lock
    104  1.111   hannken  * the cached vnode, either because vcache_tryvget() failed or
    105  1.111   hannken  * the generation number has changed while waiting for the lock.
    106    1.1       cgd  */
    107    1.1       cgd 
    108    1.1       cgd /*
    109  1.102    dennis  * The locking in this subsystem works as follows:
    110  1.102    dennis  *
    111  1.102    dennis  * When an entry is added to the cache, via cache_enter(),
    112  1.102    dennis  * namecache_lock is taken to exclude other writers.  The new
    113  1.102    dennis  * entry is added to the hash list in a way which permits
    114  1.102    dennis  * concurrent lookups and invalidations in the cache done on
    115  1.102    dennis  * other CPUs to continue in parallel.
    116  1.102    dennis  *
    117  1.102    dennis  * When a lookup is done in the cache, via cache_lookup() or
    118  1.102    dennis  * cache_lookup_raw(), the per-cpu lock below is taken.  This
    119  1.102    dennis  * protects calls to cache_lookup_entry() and cache_invalidate()
    120  1.102    dennis  * against cache_reclaim() but allows lookups to continue in
    121  1.102    dennis  * parallel with cache_enter().
    122  1.102    dennis  *
    123  1.102    dennis  * cache_revlookup() takes namecache_lock to exclude cache_enter()
    124  1.102    dennis  * and cache_reclaim() since the list it operates on is not
    125  1.102    dennis  * maintained to allow concurrent reads.
    126  1.102    dennis  *
    127  1.102    dennis  * When cache_reclaim() is called namecache_lock is held to hold
    128  1.102    dennis  * off calls to cache_enter()/cache_revlookup() and each of the
    129  1.102    dennis  * per-cpu locks is taken to hold off lookups.  Holding all these
    130  1.102    dennis  * locks essentially idles the subsystem, ensuring there are no
    131  1.102    dennis  * concurrent references to the cache entries being freed.
    132  1.102    dennis  *
    133  1.103    dennis  * 32 bit per-cpu statistic counters (struct nchstats_percpu) are
    134  1.103    dennis  * incremented when the operations they count are performed while
    135  1.103    dennis  * running on the corresponding CPU.  Frequently individual counters
    136  1.103    dennis  * are incremented while holding a lock (either a per-cpu lock or
    137  1.103    dennis  * namecache_lock) sufficient to preclude concurrent increments
    138  1.103    dennis  * being done to the same counter, so non-atomic increments are
    139  1.103    dennis  * done using the COUNT() macro.  Counters which are incremented
    140  1.103    dennis  * when one of these locks is not held use the COUNT_UNL() macro
    141  1.103    dennis  * instead.  COUNT_UNL() could be defined to do atomic increments
    142  1.103    dennis  * but currently just does what COUNT() does, on the theory that
    143  1.103    dennis  * it is unlikely the non-atomic increment will be interrupted
    144  1.103    dennis  * by something on the same CPU that increments the same counter,
    145  1.103    dennis  * but even if it does happen the consequences aren't serious.
    146  1.103    dennis  *
    147  1.103    dennis  * N.B.: Attempting to protect COUNT_UNL() increments by taking
    148  1.103    dennis  * a per-cpu lock in the namecache_count_*() functions causes
    149  1.103    dennis  * a deadlock.  Don't do that, use atomic increments instead if
    150  1.103    dennis  * the imperfections here bug you.
    151  1.103    dennis  *
    152  1.103    dennis  * The 64 bit system-wide statistic counts (struct nchstats) are
    153  1.103    dennis  * maintained by sampling the per-cpu counters periodically, adding
    154  1.103    dennis  * in the deltas since the last samples and recording the current
    155  1.103    dennis  * samples to use to compute the next delta.  The sampling is done
    156  1.103    dennis  * as a side effect of cache_reclaim() which is run periodically,
    157  1.103    dennis  * for its own purposes, often enough to avoid overflow of the 32
    158  1.103    dennis  * bit counters.  While sampling in this fashion requires no locking
    159  1.103    dennis  * it is never-the-less done only after all locks have been taken by
    160  1.103    dennis  * cache_reclaim() to allow cache_stat_sysctl() to hold off
    161  1.103    dennis  * cache_reclaim() with minimal locking.
    162  1.103    dennis  *
    163  1.103    dennis  * cache_stat_sysctl() takes its CPU's per-cpu lock to hold off
    164  1.103    dennis  * cache_reclaim() so that it can copy the subsystem total stats
    165  1.103    dennis  * without them being concurrently modified.  If CACHE_STATS_CURRENT
    166  1.103    dennis  * is defined it also harvests the per-cpu increments into the total,
    167  1.103    dennis  * which again requires cache_reclaim() to be held off.
    168  1.102    dennis  *
    169  1.103    dennis  * The per-cpu data (a lock and the per-cpu stats structures)
    170  1.103    dennis  * are defined next.
    171   1.77        ad  */
    172  1.103    dennis struct nchstats_percpu _NAMEI_CACHE_STATS(uint32_t);
    173  1.103    dennis 
    174   1.77        ad struct nchcpu {
    175  1.103    dennis 	kmutex_t		cpu_lock;
    176  1.103    dennis 	struct nchstats_percpu	cpu_stats;
    177  1.103    dennis 	/* XXX maybe __cacheline_aligned would improve this? */
    178  1.103    dennis 	struct nchstats_percpu	cpu_stats_last;	/* from last sample */
    179   1.77        ad };
    180   1.77        ad 
    181   1.77        ad /*
    182   1.90  dholland  * The type for the hash code. While the hash function generates a
    183   1.90  dholland  * u32, the hash code has historically been passed around as a u_long,
    184   1.90  dholland  * and the value is modified by xor'ing a uintptr_t, so it's not
    185   1.90  dholland  * entirely clear what the best type is. For now I'll leave it
    186   1.90  dholland  * unchanged as u_long.
    187   1.90  dholland  */
    188   1.90  dholland 
    189   1.90  dholland typedef u_long nchash_t;
    190   1.90  dholland 
    191   1.90  dholland /*
    192    1.1       cgd  * Structures associated with name cacheing.
    193    1.1       cgd  */
    194   1.89     rmind 
    195   1.89     rmind static kmutex_t *namecache_lock __read_mostly;
    196   1.89     rmind static pool_cache_t namecache_cache __read_mostly;
    197   1.89     rmind static TAILQ_HEAD(, namecache) nclruhead __cacheline_aligned;
    198   1.89     rmind 
    199   1.89     rmind static LIST_HEAD(nchashhead, namecache) *nchashtbl __read_mostly;
    200   1.89     rmind static u_long	nchash __read_mostly;
    201   1.89     rmind 
    202   1.90  dholland #define	NCHASH2(hash, dvp)	\
    203   1.90  dholland 	(((hash) ^ ((uintptr_t)(dvp) >> 3)) & nchash)
    204   1.19  sommerfe 
    205   1.89     rmind static LIST_HEAD(ncvhashhead, namecache) *ncvhashtbl __read_mostly;
    206   1.89     rmind static u_long	ncvhash __read_mostly;
    207   1.89     rmind 
    208   1.48      yamt #define	NCVHASH(vp)		(((uintptr_t)(vp) >> 3) & ncvhash)
    209   1.19  sommerfe 
    210   1.89     rmind /* Number of cache entries allocated. */
    211   1.89     rmind static long	numcache __cacheline_aligned;
    212   1.73        ad 
    213   1.89     rmind /* Garbage collection queue and number of entries pending in it. */
    214   1.89     rmind static void	*cache_gcqueue;
    215   1.89     rmind static u_int	cache_gcpend;
    216   1.89     rmind 
    217  1.103    dennis /* Cache effectiveness statistics.  This holds total from per-cpu stats */
    218   1.89     rmind struct nchstats	nchstats __cacheline_aligned;
    219  1.103    dennis 
    220  1.103    dennis /*
    221  1.103    dennis  * Macros to count an event, update the central stats with per-cpu
    222  1.103    dennis  * values and add current per-cpu increments to the subsystem total
    223  1.103    dennis  * last collected by cache_reclaim().
    224  1.103    dennis  */
    225  1.103    dennis #define	CACHE_STATS_CURRENT	/* nothing */
    226  1.103    dennis 
    227  1.103    dennis #define	COUNT(cpup, f)	((cpup)->cpu_stats.f++)
    228  1.103    dennis 
    229  1.103    dennis #define	UPDATE(cpup, f) do { \
    230  1.103    dennis 	struct nchcpu *Xcpup = (cpup); \
    231  1.103    dennis 	uint32_t Xcnt = (volatile uint32_t) Xcpup->cpu_stats.f; \
    232  1.103    dennis 	nchstats.f += Xcnt - Xcpup->cpu_stats_last.f; \
    233  1.103    dennis 	Xcpup->cpu_stats_last.f = Xcnt; \
    234  1.103    dennis } while (/* CONSTCOND */ 0)
    235  1.103    dennis 
    236  1.103    dennis #define	ADD(stats, cpup, f) do { \
    237  1.103    dennis 	struct nchcpu *Xcpup = (cpup); \
    238  1.103    dennis 	stats.f += Xcpup->cpu_stats.f - Xcpup->cpu_stats_last.f; \
    239  1.103    dennis } while (/* CONSTCOND */ 0)
    240  1.103    dennis 
    241  1.103    dennis /* Do unlocked stats the same way. Use a different name to allow mind changes */
    242  1.103    dennis #define	COUNT_UNL(cpup, f)	COUNT((cpup), f)
    243   1.38   thorpej 
    244   1.89     rmind static const int cache_lowat = 95;
    245   1.89     rmind static const int cache_hiwat = 98;
    246   1.89     rmind static const int cache_hottime = 5;	/* number of seconds */
    247   1.89     rmind static int doingcache = 1;		/* 1 => enable the cache */
    248    1.1       cgd 
    249   1.73        ad static struct evcnt cache_ev_scan;
    250   1.73        ad static struct evcnt cache_ev_gc;
    251   1.73        ad static struct evcnt cache_ev_over;
    252   1.73        ad static struct evcnt cache_ev_under;
    253   1.73        ad static struct evcnt cache_ev_forced;
    254   1.73        ad 
    255   1.73        ad static void cache_invalidate(struct namecache *);
    256   1.89     rmind static struct namecache *cache_lookup_entry(
    257   1.91  dholland     const struct vnode *, const char *, size_t);
    258   1.73        ad static void cache_thread(void *);
    259   1.73        ad static void cache_invalidate(struct namecache *);
    260   1.73        ad static void cache_disassociate(struct namecache *);
    261   1.73        ad static void cache_reclaim(void);
    262   1.73        ad static int cache_ctor(void *, void *, int);
    263   1.73        ad static void cache_dtor(void *, void *);
    264   1.46      yamt 
    265  1.104     pooka static struct sysctllog *sysctllog;
    266  1.104     pooka static void sysctl_cache_stat_setup(void);
    267  1.104     pooka 
    268  1.108  christos SDT_PROVIDER_DEFINE(vfs);
    269  1.108  christos 
    270  1.108  christos SDT_PROBE_DEFINE1(vfs, namecache, invalidate, done, "struct vnode *");
    271  1.108  christos SDT_PROBE_DEFINE1(vfs, namecache, purge, parents, "struct vnode *");
    272  1.108  christos SDT_PROBE_DEFINE1(vfs, namecache, purge, children, "struct vnode *");
    273  1.108  christos SDT_PROBE_DEFINE2(vfs, namecache, purge, name, "char *", "size_t");
    274  1.108  christos SDT_PROBE_DEFINE1(vfs, namecache, purge, vfs, "struct mount *");
    275  1.108  christos SDT_PROBE_DEFINE3(vfs, namecache, lookup, hit, "struct vnode *",
    276  1.108  christos     "char *", "size_t");
    277  1.108  christos SDT_PROBE_DEFINE3(vfs, namecache, lookup, miss, "struct vnode *",
    278  1.108  christos     "char *", "size_t");
    279  1.108  christos SDT_PROBE_DEFINE3(vfs, namecache, lookup, toolong, "struct vnode *",
    280  1.108  christos     "char *", "size_t");
    281  1.108  christos SDT_PROBE_DEFINE2(vfs, namecache, revlookup, success, "struct vnode *",
    282  1.108  christos      "struct vnode *");
    283  1.108  christos SDT_PROBE_DEFINE2(vfs, namecache, revlookup, fail, "struct vnode *",
    284  1.108  christos      "int");
    285  1.108  christos SDT_PROBE_DEFINE2(vfs, namecache, prune, done, "int", "int");
    286  1.108  christos SDT_PROBE_DEFINE3(vfs, namecache, enter, toolong, "struct vnode *",
    287  1.108  christos     "char *", "size_t");
    288  1.108  christos SDT_PROBE_DEFINE3(vfs, namecache, enter, done, "struct vnode *",
    289  1.108  christos     "char *", "size_t");
    290  1.108  christos 
    291   1.73        ad /*
    292   1.90  dholland  * Compute the hash for an entry.
    293   1.90  dholland  *
    294   1.90  dholland  * (This is for now a wrapper around namei_hash, whose interface is
    295   1.90  dholland  * for the time being slightly inconvenient.)
    296   1.90  dholland  */
    297   1.90  dholland static nchash_t
    298   1.91  dholland cache_hash(const char *name, size_t namelen)
    299   1.90  dholland {
    300   1.90  dholland 	const char *endptr;
    301   1.90  dholland 
    302   1.91  dholland 	endptr = name + namelen;
    303   1.91  dholland 	return namei_hash(name, &endptr);
    304   1.90  dholland }
    305   1.90  dholland 
    306   1.90  dholland /*
    307   1.73        ad  * Invalidate a cache entry and enqueue it for garbage collection.
    308  1.103    dennis  * The caller needs to hold namecache_lock or a per-cpu lock to hold
    309  1.103    dennis  * off cache_reclaim().
    310   1.73        ad  */
    311   1.46      yamt static void
    312   1.73        ad cache_invalidate(struct namecache *ncp)
    313   1.46      yamt {
    314   1.73        ad 	void *head;
    315   1.46      yamt 
    316   1.73        ad 	KASSERT(mutex_owned(&ncp->nc_lock));
    317   1.46      yamt 
    318   1.73        ad 	if (ncp->nc_dvp != NULL) {
    319  1.108  christos 		SDT_PROBE(vfs, namecache, invalidate, done, ncp->nc_dvp,
    320  1.108  christos 		    0, 0, 0, 0);
    321  1.108  christos 
    322   1.73        ad 		ncp->nc_vp = NULL;
    323   1.73        ad 		ncp->nc_dvp = NULL;
    324   1.73        ad 		do {
    325   1.73        ad 			head = cache_gcqueue;
    326   1.73        ad 			ncp->nc_gcqueue = head;
    327   1.73        ad 		} while (atomic_cas_ptr(&cache_gcqueue, head, ncp) != head);
    328   1.73        ad 		atomic_inc_uint(&cache_gcpend);
    329   1.73        ad 	}
    330   1.73        ad }
    331   1.46      yamt 
    332   1.73        ad /*
    333   1.73        ad  * Disassociate a namecache entry from any vnodes it is attached to,
    334   1.73        ad  * and remove from the global LRU list.
    335   1.73        ad  */
    336   1.73        ad static void
    337   1.73        ad cache_disassociate(struct namecache *ncp)
    338   1.73        ad {
    339   1.73        ad 
    340   1.73        ad 	KASSERT(mutex_owned(namecache_lock));
    341   1.73        ad 	KASSERT(ncp->nc_dvp == NULL);
    342   1.73        ad 
    343   1.73        ad 	if (ncp->nc_lru.tqe_prev != NULL) {
    344   1.73        ad 		TAILQ_REMOVE(&nclruhead, ncp, nc_lru);
    345   1.73        ad 		ncp->nc_lru.tqe_prev = NULL;
    346   1.46      yamt 	}
    347   1.46      yamt 	if (ncp->nc_vhash.le_prev != NULL) {
    348   1.46      yamt 		LIST_REMOVE(ncp, nc_vhash);
    349   1.46      yamt 		ncp->nc_vhash.le_prev = NULL;
    350   1.46      yamt 	}
    351   1.46      yamt 	if (ncp->nc_vlist.le_prev != NULL) {
    352   1.46      yamt 		LIST_REMOVE(ncp, nc_vlist);
    353   1.46      yamt 		ncp->nc_vlist.le_prev = NULL;
    354   1.46      yamt 	}
    355   1.46      yamt 	if (ncp->nc_dvlist.le_prev != NULL) {
    356   1.46      yamt 		LIST_REMOVE(ncp, nc_dvlist);
    357   1.46      yamt 		ncp->nc_dvlist.le_prev = NULL;
    358   1.46      yamt 	}
    359   1.46      yamt }
    360   1.46      yamt 
    361   1.73        ad /*
    362   1.73        ad  * Lock all CPUs to prevent any cache lookup activity.  Conceptually,
    363   1.73        ad  * this locks out all "readers".
    364   1.73        ad  */
    365   1.46      yamt static void
    366   1.73        ad cache_lock_cpus(void)
    367   1.46      yamt {
    368   1.73        ad 	CPU_INFO_ITERATOR cii;
    369   1.73        ad 	struct cpu_info *ci;
    370   1.77        ad 	struct nchcpu *cpup;
    371   1.46      yamt 
    372  1.103    dennis 	/*
    373  1.103    dennis 	 * Lock out all CPUs first, then harvest per-cpu stats.  This
    374  1.103    dennis 	 * is probably not quite as cache-efficient as doing the lock
    375  1.103    dennis 	 * and harvest at the same time, but allows cache_stat_sysctl()
    376  1.103    dennis 	 * to make do with a per-cpu lock.
    377  1.103    dennis 	 */
    378   1.73        ad 	for (CPU_INFO_FOREACH(cii, ci)) {
    379   1.77        ad 		cpup = ci->ci_data.cpu_nch;
    380   1.77        ad 		mutex_enter(&cpup->cpu_lock);
    381  1.103    dennis 	}
    382  1.103    dennis 	for (CPU_INFO_FOREACH(cii, ci)) {
    383  1.103    dennis 		cpup = ci->ci_data.cpu_nch;
    384  1.103    dennis 		UPDATE(cpup, ncs_goodhits);
    385  1.103    dennis 		UPDATE(cpup, ncs_neghits);
    386  1.103    dennis 		UPDATE(cpup, ncs_badhits);
    387  1.103    dennis 		UPDATE(cpup, ncs_falsehits);
    388  1.103    dennis 		UPDATE(cpup, ncs_miss);
    389  1.103    dennis 		UPDATE(cpup, ncs_long);
    390  1.103    dennis 		UPDATE(cpup, ncs_pass2);
    391  1.103    dennis 		UPDATE(cpup, ncs_2passes);
    392  1.103    dennis 		UPDATE(cpup, ncs_revhits);
    393  1.103    dennis 		UPDATE(cpup, ncs_revmiss);
    394   1.73        ad 	}
    395   1.46      yamt }
    396   1.46      yamt 
    397   1.73        ad /*
    398   1.73        ad  * Release all CPU locks.
    399   1.73        ad  */
    400   1.73        ad static void
    401   1.73        ad cache_unlock_cpus(void)
    402   1.73        ad {
    403   1.73        ad 	CPU_INFO_ITERATOR cii;
    404   1.73        ad 	struct cpu_info *ci;
    405   1.77        ad 	struct nchcpu *cpup;
    406   1.73        ad 
    407   1.73        ad 	for (CPU_INFO_FOREACH(cii, ci)) {
    408   1.77        ad 		cpup = ci->ci_data.cpu_nch;
    409   1.77        ad 		mutex_exit(&cpup->cpu_lock);
    410   1.73        ad 	}
    411   1.73        ad }
    412   1.73        ad 
    413   1.73        ad /*
    414  1.103    dennis  * Find a single cache entry and return it locked.
    415  1.103    dennis  * The caller needs to hold namecache_lock or a per-cpu lock to hold
    416  1.103    dennis  * off cache_reclaim().
    417   1.73        ad  */
    418   1.73        ad static struct namecache *
    419   1.91  dholland cache_lookup_entry(const struct vnode *dvp, const char *name, size_t namelen)
    420   1.55      yamt {
    421   1.55      yamt 	struct nchashhead *ncpp;
    422   1.55      yamt 	struct namecache *ncp;
    423   1.90  dholland 	nchash_t hash;
    424   1.55      yamt 
    425   1.84      yamt 	KASSERT(dvp != NULL);
    426   1.91  dholland 	hash = cache_hash(name, namelen);
    427   1.90  dholland 	ncpp = &nchashtbl[NCHASH2(hash, dvp)];
    428   1.55      yamt 
    429   1.55      yamt 	LIST_FOREACH(ncp, ncpp, nc_hash) {
    430  1.105    dennis 		membar_datadep_consumer();	/* for Alpha... */
    431   1.73        ad 		if (ncp->nc_dvp != dvp ||
    432   1.91  dholland 		    ncp->nc_nlen != namelen ||
    433   1.91  dholland 		    memcmp(ncp->nc_name, name, (u_int)ncp->nc_nlen))
    434   1.73        ad 		    	continue;
    435   1.73        ad 	    	mutex_enter(&ncp->nc_lock);
    436   1.77        ad 		if (__predict_true(ncp->nc_dvp == dvp)) {
    437   1.73        ad 			ncp->nc_hittime = hardclock_ticks;
    438  1.108  christos 			SDT_PROBE(vfs, namecache, lookup, hit, dvp,
    439  1.108  christos 			    name, namelen, 0, 0);
    440   1.73        ad 			return ncp;
    441   1.73        ad 		}
    442   1.73        ad 		/* Raced: entry has been nullified. */
    443   1.73        ad 		mutex_exit(&ncp->nc_lock);
    444   1.55      yamt 	}
    445   1.55      yamt 
    446  1.108  christos 	SDT_PROBE(vfs, namecache, lookup, miss, dvp,
    447  1.108  christos 	    name, namelen, 0, 0);
    448   1.73        ad 	return NULL;
    449   1.55      yamt }
    450   1.55      yamt 
    451    1.1       cgd /*
    452    1.1       cgd  * Look for a the name in the cache. We don't do this
    453    1.1       cgd  * if the segment name is long, simply so the cache can avoid
    454    1.1       cgd  * holding long names (which would either waste space, or
    455    1.1       cgd  * add greatly to the complexity).
    456    1.1       cgd  *
    457   1.90  dholland  * Lookup is called with DVP pointing to the directory to search,
    458   1.90  dholland  * and CNP providing the name of the entry being sought: cn_nameptr
    459   1.90  dholland  * is the name, cn_namelen is its length, and cn_flags is the flags
    460   1.90  dholland  * word from the namei operation.
    461   1.90  dholland  *
    462   1.90  dholland  * DVP must be locked.
    463   1.90  dholland  *
    464   1.90  dholland  * There are three possible non-error return states:
    465   1.90  dholland  *    1. Nothing was found in the cache. Nothing is known about
    466   1.90  dholland  *       the requested name.
    467   1.90  dholland  *    2. A negative entry was found in the cache, meaning that the
    468   1.90  dholland  *       requested name definitely does not exist.
    469   1.90  dholland  *    3. A positive entry was found in the cache, meaning that the
    470   1.90  dholland  *       requested name does exist and that we are providing the
    471   1.90  dholland  *       vnode.
    472   1.90  dholland  * In these cases the results are:
    473   1.90  dholland  *    1. 0 returned; VN is set to NULL.
    474   1.90  dholland  *    2. 1 returned; VN is set to NULL.
    475   1.90  dholland  *    3. 1 returned; VN is set to the vnode found.
    476   1.90  dholland  *
    477   1.90  dholland  * The additional result argument ISWHT is set to zero, unless a
    478   1.90  dholland  * negative entry is found that was entered as a whiteout, in which
    479   1.90  dholland  * case ISWHT is set to one.
    480   1.90  dholland  *
    481   1.90  dholland  * The ISWHT_RET argument pointer may be null. In this case an
    482   1.90  dholland  * assertion is made that the whiteout flag is not set. File systems
    483   1.90  dholland  * that do not support whiteouts can/should do this.
    484   1.90  dholland  *
    485   1.90  dholland  * Filesystems that do support whiteouts should add ISWHITEOUT to
    486   1.90  dholland  * cnp->cn_flags if ISWHT comes back nonzero.
    487   1.90  dholland  *
    488   1.90  dholland  * When a vnode is returned, it is locked, as per the vnode lookup
    489   1.90  dholland  * locking protocol.
    490   1.90  dholland  *
    491   1.90  dholland  * There is no way for this function to fail, in the sense of
    492   1.90  dholland  * generating an error that requires aborting the namei operation.
    493   1.90  dholland  *
    494   1.90  dholland  * (Prior to October 2012, this function returned an integer status,
    495   1.90  dholland  * and a vnode, and mucked with the flags word in CNP for whiteouts.
    496   1.90  dholland  * The integer status was -1 for "nothing found", ENOENT for "a
    497   1.90  dholland  * negative entry found", 0 for "a positive entry found", and possibly
    498   1.90  dholland  * other errors, and the value of VN might or might not have been set
    499   1.90  dholland  * depending on what error occurred.)
    500    1.1       cgd  */
    501    1.5   mycroft int
    502   1.91  dholland cache_lookup(struct vnode *dvp, const char *name, size_t namelen,
    503   1.91  dholland 	     uint32_t nameiop, uint32_t cnflags,
    504   1.90  dholland 	     int *iswht_ret, struct vnode **vn_ret)
    505    1.1       cgd {
    506   1.23  augustss 	struct namecache *ncp;
    507   1.20  jdolecek 	struct vnode *vp;
    508   1.77        ad 	struct nchcpu *cpup;
    509  1.103    dennis 	int error, ret_value;
    510  1.103    dennis 
    511    1.1       cgd 
    512   1.90  dholland 	/* Establish default result values */
    513   1.90  dholland 	if (iswht_ret != NULL) {
    514   1.90  dholland 		*iswht_ret = 0;
    515   1.90  dholland 	}
    516   1.90  dholland 	*vn_ret = NULL;
    517   1.90  dholland 
    518   1.77        ad 	if (__predict_false(!doingcache)) {
    519   1.90  dholland 		return 0;
    520    1.8       cgd 	}
    521   1.39        pk 
    522   1.77        ad 	cpup = curcpu()->ci_data.cpu_nch;
    523  1.102    dennis 	mutex_enter(&cpup->cpu_lock);
    524   1.91  dholland 	if (__predict_false(namelen > NCHNAMLEN)) {
    525  1.108  christos 		SDT_PROBE(vfs, namecache, lookup, toolong, dvp,
    526  1.108  christos 		    name, namelen, 0, 0);
    527  1.103    dennis 		COUNT(cpup, ncs_long);
    528   1.77        ad 		mutex_exit(&cpup->cpu_lock);
    529   1.90  dholland 		/* found nothing */
    530   1.90  dholland 		return 0;
    531    1.1       cgd 	}
    532  1.103    dennis 
    533   1.91  dholland 	ncp = cache_lookup_entry(dvp, name, namelen);
    534   1.77        ad 	if (__predict_false(ncp == NULL)) {
    535  1.103    dennis 		COUNT(cpup, ncs_miss);
    536   1.77        ad 		mutex_exit(&cpup->cpu_lock);
    537   1.90  dholland 		/* found nothing */
    538   1.90  dholland 		return 0;
    539    1.1       cgd 	}
    540   1.91  dholland 	if ((cnflags & MAKEENTRY) == 0) {
    541  1.103    dennis 		COUNT(cpup, ncs_badhits);
    542   1.77        ad 		/*
    543   1.77        ad 		 * Last component and we are renaming or deleting,
    544   1.77        ad 		 * the cache entry is invalid, or otherwise don't
    545   1.77        ad 		 * want cache entry to exist.
    546   1.77        ad 		 */
    547   1.77        ad 		cache_invalidate(ncp);
    548   1.77        ad 		mutex_exit(&ncp->nc_lock);
    549  1.102    dennis 		mutex_exit(&cpup->cpu_lock);
    550   1.90  dholland 		/* found nothing */
    551   1.90  dholland 		return 0;
    552   1.90  dholland 	}
    553   1.90  dholland 	if (ncp->nc_vp == NULL) {
    554   1.90  dholland 		if (iswht_ret != NULL) {
    555   1.90  dholland 			/*
    556   1.90  dholland 			 * Restore the ISWHITEOUT flag saved earlier.
    557   1.90  dholland 			 */
    558   1.90  dholland 			KASSERT((ncp->nc_flags & ~ISWHITEOUT) == 0);
    559   1.90  dholland 			*iswht_ret = (ncp->nc_flags & ISWHITEOUT) != 0;
    560   1.90  dholland 		} else {
    561   1.90  dholland 			KASSERT(ncp->nc_flags == 0);
    562   1.90  dholland 		}
    563   1.90  dholland 
    564   1.91  dholland 		if (__predict_true(nameiop != CREATE ||
    565   1.91  dholland 		    (cnflags & ISLASTCN) == 0)) {
    566  1.103    dennis 			COUNT(cpup, ncs_neghits);
    567   1.90  dholland 			/* found neg entry; vn is already null from above */
    568  1.103    dennis 			ret_value = 1;
    569   1.20  jdolecek 		} else {
    570  1.103    dennis 			COUNT(cpup, ncs_badhits);
    571   1.77        ad 			/*
    572  1.109  dholland 			 * Last component and we are preparing to create
    573  1.109  dholland 			 * the named object, so flush the negative cache
    574  1.109  dholland 			 * entry.
    575   1.77        ad 			 */
    576   1.77        ad 			cache_invalidate(ncp);
    577   1.90  dholland 			/* found nothing */
    578  1.103    dennis 			ret_value = 0;
    579   1.20  jdolecek 		}
    580  1.103    dennis 		mutex_exit(&ncp->nc_lock);
    581  1.103    dennis 		mutex_exit(&cpup->cpu_lock);
    582  1.103    dennis 		return ret_value;
    583   1.20  jdolecek 	}
    584   1.20  jdolecek 
    585   1.20  jdolecek 	vp = ncp->nc_vp;
    586   1.92   hannken 	mutex_enter(vp->v_interlock);
    587   1.92   hannken 	mutex_exit(&ncp->nc_lock);
    588  1.102    dennis 	mutex_exit(&cpup->cpu_lock);
    589  1.103    dennis 
    590  1.103    dennis 	/*
    591  1.111   hannken 	 * Unlocked except for the vnode interlock.  Call vcache_tryvget().
    592  1.103    dennis 	 */
    593  1.111   hannken 	error = vcache_tryvget(vp);
    594   1.92   hannken 	if (error) {
    595   1.92   hannken 		KASSERT(error == EBUSY);
    596   1.92   hannken 		/*
    597   1.92   hannken 		 * This vnode is being cleaned out.
    598   1.92   hannken 		 * XXX badhits?
    599   1.92   hannken 		 */
    600  1.103    dennis 		COUNT_UNL(cpup, ncs_falsehits);
    601   1.92   hannken 		/* found nothing */
    602  1.101  christos 		return 0;
    603   1.77        ad 	}
    604  1.101  christos 
    605  1.103    dennis 	COUNT_UNL(cpup, ncs_goodhits);
    606  1.101  christos 	/* found it */
    607  1.101  christos 	*vn_ret = vp;
    608  1.101  christos 	return 1;
    609    1.1       cgd }
    610    1.1       cgd 
    611  1.103    dennis 
    612  1.103    dennis /*
    613  1.103    dennis  * Cut-'n-pasted version of the above without the nameiop argument.
    614  1.103    dennis  */
    615   1.61      yamt int
    616   1.91  dholland cache_lookup_raw(struct vnode *dvp, const char *name, size_t namelen,
    617   1.91  dholland 		 uint32_t cnflags,
    618   1.90  dholland 		 int *iswht_ret, struct vnode **vn_ret)
    619   1.61      yamt {
    620   1.61      yamt 	struct namecache *ncp;
    621   1.61      yamt 	struct vnode *vp;
    622   1.77        ad 	struct nchcpu *cpup;
    623  1.101  christos 	int error;
    624   1.61      yamt 
    625   1.90  dholland 	/* Establish default results. */
    626   1.90  dholland 	if (iswht_ret != NULL) {
    627   1.90  dholland 		*iswht_ret = 0;
    628   1.90  dholland 	}
    629   1.90  dholland 	*vn_ret = NULL;
    630   1.90  dholland 
    631   1.77        ad 	if (__predict_false(!doingcache)) {
    632   1.90  dholland 		/* found nothing */
    633   1.90  dholland 		return 0;
    634   1.61      yamt 	}
    635   1.61      yamt 
    636   1.77        ad 	cpup = curcpu()->ci_data.cpu_nch;
    637  1.102    dennis 	mutex_enter(&cpup->cpu_lock);
    638   1.91  dholland 	if (__predict_false(namelen > NCHNAMLEN)) {
    639  1.103    dennis 		COUNT(cpup, ncs_long);
    640   1.77        ad 		mutex_exit(&cpup->cpu_lock);
    641   1.90  dholland 		/* found nothing */
    642   1.90  dholland 		return 0;
    643   1.61      yamt 	}
    644   1.91  dholland 	ncp = cache_lookup_entry(dvp, name, namelen);
    645   1.77        ad 	if (__predict_false(ncp == NULL)) {
    646  1.103    dennis 		COUNT(cpup, ncs_miss);
    647   1.77        ad 		mutex_exit(&cpup->cpu_lock);
    648   1.90  dholland 		/* found nothing */
    649   1.90  dholland 		return 0;
    650   1.61      yamt 	}
    651   1.61      yamt 	vp = ncp->nc_vp;
    652   1.61      yamt 	if (vp == NULL) {
    653   1.61      yamt 		/*
    654   1.61      yamt 		 * Restore the ISWHITEOUT flag saved earlier.
    655   1.61      yamt 		 */
    656   1.90  dholland 		if (iswht_ret != NULL) {
    657   1.90  dholland 			KASSERT((ncp->nc_flags & ~ISWHITEOUT) == 0);
    658   1.90  dholland 			/*cnp->cn_flags |= ncp->nc_flags;*/
    659   1.90  dholland 			*iswht_ret = (ncp->nc_flags & ISWHITEOUT) != 0;
    660   1.90  dholland 		}
    661  1.103    dennis 		COUNT(cpup, ncs_neghits);
    662  1.102    dennis 		mutex_exit(&ncp->nc_lock);
    663  1.101  christos 		mutex_exit(&cpup->cpu_lock);
    664   1.90  dholland 		/* found negative entry; vn is already null from above */
    665   1.90  dholland 		return 1;
    666   1.61      yamt 	}
    667   1.92   hannken 	mutex_enter(vp->v_interlock);
    668   1.92   hannken 	mutex_exit(&ncp->nc_lock);
    669  1.102    dennis 	mutex_exit(&cpup->cpu_lock);
    670  1.103    dennis 
    671  1.103    dennis 	/*
    672  1.111   hannken 	 * Unlocked except for the vnode interlock.  Call vcache_tryvget().
    673  1.103    dennis 	 */
    674  1.111   hannken 	error = vcache_tryvget(vp);
    675   1.92   hannken 	if (error) {
    676   1.92   hannken 		KASSERT(error == EBUSY);
    677   1.92   hannken 		/*
    678   1.92   hannken 		 * This vnode is being cleaned out.
    679   1.92   hannken 		 * XXX badhits?
    680   1.92   hannken 		 */
    681  1.103    dennis 		COUNT_UNL(cpup, ncs_falsehits);
    682   1.92   hannken 		/* found nothing */
    683  1.101  christos 		return 0;
    684   1.61      yamt 	}
    685  1.101  christos 
    686  1.103    dennis 	COUNT_UNL(cpup, ncs_goodhits); /* XXX can be "badhits" */
    687  1.101  christos 	/* found it */
    688  1.101  christos 	*vn_ret = vp;
    689  1.101  christos 	return 1;
    690   1.61      yamt }
    691   1.61      yamt 
    692    1.1       cgd /*
    693   1.19  sommerfe  * Scan cache looking for name of directory entry pointing at vp.
    694   1.19  sommerfe  *
    695   1.86   hannken  * If the lookup succeeds the vnode is referenced and stored in dvpp.
    696   1.19  sommerfe  *
    697   1.19  sommerfe  * If bufp is non-NULL, also place the name in the buffer which starts
    698   1.19  sommerfe  * at bufp, immediately before *bpp, and move bpp backwards to point
    699   1.19  sommerfe  * at the start of it.  (Yes, this is a little baroque, but it's done
    700   1.19  sommerfe  * this way to cater to the whims of getcwd).
    701   1.19  sommerfe  *
    702   1.19  sommerfe  * Returns 0 on success, -1 on cache miss, positive errno on failure.
    703   1.19  sommerfe  */
    704   1.19  sommerfe int
    705   1.34     enami cache_revlookup(struct vnode *vp, struct vnode **dvpp, char **bpp, char *bufp)
    706   1.19  sommerfe {
    707   1.19  sommerfe 	struct namecache *ncp;
    708   1.19  sommerfe 	struct vnode *dvp;
    709  1.103    dennis 	struct ncvhashhead *nvcpp;
    710   1.95     joerg 	struct nchcpu *cpup;
    711   1.34     enami 	char *bp;
    712   1.86   hannken 	int error, nlen;
    713   1.34     enami 
    714   1.19  sommerfe 	if (!doingcache)
    715   1.19  sommerfe 		goto out;
    716   1.19  sommerfe 
    717   1.30       chs 	nvcpp = &ncvhashtbl[NCVHASH(vp)];
    718  1.103    dennis 
    719  1.103    dennis 	/*
    720  1.103    dennis 	 * We increment counters in the local CPU's per-cpu stats.
    721  1.103    dennis 	 * We don't take the per-cpu lock, however, since this function
    722  1.103    dennis 	 * is the only place these counters are incremented so no one
    723  1.103    dennis 	 * will be racing with us to increment them.
    724  1.103    dennis 	 */
    725   1.95     joerg 	cpup = curcpu()->ci_data.cpu_nch;
    726   1.73        ad 	mutex_enter(namecache_lock);
    727   1.27       chs 	LIST_FOREACH(ncp, nvcpp, nc_vhash) {
    728   1.73        ad 		mutex_enter(&ncp->nc_lock);
    729   1.34     enami 		if (ncp->nc_vp == vp &&
    730   1.34     enami 		    (dvp = ncp->nc_dvp) != NULL &&
    731   1.47      yamt 		    dvp != vp) { 		/* avoid pesky . entries.. */
    732   1.34     enami 
    733   1.19  sommerfe #ifdef DIAGNOSTIC
    734   1.34     enami 			if (ncp->nc_nlen == 1 &&
    735   1.34     enami 			    ncp->nc_name[0] == '.')
    736   1.19  sommerfe 				panic("cache_revlookup: found entry for .");
    737   1.19  sommerfe 
    738   1.34     enami 			if (ncp->nc_nlen == 2 &&
    739   1.34     enami 			    ncp->nc_name[0] == '.' &&
    740   1.34     enami 			    ncp->nc_name[1] == '.')
    741   1.19  sommerfe 				panic("cache_revlookup: found entry for ..");
    742   1.19  sommerfe #endif
    743  1.103    dennis 			COUNT(cpup, ncs_revhits);
    744   1.86   hannken 			nlen = ncp->nc_nlen;
    745   1.19  sommerfe 
    746   1.19  sommerfe 			if (bufp) {
    747   1.19  sommerfe 				bp = *bpp;
    748   1.86   hannken 				bp -= nlen;
    749   1.19  sommerfe 				if (bp <= bufp) {
    750   1.34     enami 					*dvpp = NULL;
    751   1.73        ad 					mutex_exit(&ncp->nc_lock);
    752   1.73        ad 					mutex_exit(namecache_lock);
    753  1.108  christos 					SDT_PROBE(vfs, namecache, revlookup,
    754  1.108  christos 					    fail, vp, ERANGE, 0, 0, 0);
    755   1.34     enami 					return (ERANGE);
    756   1.19  sommerfe 				}
    757   1.86   hannken 				memcpy(bp, ncp->nc_name, nlen);
    758   1.19  sommerfe 				*bpp = bp;
    759   1.19  sommerfe 			}
    760   1.34     enami 
    761   1.92   hannken 			mutex_enter(dvp->v_interlock);
    762  1.110   msaitoh 			mutex_exit(&ncp->nc_lock);
    763   1.92   hannken 			mutex_exit(namecache_lock);
    764  1.111   hannken 			error = vcache_tryvget(dvp);
    765   1.92   hannken 			if (error) {
    766   1.92   hannken 				KASSERT(error == EBUSY);
    767   1.92   hannken 				if (bufp)
    768   1.92   hannken 					(*bpp) += nlen;
    769   1.92   hannken 				*dvpp = NULL;
    770  1.108  christos 				SDT_PROBE(vfs, namecache, revlookup, fail, vp,
    771  1.108  christos 				    error, 0, 0, 0);
    772   1.92   hannken 				return -1;
    773   1.86   hannken 			}
    774   1.19  sommerfe 			*dvpp = dvp;
    775  1.108  christos 			SDT_PROBE(vfs, namecache, revlookup, success, vp, dvp,
    776  1.108  christos 			    0, 0, 0);
    777   1.34     enami 			return (0);
    778   1.19  sommerfe 		}
    779   1.73        ad 		mutex_exit(&ncp->nc_lock);
    780   1.19  sommerfe 	}
    781  1.103    dennis 	COUNT(cpup, ncs_revmiss);
    782   1.73        ad 	mutex_exit(namecache_lock);
    783   1.19  sommerfe  out:
    784   1.34     enami 	*dvpp = NULL;
    785   1.34     enami 	return (-1);
    786   1.19  sommerfe }
    787   1.19  sommerfe 
    788   1.19  sommerfe /*
    789    1.1       cgd  * Add an entry to the cache
    790    1.1       cgd  */
    791   1.13  christos void
    792   1.91  dholland cache_enter(struct vnode *dvp, struct vnode *vp,
    793   1.91  dholland 	    const char *name, size_t namelen, uint32_t cnflags)
    794    1.1       cgd {
    795   1.23  augustss 	struct namecache *ncp;
    796   1.59      yamt 	struct namecache *oncp;
    797   1.23  augustss 	struct nchashhead *ncpp;
    798   1.23  augustss 	struct ncvhashhead *nvcpp;
    799   1.90  dholland 	nchash_t hash;
    800    1.1       cgd 
    801   1.89     rmind 	/* First, check whether we can/should add a cache entry. */
    802   1.91  dholland 	if ((cnflags & MAKEENTRY) == 0 ||
    803   1.91  dholland 	    __predict_false(namelen > NCHNAMLEN || !doingcache)) {
    804  1.108  christos 		SDT_PROBE(vfs, namecache, enter, toolong, vp, name, namelen,
    805  1.108  christos 		    0, 0);
    806    1.1       cgd 		return;
    807   1.89     rmind 	}
    808   1.58      yamt 
    809  1.108  christos 	SDT_PROBE(vfs, namecache, enter, done, vp, name, namelen, 0, 0);
    810   1.73        ad 	if (numcache > desiredvnodes) {
    811   1.73        ad 		mutex_enter(namecache_lock);
    812   1.73        ad 		cache_ev_forced.ev_count++;
    813   1.73        ad 		cache_reclaim();
    814   1.73        ad 		mutex_exit(namecache_lock);
    815   1.39        pk 	}
    816   1.57        pk 
    817   1.73        ad 	ncp = pool_cache_get(namecache_cache, PR_WAITOK);
    818   1.73        ad 	mutex_enter(namecache_lock);
    819   1.73        ad 	numcache++;
    820   1.73        ad 
    821   1.59      yamt 	/*
    822   1.59      yamt 	 * Concurrent lookups in the same directory may race for a
    823   1.59      yamt 	 * cache entry.  if there's a duplicated entry, free it.
    824   1.59      yamt 	 */
    825   1.91  dholland 	oncp = cache_lookup_entry(dvp, name, namelen);
    826   1.59      yamt 	if (oncp) {
    827   1.73        ad 		cache_invalidate(oncp);
    828   1.73        ad 		mutex_exit(&oncp->nc_lock);
    829   1.59      yamt 	}
    830   1.59      yamt 
    831   1.34     enami 	/* Grab the vnode we just found. */
    832   1.73        ad 	mutex_enter(&ncp->nc_lock);
    833    1.5   mycroft 	ncp->nc_vp = vp;
    834   1.73        ad 	ncp->nc_flags = 0;
    835   1.73        ad 	ncp->nc_hittime = 0;
    836   1.73        ad 	ncp->nc_gcqueue = NULL;
    837   1.47      yamt 	if (vp == NULL) {
    838   1.11   mycroft 		/*
    839   1.11   mycroft 		 * For negative hits, save the ISWHITEOUT flag so we can
    840   1.11   mycroft 		 * restore it later when the cache entry is used again.
    841   1.11   mycroft 		 */
    842   1.91  dholland 		ncp->nc_flags = cnflags & ISWHITEOUT;
    843   1.11   mycroft 	}
    844   1.89     rmind 
    845   1.34     enami 	/* Fill in cache info. */
    846    1.5   mycroft 	ncp->nc_dvp = dvp;
    847   1.46      yamt 	LIST_INSERT_HEAD(&dvp->v_dnclist, ncp, nc_dvlist);
    848   1.46      yamt 	if (vp)
    849   1.46      yamt 		LIST_INSERT_HEAD(&vp->v_nclist, ncp, nc_vlist);
    850   1.73        ad 	else {
    851   1.73        ad 		ncp->nc_vlist.le_prev = NULL;
    852   1.73        ad 		ncp->nc_vlist.le_next = NULL;
    853   1.73        ad 	}
    854   1.91  dholland 	KASSERT(namelen <= NCHNAMLEN);
    855   1.91  dholland 	ncp->nc_nlen = namelen;
    856   1.91  dholland 	memcpy(ncp->nc_name, name, (unsigned)ncp->nc_nlen);
    857   1.73        ad 	TAILQ_INSERT_TAIL(&nclruhead, ncp, nc_lru);
    858   1.91  dholland 	hash = cache_hash(name, namelen);
    859   1.90  dholland 	ncpp = &nchashtbl[NCHASH2(hash, dvp)];
    860   1.73        ad 
    861   1.73        ad 	/*
    862   1.73        ad 	 * Flush updates before making visible in table.  No need for a
    863   1.73        ad 	 * memory barrier on the other side: to see modifications the
    864   1.73        ad 	 * list must be followed, meaning a dependent pointer load.
    865   1.74        ad 	 * The below is LIST_INSERT_HEAD() inlined, with the memory
    866   1.74        ad 	 * barrier included in the correct place.
    867   1.73        ad 	 */
    868   1.74        ad 	if ((ncp->nc_hash.le_next = ncpp->lh_first) != NULL)
    869   1.74        ad 		ncpp->lh_first->nc_hash.le_prev = &ncp->nc_hash.le_next;
    870   1.74        ad 	ncp->nc_hash.le_prev = &ncpp->lh_first;
    871   1.73        ad 	membar_producer();
    872   1.74        ad 	ncpp->lh_first = ncp;
    873   1.19  sommerfe 
    874   1.34     enami 	ncp->nc_vhash.le_prev = NULL;
    875   1.34     enami 	ncp->nc_vhash.le_next = NULL;
    876   1.34     enami 
    877   1.19  sommerfe 	/*
    878   1.19  sommerfe 	 * Create reverse-cache entries (used in getcwd) for directories.
    879   1.66  christos 	 * (and in linux procfs exe node)
    880   1.19  sommerfe 	 */
    881   1.33     enami 	if (vp != NULL &&
    882   1.33     enami 	    vp != dvp &&
    883   1.29      fvdl #ifndef NAMECACHE_ENTER_REVERSE
    884   1.33     enami 	    vp->v_type == VDIR &&
    885   1.29      fvdl #endif
    886   1.33     enami 	    (ncp->nc_nlen > 2 ||
    887   1.33     enami 	    (ncp->nc_nlen > 1 && ncp->nc_name[1] != '.') ||
    888   1.33     enami 	    (/* ncp->nc_nlen > 0 && */ ncp->nc_name[0] != '.'))) {
    889   1.30       chs 		nvcpp = &ncvhashtbl[NCVHASH(vp)];
    890   1.19  sommerfe 		LIST_INSERT_HEAD(nvcpp, ncp, nc_vhash);
    891   1.19  sommerfe 	}
    892   1.73        ad 	mutex_exit(&ncp->nc_lock);
    893   1.73        ad 	mutex_exit(namecache_lock);
    894    1.1       cgd }
    895    1.1       cgd 
    896    1.1       cgd /*
    897    1.1       cgd  * Name cache initialization, from vfs_init() when we are booting
    898    1.1       cgd  */
    899   1.13  christos void
    900   1.34     enami nchinit(void)
    901    1.1       cgd {
    902   1.73        ad 	int error;
    903    1.1       cgd 
    904   1.89     rmind 	TAILQ_INIT(&nclruhead);
    905   1.73        ad 	namecache_cache = pool_cache_init(sizeof(struct namecache),
    906   1.73        ad 	    coherency_unit, 0, 0, "ncache", NULL, IPL_NONE, cache_ctor,
    907   1.73        ad 	    cache_dtor, NULL);
    908   1.71        ad 	KASSERT(namecache_cache != NULL);
    909   1.71        ad 
    910   1.73        ad 	namecache_lock = mutex_obj_alloc(MUTEX_DEFAULT, IPL_NONE);
    911   1.73        ad 
    912   1.76        ad 	nchashtbl = hashinit(desiredvnodes, HASH_LIST, true, &nchash);
    913   1.26        ad 	ncvhashtbl =
    914   1.29      fvdl #ifdef NAMECACHE_ENTER_REVERSE
    915   1.76        ad 	    hashinit(desiredvnodes, HASH_LIST, true, &ncvhash);
    916   1.29      fvdl #else
    917   1.76        ad 	    hashinit(desiredvnodes/8, HASH_LIST, true, &ncvhash);
    918   1.29      fvdl #endif
    919   1.73        ad 
    920   1.73        ad 	error = kthread_create(PRI_VM, KTHREAD_MPSAFE, NULL, cache_thread,
    921   1.73        ad 	    NULL, NULL, "cachegc");
    922   1.73        ad 	if (error != 0)
    923   1.73        ad 		panic("nchinit %d", error);
    924   1.73        ad 
    925   1.73        ad 	evcnt_attach_dynamic(&cache_ev_scan, EVCNT_TYPE_MISC, NULL,
    926   1.73        ad 	   "namecache", "entries scanned");
    927   1.73        ad 	evcnt_attach_dynamic(&cache_ev_gc, EVCNT_TYPE_MISC, NULL,
    928   1.73        ad 	   "namecache", "entries collected");
    929   1.73        ad 	evcnt_attach_dynamic(&cache_ev_over, EVCNT_TYPE_MISC, NULL,
    930   1.73        ad 	   "namecache", "over scan target");
    931   1.73        ad 	evcnt_attach_dynamic(&cache_ev_under, EVCNT_TYPE_MISC, NULL,
    932   1.73        ad 	   "namecache", "under scan target");
    933   1.73        ad 	evcnt_attach_dynamic(&cache_ev_forced, EVCNT_TYPE_MISC, NULL,
    934   1.73        ad 	   "namecache", "forced reclaims");
    935  1.104     pooka 
    936  1.104     pooka 	sysctl_cache_stat_setup();
    937   1.73        ad }
    938   1.73        ad 
    939   1.73        ad static int
    940   1.73        ad cache_ctor(void *arg, void *obj, int flag)
    941   1.73        ad {
    942   1.73        ad 	struct namecache *ncp;
    943   1.73        ad 
    944   1.73        ad 	ncp = obj;
    945   1.73        ad 	mutex_init(&ncp->nc_lock, MUTEX_DEFAULT, IPL_NONE);
    946   1.73        ad 
    947   1.73        ad 	return 0;
    948   1.73        ad }
    949   1.73        ad 
    950   1.73        ad static void
    951   1.73        ad cache_dtor(void *arg, void *obj)
    952   1.73        ad {
    953   1.73        ad 	struct namecache *ncp;
    954   1.73        ad 
    955   1.73        ad 	ncp = obj;
    956   1.73        ad 	mutex_destroy(&ncp->nc_lock);
    957   1.73        ad }
    958   1.73        ad 
    959   1.73        ad /*
    960   1.73        ad  * Called once for each CPU in the system as attached.
    961   1.73        ad  */
    962   1.73        ad void
    963   1.73        ad cache_cpu_init(struct cpu_info *ci)
    964   1.73        ad {
    965   1.77        ad 	struct nchcpu *cpup;
    966   1.77        ad 	size_t sz;
    967   1.73        ad 
    968   1.77        ad 	sz = roundup2(sizeof(*cpup), coherency_unit) + coherency_unit;
    969   1.77        ad 	cpup = kmem_zalloc(sz, KM_SLEEP);
    970   1.77        ad 	cpup = (void *)roundup2((uintptr_t)cpup, coherency_unit);
    971   1.77        ad 	mutex_init(&cpup->cpu_lock, MUTEX_DEFAULT, IPL_NONE);
    972   1.77        ad 	ci->ci_data.cpu_nch = cpup;
    973   1.30       chs }
    974   1.30       chs 
    975   1.30       chs /*
    976   1.30       chs  * Name cache reinitialization, for when the maximum number of vnodes increases.
    977   1.30       chs  */
    978   1.30       chs void
    979   1.34     enami nchreinit(void)
    980   1.30       chs {
    981   1.30       chs 	struct namecache *ncp;
    982   1.30       chs 	struct nchashhead *oldhash1, *hash1;
    983   1.30       chs 	struct ncvhashhead *oldhash2, *hash2;
    984   1.36   thorpej 	u_long i, oldmask1, oldmask2, mask1, mask2;
    985   1.30       chs 
    986   1.76        ad 	hash1 = hashinit(desiredvnodes, HASH_LIST, true, &mask1);
    987   1.30       chs 	hash2 =
    988   1.30       chs #ifdef NAMECACHE_ENTER_REVERSE
    989   1.76        ad 	    hashinit(desiredvnodes, HASH_LIST, true, &mask2);
    990   1.30       chs #else
    991   1.76        ad 	    hashinit(desiredvnodes/8, HASH_LIST, true, &mask2);
    992   1.30       chs #endif
    993   1.73        ad 	mutex_enter(namecache_lock);
    994   1.73        ad 	cache_lock_cpus();
    995   1.30       chs 	oldhash1 = nchashtbl;
    996   1.30       chs 	oldmask1 = nchash;
    997   1.30       chs 	nchashtbl = hash1;
    998   1.30       chs 	nchash = mask1;
    999   1.30       chs 	oldhash2 = ncvhashtbl;
   1000   1.30       chs 	oldmask2 = ncvhash;
   1001   1.30       chs 	ncvhashtbl = hash2;
   1002   1.30       chs 	ncvhash = mask2;
   1003   1.30       chs 	for (i = 0; i <= oldmask1; i++) {
   1004   1.30       chs 		while ((ncp = LIST_FIRST(&oldhash1[i])) != NULL) {
   1005   1.30       chs 			LIST_REMOVE(ncp, nc_hash);
   1006   1.30       chs 			ncp->nc_hash.le_prev = NULL;
   1007   1.30       chs 		}
   1008   1.30       chs 	}
   1009   1.30       chs 	for (i = 0; i <= oldmask2; i++) {
   1010   1.30       chs 		while ((ncp = LIST_FIRST(&oldhash2[i])) != NULL) {
   1011   1.30       chs 			LIST_REMOVE(ncp, nc_vhash);
   1012   1.30       chs 			ncp->nc_vhash.le_prev = NULL;
   1013   1.30       chs 		}
   1014   1.30       chs 	}
   1015   1.73        ad 	cache_unlock_cpus();
   1016   1.73        ad 	mutex_exit(namecache_lock);
   1017   1.76        ad 	hashdone(oldhash1, HASH_LIST, oldmask1);
   1018   1.76        ad 	hashdone(oldhash2, HASH_LIST, oldmask2);
   1019    1.1       cgd }
   1020    1.1       cgd 
   1021    1.1       cgd /*
   1022    1.1       cgd  * Cache flush, a particular vnode; called when a vnode is renamed to
   1023    1.1       cgd  * hide entries that would now be invalid
   1024    1.1       cgd  */
   1025   1.13  christos void
   1026   1.91  dholland cache_purge1(struct vnode *vp, const char *name, size_t namelen, int flags)
   1027    1.1       cgd {
   1028   1.46      yamt 	struct namecache *ncp, *ncnext;
   1029    1.1       cgd 
   1030   1.73        ad 	mutex_enter(namecache_lock);
   1031   1.55      yamt 	if (flags & PURGE_PARENTS) {
   1032  1.108  christos 		SDT_PROBE(vfs, namecache, purge, parents, vp, 0, 0, 0, 0);
   1033  1.108  christos 
   1034   1.55      yamt 		for (ncp = LIST_FIRST(&vp->v_nclist); ncp != NULL;
   1035   1.55      yamt 		    ncp = ncnext) {
   1036   1.55      yamt 			ncnext = LIST_NEXT(ncp, nc_vlist);
   1037   1.73        ad 			mutex_enter(&ncp->nc_lock);
   1038   1.73        ad 			cache_invalidate(ncp);
   1039   1.73        ad 			mutex_exit(&ncp->nc_lock);
   1040   1.73        ad 			cache_disassociate(ncp);
   1041   1.55      yamt 		}
   1042   1.55      yamt 	}
   1043   1.55      yamt 	if (flags & PURGE_CHILDREN) {
   1044  1.108  christos 		SDT_PROBE(vfs, namecache, purge, children, vp, 0, 0, 0, 0);
   1045   1.55      yamt 		for (ncp = LIST_FIRST(&vp->v_dnclist); ncp != NULL;
   1046   1.55      yamt 		    ncp = ncnext) {
   1047   1.55      yamt 			ncnext = LIST_NEXT(ncp, nc_dvlist);
   1048   1.73        ad 			mutex_enter(&ncp->nc_lock);
   1049   1.73        ad 			cache_invalidate(ncp);
   1050   1.73        ad 			mutex_exit(&ncp->nc_lock);
   1051   1.73        ad 			cache_disassociate(ncp);
   1052   1.55      yamt 		}
   1053   1.46      yamt 	}
   1054   1.91  dholland 	if (name != NULL) {
   1055  1.108  christos 		SDT_PROBE(vfs, namecache, purge, name, name, namelen, 0, 0, 0);
   1056   1.91  dholland 		ncp = cache_lookup_entry(vp, name, namelen);
   1057   1.55      yamt 		if (ncp) {
   1058   1.73        ad 			cache_invalidate(ncp);
   1059   1.83      yamt 			mutex_exit(&ncp->nc_lock);
   1060   1.73        ad 			cache_disassociate(ncp);
   1061   1.55      yamt 		}
   1062   1.46      yamt 	}
   1063   1.73        ad 	mutex_exit(namecache_lock);
   1064    1.1       cgd }
   1065    1.1       cgd 
   1066    1.1       cgd /*
   1067    1.1       cgd  * Cache flush, a whole filesystem; called when filesys is umounted to
   1068   1.27       chs  * remove entries that would now be invalid.
   1069    1.1       cgd  */
   1070   1.13  christos void
   1071   1.34     enami cache_purgevfs(struct mount *mp)
   1072    1.1       cgd {
   1073   1.23  augustss 	struct namecache *ncp, *nxtcp;
   1074    1.1       cgd 
   1075  1.108  christos 	SDT_PROBE(vfs, namecache, purge, vfs, mp, 0, 0, 0, 0);
   1076   1.73        ad 	mutex_enter(namecache_lock);
   1077   1.73        ad 	for (ncp = TAILQ_FIRST(&nclruhead); ncp != NULL; ncp = nxtcp) {
   1078   1.73        ad 		nxtcp = TAILQ_NEXT(ncp, nc_lru);
   1079   1.73        ad 		mutex_enter(&ncp->nc_lock);
   1080   1.73        ad 		if (ncp->nc_dvp != NULL && ncp->nc_dvp->v_mount == mp) {
   1081   1.73        ad 			/* Free the resources we had. */
   1082   1.73        ad 			cache_invalidate(ncp);
   1083   1.73        ad 			cache_disassociate(ncp);
   1084   1.73        ad 		}
   1085   1.73        ad 		mutex_exit(&ncp->nc_lock);
   1086   1.73        ad 	}
   1087   1.73        ad 	cache_reclaim();
   1088   1.73        ad 	mutex_exit(namecache_lock);
   1089   1.73        ad }
   1090   1.73        ad 
   1091   1.73        ad /*
   1092   1.73        ad  * Scan global list invalidating entries until we meet a preset target.
   1093   1.73        ad  * Prefer to invalidate entries that have not scored a hit within
   1094   1.73        ad  * cache_hottime seconds.  We sort the LRU list only for this routine's
   1095   1.73        ad  * benefit.
   1096   1.73        ad  */
   1097   1.73        ad static void
   1098   1.73        ad cache_prune(int incache, int target)
   1099   1.73        ad {
   1100   1.73        ad 	struct namecache *ncp, *nxtcp, *sentinel;
   1101   1.73        ad 	int items, recent, tryharder;
   1102   1.73        ad 
   1103   1.73        ad 	KASSERT(mutex_owned(namecache_lock));
   1104   1.73        ad 
   1105  1.108  christos 	SDT_PROBE(vfs, namecache, prune, done, incache, target, 0, 0, 0);
   1106   1.73        ad 	items = 0;
   1107   1.73        ad 	tryharder = 0;
   1108   1.73        ad 	recent = hardclock_ticks - hz * cache_hottime;
   1109   1.73        ad 	sentinel = NULL;
   1110   1.27       chs 	for (ncp = TAILQ_FIRST(&nclruhead); ncp != NULL; ncp = nxtcp) {
   1111   1.73        ad 		if (incache <= target)
   1112   1.73        ad 			break;
   1113   1.73        ad 		items++;
   1114   1.27       chs 		nxtcp = TAILQ_NEXT(ncp, nc_lru);
   1115   1.73        ad 		if (ncp == sentinel) {
   1116   1.73        ad 			/*
   1117   1.73        ad 			 * If we looped back on ourself, then ignore
   1118   1.73        ad 			 * recent entries and purge whatever we find.
   1119   1.73        ad 			 */
   1120   1.73        ad 			tryharder = 1;
   1121    1.5   mycroft 		}
   1122   1.93   hannken 		if (ncp->nc_dvp == NULL)
   1123   1.93   hannken 			continue;
   1124   1.81      yamt 		if (!tryharder && (ncp->nc_hittime - recent) > 0) {
   1125   1.73        ad 			if (sentinel == NULL)
   1126   1.73        ad 				sentinel = ncp;
   1127   1.73        ad 			TAILQ_REMOVE(&nclruhead, ncp, nc_lru);
   1128   1.73        ad 			TAILQ_INSERT_TAIL(&nclruhead, ncp, nc_lru);
   1129   1.73        ad 			continue;
   1130   1.73        ad 		}
   1131   1.73        ad 		mutex_enter(&ncp->nc_lock);
   1132   1.73        ad 		if (ncp->nc_dvp != NULL) {
   1133   1.73        ad 			cache_invalidate(ncp);
   1134   1.73        ad 			cache_disassociate(ncp);
   1135   1.73        ad 			incache--;
   1136   1.73        ad 		}
   1137   1.73        ad 		mutex_exit(&ncp->nc_lock);
   1138   1.73        ad 	}
   1139   1.73        ad 	cache_ev_scan.ev_count += items;
   1140   1.73        ad }
   1141   1.73        ad 
   1142   1.73        ad /*
   1143   1.73        ad  * Collect dead cache entries from all CPUs and garbage collect.
   1144   1.73        ad  */
   1145   1.73        ad static void
   1146   1.73        ad cache_reclaim(void)
   1147   1.73        ad {
   1148   1.73        ad 	struct namecache *ncp, *next;
   1149   1.73        ad 	int items;
   1150   1.73        ad 
   1151   1.73        ad 	KASSERT(mutex_owned(namecache_lock));
   1152   1.73        ad 
   1153   1.73        ad 	/*
   1154   1.73        ad 	 * If the number of extant entries not awaiting garbage collection
   1155   1.73        ad 	 * exceeds the high water mark, then reclaim stale entries until we
   1156   1.73        ad 	 * reach our low water mark.
   1157   1.73        ad 	 */
   1158   1.73        ad 	items = numcache - cache_gcpend;
   1159   1.73        ad 	if (items > (uint64_t)desiredvnodes * cache_hiwat / 100) {
   1160   1.73        ad 		cache_prune(items, (int)((uint64_t)desiredvnodes *
   1161   1.73        ad 		    cache_lowat / 100));
   1162   1.73        ad 		cache_ev_over.ev_count++;
   1163   1.73        ad 	} else
   1164   1.73        ad 		cache_ev_under.ev_count++;
   1165   1.73        ad 
   1166   1.73        ad 	/*
   1167   1.73        ad 	 * Stop forward lookup activity on all CPUs and garbage collect dead
   1168   1.73        ad 	 * entries.
   1169   1.73        ad 	 */
   1170   1.73        ad 	cache_lock_cpus();
   1171   1.73        ad 	ncp = cache_gcqueue;
   1172   1.73        ad 	cache_gcqueue = NULL;
   1173   1.73        ad 	items = cache_gcpend;
   1174   1.73        ad 	cache_gcpend = 0;
   1175   1.73        ad 	while (ncp != NULL) {
   1176   1.73        ad 		next = ncp->nc_gcqueue;
   1177   1.73        ad 		cache_disassociate(ncp);
   1178   1.73        ad 		KASSERT(ncp->nc_dvp == NULL);
   1179   1.73        ad 		if (ncp->nc_hash.le_prev != NULL) {
   1180   1.73        ad 			LIST_REMOVE(ncp, nc_hash);
   1181   1.73        ad 			ncp->nc_hash.le_prev = NULL;
   1182   1.73        ad 		}
   1183   1.73        ad 		pool_cache_put(namecache_cache, ncp);
   1184   1.73        ad 		ncp = next;
   1185   1.73        ad 	}
   1186   1.73        ad 	cache_unlock_cpus();
   1187   1.73        ad 	numcache -= items;
   1188   1.73        ad 	cache_ev_gc.ev_count += items;
   1189   1.73        ad }
   1190   1.73        ad 
   1191   1.73        ad /*
   1192   1.73        ad  * Cache maintainence thread, awakening once per second to:
   1193   1.73        ad  *
   1194   1.73        ad  * => keep number of entries below the high water mark
   1195   1.73        ad  * => sort pseudo-LRU list
   1196   1.73        ad  * => garbage collect dead entries
   1197   1.73        ad  */
   1198   1.73        ad static void
   1199   1.73        ad cache_thread(void *arg)
   1200   1.73        ad {
   1201   1.73        ad 
   1202   1.73        ad 	mutex_enter(namecache_lock);
   1203   1.73        ad 	for (;;) {
   1204   1.73        ad 		cache_reclaim();
   1205   1.73        ad 		kpause("cachegc", false, hz, namecache_lock);
   1206    1.1       cgd 	}
   1207    1.1       cgd }
   1208   1.19  sommerfe 
   1209   1.28       chs #ifdef DDB
   1210   1.28       chs void
   1211   1.28       chs namecache_print(struct vnode *vp, void (*pr)(const char *, ...))
   1212   1.28       chs {
   1213   1.28       chs 	struct vnode *dvp = NULL;
   1214   1.28       chs 	struct namecache *ncp;
   1215   1.28       chs 
   1216   1.28       chs 	TAILQ_FOREACH(ncp, &nclruhead, nc_lru) {
   1217   1.73        ad 		if (ncp->nc_vp == vp && ncp->nc_dvp != NULL) {
   1218   1.28       chs 			(*pr)("name %.*s\n", ncp->nc_nlen, ncp->nc_name);
   1219   1.28       chs 			dvp = ncp->nc_dvp;
   1220   1.28       chs 		}
   1221   1.28       chs 	}
   1222   1.28       chs 	if (dvp == NULL) {
   1223   1.28       chs 		(*pr)("name not found\n");
   1224   1.28       chs 		return;
   1225   1.28       chs 	}
   1226   1.28       chs 	vp = dvp;
   1227   1.28       chs 	TAILQ_FOREACH(ncp, &nclruhead, nc_lru) {
   1228   1.47      yamt 		if (ncp->nc_vp == vp) {
   1229   1.28       chs 			(*pr)("parent %.*s\n", ncp->nc_nlen, ncp->nc_name);
   1230   1.28       chs 		}
   1231   1.28       chs 	}
   1232   1.28       chs }
   1233   1.28       chs #endif
   1234   1.95     joerg 
   1235   1.95     joerg void
   1236   1.95     joerg namecache_count_pass2(void)
   1237   1.95     joerg {
   1238   1.95     joerg 	struct nchcpu *cpup = curcpu()->ci_data.cpu_nch;
   1239   1.95     joerg 
   1240  1.103    dennis 	COUNT_UNL(cpup, ncs_pass2);
   1241   1.95     joerg }
   1242   1.95     joerg 
   1243   1.95     joerg void
   1244   1.95     joerg namecache_count_2passes(void)
   1245   1.95     joerg {
   1246   1.95     joerg 	struct nchcpu *cpup = curcpu()->ci_data.cpu_nch;
   1247   1.95     joerg 
   1248  1.103    dennis 	COUNT_UNL(cpup, ncs_2passes);
   1249   1.95     joerg }
   1250   1.97     joerg 
   1251  1.103    dennis /*
   1252  1.103    dennis  * Fetch the current values of the stats.  We return the most
   1253  1.103    dennis  * recent values harvested into nchstats by cache_reclaim(), which
   1254  1.103    dennis  * will be less than a second old.
   1255  1.103    dennis  */
   1256   1.97     joerg static int
   1257   1.97     joerg cache_stat_sysctl(SYSCTLFN_ARGS)
   1258   1.97     joerg {
   1259  1.103    dennis 	struct nchstats stats;
   1260  1.103    dennis 	struct nchcpu *my_cpup;
   1261  1.103    dennis #ifdef CACHE_STATS_CURRENT
   1262  1.103    dennis 	CPU_INFO_ITERATOR cii;
   1263  1.103    dennis 	struct cpu_info *ci;
   1264  1.103    dennis #endif	/* CACHE_STATS_CURRENT */
   1265   1.97     joerg 
   1266   1.97     joerg 	if (oldp == NULL) {
   1267   1.97     joerg 		*oldlenp = sizeof(stats);
   1268   1.97     joerg 		return 0;
   1269   1.97     joerg 	}
   1270   1.97     joerg 
   1271   1.97     joerg 	if (*oldlenp < sizeof(stats)) {
   1272   1.97     joerg 		*oldlenp = 0;
   1273   1.97     joerg 		return 0;
   1274   1.97     joerg 	}
   1275   1.97     joerg 
   1276  1.103    dennis 	/*
   1277  1.103    dennis 	 * Take this CPU's per-cpu lock to hold off cache_reclaim()
   1278  1.103    dennis 	 * from doing a stats update while doing minimal damage to
   1279  1.103    dennis 	 * concurrent operations.
   1280  1.103    dennis 	 */
   1281  1.103    dennis 	sysctl_unlock();
   1282  1.103    dennis 	my_cpup = curcpu()->ci_data.cpu_nch;
   1283  1.103    dennis 	mutex_enter(&my_cpup->cpu_lock);
   1284  1.103    dennis 	stats = nchstats;
   1285  1.103    dennis #ifdef CACHE_STATS_CURRENT
   1286  1.103    dennis 	for (CPU_INFO_FOREACH(cii, ci)) {
   1287  1.103    dennis 		struct nchcpu *cpup = ci->ci_data.cpu_nch;
   1288   1.97     joerg 
   1289  1.103    dennis 		ADD(stats, cpup, ncs_goodhits);
   1290  1.103    dennis 		ADD(stats, cpup, ncs_neghits);
   1291  1.103    dennis 		ADD(stats, cpup, ncs_badhits);
   1292  1.103    dennis 		ADD(stats, cpup, ncs_falsehits);
   1293  1.103    dennis 		ADD(stats, cpup, ncs_miss);
   1294  1.103    dennis 		ADD(stats, cpup, ncs_long);
   1295  1.103    dennis 		ADD(stats, cpup, ncs_pass2);
   1296  1.103    dennis 		ADD(stats, cpup, ncs_2passes);
   1297  1.103    dennis 		ADD(stats, cpup, ncs_revhits);
   1298  1.103    dennis 		ADD(stats, cpup, ncs_revmiss);
   1299  1.103    dennis 	}
   1300  1.103    dennis #endif	/* CACHE_STATS_CURRENT */
   1301  1.103    dennis 	mutex_exit(&my_cpup->cpu_lock);
   1302   1.97     joerg 	sysctl_relock();
   1303   1.97     joerg 
   1304   1.97     joerg 	*oldlenp = sizeof(stats);
   1305   1.97     joerg 	return sysctl_copyout(l, &stats, oldp, sizeof(stats));
   1306   1.97     joerg }
   1307   1.97     joerg 
   1308  1.104     pooka static void
   1309  1.104     pooka sysctl_cache_stat_setup(void)
   1310   1.97     joerg {
   1311  1.104     pooka 
   1312  1.104     pooka 	KASSERT(sysctllog == NULL);
   1313  1.104     pooka 	sysctl_createv(&sysctllog, 0, NULL, NULL,
   1314   1.97     joerg 		       CTLFLAG_PERMANENT,
   1315   1.97     joerg 		       CTLTYPE_STRUCT, "namecache_stats",
   1316   1.97     joerg 		       SYSCTL_DESCR("namecache statistics"),
   1317   1.97     joerg 		       cache_stat_sysctl, 0, NULL, 0,
   1318   1.97     joerg 		       CTL_VFS, CTL_CREATE, CTL_EOL);
   1319   1.97     joerg }
   1320