xref: /freebsd/sys/vm/uma_core.c (revision 6c125b8df6750dba0aa916ee7779fe5b20bf63b8)
160727d8bSWarner Losh /*-
208ecce74SRobert Watson  * Copyright (c) 2002, 2003, 2004, 2005 Jeffrey Roberson <jeff@FreeBSD.org>
308ecce74SRobert Watson  * Copyright (c) 2004, 2005 Bosko Milekic <bmilekic@FreeBSD.org>
4ae4e9636SRobert Watson  * Copyright (c) 2004-2006 Robert N. M. Watson
508ecce74SRobert Watson  * All rights reserved.
68355f576SJeff Roberson  *
78355f576SJeff Roberson  * Redistribution and use in source and binary forms, with or without
88355f576SJeff Roberson  * modification, are permitted provided that the following conditions
98355f576SJeff Roberson  * are met:
108355f576SJeff Roberson  * 1. Redistributions of source code must retain the above copyright
118355f576SJeff Roberson  *    notice unmodified, this list of conditions, and the following
128355f576SJeff Roberson  *    disclaimer.
138355f576SJeff Roberson  * 2. Redistributions in binary form must reproduce the above copyright
148355f576SJeff Roberson  *    notice, this list of conditions and the following disclaimer in the
158355f576SJeff Roberson  *    documentation and/or other materials provided with the distribution.
168355f576SJeff Roberson  *
178355f576SJeff Roberson  * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
188355f576SJeff Roberson  * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
198355f576SJeff Roberson  * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
208355f576SJeff Roberson  * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
218355f576SJeff Roberson  * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
228355f576SJeff Roberson  * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
238355f576SJeff Roberson  * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
248355f576SJeff Roberson  * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
258355f576SJeff Roberson  * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
268355f576SJeff Roberson  * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
278355f576SJeff Roberson  */
288355f576SJeff Roberson 
298355f576SJeff Roberson /*
308355f576SJeff Roberson  * uma_core.c  Implementation of the Universal Memory allocator
318355f576SJeff Roberson  *
328355f576SJeff Roberson  * This allocator is intended to replace the multitude of similar object caches
338355f576SJeff Roberson  * in the standard FreeBSD kernel.  The intent is to be flexible as well as
348355f576SJeff Roberson  * effecient.  A primary design goal is to return unused memory to the rest of
358355f576SJeff Roberson  * the system.  This will make the system as a whole more flexible due to the
368355f576SJeff Roberson  * ability to move memory to subsystems which most need it instead of leaving
378355f576SJeff Roberson  * pools of reserved memory unused.
388355f576SJeff Roberson  *
398355f576SJeff Roberson  * The basic ideas stem from similar slab/zone based allocators whose algorithms
408355f576SJeff Roberson  * are well known.
418355f576SJeff Roberson  *
428355f576SJeff Roberson  */
438355f576SJeff Roberson 
448355f576SJeff Roberson /*
458355f576SJeff Roberson  * TODO:
468355f576SJeff Roberson  *	- Improve memory usage for large allocations
478355f576SJeff Roberson  *	- Investigate cache size adjustments
488355f576SJeff Roberson  */
498355f576SJeff Roberson 
50874651b1SDavid E. O'Brien #include <sys/cdefs.h>
51874651b1SDavid E. O'Brien __FBSDID("$FreeBSD$");
52874651b1SDavid E. O'Brien 
538355f576SJeff Roberson /* I should really use ktr.. */
548355f576SJeff Roberson /*
558355f576SJeff Roberson #define UMA_DEBUG 1
568355f576SJeff Roberson #define UMA_DEBUG_ALLOC 1
578355f576SJeff Roberson #define UMA_DEBUG_ALLOC_1 1
588355f576SJeff Roberson */
598355f576SJeff Roberson 
6048c5777eSRobert Watson #include "opt_ddb.h"
618355f576SJeff Roberson #include "opt_param.h"
6248c5777eSRobert Watson 
638355f576SJeff Roberson #include <sys/param.h>
648355f576SJeff Roberson #include <sys/systm.h>
658355f576SJeff Roberson #include <sys/kernel.h>
668355f576SJeff Roberson #include <sys/types.h>
678355f576SJeff Roberson #include <sys/queue.h>
688355f576SJeff Roberson #include <sys/malloc.h>
693659f747SRobert Watson #include <sys/ktr.h>
708355f576SJeff Roberson #include <sys/lock.h>
718355f576SJeff Roberson #include <sys/sysctl.h>
728355f576SJeff Roberson #include <sys/mutex.h>
734c1cc01cSJohn Baldwin #include <sys/proc.h>
747a52a97eSRobert Watson #include <sys/sbuf.h>
758355f576SJeff Roberson #include <sys/smp.h>
7686bbae32SJeff Roberson #include <sys/vmmeter.h>
7786bbae32SJeff Roberson 
788355f576SJeff Roberson #include <vm/vm.h>
798355f576SJeff Roberson #include <vm/vm_object.h>
808355f576SJeff Roberson #include <vm/vm_page.h>
818355f576SJeff Roberson #include <vm/vm_param.h>
828355f576SJeff Roberson #include <vm/vm_map.h>
838355f576SJeff Roberson #include <vm/vm_kern.h>
848355f576SJeff Roberson #include <vm/vm_extern.h>
858355f576SJeff Roberson #include <vm/uma.h>
868355f576SJeff Roberson #include <vm/uma_int.h>
87639c9550SJeff Roberson #include <vm/uma_dbg.h>
888355f576SJeff Roberson 
8948eea375SJeff Roberson #include <machine/vmparam.h>
9048eea375SJeff Roberson 
9148c5777eSRobert Watson #include <ddb/ddb.h>
9248c5777eSRobert Watson 
938355f576SJeff Roberson /*
94099a0e58SBosko Milekic  * This is the zone and keg from which all zones are spawned.  The idea is that
95099a0e58SBosko Milekic  * even the zone & keg heads are allocated from the allocator, so we use the
96099a0e58SBosko Milekic  * bss section to bootstrap us.
978355f576SJeff Roberson  */
98099a0e58SBosko Milekic static struct uma_keg masterkeg;
99099a0e58SBosko Milekic static struct uma_zone masterzone_k;
100099a0e58SBosko Milekic static struct uma_zone masterzone_z;
101099a0e58SBosko Milekic static uma_zone_t kegs = &masterzone_k;
102099a0e58SBosko Milekic static uma_zone_t zones = &masterzone_z;
1038355f576SJeff Roberson 
1048355f576SJeff Roberson /* This is the zone from which all of uma_slab_t's are allocated. */
1058355f576SJeff Roberson static uma_zone_t slabzone;
106099a0e58SBosko Milekic static uma_zone_t slabrefzone;	/* With refcounters (for UMA_ZONE_REFCNT) */
1078355f576SJeff Roberson 
1088355f576SJeff Roberson /*
1098355f576SJeff Roberson  * The initial hash tables come out of this zone so they can be allocated
1108355f576SJeff Roberson  * prior to malloc coming up.
1118355f576SJeff Roberson  */
1128355f576SJeff Roberson static uma_zone_t hashzone;
1138355f576SJeff Roberson 
114961647dfSJeff Roberson static MALLOC_DEFINE(M_UMAHASH, "UMAHash", "UMA Hash Buckets");
115961647dfSJeff Roberson 
1168355f576SJeff Roberson /*
11786bbae32SJeff Roberson  * Are we allowed to allocate buckets?
11886bbae32SJeff Roberson  */
11986bbae32SJeff Roberson static int bucketdisable = 1;
12086bbae32SJeff Roberson 
121099a0e58SBosko Milekic /* Linked list of all kegs in the system */
122099a0e58SBosko Milekic static LIST_HEAD(,uma_keg) uma_kegs = LIST_HEAD_INITIALIZER(&uma_kegs);
1238355f576SJeff Roberson 
124099a0e58SBosko Milekic /* This mutex protects the keg list */
1258355f576SJeff Roberson static struct mtx uma_mtx;
1268355f576SJeff Roberson 
1278355f576SJeff Roberson /* Linked list of boot time pages */
1288355f576SJeff Roberson static LIST_HEAD(,uma_slab) uma_boot_pages =
1298355f576SJeff Roberson     LIST_HEAD_INITIALIZER(&uma_boot_pages);
1308355f576SJeff Roberson 
131f353d338SAlan Cox /* This mutex protects the boot time pages list */
132f353d338SAlan Cox static struct mtx uma_boot_pages_mtx;
1338355f576SJeff Roberson 
1348355f576SJeff Roberson /* Is the VM done starting up? */
1358355f576SJeff Roberson static int booted = 0;
1368355f576SJeff Roberson 
137244f4554SBosko Milekic /* Maximum number of allowed items-per-slab if the slab header is OFFPAGE */
138244f4554SBosko Milekic static u_int uma_max_ipers;
139244f4554SBosko Milekic static u_int uma_max_ipers_ref;
140244f4554SBosko Milekic 
1419643769aSJeff Roberson /*
1429643769aSJeff Roberson  * This is the handle used to schedule events that need to happen
1439643769aSJeff Roberson  * outside of the allocation fast path.
1449643769aSJeff Roberson  */
1458355f576SJeff Roberson static struct callout uma_callout;
1469643769aSJeff Roberson #define	UMA_TIMEOUT	20		/* Seconds for callout interval. */
1478355f576SJeff Roberson 
1488355f576SJeff Roberson /*
1498355f576SJeff Roberson  * This structure is passed as the zone ctor arg so that I don't have to create
1508355f576SJeff Roberson  * a special allocation function just for zones.
1518355f576SJeff Roberson  */
1528355f576SJeff Roberson struct uma_zctor_args {
1538355f576SJeff Roberson 	char *name;
154c3bdc05fSAndrew R. Reiter 	size_t size;
1558355f576SJeff Roberson 	uma_ctor ctor;
1568355f576SJeff Roberson 	uma_dtor dtor;
1578355f576SJeff Roberson 	uma_init uminit;
1588355f576SJeff Roberson 	uma_fini fini;
159099a0e58SBosko Milekic 	uma_keg_t keg;
160099a0e58SBosko Milekic 	int align;
1612018f30cSMike Silbersack 	u_int32_t flags;
162099a0e58SBosko Milekic };
163099a0e58SBosko Milekic 
164099a0e58SBosko Milekic struct uma_kctor_args {
165099a0e58SBosko Milekic 	uma_zone_t zone;
166099a0e58SBosko Milekic 	size_t size;
167099a0e58SBosko Milekic 	uma_init uminit;
168099a0e58SBosko Milekic 	uma_fini fini;
1698355f576SJeff Roberson 	int align;
1702018f30cSMike Silbersack 	u_int32_t flags;
1718355f576SJeff Roberson };
1728355f576SJeff Roberson 
173cae33c14SJeff Roberson struct uma_bucket_zone {
174cae33c14SJeff Roberson 	uma_zone_t	ubz_zone;
175cae33c14SJeff Roberson 	char		*ubz_name;
176cae33c14SJeff Roberson 	int		ubz_entries;
177cae33c14SJeff Roberson };
178cae33c14SJeff Roberson 
179cae33c14SJeff Roberson #define	BUCKET_MAX	128
180cae33c14SJeff Roberson 
181cae33c14SJeff Roberson struct uma_bucket_zone bucket_zones[] = {
182cae33c14SJeff Roberson 	{ NULL, "16 Bucket", 16 },
183cae33c14SJeff Roberson 	{ NULL, "32 Bucket", 32 },
184cae33c14SJeff Roberson 	{ NULL, "64 Bucket", 64 },
185cae33c14SJeff Roberson 	{ NULL, "128 Bucket", 128 },
186cae33c14SJeff Roberson 	{ NULL, NULL, 0}
187cae33c14SJeff Roberson };
188cae33c14SJeff Roberson 
189cae33c14SJeff Roberson #define	BUCKET_SHIFT	4
190cae33c14SJeff Roberson #define	BUCKET_ZONES	((BUCKET_MAX >> BUCKET_SHIFT) + 1)
191cae33c14SJeff Roberson 
192f9d27e75SRobert Watson /*
193f9d27e75SRobert Watson  * bucket_size[] maps requested bucket sizes to zones that allocate a bucket
194f9d27e75SRobert Watson  * of approximately the right size.
195f9d27e75SRobert Watson  */
196f9d27e75SRobert Watson static uint8_t bucket_size[BUCKET_ZONES];
197cae33c14SJeff Roberson 
1982019094aSRobert Watson /*
1992019094aSRobert Watson  * Flags and enumerations to be passed to internal functions.
2002019094aSRobert Watson  */
201b23f72e9SBrian Feldman enum zfreeskip { SKIP_NONE, SKIP_DTOR, SKIP_FINI };
202b23f72e9SBrian Feldman 
2032019094aSRobert Watson #define	ZFREE_STATFAIL	0x00000001	/* Update zone failure statistic. */
204f4ff923bSRobert Watson #define	ZFREE_STATFREE	0x00000002	/* Update zone free statistic. */
2052019094aSRobert Watson 
2068355f576SJeff Roberson /* Prototypes.. */
2078355f576SJeff Roberson 
2088355f576SJeff Roberson static void *obj_alloc(uma_zone_t, int, u_int8_t *, int);
2098355f576SJeff Roberson static void *page_alloc(uma_zone_t, int, u_int8_t *, int);
210009b6fcbSJeff Roberson static void *startup_alloc(uma_zone_t, int, u_int8_t *, int);
2118355f576SJeff Roberson static void page_free(void *, int, u_int8_t);
2128355f576SJeff Roberson static uma_slab_t slab_zalloc(uma_zone_t, int);
2139643769aSJeff Roberson static void cache_drain(uma_zone_t);
2148355f576SJeff Roberson static void bucket_drain(uma_zone_t, uma_bucket_t);
215aaa8bb16SJeff Roberson static void bucket_cache_drain(uma_zone_t zone);
216b23f72e9SBrian Feldman static int keg_ctor(void *, int, void *, int);
217099a0e58SBosko Milekic static void keg_dtor(void *, int, void *);
218b23f72e9SBrian Feldman static int zone_ctor(void *, int, void *, int);
2199c2cd7e5SJeff Roberson static void zone_dtor(void *, int, void *);
220b23f72e9SBrian Feldman static int zero_init(void *, int, int);
2218355f576SJeff Roberson static void zone_small_init(uma_zone_t zone);
2228355f576SJeff Roberson static void zone_large_init(uma_zone_t zone);
2238355f576SJeff Roberson static void zone_foreach(void (*zfunc)(uma_zone_t));
2248355f576SJeff Roberson static void zone_timeout(uma_zone_t zone);
2250aef6126SJeff Roberson static int hash_alloc(struct uma_hash *);
2260aef6126SJeff Roberson static int hash_expand(struct uma_hash *, struct uma_hash *);
2270aef6126SJeff Roberson static void hash_free(struct uma_hash *hash);
2288355f576SJeff Roberson static void uma_timeout(void *);
2298355f576SJeff Roberson static void uma_startup3(void);
230bbee39c6SJeff Roberson static void *uma_zalloc_internal(uma_zone_t, void *, int);
2312019094aSRobert Watson static void uma_zfree_internal(uma_zone_t, void *, void *, enum zfreeskip,
2322019094aSRobert Watson     int);
23386bbae32SJeff Roberson static void bucket_enable(void);
234cae33c14SJeff Roberson static void bucket_init(void);
235cae33c14SJeff Roberson static uma_bucket_t bucket_alloc(int, int);
236cae33c14SJeff Roberson static void bucket_free(uma_bucket_t);
237cae33c14SJeff Roberson static void bucket_zone_drain(void);
238bbee39c6SJeff Roberson static int uma_zalloc_bucket(uma_zone_t zone, int flags);
239bbee39c6SJeff Roberson static uma_slab_t uma_zone_slab(uma_zone_t zone, int flags);
240bbee39c6SJeff Roberson static void *uma_slab_alloc(uma_zone_t zone, uma_slab_t slab);
241b23f72e9SBrian Feldman static uma_zone_t uma_kcreate(uma_zone_t zone, size_t size, uma_init uminit,
2422018f30cSMike Silbersack     uma_fini fini, int align, u_int32_t flags);
243bbee39c6SJeff Roberson 
2448355f576SJeff Roberson void uma_print_zone(uma_zone_t);
2458355f576SJeff Roberson void uma_print_stats(void);
2467a52a97eSRobert Watson static int sysctl_vm_zone_count(SYSCTL_HANDLER_ARGS);
2477a52a97eSRobert Watson static int sysctl_vm_zone_stats(SYSCTL_HANDLER_ARGS);
2488355f576SJeff Roberson 
2490c3c862eSBrian Feldman #ifdef WITNESS
25055fc8c11SBrian Feldman static int nosleepwithlocks = 1;
2510c3c862eSBrian Feldman #else
2520d0837eeSBosko Milekic static int nosleepwithlocks = 0;
253ca49f12fSJohn Baldwin #endif
2540d0837eeSBosko Milekic SYSCTL_INT(_debug, OID_AUTO, nosleepwithlocks, CTLFLAG_RW, &nosleepwithlocks,
2550d0837eeSBosko Milekic     0, "Convert M_WAITOK to M_NOWAIT to avoid lock-held-across-sleep paths");
2568355f576SJeff Roberson SYSINIT(uma_startup3, SI_SUB_VM_CONF, SI_ORDER_SECOND, uma_startup3, NULL);
2578355f576SJeff Roberson 
2587a52a97eSRobert Watson SYSCTL_PROC(_vm, OID_AUTO, zone_count, CTLFLAG_RD|CTLTYPE_INT,
2597a52a97eSRobert Watson     0, 0, sysctl_vm_zone_count, "I", "Number of UMA zones");
2607a52a97eSRobert Watson 
2617a52a97eSRobert Watson SYSCTL_PROC(_vm, OID_AUTO, zone_stats, CTLFLAG_RD|CTLTYPE_STRUCT,
2627a52a97eSRobert Watson     0, 0, sysctl_vm_zone_stats, "s,struct uma_type_header", "Zone Stats");
2637a52a97eSRobert Watson 
26486bbae32SJeff Roberson /*
26586bbae32SJeff Roberson  * This routine checks to see whether or not it's safe to enable buckets.
26686bbae32SJeff Roberson  */
26786bbae32SJeff Roberson 
26886bbae32SJeff Roberson static void
26986bbae32SJeff Roberson bucket_enable(void)
27086bbae32SJeff Roberson {
27186bbae32SJeff Roberson 	if (cnt.v_free_count < cnt.v_free_min)
27286bbae32SJeff Roberson 		bucketdisable = 1;
27386bbae32SJeff Roberson 	else
27486bbae32SJeff Roberson 		bucketdisable = 0;
27586bbae32SJeff Roberson }
27686bbae32SJeff Roberson 
277dc2c7965SRobert Watson /*
278dc2c7965SRobert Watson  * Initialize bucket_zones, the array of zones of buckets of various sizes.
279dc2c7965SRobert Watson  *
280dc2c7965SRobert Watson  * For each zone, calculate the memory required for each bucket, consisting
281dc2c7965SRobert Watson  * of the header and an array of pointers.  Initialize bucket_size[] to point
282dc2c7965SRobert Watson  * the range of appropriate bucket sizes at the zone.
283dc2c7965SRobert Watson  */
284cae33c14SJeff Roberson static void
285cae33c14SJeff Roberson bucket_init(void)
286cae33c14SJeff Roberson {
287cae33c14SJeff Roberson 	struct uma_bucket_zone *ubz;
288cae33c14SJeff Roberson 	int i;
289cae33c14SJeff Roberson 	int j;
290cae33c14SJeff Roberson 
291cae33c14SJeff Roberson 	for (i = 0, j = 0; bucket_zones[j].ubz_entries != 0; j++) {
292cae33c14SJeff Roberson 		int size;
293cae33c14SJeff Roberson 
294cae33c14SJeff Roberson 		ubz = &bucket_zones[j];
295cae33c14SJeff Roberson 		size = roundup(sizeof(struct uma_bucket), sizeof(void *));
296cae33c14SJeff Roberson 		size += sizeof(void *) * ubz->ubz_entries;
297cae33c14SJeff Roberson 		ubz->ubz_zone = uma_zcreate(ubz->ubz_name, size,
298b60f5b79SJeff Roberson 		    NULL, NULL, NULL, NULL, UMA_ALIGN_PTR, UMA_ZFLAG_INTERNAL);
299cae33c14SJeff Roberson 		for (; i <= ubz->ubz_entries; i += (1 << BUCKET_SHIFT))
300cae33c14SJeff Roberson 			bucket_size[i >> BUCKET_SHIFT] = j;
301cae33c14SJeff Roberson 	}
302cae33c14SJeff Roberson }
303cae33c14SJeff Roberson 
304dc2c7965SRobert Watson /*
305dc2c7965SRobert Watson  * Given a desired number of entries for a bucket, return the zone from which
306dc2c7965SRobert Watson  * to allocate the bucket.
307dc2c7965SRobert Watson  */
308dc2c7965SRobert Watson static struct uma_bucket_zone *
309dc2c7965SRobert Watson bucket_zone_lookup(int entries)
310dc2c7965SRobert Watson {
311dc2c7965SRobert Watson 	int idx;
312dc2c7965SRobert Watson 
313dc2c7965SRobert Watson 	idx = howmany(entries, 1 << BUCKET_SHIFT);
314dc2c7965SRobert Watson 	return (&bucket_zones[bucket_size[idx]]);
315dc2c7965SRobert Watson }
316dc2c7965SRobert Watson 
317cae33c14SJeff Roberson static uma_bucket_t
318cae33c14SJeff Roberson bucket_alloc(int entries, int bflags)
319cae33c14SJeff Roberson {
320cae33c14SJeff Roberson 	struct uma_bucket_zone *ubz;
321cae33c14SJeff Roberson 	uma_bucket_t bucket;
322cae33c14SJeff Roberson 
323cae33c14SJeff Roberson 	/*
324cae33c14SJeff Roberson 	 * This is to stop us from allocating per cpu buckets while we're
3253803b26bSDag-Erling Smørgrav 	 * running out of vm.boot_pages.  Otherwise, we would exhaust the
326cae33c14SJeff Roberson 	 * boot pages.  This also prevents us from allocating buckets in
327cae33c14SJeff Roberson 	 * low memory situations.
328cae33c14SJeff Roberson 	 */
329cae33c14SJeff Roberson 	if (bucketdisable)
330cae33c14SJeff Roberson 		return (NULL);
331dc2c7965SRobert Watson 
332dc2c7965SRobert Watson 	ubz = bucket_zone_lookup(entries);
333cae33c14SJeff Roberson 	bucket = uma_zalloc_internal(ubz->ubz_zone, NULL, bflags);
334cae33c14SJeff Roberson 	if (bucket) {
335cae33c14SJeff Roberson #ifdef INVARIANTS
336cae33c14SJeff Roberson 		bzero(bucket->ub_bucket, sizeof(void *) * ubz->ubz_entries);
337cae33c14SJeff Roberson #endif
338cae33c14SJeff Roberson 		bucket->ub_cnt = 0;
339cae33c14SJeff Roberson 		bucket->ub_entries = ubz->ubz_entries;
340cae33c14SJeff Roberson 	}
341cae33c14SJeff Roberson 
342cae33c14SJeff Roberson 	return (bucket);
343cae33c14SJeff Roberson }
344cae33c14SJeff Roberson 
345cae33c14SJeff Roberson static void
346cae33c14SJeff Roberson bucket_free(uma_bucket_t bucket)
347cae33c14SJeff Roberson {
348cae33c14SJeff Roberson 	struct uma_bucket_zone *ubz;
349cae33c14SJeff Roberson 
350dc2c7965SRobert Watson 	ubz = bucket_zone_lookup(bucket->ub_entries);
351f4ff923bSRobert Watson 	uma_zfree_internal(ubz->ubz_zone, bucket, NULL, SKIP_NONE,
352f4ff923bSRobert Watson 	    ZFREE_STATFREE);
353cae33c14SJeff Roberson }
354cae33c14SJeff Roberson 
355cae33c14SJeff Roberson static void
356cae33c14SJeff Roberson bucket_zone_drain(void)
357cae33c14SJeff Roberson {
358cae33c14SJeff Roberson 	struct uma_bucket_zone *ubz;
359cae33c14SJeff Roberson 
360cae33c14SJeff Roberson 	for (ubz = &bucket_zones[0]; ubz->ubz_entries != 0; ubz++)
361cae33c14SJeff Roberson 		zone_drain(ubz->ubz_zone);
362cae33c14SJeff Roberson }
363cae33c14SJeff Roberson 
3648355f576SJeff Roberson 
3658355f576SJeff Roberson /*
3668355f576SJeff Roberson  * Routine called by timeout which is used to fire off some time interval
3679643769aSJeff Roberson  * based calculations.  (stats, hash size, etc.)
3688355f576SJeff Roberson  *
3698355f576SJeff Roberson  * Arguments:
3708355f576SJeff Roberson  *	arg   Unused
3718355f576SJeff Roberson  *
3728355f576SJeff Roberson  * Returns:
3738355f576SJeff Roberson  *	Nothing
3748355f576SJeff Roberson  */
3758355f576SJeff Roberson static void
3768355f576SJeff Roberson uma_timeout(void *unused)
3778355f576SJeff Roberson {
37886bbae32SJeff Roberson 	bucket_enable();
3798355f576SJeff Roberson 	zone_foreach(zone_timeout);
3808355f576SJeff Roberson 
3818355f576SJeff Roberson 	/* Reschedule this event */
3829643769aSJeff Roberson 	callout_reset(&uma_callout, UMA_TIMEOUT * hz, uma_timeout, NULL);
3838355f576SJeff Roberson }
3848355f576SJeff Roberson 
3858355f576SJeff Roberson /*
3869643769aSJeff Roberson  * Routine to perform timeout driven calculations.  This expands the
3879643769aSJeff Roberson  * hashes and does per cpu statistics aggregation.
3888355f576SJeff Roberson  *
3898355f576SJeff Roberson  *  Arguments:
3908355f576SJeff Roberson  *	zone  The zone to operate on
3918355f576SJeff Roberson  *
3928355f576SJeff Roberson  *  Returns:
3938355f576SJeff Roberson  *	Nothing
3948355f576SJeff Roberson  */
3958355f576SJeff Roberson static void
3968355f576SJeff Roberson zone_timeout(uma_zone_t zone)
3978355f576SJeff Roberson {
398099a0e58SBosko Milekic 	uma_keg_t keg;
3998355f576SJeff Roberson 	u_int64_t alloc;
4008355f576SJeff Roberson 
401099a0e58SBosko Milekic 	keg = zone->uz_keg;
4028355f576SJeff Roberson 	alloc = 0;
4038355f576SJeff Roberson 
4048355f576SJeff Roberson 	/*
4058355f576SJeff Roberson 	 * Expand the zone hash table.
4068355f576SJeff Roberson 	 *
4078355f576SJeff Roberson 	 * This is done if the number of slabs is larger than the hash size.
4088355f576SJeff Roberson 	 * What I'm trying to do here is completely reduce collisions.  This
4098355f576SJeff Roberson 	 * may be a little aggressive.  Should I allow for two collisions max?
4108355f576SJeff Roberson 	 */
4115d1ae027SRobert Watson 	ZONE_LOCK(zone);
412099a0e58SBosko Milekic 	if (keg->uk_flags & UMA_ZONE_HASH &&
413099a0e58SBosko Milekic 	    keg->uk_pages / keg->uk_ppera >= keg->uk_hash.uh_hashsize) {
4140aef6126SJeff Roberson 		struct uma_hash newhash;
4150aef6126SJeff Roberson 		struct uma_hash oldhash;
4160aef6126SJeff Roberson 		int ret;
4175300d9ddSJeff Roberson 
4180aef6126SJeff Roberson 		/*
4190aef6126SJeff Roberson 		 * This is so involved because allocating and freeing
4200aef6126SJeff Roberson 		 * while the zone lock is held will lead to deadlock.
4210aef6126SJeff Roberson 		 * I have to do everything in stages and check for
4220aef6126SJeff Roberson 		 * races.
4230aef6126SJeff Roberson 		 */
424099a0e58SBosko Milekic 		newhash = keg->uk_hash;
4255300d9ddSJeff Roberson 		ZONE_UNLOCK(zone);
4260aef6126SJeff Roberson 		ret = hash_alloc(&newhash);
4275300d9ddSJeff Roberson 		ZONE_LOCK(zone);
4280aef6126SJeff Roberson 		if (ret) {
429099a0e58SBosko Milekic 			if (hash_expand(&keg->uk_hash, &newhash)) {
430099a0e58SBosko Milekic 				oldhash = keg->uk_hash;
431099a0e58SBosko Milekic 				keg->uk_hash = newhash;
4320aef6126SJeff Roberson 			} else
4330aef6126SJeff Roberson 				oldhash = newhash;
4340aef6126SJeff Roberson 
4350aef6126SJeff Roberson 			ZONE_UNLOCK(zone);
4360aef6126SJeff Roberson 			hash_free(&oldhash);
4370aef6126SJeff Roberson 			ZONE_LOCK(zone);
4380aef6126SJeff Roberson 		}
4395300d9ddSJeff Roberson 	}
4408355f576SJeff Roberson 	ZONE_UNLOCK(zone);
4418355f576SJeff Roberson }
4428355f576SJeff Roberson 
4438355f576SJeff Roberson /*
4445300d9ddSJeff Roberson  * Allocate and zero fill the next sized hash table from the appropriate
4455300d9ddSJeff Roberson  * backing store.
4465300d9ddSJeff Roberson  *
4475300d9ddSJeff Roberson  * Arguments:
4480aef6126SJeff Roberson  *	hash  A new hash structure with the old hash size in uh_hashsize
4495300d9ddSJeff Roberson  *
4505300d9ddSJeff Roberson  * Returns:
4510aef6126SJeff Roberson  *	1 on sucess and 0 on failure.
4525300d9ddSJeff Roberson  */
45337c84183SPoul-Henning Kamp static int
4540aef6126SJeff Roberson hash_alloc(struct uma_hash *hash)
4555300d9ddSJeff Roberson {
4560aef6126SJeff Roberson 	int oldsize;
4575300d9ddSJeff Roberson 	int alloc;
4585300d9ddSJeff Roberson 
4590aef6126SJeff Roberson 	oldsize = hash->uh_hashsize;
4600aef6126SJeff Roberson 
4615300d9ddSJeff Roberson 	/* We're just going to go to a power of two greater */
4620aef6126SJeff Roberson 	if (oldsize)  {
4630aef6126SJeff Roberson 		hash->uh_hashsize = oldsize * 2;
4640aef6126SJeff Roberson 		alloc = sizeof(hash->uh_slab_hash[0]) * hash->uh_hashsize;
4650aef6126SJeff Roberson 		hash->uh_slab_hash = (struct slabhead *)malloc(alloc,
466961647dfSJeff Roberson 		    M_UMAHASH, M_NOWAIT);
4675300d9ddSJeff Roberson 	} else {
4680aef6126SJeff Roberson 		alloc = sizeof(hash->uh_slab_hash[0]) * UMA_HASH_SIZE_INIT;
4690aef6126SJeff Roberson 		hash->uh_slab_hash = uma_zalloc_internal(hashzone, NULL,
470a163d034SWarner Losh 		    M_WAITOK);
4710aef6126SJeff Roberson 		hash->uh_hashsize = UMA_HASH_SIZE_INIT;
4725300d9ddSJeff Roberson 	}
4730aef6126SJeff Roberson 	if (hash->uh_slab_hash) {
4740aef6126SJeff Roberson 		bzero(hash->uh_slab_hash, alloc);
4750aef6126SJeff Roberson 		hash->uh_hashmask = hash->uh_hashsize - 1;
4760aef6126SJeff Roberson 		return (1);
4770aef6126SJeff Roberson 	}
4785300d9ddSJeff Roberson 
4790aef6126SJeff Roberson 	return (0);
4805300d9ddSJeff Roberson }
4815300d9ddSJeff Roberson 
4825300d9ddSJeff Roberson /*
48364f051e9SJeff Roberson  * Expands the hash table for HASH zones.  This is done from zone_timeout
48464f051e9SJeff Roberson  * to reduce collisions.  This must not be done in the regular allocation
48564f051e9SJeff Roberson  * path, otherwise, we can recurse on the vm while allocating pages.
4868355f576SJeff Roberson  *
4878355f576SJeff Roberson  * Arguments:
4880aef6126SJeff Roberson  *	oldhash  The hash you want to expand
4890aef6126SJeff Roberson  *	newhash  The hash structure for the new table
4908355f576SJeff Roberson  *
4918355f576SJeff Roberson  * Returns:
4928355f576SJeff Roberson  *	Nothing
4938355f576SJeff Roberson  *
4948355f576SJeff Roberson  * Discussion:
4958355f576SJeff Roberson  */
4960aef6126SJeff Roberson static int
4970aef6126SJeff Roberson hash_expand(struct uma_hash *oldhash, struct uma_hash *newhash)
4988355f576SJeff Roberson {
4998355f576SJeff Roberson 	uma_slab_t slab;
5008355f576SJeff Roberson 	int hval;
5018355f576SJeff Roberson 	int i;
5028355f576SJeff Roberson 
5030aef6126SJeff Roberson 	if (!newhash->uh_slab_hash)
5040aef6126SJeff Roberson 		return (0);
5058355f576SJeff Roberson 
5060aef6126SJeff Roberson 	if (oldhash->uh_hashsize >= newhash->uh_hashsize)
5070aef6126SJeff Roberson 		return (0);
5088355f576SJeff Roberson 
5098355f576SJeff Roberson 	/*
5108355f576SJeff Roberson 	 * I need to investigate hash algorithms for resizing without a
5118355f576SJeff Roberson 	 * full rehash.
5128355f576SJeff Roberson 	 */
5138355f576SJeff Roberson 
5140aef6126SJeff Roberson 	for (i = 0; i < oldhash->uh_hashsize; i++)
5150aef6126SJeff Roberson 		while (!SLIST_EMPTY(&oldhash->uh_slab_hash[i])) {
5160aef6126SJeff Roberson 			slab = SLIST_FIRST(&oldhash->uh_slab_hash[i]);
5170aef6126SJeff Roberson 			SLIST_REMOVE_HEAD(&oldhash->uh_slab_hash[i], us_hlink);
5180aef6126SJeff Roberson 			hval = UMA_HASH(newhash, slab->us_data);
5190aef6126SJeff Roberson 			SLIST_INSERT_HEAD(&newhash->uh_slab_hash[hval],
5200aef6126SJeff Roberson 			    slab, us_hlink);
5218355f576SJeff Roberson 		}
5228355f576SJeff Roberson 
5230aef6126SJeff Roberson 	return (1);
5249c2cd7e5SJeff Roberson }
5259c2cd7e5SJeff Roberson 
5265300d9ddSJeff Roberson /*
5275300d9ddSJeff Roberson  * Free the hash bucket to the appropriate backing store.
5285300d9ddSJeff Roberson  *
5295300d9ddSJeff Roberson  * Arguments:
5305300d9ddSJeff Roberson  *	slab_hash  The hash bucket we're freeing
5315300d9ddSJeff Roberson  *	hashsize   The number of entries in that hash bucket
5325300d9ddSJeff Roberson  *
5335300d9ddSJeff Roberson  * Returns:
5345300d9ddSJeff Roberson  *	Nothing
5355300d9ddSJeff Roberson  */
5369c2cd7e5SJeff Roberson static void
5370aef6126SJeff Roberson hash_free(struct uma_hash *hash)
5389c2cd7e5SJeff Roberson {
5390aef6126SJeff Roberson 	if (hash->uh_slab_hash == NULL)
5400aef6126SJeff Roberson 		return;
5410aef6126SJeff Roberson 	if (hash->uh_hashsize == UMA_HASH_SIZE_INIT)
5428355f576SJeff Roberson 		uma_zfree_internal(hashzone,
543f4ff923bSRobert Watson 		    hash->uh_slab_hash, NULL, SKIP_NONE, ZFREE_STATFREE);
5448355f576SJeff Roberson 	else
545961647dfSJeff Roberson 		free(hash->uh_slab_hash, M_UMAHASH);
5468355f576SJeff Roberson }
5478355f576SJeff Roberson 
5488355f576SJeff Roberson /*
5498355f576SJeff Roberson  * Frees all outstanding items in a bucket
5508355f576SJeff Roberson  *
5518355f576SJeff Roberson  * Arguments:
5528355f576SJeff Roberson  *	zone   The zone to free to, must be unlocked.
5538355f576SJeff Roberson  *	bucket The free/alloc bucket with items, cpu queue must be locked.
5548355f576SJeff Roberson  *
5558355f576SJeff Roberson  * Returns:
5568355f576SJeff Roberson  *	Nothing
5578355f576SJeff Roberson  */
5588355f576SJeff Roberson 
5598355f576SJeff Roberson static void
5608355f576SJeff Roberson bucket_drain(uma_zone_t zone, uma_bucket_t bucket)
5618355f576SJeff Roberson {
5628355f576SJeff Roberson 	uma_slab_t slab;
5638355f576SJeff Roberson 	int mzone;
5648355f576SJeff Roberson 	void *item;
5658355f576SJeff Roberson 
5668355f576SJeff Roberson 	if (bucket == NULL)
5678355f576SJeff Roberson 		return;
5688355f576SJeff Roberson 
5698355f576SJeff Roberson 	slab = NULL;
5708355f576SJeff Roberson 	mzone = 0;
5718355f576SJeff Roberson 
5728355f576SJeff Roberson 	/* We have to lookup the slab again for malloc.. */
573099a0e58SBosko Milekic 	if (zone->uz_keg->uk_flags & UMA_ZONE_MALLOC)
5748355f576SJeff Roberson 		mzone = 1;
5758355f576SJeff Roberson 
576cae33c14SJeff Roberson 	while (bucket->ub_cnt > 0)  {
577cae33c14SJeff Roberson 		bucket->ub_cnt--;
578cae33c14SJeff Roberson 		item = bucket->ub_bucket[bucket->ub_cnt];
5798355f576SJeff Roberson #ifdef INVARIANTS
580cae33c14SJeff Roberson 		bucket->ub_bucket[bucket->ub_cnt] = NULL;
5818355f576SJeff Roberson 		KASSERT(item != NULL,
5828355f576SJeff Roberson 		    ("bucket_drain: botched ptr, item is NULL"));
5838355f576SJeff Roberson #endif
5848355f576SJeff Roberson 		/*
5858355f576SJeff Roberson 		 * This is extremely inefficient.  The slab pointer was passed
5868355f576SJeff Roberson 		 * to uma_zfree_arg, but we lost it because the buckets don't
5878355f576SJeff Roberson 		 * hold them.  This will go away when free() gets a size passed
5888355f576SJeff Roberson 		 * to it.
5898355f576SJeff Roberson 		 */
59099571dc3SJeff Roberson 		if (mzone)
59199571dc3SJeff Roberson 			slab = vtoslab((vm_offset_t)item & (~UMA_SLAB_MASK));
5922019094aSRobert Watson 		uma_zfree_internal(zone, item, slab, SKIP_DTOR, 0);
5938355f576SJeff Roberson 	}
5948355f576SJeff Roberson }
5958355f576SJeff Roberson 
5968355f576SJeff Roberson /*
5978355f576SJeff Roberson  * Drains the per cpu caches for a zone.
5988355f576SJeff Roberson  *
5995d1ae027SRobert Watson  * NOTE: This may only be called while the zone is being turn down, and not
6005d1ae027SRobert Watson  * during normal operation.  This is necessary in order that we do not have
6015d1ae027SRobert Watson  * to migrate CPUs to drain the per-CPU caches.
6025d1ae027SRobert Watson  *
6038355f576SJeff Roberson  * Arguments:
6048355f576SJeff Roberson  *	zone     The zone to drain, must be unlocked.
6058355f576SJeff Roberson  *
6068355f576SJeff Roberson  * Returns:
6078355f576SJeff Roberson  *	Nothing
6088355f576SJeff Roberson  */
6098355f576SJeff Roberson static void
6109643769aSJeff Roberson cache_drain(uma_zone_t zone)
6118355f576SJeff Roberson {
6128355f576SJeff Roberson 	uma_cache_t cache;
6138355f576SJeff Roberson 	int cpu;
6148355f576SJeff Roberson 
6158355f576SJeff Roberson 	/*
6165d1ae027SRobert Watson 	 * XXX: It is safe to not lock the per-CPU caches, because we're
6175d1ae027SRobert Watson 	 * tearing down the zone anyway.  I.e., there will be no further use
6185d1ae027SRobert Watson 	 * of the caches at this point.
6195d1ae027SRobert Watson 	 *
6205d1ae027SRobert Watson 	 * XXX: It would good to be able to assert that the zone is being
6215d1ae027SRobert Watson 	 * torn down to prevent improper use of cache_drain().
6225d1ae027SRobert Watson 	 *
6235d1ae027SRobert Watson 	 * XXX: We lock the zone before passing into bucket_cache_drain() as
6245d1ae027SRobert Watson 	 * it is used elsewhere.  Should the tear-down path be made special
6255d1ae027SRobert Watson 	 * there in some form?
6268355f576SJeff Roberson 	 */
627b6c71225SJohn Baldwin 	for (cpu = 0; cpu <= mp_maxid; cpu++) {
6288355f576SJeff Roberson 		if (CPU_ABSENT(cpu))
6298355f576SJeff Roberson 			continue;
6308355f576SJeff Roberson 		cache = &zone->uz_cpu[cpu];
6318355f576SJeff Roberson 		bucket_drain(zone, cache->uc_allocbucket);
6328355f576SJeff Roberson 		bucket_drain(zone, cache->uc_freebucket);
633174ab450SBosko Milekic 		if (cache->uc_allocbucket != NULL)
634cae33c14SJeff Roberson 			bucket_free(cache->uc_allocbucket);
635174ab450SBosko Milekic 		if (cache->uc_freebucket != NULL)
636cae33c14SJeff Roberson 			bucket_free(cache->uc_freebucket);
637d56368d7SBosko Milekic 		cache->uc_allocbucket = cache->uc_freebucket = NULL;
638d56368d7SBosko Milekic 	}
639aaa8bb16SJeff Roberson 	ZONE_LOCK(zone);
640aaa8bb16SJeff Roberson 	bucket_cache_drain(zone);
641aaa8bb16SJeff Roberson 	ZONE_UNLOCK(zone);
642aaa8bb16SJeff Roberson }
643aaa8bb16SJeff Roberson 
644aaa8bb16SJeff Roberson /*
645aaa8bb16SJeff Roberson  * Drain the cached buckets from a zone.  Expects a locked zone on entry.
646aaa8bb16SJeff Roberson  */
647aaa8bb16SJeff Roberson static void
648aaa8bb16SJeff Roberson bucket_cache_drain(uma_zone_t zone)
649aaa8bb16SJeff Roberson {
650aaa8bb16SJeff Roberson 	uma_bucket_t bucket;
6518355f576SJeff Roberson 
6528355f576SJeff Roberson 	/*
6538355f576SJeff Roberson 	 * Drain the bucket queues and free the buckets, we just keep two per
6548355f576SJeff Roberson 	 * cpu (alloc/free).
6558355f576SJeff Roberson 	 */
6568355f576SJeff Roberson 	while ((bucket = LIST_FIRST(&zone->uz_full_bucket)) != NULL) {
6578355f576SJeff Roberson 		LIST_REMOVE(bucket, ub_link);
6588355f576SJeff Roberson 		ZONE_UNLOCK(zone);
6598355f576SJeff Roberson 		bucket_drain(zone, bucket);
660cae33c14SJeff Roberson 		bucket_free(bucket);
6618355f576SJeff Roberson 		ZONE_LOCK(zone);
6628355f576SJeff Roberson 	}
6638355f576SJeff Roberson 
6648355f576SJeff Roberson 	/* Now we do the free queue.. */
6658355f576SJeff Roberson 	while ((bucket = LIST_FIRST(&zone->uz_free_bucket)) != NULL) {
6668355f576SJeff Roberson 		LIST_REMOVE(bucket, ub_link);
667cae33c14SJeff Roberson 		bucket_free(bucket);
6688355f576SJeff Roberson 	}
6698355f576SJeff Roberson }
6708355f576SJeff Roberson 
6718355f576SJeff Roberson /*
6728355f576SJeff Roberson  * Frees pages from a zone back to the system.  This is done on demand from
6738355f576SJeff Roberson  * the pageout daemon.
6748355f576SJeff Roberson  *
6758355f576SJeff Roberson  * Arguments:
6768355f576SJeff Roberson  *	zone  The zone to free pages from
6779c2cd7e5SJeff Roberson  *	 all  Should we drain all items?
6788355f576SJeff Roberson  *
6798355f576SJeff Roberson  * Returns:
6808355f576SJeff Roberson  *	Nothing.
6818355f576SJeff Roberson  */
6826c125b8dSMohan Srinivasan void
6839643769aSJeff Roberson zone_drain(uma_zone_t zone)
6848355f576SJeff Roberson {
6851e183df2SStefan Farfeleder 	struct slabhead freeslabs = { 0 };
686099a0e58SBosko Milekic 	uma_keg_t keg;
6878355f576SJeff Roberson 	uma_slab_t slab;
6888355f576SJeff Roberson 	uma_slab_t n;
6898355f576SJeff Roberson 	u_int8_t flags;
6908355f576SJeff Roberson 	u_int8_t *mem;
6918355f576SJeff Roberson 	int i;
6928355f576SJeff Roberson 
693099a0e58SBosko Milekic 	keg = zone->uz_keg;
694099a0e58SBosko Milekic 
6958355f576SJeff Roberson 	/*
696099a0e58SBosko Milekic 	 * We don't want to take pages from statically allocated zones at this
6978355f576SJeff Roberson 	 * time
6988355f576SJeff Roberson 	 */
699099a0e58SBosko Milekic 	if (keg->uk_flags & UMA_ZONE_NOFREE || keg->uk_freef == NULL)
7008355f576SJeff Roberson 		return;
7018355f576SJeff Roberson 
7028355f576SJeff Roberson 	ZONE_LOCK(zone);
7038355f576SJeff Roberson 
7048355f576SJeff Roberson #ifdef UMA_DEBUG
705099a0e58SBosko Milekic 	printf("%s free items: %u\n", zone->uz_name, keg->uk_free);
7068355f576SJeff Roberson #endif
707aaa8bb16SJeff Roberson 	bucket_cache_drain(zone);
708099a0e58SBosko Milekic 	if (keg->uk_free == 0)
7098355f576SJeff Roberson 		goto finished;
7108355f576SJeff Roberson 
711099a0e58SBosko Milekic 	slab = LIST_FIRST(&keg->uk_free_slab);
7129643769aSJeff Roberson 	while (slab) {
7138355f576SJeff Roberson 		n = LIST_NEXT(slab, us_link);
7148355f576SJeff Roberson 
7158355f576SJeff Roberson 		/* We have no where to free these to */
7168355f576SJeff Roberson 		if (slab->us_flags & UMA_SLAB_BOOT) {
7178355f576SJeff Roberson 			slab = n;
7188355f576SJeff Roberson 			continue;
7198355f576SJeff Roberson 		}
7208355f576SJeff Roberson 
7218355f576SJeff Roberson 		LIST_REMOVE(slab, us_link);
722099a0e58SBosko Milekic 		keg->uk_pages -= keg->uk_ppera;
723099a0e58SBosko Milekic 		keg->uk_free -= keg->uk_ipers;
724713deb36SJeff Roberson 
725099a0e58SBosko Milekic 		if (keg->uk_flags & UMA_ZONE_HASH)
726099a0e58SBosko Milekic 			UMA_HASH_REMOVE(&keg->uk_hash, slab, slab->us_data);
727713deb36SJeff Roberson 
728713deb36SJeff Roberson 		SLIST_INSERT_HEAD(&freeslabs, slab, us_hlink);
729713deb36SJeff Roberson 
730713deb36SJeff Roberson 		slab = n;
731713deb36SJeff Roberson 	}
732713deb36SJeff Roberson finished:
733713deb36SJeff Roberson 	ZONE_UNLOCK(zone);
734713deb36SJeff Roberson 
735713deb36SJeff Roberson 	while ((slab = SLIST_FIRST(&freeslabs)) != NULL) {
736713deb36SJeff Roberson 		SLIST_REMOVE(&freeslabs, slab, uma_slab, us_hlink);
737099a0e58SBosko Milekic 		if (keg->uk_fini)
738099a0e58SBosko Milekic 			for (i = 0; i < keg->uk_ipers; i++)
739099a0e58SBosko Milekic 				keg->uk_fini(
740099a0e58SBosko Milekic 				    slab->us_data + (keg->uk_rsize * i),
741099a0e58SBosko Milekic 				    keg->uk_size);
7428355f576SJeff Roberson 		flags = slab->us_flags;
7438355f576SJeff Roberson 		mem = slab->us_data;
74499571dc3SJeff Roberson 
745099a0e58SBosko Milekic 		if ((keg->uk_flags & UMA_ZONE_MALLOC) ||
746099a0e58SBosko Milekic 		    (keg->uk_flags & UMA_ZONE_REFCNT)) {
747b70458aeSAlan Cox 			vm_object_t obj;
748b70458aeSAlan Cox 
749b70458aeSAlan Cox 			if (flags & UMA_SLAB_KMEM)
750b70458aeSAlan Cox 				obj = kmem_object;
751b70458aeSAlan Cox 			else
752b70458aeSAlan Cox 				obj = NULL;
753099a0e58SBosko Milekic 			for (i = 0; i < keg->uk_ppera; i++)
75499571dc3SJeff Roberson 				vsetobj((vm_offset_t)mem + (i * PAGE_SIZE),
755b70458aeSAlan Cox 				    obj);
75648eea375SJeff Roberson 		}
757099a0e58SBosko Milekic 		if (keg->uk_flags & UMA_ZONE_OFFPAGE)
758b23f72e9SBrian Feldman 			uma_zfree_internal(keg->uk_slabzone, slab, NULL,
759f4ff923bSRobert Watson 			    SKIP_NONE, ZFREE_STATFREE);
7608355f576SJeff Roberson #ifdef UMA_DEBUG
7618355f576SJeff Roberson 		printf("%s: Returning %d bytes.\n",
762099a0e58SBosko Milekic 		    zone->uz_name, UMA_SLAB_SIZE * keg->uk_ppera);
7638355f576SJeff Roberson #endif
764099a0e58SBosko Milekic 		keg->uk_freef(mem, UMA_SLAB_SIZE * keg->uk_ppera, flags);
7658355f576SJeff Roberson 	}
7668355f576SJeff Roberson }
7678355f576SJeff Roberson 
7688355f576SJeff Roberson /*
7698355f576SJeff Roberson  * Allocate a new slab for a zone.  This does not insert the slab onto a list.
7708355f576SJeff Roberson  *
7718355f576SJeff Roberson  * Arguments:
7728355f576SJeff Roberson  *	zone  The zone to allocate slabs for
7738355f576SJeff Roberson  *	wait  Shall we wait?
7748355f576SJeff Roberson  *
7758355f576SJeff Roberson  * Returns:
7768355f576SJeff Roberson  *	The slab that was allocated or NULL if there is no memory and the
7778355f576SJeff Roberson  *	caller specified M_NOWAIT.
7788355f576SJeff Roberson  */
7798355f576SJeff Roberson static uma_slab_t
7808355f576SJeff Roberson slab_zalloc(uma_zone_t zone, int wait)
7818355f576SJeff Roberson {
782099a0e58SBosko Milekic 	uma_slabrefcnt_t slabref;
783099a0e58SBosko Milekic 	uma_slab_t slab;
784099a0e58SBosko Milekic 	uma_keg_t keg;
7858355f576SJeff Roberson 	u_int8_t *mem;
7868355f576SJeff Roberson 	u_int8_t flags;
7878355f576SJeff Roberson 	int i;
7888355f576SJeff Roberson 
789a553d4b8SJeff Roberson 	slab = NULL;
790099a0e58SBosko Milekic 	keg = zone->uz_keg;
791a553d4b8SJeff Roberson 
7928355f576SJeff Roberson #ifdef UMA_DEBUG
7938355f576SJeff Roberson 	printf("slab_zalloc:  Allocating a new slab for %s\n", zone->uz_name);
7948355f576SJeff Roberson #endif
7958355f576SJeff Roberson 	ZONE_UNLOCK(zone);
796a553d4b8SJeff Roberson 
797099a0e58SBosko Milekic 	if (keg->uk_flags & UMA_ZONE_OFFPAGE) {
798099a0e58SBosko Milekic 		slab = uma_zalloc_internal(keg->uk_slabzone, NULL, wait);
799a553d4b8SJeff Roberson 		if (slab == NULL) {
800a553d4b8SJeff Roberson 			ZONE_LOCK(zone);
801a553d4b8SJeff Roberson 			return NULL;
802a553d4b8SJeff Roberson 		}
803a553d4b8SJeff Roberson 	}
804a553d4b8SJeff Roberson 
8053370c5bfSJeff Roberson 	/*
8063370c5bfSJeff Roberson 	 * This reproduces the old vm_zone behavior of zero filling pages the
8073370c5bfSJeff Roberson 	 * first time they are added to a zone.
8083370c5bfSJeff Roberson 	 *
8093370c5bfSJeff Roberson 	 * Malloced items are zeroed in uma_zalloc.
8103370c5bfSJeff Roberson 	 */
8113370c5bfSJeff Roberson 
812099a0e58SBosko Milekic 	if ((keg->uk_flags & UMA_ZONE_MALLOC) == 0)
8133370c5bfSJeff Roberson 		wait |= M_ZERO;
8143370c5bfSJeff Roberson 	else
8153370c5bfSJeff Roberson 		wait &= ~M_ZERO;
8163370c5bfSJeff Roberson 
817099a0e58SBosko Milekic 	mem = keg->uk_allocf(zone, keg->uk_ppera * UMA_SLAB_SIZE,
818234c7726SAlan Cox 	    &flags, wait);
819a553d4b8SJeff Roberson 	if (mem == NULL) {
820b23f72e9SBrian Feldman 		if (keg->uk_flags & UMA_ZONE_OFFPAGE)
8215d1ae027SRobert Watson 			uma_zfree_internal(keg->uk_slabzone, slab, NULL,
822f4ff923bSRobert Watson 			    SKIP_NONE, ZFREE_STATFREE);
8238355f576SJeff Roberson 		ZONE_LOCK(zone);
8248355f576SJeff Roberson 		return (NULL);
825a553d4b8SJeff Roberson 	}
8268355f576SJeff Roberson 
8275c0e403bSJeff Roberson 	/* Point the slab into the allocated memory */
828099a0e58SBosko Milekic 	if (!(keg->uk_flags & UMA_ZONE_OFFPAGE))
829099a0e58SBosko Milekic 		slab = (uma_slab_t )(mem + keg->uk_pgoff);
8305c0e403bSJeff Roberson 
831099a0e58SBosko Milekic 	if ((keg->uk_flags & UMA_ZONE_MALLOC) ||
832099a0e58SBosko Milekic 	    (keg->uk_flags & UMA_ZONE_REFCNT))
833099a0e58SBosko Milekic 		for (i = 0; i < keg->uk_ppera; i++)
83499571dc3SJeff Roberson 			vsetslab((vm_offset_t)mem + (i * PAGE_SIZE), slab);
8358355f576SJeff Roberson 
836099a0e58SBosko Milekic 	slab->us_keg = keg;
8378355f576SJeff Roberson 	slab->us_data = mem;
838099a0e58SBosko Milekic 	slab->us_freecount = keg->uk_ipers;
8398355f576SJeff Roberson 	slab->us_firstfree = 0;
8408355f576SJeff Roberson 	slab->us_flags = flags;
8418355f576SJeff Roberson 
842099a0e58SBosko Milekic 	if (keg->uk_flags & UMA_ZONE_REFCNT) {
843099a0e58SBosko Milekic 		slabref = (uma_slabrefcnt_t)slab;
844ab14a3f7SBrian Feldman 		for (i = 0; i < keg->uk_ipers; i++) {
845099a0e58SBosko Milekic 			slabref->us_freelist[i].us_refcnt = 0;
846ab14a3f7SBrian Feldman 			slabref->us_freelist[i].us_item = i+1;
847ab14a3f7SBrian Feldman 		}
848ab14a3f7SBrian Feldman 	} else {
849ab14a3f7SBrian Feldman 		for (i = 0; i < keg->uk_ipers; i++)
850ab14a3f7SBrian Feldman 			slab->us_freelist[i].us_item = i+1;
851099a0e58SBosko Milekic 	}
852099a0e58SBosko Milekic 
853b23f72e9SBrian Feldman 	if (keg->uk_init != NULL) {
854099a0e58SBosko Milekic 		for (i = 0; i < keg->uk_ipers; i++)
855b23f72e9SBrian Feldman 			if (keg->uk_init(slab->us_data + (keg->uk_rsize * i),
856b23f72e9SBrian Feldman 			    keg->uk_size, wait) != 0)
857b23f72e9SBrian Feldman 				break;
858b23f72e9SBrian Feldman 		if (i != keg->uk_ipers) {
859b23f72e9SBrian Feldman 			if (keg->uk_fini != NULL) {
860b23f72e9SBrian Feldman 				for (i--; i > -1; i--)
861b23f72e9SBrian Feldman 					keg->uk_fini(slab->us_data +
862b23f72e9SBrian Feldman 					    (keg->uk_rsize * i),
863099a0e58SBosko Milekic 					    keg->uk_size);
864b23f72e9SBrian Feldman 			}
865b23f72e9SBrian Feldman 			if ((keg->uk_flags & UMA_ZONE_MALLOC) ||
866b70458aeSAlan Cox 			    (keg->uk_flags & UMA_ZONE_REFCNT)) {
867b70458aeSAlan Cox 				vm_object_t obj;
868b70458aeSAlan Cox 
869b70458aeSAlan Cox 				if (flags & UMA_SLAB_KMEM)
870b70458aeSAlan Cox 					obj = kmem_object;
871b70458aeSAlan Cox 				else
872b70458aeSAlan Cox 					obj = NULL;
873b23f72e9SBrian Feldman 				for (i = 0; i < keg->uk_ppera; i++)
874b23f72e9SBrian Feldman 					vsetobj((vm_offset_t)mem +
875b70458aeSAlan Cox 					    (i * PAGE_SIZE), obj);
876b70458aeSAlan Cox 			}
877b23f72e9SBrian Feldman 			if (keg->uk_flags & UMA_ZONE_OFFPAGE)
878b23f72e9SBrian Feldman 				uma_zfree_internal(keg->uk_slabzone, slab,
879f4ff923bSRobert Watson 				    NULL, SKIP_NONE, ZFREE_STATFREE);
880b23f72e9SBrian Feldman 			keg->uk_freef(mem, UMA_SLAB_SIZE * keg->uk_ppera,
881b23f72e9SBrian Feldman 			    flags);
882b23f72e9SBrian Feldman 			ZONE_LOCK(zone);
883b23f72e9SBrian Feldman 			return (NULL);
884b23f72e9SBrian Feldman 		}
885b23f72e9SBrian Feldman 	}
8865c0e403bSJeff Roberson 	ZONE_LOCK(zone);
8875c0e403bSJeff Roberson 
888099a0e58SBosko Milekic 	if (keg->uk_flags & UMA_ZONE_HASH)
889099a0e58SBosko Milekic 		UMA_HASH_INSERT(&keg->uk_hash, slab, mem);
8908355f576SJeff Roberson 
891099a0e58SBosko Milekic 	keg->uk_pages += keg->uk_ppera;
892099a0e58SBosko Milekic 	keg->uk_free += keg->uk_ipers;
8938355f576SJeff Roberson 
8948355f576SJeff Roberson 	return (slab);
8958355f576SJeff Roberson }
8968355f576SJeff Roberson 
8978355f576SJeff Roberson /*
898009b6fcbSJeff Roberson  * This function is intended to be used early on in place of page_alloc() so
899009b6fcbSJeff Roberson  * that we may use the boot time page cache to satisfy allocations before
900009b6fcbSJeff Roberson  * the VM is ready.
901009b6fcbSJeff Roberson  */
902009b6fcbSJeff Roberson static void *
903009b6fcbSJeff Roberson startup_alloc(uma_zone_t zone, int bytes, u_int8_t *pflag, int wait)
904009b6fcbSJeff Roberson {
905099a0e58SBosko Milekic 	uma_keg_t keg;
906f353d338SAlan Cox 	uma_slab_t tmps;
907099a0e58SBosko Milekic 
908099a0e58SBosko Milekic 	keg = zone->uz_keg;
909099a0e58SBosko Milekic 
910009b6fcbSJeff Roberson 	/*
911009b6fcbSJeff Roberson 	 * Check our small startup cache to see if it has pages remaining.
912009b6fcbSJeff Roberson 	 */
913f353d338SAlan Cox 	mtx_lock(&uma_boot_pages_mtx);
914f353d338SAlan Cox 	if ((tmps = LIST_FIRST(&uma_boot_pages)) != NULL) {
915009b6fcbSJeff Roberson 		LIST_REMOVE(tmps, us_link);
916f353d338SAlan Cox 		mtx_unlock(&uma_boot_pages_mtx);
917009b6fcbSJeff Roberson 		*pflag = tmps->us_flags;
918009b6fcbSJeff Roberson 		return (tmps->us_data);
919009b6fcbSJeff Roberson 	}
920f353d338SAlan Cox 	mtx_unlock(&uma_boot_pages_mtx);
921009b6fcbSJeff Roberson 	if (booted == 0)
9223803b26bSDag-Erling Smørgrav 		panic("UMA: Increase vm.boot_pages");
923009b6fcbSJeff Roberson 	/*
924009b6fcbSJeff Roberson 	 * Now that we've booted reset these users to their real allocator.
925009b6fcbSJeff Roberson 	 */
926009b6fcbSJeff Roberson #ifdef UMA_MD_SMALL_ALLOC
927099a0e58SBosko Milekic 	keg->uk_allocf = uma_small_alloc;
928009b6fcbSJeff Roberson #else
929099a0e58SBosko Milekic 	keg->uk_allocf = page_alloc;
930009b6fcbSJeff Roberson #endif
931099a0e58SBosko Milekic 	return keg->uk_allocf(zone, bytes, pflag, wait);
932009b6fcbSJeff Roberson }
933009b6fcbSJeff Roberson 
934009b6fcbSJeff Roberson /*
9358355f576SJeff Roberson  * Allocates a number of pages from the system
9368355f576SJeff Roberson  *
9378355f576SJeff Roberson  * Arguments:
9388355f576SJeff Roberson  *	zone  Unused
9398355f576SJeff Roberson  *	bytes  The number of bytes requested
9408355f576SJeff Roberson  *	wait  Shall we wait?
9418355f576SJeff Roberson  *
9428355f576SJeff Roberson  * Returns:
9438355f576SJeff Roberson  *	A pointer to the alloced memory or possibly
9448355f576SJeff Roberson  *	NULL if M_NOWAIT is set.
9458355f576SJeff Roberson  */
9468355f576SJeff Roberson static void *
9478355f576SJeff Roberson page_alloc(uma_zone_t zone, int bytes, u_int8_t *pflag, int wait)
9488355f576SJeff Roberson {
9498355f576SJeff Roberson 	void *p;	/* Returned page */
9508355f576SJeff Roberson 
9518355f576SJeff Roberson 	*pflag = UMA_SLAB_KMEM;
9528355f576SJeff Roberson 	p = (void *) kmem_malloc(kmem_map, bytes, wait);
9538355f576SJeff Roberson 
9548355f576SJeff Roberson 	return (p);
9558355f576SJeff Roberson }
9568355f576SJeff Roberson 
9578355f576SJeff Roberson /*
9588355f576SJeff Roberson  * Allocates a number of pages from within an object
9598355f576SJeff Roberson  *
9608355f576SJeff Roberson  * Arguments:
9618355f576SJeff Roberson  *	zone   Unused
9628355f576SJeff Roberson  *	bytes  The number of bytes requested
9638355f576SJeff Roberson  *	wait   Shall we wait?
9648355f576SJeff Roberson  *
9658355f576SJeff Roberson  * Returns:
9668355f576SJeff Roberson  *	A pointer to the alloced memory or possibly
9678355f576SJeff Roberson  *	NULL if M_NOWAIT is set.
9688355f576SJeff Roberson  */
9698355f576SJeff Roberson static void *
9708355f576SJeff Roberson obj_alloc(uma_zone_t zone, int bytes, u_int8_t *flags, int wait)
9718355f576SJeff Roberson {
972b245ac95SAlan Cox 	vm_object_t object;
973b245ac95SAlan Cox 	vm_offset_t retkva, zkva;
9748355f576SJeff Roberson 	vm_page_t p;
975b245ac95SAlan Cox 	int pages, startpages;
9768355f576SJeff Roberson 
977099a0e58SBosko Milekic 	object = zone->uz_keg->uk_obj;
97855f7c614SArchie Cobbs 	retkva = 0;
9798355f576SJeff Roberson 
9808355f576SJeff Roberson 	/*
98164f051e9SJeff Roberson 	 * This looks a little weird since we're getting one page at a time.
9828355f576SJeff Roberson 	 */
983b245ac95SAlan Cox 	VM_OBJECT_LOCK(object);
984b245ac95SAlan Cox 	p = TAILQ_LAST(&object->memq, pglist);
985b245ac95SAlan Cox 	pages = p != NULL ? p->pindex + 1 : 0;
986b245ac95SAlan Cox 	startpages = pages;
987099a0e58SBosko Milekic 	zkva = zone->uz_keg->uk_kva + pages * PAGE_SIZE;
988b245ac95SAlan Cox 	for (; bytes > 0; bytes -= PAGE_SIZE) {
989b245ac95SAlan Cox 		p = vm_page_alloc(object, pages,
990b245ac95SAlan Cox 		    VM_ALLOC_INTERRUPT | VM_ALLOC_WIRED);
991b245ac95SAlan Cox 		if (p == NULL) {
992b245ac95SAlan Cox 			if (pages != startpages)
993b245ac95SAlan Cox 				pmap_qremove(retkva, pages - startpages);
994b245ac95SAlan Cox 			while (pages != startpages) {
995b245ac95SAlan Cox 				pages--;
996b245ac95SAlan Cox 				p = TAILQ_LAST(&object->memq, pglist);
997b245ac95SAlan Cox 				vm_page_lock_queues();
998b245ac95SAlan Cox 				vm_page_unwire(p, 0);
999b245ac95SAlan Cox 				vm_page_free(p);
1000b245ac95SAlan Cox 				vm_page_unlock_queues();
1001b245ac95SAlan Cox 			}
1002b245ac95SAlan Cox 			retkva = 0;
1003b245ac95SAlan Cox 			goto done;
1004b245ac95SAlan Cox 		}
1005b245ac95SAlan Cox 		pmap_qenter(zkva, &p, 1);
100655f7c614SArchie Cobbs 		if (retkva == 0)
10078355f576SJeff Roberson 			retkva = zkva;
1008b245ac95SAlan Cox 		zkva += PAGE_SIZE;
10098355f576SJeff Roberson 		pages += 1;
10108355f576SJeff Roberson 	}
1011b245ac95SAlan Cox done:
1012b245ac95SAlan Cox 	VM_OBJECT_UNLOCK(object);
10138355f576SJeff Roberson 	*flags = UMA_SLAB_PRIV;
10148355f576SJeff Roberson 
10158355f576SJeff Roberson 	return ((void *)retkva);
10168355f576SJeff Roberson }
10178355f576SJeff Roberson 
10188355f576SJeff Roberson /*
10198355f576SJeff Roberson  * Frees a number of pages to the system
10208355f576SJeff Roberson  *
10218355f576SJeff Roberson  * Arguments:
10228355f576SJeff Roberson  *	mem   A pointer to the memory to be freed
10238355f576SJeff Roberson  *	size  The size of the memory being freed
10248355f576SJeff Roberson  *	flags The original p->us_flags field
10258355f576SJeff Roberson  *
10268355f576SJeff Roberson  * Returns:
10278355f576SJeff Roberson  *	Nothing
10288355f576SJeff Roberson  */
10298355f576SJeff Roberson static void
10308355f576SJeff Roberson page_free(void *mem, int size, u_int8_t flags)
10318355f576SJeff Roberson {
10328355f576SJeff Roberson 	vm_map_t map;
10333370c5bfSJeff Roberson 
10348355f576SJeff Roberson 	if (flags & UMA_SLAB_KMEM)
10358355f576SJeff Roberson 		map = kmem_map;
10368355f576SJeff Roberson 	else
10378355f576SJeff Roberson 		panic("UMA: page_free used with invalid flags %d\n", flags);
10388355f576SJeff Roberson 
10398355f576SJeff Roberson 	kmem_free(map, (vm_offset_t)mem, size);
10408355f576SJeff Roberson }
10418355f576SJeff Roberson 
10428355f576SJeff Roberson /*
10438355f576SJeff Roberson  * Zero fill initializer
10448355f576SJeff Roberson  *
10458355f576SJeff Roberson  * Arguments/Returns follow uma_init specifications
10468355f576SJeff Roberson  */
1047b23f72e9SBrian Feldman static int
1048b23f72e9SBrian Feldman zero_init(void *mem, int size, int flags)
10498355f576SJeff Roberson {
10508355f576SJeff Roberson 	bzero(mem, size);
1051b23f72e9SBrian Feldman 	return (0);
10528355f576SJeff Roberson }
10538355f576SJeff Roberson 
10548355f576SJeff Roberson /*
10558355f576SJeff Roberson  * Finish creating a small uma zone.  This calculates ipers, and the zone size.
10568355f576SJeff Roberson  *
10578355f576SJeff Roberson  * Arguments
10588355f576SJeff Roberson  *	zone  The zone we should initialize
10598355f576SJeff Roberson  *
10608355f576SJeff Roberson  * Returns
10618355f576SJeff Roberson  *	Nothing
10628355f576SJeff Roberson  */
10638355f576SJeff Roberson static void
10648355f576SJeff Roberson zone_small_init(uma_zone_t zone)
10658355f576SJeff Roberson {
1066099a0e58SBosko Milekic 	uma_keg_t keg;
1067244f4554SBosko Milekic 	u_int rsize;
1068244f4554SBosko Milekic 	u_int memused;
1069244f4554SBosko Milekic 	u_int wastedspace;
1070244f4554SBosko Milekic 	u_int shsize;
10718355f576SJeff Roberson 
1072099a0e58SBosko Milekic 	keg = zone->uz_keg;
1073099a0e58SBosko Milekic 	KASSERT(keg != NULL, ("Keg is null in zone_small_init"));
1074099a0e58SBosko Milekic 	rsize = keg->uk_size;
10758355f576SJeff Roberson 
10768355f576SJeff Roberson 	if (rsize < UMA_SMALLEST_UNIT)
10778355f576SJeff Roberson 		rsize = UMA_SMALLEST_UNIT;
1078099a0e58SBosko Milekic 	if (rsize & keg->uk_align)
1079099a0e58SBosko Milekic 		rsize = (rsize & ~keg->uk_align) + (keg->uk_align + 1);
10808355f576SJeff Roberson 
1081099a0e58SBosko Milekic 	keg->uk_rsize = rsize;
1082099a0e58SBosko Milekic 	keg->uk_ppera = 1;
10838355f576SJeff Roberson 
1084244f4554SBosko Milekic 	if (keg->uk_flags & UMA_ZONE_REFCNT) {
1085244f4554SBosko Milekic 		rsize += UMA_FRITMREF_SZ;	/* linkage & refcnt */
1086244f4554SBosko Milekic 		shsize = sizeof(struct uma_slab_refcnt);
1087244f4554SBosko Milekic 	} else {
1088244f4554SBosko Milekic 		rsize += UMA_FRITM_SZ;	/* Account for linkage */
1089244f4554SBosko Milekic 		shsize = sizeof(struct uma_slab);
1090244f4554SBosko Milekic 	}
10918355f576SJeff Roberson 
1092244f4554SBosko Milekic 	keg->uk_ipers = (UMA_SLAB_SIZE - shsize) / rsize;
1093244f4554SBosko Milekic 	KASSERT(keg->uk_ipers != 0, ("zone_small_init: ipers is 0"));
1094244f4554SBosko Milekic 	memused = keg->uk_ipers * rsize + shsize;
1095244f4554SBosko Milekic 	wastedspace = UMA_SLAB_SIZE - memused;
1096244f4554SBosko Milekic 
109720e8e865SBosko Milekic 	/*
1098244f4554SBosko Milekic 	 * We can't do OFFPAGE if we're internal or if we've been
109920e8e865SBosko Milekic 	 * asked to not go to the VM for buckets.  If we do this we
110020e8e865SBosko Milekic 	 * may end up going to the VM (kmem_map) for slabs which we
110120e8e865SBosko Milekic 	 * do not want to do if we're UMA_ZFLAG_CACHEONLY as a
110220e8e865SBosko Milekic 	 * result of UMA_ZONE_VM, which clearly forbids it.
110320e8e865SBosko Milekic 	 */
1104099a0e58SBosko Milekic 	if ((keg->uk_flags & UMA_ZFLAG_INTERNAL) ||
1105099a0e58SBosko Milekic 	    (keg->uk_flags & UMA_ZFLAG_CACHEONLY))
11068355f576SJeff Roberson 		return;
1107244f4554SBosko Milekic 
1108244f4554SBosko Milekic 	if ((wastedspace >= UMA_MAX_WASTE) &&
1109244f4554SBosko Milekic 	    (keg->uk_ipers < (UMA_SLAB_SIZE / keg->uk_rsize))) {
1110244f4554SBosko Milekic 		keg->uk_ipers = UMA_SLAB_SIZE / keg->uk_rsize;
1111244f4554SBosko Milekic 		KASSERT(keg->uk_ipers <= 255,
1112244f4554SBosko Milekic 		    ("zone_small_init: keg->uk_ipers too high!"));
1113244f4554SBosko Milekic #ifdef UMA_DEBUG
1114244f4554SBosko Milekic 		printf("UMA decided we need offpage slab headers for "
1115244f4554SBosko Milekic 		    "zone: %s, calculated wastedspace = %d, "
1116244f4554SBosko Milekic 		    "maximum wasted space allowed = %d, "
1117244f4554SBosko Milekic 		    "calculated ipers = %d, "
1118244f4554SBosko Milekic 		    "new wasted space = %d\n", zone->uz_name, wastedspace,
1119244f4554SBosko Milekic 		    UMA_MAX_WASTE, keg->uk_ipers,
1120244f4554SBosko Milekic 		    UMA_SLAB_SIZE - keg->uk_ipers * keg->uk_rsize);
1121244f4554SBosko Milekic #endif
1122099a0e58SBosko Milekic 		keg->uk_flags |= UMA_ZONE_OFFPAGE;
1123099a0e58SBosko Milekic 		if ((keg->uk_flags & UMA_ZONE_MALLOC) == 0)
1124099a0e58SBosko Milekic 			keg->uk_flags |= UMA_ZONE_HASH;
11258355f576SJeff Roberson 	}
11268355f576SJeff Roberson }
11278355f576SJeff Roberson 
11288355f576SJeff Roberson /*
11298355f576SJeff Roberson  * Finish creating a large (> UMA_SLAB_SIZE) uma zone.  Just give in and do
11308355f576SJeff Roberson  * OFFPAGE for now.  When I can allow for more dynamic slab sizes this will be
11318355f576SJeff Roberson  * more complicated.
11328355f576SJeff Roberson  *
11338355f576SJeff Roberson  * Arguments
11348355f576SJeff Roberson  *	zone  The zone we should initialize
11358355f576SJeff Roberson  *
11368355f576SJeff Roberson  * Returns
11378355f576SJeff Roberson  *	Nothing
11388355f576SJeff Roberson  */
11398355f576SJeff Roberson static void
11408355f576SJeff Roberson zone_large_init(uma_zone_t zone)
11418355f576SJeff Roberson {
1142099a0e58SBosko Milekic 	uma_keg_t keg;
11438355f576SJeff Roberson 	int pages;
11448355f576SJeff Roberson 
1145099a0e58SBosko Milekic 	keg = zone->uz_keg;
1146099a0e58SBosko Milekic 
1147099a0e58SBosko Milekic 	KASSERT(keg != NULL, ("Keg is null in zone_large_init"));
1148099a0e58SBosko Milekic 	KASSERT((keg->uk_flags & UMA_ZFLAG_CACHEONLY) == 0,
114920e8e865SBosko Milekic 	    ("zone_large_init: Cannot large-init a UMA_ZFLAG_CACHEONLY zone"));
115020e8e865SBosko Milekic 
1151099a0e58SBosko Milekic 	pages = keg->uk_size / UMA_SLAB_SIZE;
11528355f576SJeff Roberson 
11538355f576SJeff Roberson 	/* Account for remainder */
1154099a0e58SBosko Milekic 	if ((pages * UMA_SLAB_SIZE) < keg->uk_size)
11558355f576SJeff Roberson 		pages++;
11568355f576SJeff Roberson 
1157099a0e58SBosko Milekic 	keg->uk_ppera = pages;
1158099a0e58SBosko Milekic 	keg->uk_ipers = 1;
11598355f576SJeff Roberson 
1160099a0e58SBosko Milekic 	keg->uk_flags |= UMA_ZONE_OFFPAGE;
1161099a0e58SBosko Milekic 	if ((keg->uk_flags & UMA_ZONE_MALLOC) == 0)
1162099a0e58SBosko Milekic 		keg->uk_flags |= UMA_ZONE_HASH;
116399571dc3SJeff Roberson 
1164099a0e58SBosko Milekic 	keg->uk_rsize = keg->uk_size;
11658355f576SJeff Roberson }
11668355f576SJeff Roberson 
11678355f576SJeff Roberson /*
1168099a0e58SBosko Milekic  * Keg header ctor.  This initializes all fields, locks, etc.  And inserts
1169099a0e58SBosko Milekic  * the keg onto the global keg list.
11708355f576SJeff Roberson  *
11718355f576SJeff Roberson  * Arguments/Returns follow uma_ctor specifications
1172099a0e58SBosko Milekic  *	udata  Actually uma_kctor_args
1173099a0e58SBosko Milekic  */
1174b23f72e9SBrian Feldman static int
1175b23f72e9SBrian Feldman keg_ctor(void *mem, int size, void *udata, int flags)
1176099a0e58SBosko Milekic {
1177099a0e58SBosko Milekic 	struct uma_kctor_args *arg = udata;
1178099a0e58SBosko Milekic 	uma_keg_t keg = mem;
1179099a0e58SBosko Milekic 	uma_zone_t zone;
1180099a0e58SBosko Milekic 
1181099a0e58SBosko Milekic 	bzero(keg, size);
1182099a0e58SBosko Milekic 	keg->uk_size = arg->size;
1183099a0e58SBosko Milekic 	keg->uk_init = arg->uminit;
1184099a0e58SBosko Milekic 	keg->uk_fini = arg->fini;
1185099a0e58SBosko Milekic 	keg->uk_align = arg->align;
1186099a0e58SBosko Milekic 	keg->uk_free = 0;
1187099a0e58SBosko Milekic 	keg->uk_pages = 0;
1188099a0e58SBosko Milekic 	keg->uk_flags = arg->flags;
1189099a0e58SBosko Milekic 	keg->uk_allocf = page_alloc;
1190099a0e58SBosko Milekic 	keg->uk_freef = page_free;
1191099a0e58SBosko Milekic 	keg->uk_recurse = 0;
1192099a0e58SBosko Milekic 	keg->uk_slabzone = NULL;
1193099a0e58SBosko Milekic 
1194099a0e58SBosko Milekic 	/*
1195099a0e58SBosko Milekic 	 * The master zone is passed to us at keg-creation time.
1196099a0e58SBosko Milekic 	 */
1197099a0e58SBosko Milekic 	zone = arg->zone;
1198099a0e58SBosko Milekic 	zone->uz_keg = keg;
1199099a0e58SBosko Milekic 
1200099a0e58SBosko Milekic 	if (arg->flags & UMA_ZONE_VM)
1201099a0e58SBosko Milekic 		keg->uk_flags |= UMA_ZFLAG_CACHEONLY;
1202099a0e58SBosko Milekic 
1203099a0e58SBosko Milekic 	if (arg->flags & UMA_ZONE_ZINIT)
1204099a0e58SBosko Milekic 		keg->uk_init = zero_init;
1205099a0e58SBosko Milekic 
1206099a0e58SBosko Milekic 	/*
1207244f4554SBosko Milekic 	 * The +UMA_FRITM_SZ added to uk_size is to account for the
1208099a0e58SBosko Milekic 	 * linkage that is added to the size in zone_small_init().  If
1209099a0e58SBosko Milekic 	 * we don't account for this here then we may end up in
1210099a0e58SBosko Milekic 	 * zone_small_init() with a calculated 'ipers' of 0.
1211099a0e58SBosko Milekic 	 */
1212244f4554SBosko Milekic 	if (keg->uk_flags & UMA_ZONE_REFCNT) {
1213244f4554SBosko Milekic 		if ((keg->uk_size+UMA_FRITMREF_SZ) >
1214244f4554SBosko Milekic 		    (UMA_SLAB_SIZE - sizeof(struct uma_slab_refcnt)))
1215099a0e58SBosko Milekic 			zone_large_init(zone);
1216099a0e58SBosko Milekic 		else
1217099a0e58SBosko Milekic 			zone_small_init(zone);
1218244f4554SBosko Milekic 	} else {
1219244f4554SBosko Milekic 		if ((keg->uk_size+UMA_FRITM_SZ) >
1220244f4554SBosko Milekic 		    (UMA_SLAB_SIZE - sizeof(struct uma_slab)))
1221244f4554SBosko Milekic 			zone_large_init(zone);
1222244f4554SBosko Milekic 		else
1223244f4554SBosko Milekic 			zone_small_init(zone);
1224244f4554SBosko Milekic 	}
1225099a0e58SBosko Milekic 
1226244f4554SBosko Milekic 	if (keg->uk_flags & UMA_ZONE_OFFPAGE) {
1227099a0e58SBosko Milekic 		if (keg->uk_flags & UMA_ZONE_REFCNT)
1228099a0e58SBosko Milekic 			keg->uk_slabzone = slabrefzone;
1229244f4554SBosko Milekic 		else
1230099a0e58SBosko Milekic 			keg->uk_slabzone = slabzone;
1231244f4554SBosko Milekic 	}
1232099a0e58SBosko Milekic 
1233099a0e58SBosko Milekic 	/*
1234099a0e58SBosko Milekic 	 * If we haven't booted yet we need allocations to go through the
1235099a0e58SBosko Milekic 	 * startup cache until the vm is ready.
1236099a0e58SBosko Milekic 	 */
1237099a0e58SBosko Milekic 	if (keg->uk_ppera == 1) {
1238099a0e58SBosko Milekic #ifdef UMA_MD_SMALL_ALLOC
1239099a0e58SBosko Milekic 		keg->uk_allocf = uma_small_alloc;
1240099a0e58SBosko Milekic 		keg->uk_freef = uma_small_free;
1241099a0e58SBosko Milekic #endif
1242099a0e58SBosko Milekic 		if (booted == 0)
1243099a0e58SBosko Milekic 			keg->uk_allocf = startup_alloc;
1244099a0e58SBosko Milekic 	}
1245099a0e58SBosko Milekic 
1246099a0e58SBosko Milekic 	/*
1247099a0e58SBosko Milekic 	 * Initialize keg's lock (shared among zones) through
1248099a0e58SBosko Milekic 	 * Master zone
1249099a0e58SBosko Milekic 	 */
1250099a0e58SBosko Milekic 	zone->uz_lock = &keg->uk_lock;
1251099a0e58SBosko Milekic 	if (arg->flags & UMA_ZONE_MTXCLASS)
1252099a0e58SBosko Milekic 		ZONE_LOCK_INIT(zone, 1);
1253099a0e58SBosko Milekic 	else
1254099a0e58SBosko Milekic 		ZONE_LOCK_INIT(zone, 0);
1255099a0e58SBosko Milekic 
1256099a0e58SBosko Milekic 	/*
1257099a0e58SBosko Milekic 	 * If we're putting the slab header in the actual page we need to
1258099a0e58SBosko Milekic 	 * figure out where in each page it goes.  This calculates a right
1259099a0e58SBosko Milekic 	 * justified offset into the memory on an ALIGN_PTR boundary.
1260099a0e58SBosko Milekic 	 */
1261099a0e58SBosko Milekic 	if (!(keg->uk_flags & UMA_ZONE_OFFPAGE)) {
1262244f4554SBosko Milekic 		u_int totsize;
1263099a0e58SBosko Milekic 
1264099a0e58SBosko Milekic 		/* Size of the slab struct and free list */
1265244f4554SBosko Milekic 		if (keg->uk_flags & UMA_ZONE_REFCNT)
1266244f4554SBosko Milekic 			totsize = sizeof(struct uma_slab_refcnt) +
1267244f4554SBosko Milekic 			    keg->uk_ipers * UMA_FRITMREF_SZ;
1268244f4554SBosko Milekic 		else
1269244f4554SBosko Milekic 			totsize = sizeof(struct uma_slab) +
1270244f4554SBosko Milekic 			    keg->uk_ipers * UMA_FRITM_SZ;
1271244f4554SBosko Milekic 
1272099a0e58SBosko Milekic 		if (totsize & UMA_ALIGN_PTR)
1273099a0e58SBosko Milekic 			totsize = (totsize & ~UMA_ALIGN_PTR) +
1274099a0e58SBosko Milekic 			    (UMA_ALIGN_PTR + 1);
1275099a0e58SBosko Milekic 		keg->uk_pgoff = UMA_SLAB_SIZE - totsize;
1276244f4554SBosko Milekic 
1277244f4554SBosko Milekic 		if (keg->uk_flags & UMA_ZONE_REFCNT)
1278244f4554SBosko Milekic 			totsize = keg->uk_pgoff + sizeof(struct uma_slab_refcnt)
1279244f4554SBosko Milekic 			    + keg->uk_ipers * UMA_FRITMREF_SZ;
1280244f4554SBosko Milekic 		else
1281099a0e58SBosko Milekic 			totsize = keg->uk_pgoff + sizeof(struct uma_slab)
1282244f4554SBosko Milekic 			    + keg->uk_ipers * UMA_FRITM_SZ;
1283244f4554SBosko Milekic 
1284244f4554SBosko Milekic 		/*
1285244f4554SBosko Milekic 		 * The only way the following is possible is if with our
1286244f4554SBosko Milekic 		 * UMA_ALIGN_PTR adjustments we are now bigger than
1287244f4554SBosko Milekic 		 * UMA_SLAB_SIZE.  I haven't checked whether this is
1288244f4554SBosko Milekic 		 * mathematically possible for all cases, so we make
1289244f4554SBosko Milekic 		 * sure here anyway.
1290244f4554SBosko Milekic 		 */
1291099a0e58SBosko Milekic 		if (totsize > UMA_SLAB_SIZE) {
1292099a0e58SBosko Milekic 			printf("zone %s ipers %d rsize %d size %d\n",
1293099a0e58SBosko Milekic 			    zone->uz_name, keg->uk_ipers, keg->uk_rsize,
1294099a0e58SBosko Milekic 			    keg->uk_size);
1295099a0e58SBosko Milekic 			panic("UMA slab won't fit.\n");
1296099a0e58SBosko Milekic 		}
1297099a0e58SBosko Milekic 	}
1298099a0e58SBosko Milekic 
1299099a0e58SBosko Milekic 	if (keg->uk_flags & UMA_ZONE_HASH)
1300099a0e58SBosko Milekic 		hash_alloc(&keg->uk_hash);
1301099a0e58SBosko Milekic 
1302099a0e58SBosko Milekic #ifdef UMA_DEBUG
1303099a0e58SBosko Milekic 	printf("%s(%p) size = %d ipers = %d ppera = %d pgoff = %d\n",
1304099a0e58SBosko Milekic 	    zone->uz_name, zone,
1305099a0e58SBosko Milekic 	    keg->uk_size, keg->uk_ipers,
1306099a0e58SBosko Milekic 	    keg->uk_ppera, keg->uk_pgoff);
1307099a0e58SBosko Milekic #endif
1308099a0e58SBosko Milekic 
1309099a0e58SBosko Milekic 	LIST_INSERT_HEAD(&keg->uk_zones, zone, uz_link);
1310099a0e58SBosko Milekic 
1311099a0e58SBosko Milekic 	mtx_lock(&uma_mtx);
1312099a0e58SBosko Milekic 	LIST_INSERT_HEAD(&uma_kegs, keg, uk_link);
1313099a0e58SBosko Milekic 	mtx_unlock(&uma_mtx);
1314b23f72e9SBrian Feldman 	return (0);
1315099a0e58SBosko Milekic }
1316099a0e58SBosko Milekic 
1317099a0e58SBosko Milekic /*
1318099a0e58SBosko Milekic  * Zone header ctor.  This initializes all fields, locks, etc.
1319099a0e58SBosko Milekic  *
1320099a0e58SBosko Milekic  * Arguments/Returns follow uma_ctor specifications
1321099a0e58SBosko Milekic  *	udata  Actually uma_zctor_args
13228355f576SJeff Roberson  */
13238355f576SJeff Roberson 
1324b23f72e9SBrian Feldman static int
1325b23f72e9SBrian Feldman zone_ctor(void *mem, int size, void *udata, int flags)
13268355f576SJeff Roberson {
13278355f576SJeff Roberson 	struct uma_zctor_args *arg = udata;
13288355f576SJeff Roberson 	uma_zone_t zone = mem;
1329099a0e58SBosko Milekic 	uma_zone_t z;
1330099a0e58SBosko Milekic 	uma_keg_t keg;
13318355f576SJeff Roberson 
13328355f576SJeff Roberson 	bzero(zone, size);
13338355f576SJeff Roberson 	zone->uz_name = arg->name;
13348355f576SJeff Roberson 	zone->uz_ctor = arg->ctor;
13358355f576SJeff Roberson 	zone->uz_dtor = arg->dtor;
1336099a0e58SBosko Milekic 	zone->uz_init = NULL;
1337099a0e58SBosko Milekic 	zone->uz_fini = NULL;
1338099a0e58SBosko Milekic 	zone->uz_allocs = 0;
1339773df9abSRobert Watson 	zone->uz_frees = 0;
13402019094aSRobert Watson 	zone->uz_fails = 0;
1341099a0e58SBosko Milekic 	zone->uz_fills = zone->uz_count = 0;
1342099a0e58SBosko Milekic 
1343099a0e58SBosko Milekic 	if (arg->flags & UMA_ZONE_SECONDARY) {
1344099a0e58SBosko Milekic 		KASSERT(arg->keg != NULL, ("Secondary zone on zero'd keg"));
1345099a0e58SBosko Milekic 		keg = arg->keg;
1346099a0e58SBosko Milekic 		zone->uz_keg = keg;
13478355f576SJeff Roberson 		zone->uz_init = arg->uminit;
1348e221e841SJeff Roberson 		zone->uz_fini = arg->fini;
1349099a0e58SBosko Milekic 		zone->uz_lock = &keg->uk_lock;
13508355f576SJeff Roberson 		mtx_lock(&uma_mtx);
1351099a0e58SBosko Milekic 		ZONE_LOCK(zone);
1352099a0e58SBosko Milekic 		keg->uk_flags |= UMA_ZONE_SECONDARY;
1353099a0e58SBosko Milekic 		LIST_FOREACH(z, &keg->uk_zones, uz_link) {
1354099a0e58SBosko Milekic 			if (LIST_NEXT(z, uz_link) == NULL) {
1355099a0e58SBosko Milekic 				LIST_INSERT_AFTER(z, zone, uz_link);
1356099a0e58SBosko Milekic 				break;
1357099a0e58SBosko Milekic 			}
1358099a0e58SBosko Milekic 		}
1359099a0e58SBosko Milekic 		ZONE_UNLOCK(zone);
13608355f576SJeff Roberson 		mtx_unlock(&uma_mtx);
1361099a0e58SBosko Milekic 	} else if (arg->keg == NULL) {
1362b23f72e9SBrian Feldman 		if (uma_kcreate(zone, arg->size, arg->uminit, arg->fini,
1363b23f72e9SBrian Feldman 		    arg->align, arg->flags) == NULL)
1364b23f72e9SBrian Feldman 			return (ENOMEM);
1365099a0e58SBosko Milekic 	} else {
1366099a0e58SBosko Milekic 		struct uma_kctor_args karg;
1367b23f72e9SBrian Feldman 		int error;
1368099a0e58SBosko Milekic 
1369099a0e58SBosko Milekic 		/* We should only be here from uma_startup() */
1370099a0e58SBosko Milekic 		karg.size = arg->size;
1371099a0e58SBosko Milekic 		karg.uminit = arg->uminit;
1372099a0e58SBosko Milekic 		karg.fini = arg->fini;
1373099a0e58SBosko Milekic 		karg.align = arg->align;
1374099a0e58SBosko Milekic 		karg.flags = arg->flags;
1375099a0e58SBosko Milekic 		karg.zone = zone;
1376b23f72e9SBrian Feldman 		error = keg_ctor(arg->keg, sizeof(struct uma_keg), &karg,
1377b23f72e9SBrian Feldman 		    flags);
1378b23f72e9SBrian Feldman 		if (error)
1379b23f72e9SBrian Feldman 			return (error);
1380099a0e58SBosko Milekic 	}
1381099a0e58SBosko Milekic 	keg = zone->uz_keg;
1382099a0e58SBosko Milekic 	zone->uz_lock = &keg->uk_lock;
13838355f576SJeff Roberson 
13848355f576SJeff Roberson 	/*
13858355f576SJeff Roberson 	 * Some internal zones don't have room allocated for the per cpu
13868355f576SJeff Roberson 	 * caches.  If we're internal, bail out here.
13878355f576SJeff Roberson 	 */
1388099a0e58SBosko Milekic 	if (keg->uk_flags & UMA_ZFLAG_INTERNAL) {
1389099a0e58SBosko Milekic 		KASSERT((keg->uk_flags & UMA_ZONE_SECONDARY) == 0,
1390099a0e58SBosko Milekic 		    ("Secondary zone requested UMA_ZFLAG_INTERNAL"));
1391b23f72e9SBrian Feldman 		return (0);
1392099a0e58SBosko Milekic 	}
13938355f576SJeff Roberson 
1394099a0e58SBosko Milekic 	if (keg->uk_flags & UMA_ZONE_MAXBUCKET)
1395099a0e58SBosko Milekic 		zone->uz_count = BUCKET_MAX;
1396099a0e58SBosko Milekic 	else if (keg->uk_ipers <= BUCKET_MAX)
1397099a0e58SBosko Milekic 		zone->uz_count = keg->uk_ipers;
13988355f576SJeff Roberson 	else
1399cae33c14SJeff Roberson 		zone->uz_count = BUCKET_MAX;
1400b23f72e9SBrian Feldman 	return (0);
14018355f576SJeff Roberson }
14028355f576SJeff Roberson 
14038355f576SJeff Roberson /*
1404099a0e58SBosko Milekic  * Keg header dtor.  This frees all data, destroys locks, frees the hash
1405099a0e58SBosko Milekic  * table and removes the keg from the global list.
14069c2cd7e5SJeff Roberson  *
14079c2cd7e5SJeff Roberson  * Arguments/Returns follow uma_dtor specifications
14089c2cd7e5SJeff Roberson  *	udata  unused
14099c2cd7e5SJeff Roberson  */
1410099a0e58SBosko Milekic static void
1411099a0e58SBosko Milekic keg_dtor(void *arg, int size, void *udata)
1412099a0e58SBosko Milekic {
1413099a0e58SBosko Milekic 	uma_keg_t keg;
14149c2cd7e5SJeff Roberson 
1415099a0e58SBosko Milekic 	keg = (uma_keg_t)arg;
1416099a0e58SBosko Milekic 	mtx_lock(&keg->uk_lock);
1417099a0e58SBosko Milekic 	if (keg->uk_free != 0) {
1418099a0e58SBosko Milekic 		printf("Freed UMA keg was not empty (%d items). "
1419099a0e58SBosko Milekic 		    " Lost %d pages of memory.\n",
1420099a0e58SBosko Milekic 		    keg->uk_free, keg->uk_pages);
1421099a0e58SBosko Milekic 	}
1422099a0e58SBosko Milekic 	mtx_unlock(&keg->uk_lock);
1423099a0e58SBosko Milekic 
1424099a0e58SBosko Milekic 	if (keg->uk_flags & UMA_ZONE_HASH)
1425099a0e58SBosko Milekic 		hash_free(&keg->uk_hash);
1426099a0e58SBosko Milekic 
1427099a0e58SBosko Milekic 	mtx_destroy(&keg->uk_lock);
1428099a0e58SBosko Milekic }
1429099a0e58SBosko Milekic 
1430099a0e58SBosko Milekic /*
1431099a0e58SBosko Milekic  * Zone header dtor.
1432099a0e58SBosko Milekic  *
1433099a0e58SBosko Milekic  * Arguments/Returns follow uma_dtor specifications
1434099a0e58SBosko Milekic  *	udata  unused
1435099a0e58SBosko Milekic  */
14369c2cd7e5SJeff Roberson static void
14379c2cd7e5SJeff Roberson zone_dtor(void *arg, int size, void *udata)
14389c2cd7e5SJeff Roberson {
14399c2cd7e5SJeff Roberson 	uma_zone_t zone;
1440099a0e58SBosko Milekic 	uma_keg_t keg;
14419c2cd7e5SJeff Roberson 
14429c2cd7e5SJeff Roberson 	zone = (uma_zone_t)arg;
1443099a0e58SBosko Milekic 	keg = zone->uz_keg;
14449643769aSJeff Roberson 
1445099a0e58SBosko Milekic 	if (!(keg->uk_flags & UMA_ZFLAG_INTERNAL))
14469643769aSJeff Roberson 		cache_drain(zone);
1447099a0e58SBosko Milekic 
144817b9cc49SJeff Roberson 	mtx_lock(&uma_mtx);
14499643769aSJeff Roberson 	zone_drain(zone);
1450099a0e58SBosko Milekic 	if (keg->uk_flags & UMA_ZONE_SECONDARY) {
1451099a0e58SBosko Milekic 		LIST_REMOVE(zone, uz_link);
1452099a0e58SBosko Milekic 		/*
1453099a0e58SBosko Milekic 		 * XXX there are some races here where
1454099a0e58SBosko Milekic 		 * the zone can be drained but zone lock
1455099a0e58SBosko Milekic 		 * released and then refilled before we
1456099a0e58SBosko Milekic 		 * remove it... we dont care for now
1457099a0e58SBosko Milekic 		 */
14589c2cd7e5SJeff Roberson 		ZONE_LOCK(zone);
1459099a0e58SBosko Milekic 		if (LIST_EMPTY(&keg->uk_zones))
1460099a0e58SBosko Milekic 			keg->uk_flags &= ~UMA_ZONE_SECONDARY;
14619c2cd7e5SJeff Roberson 		ZONE_UNLOCK(zone);
1462099a0e58SBosko Milekic 		mtx_unlock(&uma_mtx);
1463099a0e58SBosko Milekic 	} else {
1464099a0e58SBosko Milekic 		LIST_REMOVE(keg, uk_link);
1465099a0e58SBosko Milekic 		LIST_REMOVE(zone, uz_link);
1466099a0e58SBosko Milekic 		mtx_unlock(&uma_mtx);
1467f4ff923bSRobert Watson 		uma_zfree_internal(kegs, keg, NULL, SKIP_NONE,
1468f4ff923bSRobert Watson 		    ZFREE_STATFREE);
14699c2cd7e5SJeff Roberson 	}
1470099a0e58SBosko Milekic 	zone->uz_keg = NULL;
1471099a0e58SBosko Milekic }
1472099a0e58SBosko Milekic 
14739c2cd7e5SJeff Roberson /*
14748355f576SJeff Roberson  * Traverses every zone in the system and calls a callback
14758355f576SJeff Roberson  *
14768355f576SJeff Roberson  * Arguments:
14778355f576SJeff Roberson  *	zfunc  A pointer to a function which accepts a zone
14788355f576SJeff Roberson  *		as an argument.
14798355f576SJeff Roberson  *
14808355f576SJeff Roberson  * Returns:
14818355f576SJeff Roberson  *	Nothing
14828355f576SJeff Roberson  */
14838355f576SJeff Roberson static void
14848355f576SJeff Roberson zone_foreach(void (*zfunc)(uma_zone_t))
14858355f576SJeff Roberson {
1486099a0e58SBosko Milekic 	uma_keg_t keg;
14878355f576SJeff Roberson 	uma_zone_t zone;
14888355f576SJeff Roberson 
14898355f576SJeff Roberson 	mtx_lock(&uma_mtx);
1490099a0e58SBosko Milekic 	LIST_FOREACH(keg, &uma_kegs, uk_link) {
1491099a0e58SBosko Milekic 		LIST_FOREACH(zone, &keg->uk_zones, uz_link)
14928355f576SJeff Roberson 			zfunc(zone);
1493099a0e58SBosko Milekic 	}
14948355f576SJeff Roberson 	mtx_unlock(&uma_mtx);
14958355f576SJeff Roberson }
14968355f576SJeff Roberson 
14978355f576SJeff Roberson /* Public functions */
14988355f576SJeff Roberson /* See uma.h */
14998355f576SJeff Roberson void
15003803b26bSDag-Erling Smørgrav uma_startup(void *bootmem, int boot_pages)
15018355f576SJeff Roberson {
15028355f576SJeff Roberson 	struct uma_zctor_args args;
15038355f576SJeff Roberson 	uma_slab_t slab;
1504244f4554SBosko Milekic 	u_int slabsize;
1505244f4554SBosko Milekic 	u_int objsize, totsize, wsize;
15068355f576SJeff Roberson 	int i;
15078355f576SJeff Roberson 
15088355f576SJeff Roberson #ifdef UMA_DEBUG
1509099a0e58SBosko Milekic 	printf("Creating uma keg headers zone and keg.\n");
15108355f576SJeff Roberson #endif
1511f353d338SAlan Cox 	mtx_init(&uma_mtx, "UMA lock", NULL, MTX_DEF);
1512099a0e58SBosko Milekic 
1513244f4554SBosko Milekic 	/*
1514244f4554SBosko Milekic 	 * Figure out the maximum number of items-per-slab we'll have if
1515244f4554SBosko Milekic 	 * we're using the OFFPAGE slab header to track free items, given
1516244f4554SBosko Milekic 	 * all possible object sizes and the maximum desired wastage
1517244f4554SBosko Milekic 	 * (UMA_MAX_WASTE).
1518244f4554SBosko Milekic 	 *
1519244f4554SBosko Milekic 	 * We iterate until we find an object size for
1520244f4554SBosko Milekic 	 * which the calculated wastage in zone_small_init() will be
1521244f4554SBosko Milekic 	 * enough to warrant OFFPAGE.  Since wastedspace versus objsize
1522244f4554SBosko Milekic 	 * is an overall increasing see-saw function, we find the smallest
1523244f4554SBosko Milekic 	 * objsize such that the wastage is always acceptable for objects
1524244f4554SBosko Milekic 	 * with that objsize or smaller.  Since a smaller objsize always
1525244f4554SBosko Milekic 	 * generates a larger possible uma_max_ipers, we use this computed
1526244f4554SBosko Milekic 	 * objsize to calculate the largest ipers possible.  Since the
1527244f4554SBosko Milekic 	 * ipers calculated for OFFPAGE slab headers is always larger than
1528244f4554SBosko Milekic 	 * the ipers initially calculated in zone_small_init(), we use
1529244f4554SBosko Milekic 	 * the former's equation (UMA_SLAB_SIZE / keg->uk_rsize) to
1530244f4554SBosko Milekic 	 * obtain the maximum ipers possible for offpage slab headers.
1531244f4554SBosko Milekic 	 *
1532244f4554SBosko Milekic 	 * It should be noted that ipers versus objsize is an inversly
1533244f4554SBosko Milekic 	 * proportional function which drops off rather quickly so as
1534244f4554SBosko Milekic 	 * long as our UMA_MAX_WASTE is such that the objsize we calculate
1535244f4554SBosko Milekic 	 * falls into the portion of the inverse relation AFTER the steep
1536244f4554SBosko Milekic 	 * falloff, then uma_max_ipers shouldn't be too high (~10 on i386).
1537244f4554SBosko Milekic 	 *
1538244f4554SBosko Milekic 	 * Note that we have 8-bits (1 byte) to use as a freelist index
1539244f4554SBosko Milekic 	 * inside the actual slab header itself and this is enough to
1540244f4554SBosko Milekic 	 * accomodate us.  In the worst case, a UMA_SMALLEST_UNIT sized
1541244f4554SBosko Milekic 	 * object with offpage slab header would have ipers =
1542244f4554SBosko Milekic 	 * UMA_SLAB_SIZE / UMA_SMALLEST_UNIT (currently = 256), which is
1543244f4554SBosko Milekic 	 * 1 greater than what our byte-integer freelist index can
1544244f4554SBosko Milekic 	 * accomodate, but we know that this situation never occurs as
1545244f4554SBosko Milekic 	 * for UMA_SMALLEST_UNIT-sized objects, we will never calculate
1546244f4554SBosko Milekic 	 * that we need to go to offpage slab headers.  Or, if we do,
1547244f4554SBosko Milekic 	 * then we trap that condition below and panic in the INVARIANTS case.
1548244f4554SBosko Milekic 	 */
1549244f4554SBosko Milekic 	wsize = UMA_SLAB_SIZE - sizeof(struct uma_slab) - UMA_MAX_WASTE;
1550244f4554SBosko Milekic 	totsize = wsize;
1551244f4554SBosko Milekic 	objsize = UMA_SMALLEST_UNIT;
1552244f4554SBosko Milekic 	while (totsize >= wsize) {
1553244f4554SBosko Milekic 		totsize = (UMA_SLAB_SIZE - sizeof(struct uma_slab)) /
1554244f4554SBosko Milekic 		    (objsize + UMA_FRITM_SZ);
1555244f4554SBosko Milekic 		totsize *= (UMA_FRITM_SZ + objsize);
1556244f4554SBosko Milekic 		objsize++;
1557244f4554SBosko Milekic 	}
1558244f4554SBosko Milekic 	if (objsize > UMA_SMALLEST_UNIT)
1559244f4554SBosko Milekic 		objsize--;
1560244f4554SBosko Milekic 	uma_max_ipers = UMA_SLAB_SIZE / objsize;
1561244f4554SBosko Milekic 
1562244f4554SBosko Milekic 	wsize = UMA_SLAB_SIZE - sizeof(struct uma_slab_refcnt) - UMA_MAX_WASTE;
1563244f4554SBosko Milekic 	totsize = wsize;
1564244f4554SBosko Milekic 	objsize = UMA_SMALLEST_UNIT;
1565244f4554SBosko Milekic 	while (totsize >= wsize) {
1566244f4554SBosko Milekic 		totsize = (UMA_SLAB_SIZE - sizeof(struct uma_slab_refcnt)) /
1567244f4554SBosko Milekic 		    (objsize + UMA_FRITMREF_SZ);
1568244f4554SBosko Milekic 		totsize *= (UMA_FRITMREF_SZ + objsize);
1569244f4554SBosko Milekic 		objsize++;
1570244f4554SBosko Milekic 	}
1571244f4554SBosko Milekic 	if (objsize > UMA_SMALLEST_UNIT)
1572244f4554SBosko Milekic 		objsize--;
1573244f4554SBosko Milekic 	uma_max_ipers_ref = UMA_SLAB_SIZE / objsize;
1574244f4554SBosko Milekic 
1575244f4554SBosko Milekic 	KASSERT((uma_max_ipers_ref <= 255) && (uma_max_ipers <= 255),
1576244f4554SBosko Milekic 	    ("uma_startup: calculated uma_max_ipers values too large!"));
1577244f4554SBosko Milekic 
1578244f4554SBosko Milekic #ifdef UMA_DEBUG
1579244f4554SBosko Milekic 	printf("Calculated uma_max_ipers (for OFFPAGE) is %d\n", uma_max_ipers);
1580244f4554SBosko Milekic 	printf("Calculated uma_max_ipers_slab (for OFFPAGE) is %d\n",
1581244f4554SBosko Milekic 	    uma_max_ipers_ref);
1582244f4554SBosko Milekic #endif
1583244f4554SBosko Milekic 
1584099a0e58SBosko Milekic 	/* "manually" create the initial zone */
1585099a0e58SBosko Milekic 	args.name = "UMA Kegs";
1586099a0e58SBosko Milekic 	args.size = sizeof(struct uma_keg);
1587099a0e58SBosko Milekic 	args.ctor = keg_ctor;
1588099a0e58SBosko Milekic 	args.dtor = keg_dtor;
15898355f576SJeff Roberson 	args.uminit = zero_init;
15908355f576SJeff Roberson 	args.fini = NULL;
1591099a0e58SBosko Milekic 	args.keg = &masterkeg;
15928355f576SJeff Roberson 	args.align = 32 - 1;
1593b60f5b79SJeff Roberson 	args.flags = UMA_ZFLAG_INTERNAL;
15948355f576SJeff Roberson 	/* The initial zone has no Per cpu queues so it's smaller */
1595b23f72e9SBrian Feldman 	zone_ctor(kegs, sizeof(struct uma_zone), &args, M_WAITOK);
15968355f576SJeff Roberson 
15978355f576SJeff Roberson #ifdef UMA_DEBUG
15988355f576SJeff Roberson 	printf("Filling boot free list.\n");
15998355f576SJeff Roberson #endif
16003803b26bSDag-Erling Smørgrav 	for (i = 0; i < boot_pages; i++) {
16018355f576SJeff Roberson 		slab = (uma_slab_t)((u_int8_t *)bootmem + (i * UMA_SLAB_SIZE));
16028355f576SJeff Roberson 		slab->us_data = (u_int8_t *)slab;
16038355f576SJeff Roberson 		slab->us_flags = UMA_SLAB_BOOT;
16048355f576SJeff Roberson 		LIST_INSERT_HEAD(&uma_boot_pages, slab, us_link);
16058355f576SJeff Roberson 	}
1606f353d338SAlan Cox 	mtx_init(&uma_boot_pages_mtx, "UMA boot pages", NULL, MTX_DEF);
16078355f576SJeff Roberson 
16088355f576SJeff Roberson #ifdef UMA_DEBUG
1609099a0e58SBosko Milekic 	printf("Creating uma zone headers zone and keg.\n");
1610099a0e58SBosko Milekic #endif
1611099a0e58SBosko Milekic 	args.name = "UMA Zones";
1612099a0e58SBosko Milekic 	args.size = sizeof(struct uma_zone) +
1613099a0e58SBosko Milekic 	    (sizeof(struct uma_cache) * (mp_maxid + 1));
1614099a0e58SBosko Milekic 	args.ctor = zone_ctor;
1615099a0e58SBosko Milekic 	args.dtor = zone_dtor;
1616099a0e58SBosko Milekic 	args.uminit = zero_init;
1617099a0e58SBosko Milekic 	args.fini = NULL;
1618099a0e58SBosko Milekic 	args.keg = NULL;
1619099a0e58SBosko Milekic 	args.align = 32 - 1;
1620099a0e58SBosko Milekic 	args.flags = UMA_ZFLAG_INTERNAL;
1621099a0e58SBosko Milekic 	/* The initial zone has no Per cpu queues so it's smaller */
1622b23f72e9SBrian Feldman 	zone_ctor(zones, sizeof(struct uma_zone), &args, M_WAITOK);
1623099a0e58SBosko Milekic 
1624099a0e58SBosko Milekic #ifdef UMA_DEBUG
1625099a0e58SBosko Milekic 	printf("Initializing pcpu cache locks.\n");
1626099a0e58SBosko Milekic #endif
1627099a0e58SBosko Milekic #ifdef UMA_DEBUG
1628099a0e58SBosko Milekic 	printf("Creating slab and hash zones.\n");
16298355f576SJeff Roberson #endif
16308355f576SJeff Roberson 
16318355f576SJeff Roberson 	/*
16328355f576SJeff Roberson 	 * This is the max number of free list items we'll have with
16338355f576SJeff Roberson 	 * offpage slabs.
16348355f576SJeff Roberson 	 */
1635244f4554SBosko Milekic 	slabsize = uma_max_ipers * UMA_FRITM_SZ;
16368355f576SJeff Roberson 	slabsize += sizeof(struct uma_slab);
16378355f576SJeff Roberson 
16388355f576SJeff Roberson 	/* Now make a zone for slab headers */
16398355f576SJeff Roberson 	slabzone = uma_zcreate("UMA Slabs",
16408355f576SJeff Roberson 				slabsize,
16418355f576SJeff Roberson 				NULL, NULL, NULL, NULL,
1642b60f5b79SJeff Roberson 				UMA_ALIGN_PTR, UMA_ZFLAG_INTERNAL);
16438355f576SJeff Roberson 
1644099a0e58SBosko Milekic 	/*
1645099a0e58SBosko Milekic 	 * We also create a zone for the bigger slabs with reference
1646099a0e58SBosko Milekic 	 * counts in them, to accomodate UMA_ZONE_REFCNT zones.
1647099a0e58SBosko Milekic 	 */
1648244f4554SBosko Milekic 	slabsize = uma_max_ipers_ref * UMA_FRITMREF_SZ;
1649099a0e58SBosko Milekic 	slabsize += sizeof(struct uma_slab_refcnt);
1650099a0e58SBosko Milekic 	slabrefzone = uma_zcreate("UMA RCntSlabs",
1651099a0e58SBosko Milekic 				  slabsize,
1652099a0e58SBosko Milekic 				  NULL, NULL, NULL, NULL,
1653e66468eaSBosko Milekic 				  UMA_ALIGN_PTR,
16547fd87882SBosko Milekic 				  UMA_ZFLAG_INTERNAL);
1655099a0e58SBosko Milekic 
16568355f576SJeff Roberson 	hashzone = uma_zcreate("UMA Hash",
16578355f576SJeff Roberson 	    sizeof(struct slabhead *) * UMA_HASH_SIZE_INIT,
16588355f576SJeff Roberson 	    NULL, NULL, NULL, NULL,
1659b60f5b79SJeff Roberson 	    UMA_ALIGN_PTR, UMA_ZFLAG_INTERNAL);
16608355f576SJeff Roberson 
1661cae33c14SJeff Roberson 	bucket_init();
16628355f576SJeff Roberson 
1663009b6fcbSJeff Roberson #ifdef UMA_MD_SMALL_ALLOC
166448eea375SJeff Roberson 	booted = 1;
166548eea375SJeff Roberson #endif
16668355f576SJeff Roberson 
16678355f576SJeff Roberson #ifdef UMA_DEBUG
16688355f576SJeff Roberson 	printf("UMA startup complete.\n");
16698355f576SJeff Roberson #endif
16708355f576SJeff Roberson }
16718355f576SJeff Roberson 
16728355f576SJeff Roberson /* see uma.h */
16738355f576SJeff Roberson void
167499571dc3SJeff Roberson uma_startup2(void)
16758355f576SJeff Roberson {
16768355f576SJeff Roberson 	booted = 1;
167786bbae32SJeff Roberson 	bucket_enable();
16788355f576SJeff Roberson #ifdef UMA_DEBUG
16798355f576SJeff Roberson 	printf("UMA startup2 complete.\n");
16808355f576SJeff Roberson #endif
16818355f576SJeff Roberson }
16828355f576SJeff Roberson 
16838355f576SJeff Roberson /*
16848355f576SJeff Roberson  * Initialize our callout handle
16858355f576SJeff Roberson  *
16868355f576SJeff Roberson  */
16878355f576SJeff Roberson 
16888355f576SJeff Roberson static void
16898355f576SJeff Roberson uma_startup3(void)
16908355f576SJeff Roberson {
16918355f576SJeff Roberson #ifdef UMA_DEBUG
16928355f576SJeff Roberson 	printf("Starting callout.\n");
16938355f576SJeff Roberson #endif
1694a3c07611SRobert Watson 	callout_init(&uma_callout, CALLOUT_MPSAFE);
16959643769aSJeff Roberson 	callout_reset(&uma_callout, UMA_TIMEOUT * hz, uma_timeout, NULL);
16968355f576SJeff Roberson #ifdef UMA_DEBUG
16978355f576SJeff Roberson 	printf("UMA startup3 complete.\n");
16988355f576SJeff Roberson #endif
16998355f576SJeff Roberson }
17008355f576SJeff Roberson 
1701b23f72e9SBrian Feldman static uma_zone_t
1702099a0e58SBosko Milekic uma_kcreate(uma_zone_t zone, size_t size, uma_init uminit, uma_fini fini,
17032018f30cSMike Silbersack 		int align, u_int32_t flags)
1704099a0e58SBosko Milekic {
1705099a0e58SBosko Milekic 	struct uma_kctor_args args;
1706099a0e58SBosko Milekic 
1707099a0e58SBosko Milekic 	args.size = size;
1708099a0e58SBosko Milekic 	args.uminit = uminit;
1709099a0e58SBosko Milekic 	args.fini = fini;
1710099a0e58SBosko Milekic 	args.align = align;
1711099a0e58SBosko Milekic 	args.flags = flags;
1712099a0e58SBosko Milekic 	args.zone = zone;
1713b23f72e9SBrian Feldman 	return (uma_zalloc_internal(kegs, &args, M_WAITOK));
1714099a0e58SBosko Milekic }
1715099a0e58SBosko Milekic 
17168355f576SJeff Roberson /* See uma.h */
17178355f576SJeff Roberson uma_zone_t
1718c3bdc05fSAndrew R. Reiter uma_zcreate(char *name, size_t size, uma_ctor ctor, uma_dtor dtor,
17192018f30cSMike Silbersack 		uma_init uminit, uma_fini fini, int align, u_int32_t flags)
17208355f576SJeff Roberson 
17218355f576SJeff Roberson {
17228355f576SJeff Roberson 	struct uma_zctor_args args;
17238355f576SJeff Roberson 
17248355f576SJeff Roberson 	/* This stuff is essential for the zone ctor */
17258355f576SJeff Roberson 	args.name = name;
17268355f576SJeff Roberson 	args.size = size;
17278355f576SJeff Roberson 	args.ctor = ctor;
17288355f576SJeff Roberson 	args.dtor = dtor;
17298355f576SJeff Roberson 	args.uminit = uminit;
17308355f576SJeff Roberson 	args.fini = fini;
17318355f576SJeff Roberson 	args.align = align;
17328355f576SJeff Roberson 	args.flags = flags;
1733099a0e58SBosko Milekic 	args.keg = NULL;
1734099a0e58SBosko Milekic 
1735099a0e58SBosko Milekic 	return (uma_zalloc_internal(zones, &args, M_WAITOK));
1736099a0e58SBosko Milekic }
1737099a0e58SBosko Milekic 
1738099a0e58SBosko Milekic /* See uma.h */
1739099a0e58SBosko Milekic uma_zone_t
1740099a0e58SBosko Milekic uma_zsecond_create(char *name, uma_ctor ctor, uma_dtor dtor,
1741099a0e58SBosko Milekic 		    uma_init zinit, uma_fini zfini, uma_zone_t master)
1742099a0e58SBosko Milekic {
1743099a0e58SBosko Milekic 	struct uma_zctor_args args;
1744099a0e58SBosko Milekic 
1745099a0e58SBosko Milekic 	args.name = name;
1746099a0e58SBosko Milekic 	args.size = master->uz_keg->uk_size;
1747099a0e58SBosko Milekic 	args.ctor = ctor;
1748099a0e58SBosko Milekic 	args.dtor = dtor;
1749099a0e58SBosko Milekic 	args.uminit = zinit;
1750099a0e58SBosko Milekic 	args.fini = zfini;
1751099a0e58SBosko Milekic 	args.align = master->uz_keg->uk_align;
1752099a0e58SBosko Milekic 	args.flags = master->uz_keg->uk_flags | UMA_ZONE_SECONDARY;
1753099a0e58SBosko Milekic 	args.keg = master->uz_keg;
17548355f576SJeff Roberson 
1755a163d034SWarner Losh 	return (uma_zalloc_internal(zones, &args, M_WAITOK));
17568355f576SJeff Roberson }
17578355f576SJeff Roberson 
17588355f576SJeff Roberson /* See uma.h */
17599c2cd7e5SJeff Roberson void
17609c2cd7e5SJeff Roberson uma_zdestroy(uma_zone_t zone)
17619c2cd7e5SJeff Roberson {
1762f4ff923bSRobert Watson 
1763f4ff923bSRobert Watson 	uma_zfree_internal(zones, zone, NULL, SKIP_NONE, ZFREE_STATFREE);
17649c2cd7e5SJeff Roberson }
17659c2cd7e5SJeff Roberson 
17669c2cd7e5SJeff Roberson /* See uma.h */
17678355f576SJeff Roberson void *
17682cc35ff9SJeff Roberson uma_zalloc_arg(uma_zone_t zone, void *udata, int flags)
17698355f576SJeff Roberson {
17708355f576SJeff Roberson 	void *item;
17718355f576SJeff Roberson 	uma_cache_t cache;
17728355f576SJeff Roberson 	uma_bucket_t bucket;
17738355f576SJeff Roberson 	int cpu;
17748355f576SJeff Roberson 
17758355f576SJeff Roberson 	/* This is the fast path allocation */
17768355f576SJeff Roberson #ifdef UMA_DEBUG_ALLOC_1
17778355f576SJeff Roberson 	printf("Allocating one item from %s(%p)\n", zone->uz_name, zone);
17788355f576SJeff Roberson #endif
17793659f747SRobert Watson 	CTR3(KTR_UMA, "uma_zalloc_arg thread %x zone %s flags %d", curthread,
17803659f747SRobert Watson 	    zone->uz_name, flags);
1781a553d4b8SJeff Roberson 
1782635fd505SRobert Watson 	if (flags & M_WAITOK) {
1783b23f72e9SBrian Feldman 		WITNESS_WARN(WARN_GIANTOK | WARN_SLEEPOK, NULL,
1784635fd505SRobert Watson 		    "uma_zalloc_arg: zone \"%s\"", zone->uz_name);
17854c1cc01cSJohn Baldwin 	}
17864c1cc01cSJohn Baldwin 
17875d1ae027SRobert Watson 	/*
17885d1ae027SRobert Watson 	 * If possible, allocate from the per-CPU cache.  There are two
17895d1ae027SRobert Watson 	 * requirements for safe access to the per-CPU cache: (1) the thread
17905d1ae027SRobert Watson 	 * accessing the cache must not be preempted or yield during access,
17915d1ae027SRobert Watson 	 * and (2) the thread must not migrate CPUs without switching which
17925d1ae027SRobert Watson 	 * cache it accesses.  We rely on a critical section to prevent
17935d1ae027SRobert Watson 	 * preemption and migration.  We release the critical section in
17945d1ae027SRobert Watson 	 * order to acquire the zone mutex if we are unable to allocate from
17955d1ae027SRobert Watson 	 * the current cache; when we re-acquire the critical section, we
17965d1ae027SRobert Watson 	 * must detect and handle migration if it has occurred.
17975d1ae027SRobert Watson 	 */
1798a553d4b8SJeff Roberson zalloc_restart:
17995d1ae027SRobert Watson 	critical_enter();
18005d1ae027SRobert Watson 	cpu = curcpu;
18018355f576SJeff Roberson 	cache = &zone->uz_cpu[cpu];
18028355f576SJeff Roberson 
18038355f576SJeff Roberson zalloc_start:
18048355f576SJeff Roberson 	bucket = cache->uc_allocbucket;
18058355f576SJeff Roberson 
18068355f576SJeff Roberson 	if (bucket) {
1807cae33c14SJeff Roberson 		if (bucket->ub_cnt > 0) {
1808cae33c14SJeff Roberson 			bucket->ub_cnt--;
1809cae33c14SJeff Roberson 			item = bucket->ub_bucket[bucket->ub_cnt];
18108355f576SJeff Roberson #ifdef INVARIANTS
1811cae33c14SJeff Roberson 			bucket->ub_bucket[bucket->ub_cnt] = NULL;
18128355f576SJeff Roberson #endif
18138355f576SJeff Roberson 			KASSERT(item != NULL,
18148355f576SJeff Roberson 			    ("uma_zalloc: Bucket pointer mangled."));
18158355f576SJeff Roberson 			cache->uc_allocs++;
18165d1ae027SRobert Watson 			critical_exit();
1817639c9550SJeff Roberson #ifdef INVARIANTS
181881f71edaSMatt Jacob 			ZONE_LOCK(zone);
1819639c9550SJeff Roberson 			uma_dbg_alloc(zone, NULL, item);
182081f71edaSMatt Jacob 			ZONE_UNLOCK(zone);
1821639c9550SJeff Roberson #endif
1822b23f72e9SBrian Feldman 			if (zone->uz_ctor != NULL) {
1823b23f72e9SBrian Feldman 				if (zone->uz_ctor(item, zone->uz_keg->uk_size,
1824b23f72e9SBrian Feldman 				    udata, flags) != 0) {
1825b23f72e9SBrian Feldman 					uma_zfree_internal(zone, item, udata,
1826f4ff923bSRobert Watson 					    SKIP_DTOR, ZFREE_STATFAIL |
1827f4ff923bSRobert Watson 					    ZFREE_STATFREE);
1828b23f72e9SBrian Feldman 					return (NULL);
1829b23f72e9SBrian Feldman 				}
1830b23f72e9SBrian Feldman 			}
18312cc35ff9SJeff Roberson 			if (flags & M_ZERO)
1832099a0e58SBosko Milekic 				bzero(item, zone->uz_keg->uk_size);
18338355f576SJeff Roberson 			return (item);
18348355f576SJeff Roberson 		} else if (cache->uc_freebucket) {
18358355f576SJeff Roberson 			/*
18368355f576SJeff Roberson 			 * We have run out of items in our allocbucket.
18378355f576SJeff Roberson 			 * See if we can switch with our free bucket.
18388355f576SJeff Roberson 			 */
1839cae33c14SJeff Roberson 			if (cache->uc_freebucket->ub_cnt > 0) {
18408355f576SJeff Roberson #ifdef UMA_DEBUG_ALLOC
184164f051e9SJeff Roberson 				printf("uma_zalloc: Swapping empty with"
184264f051e9SJeff Roberson 				    " alloc.\n");
18438355f576SJeff Roberson #endif
1844b983089aSJeff Roberson 				bucket = cache->uc_freebucket;
18458355f576SJeff Roberson 				cache->uc_freebucket = cache->uc_allocbucket;
1846b983089aSJeff Roberson 				cache->uc_allocbucket = bucket;
18478355f576SJeff Roberson 
18488355f576SJeff Roberson 				goto zalloc_start;
18498355f576SJeff Roberson 			}
18508355f576SJeff Roberson 		}
18518355f576SJeff Roberson 	}
18525d1ae027SRobert Watson 	/*
18535d1ae027SRobert Watson 	 * Attempt to retrieve the item from the per-CPU cache has failed, so
18545d1ae027SRobert Watson 	 * we must go back to the zone.  This requires the zone lock, so we
18555d1ae027SRobert Watson 	 * must drop the critical section, then re-acquire it when we go back
18565d1ae027SRobert Watson 	 * to the cache.  Since the critical section is released, we may be
18575d1ae027SRobert Watson 	 * preempted or migrate.  As such, make sure not to maintain any
18585d1ae027SRobert Watson 	 * thread-local state specific to the cache from prior to releasing
18595d1ae027SRobert Watson 	 * the critical section.
18605d1ae027SRobert Watson 	 */
18615d1ae027SRobert Watson 	critical_exit();
1862a553d4b8SJeff Roberson 	ZONE_LOCK(zone);
18635d1ae027SRobert Watson 	critical_enter();
18645d1ae027SRobert Watson 	cpu = curcpu;
18655d1ae027SRobert Watson 	cache = &zone->uz_cpu[cpu];
18665d1ae027SRobert Watson 	bucket = cache->uc_allocbucket;
18675d1ae027SRobert Watson 	if (bucket != NULL) {
18685d1ae027SRobert Watson 		if (bucket->ub_cnt > 0) {
18695d1ae027SRobert Watson 			ZONE_UNLOCK(zone);
18705d1ae027SRobert Watson 			goto zalloc_start;
18715d1ae027SRobert Watson 		}
18725d1ae027SRobert Watson 		bucket = cache->uc_freebucket;
18735d1ae027SRobert Watson 		if (bucket != NULL && bucket->ub_cnt > 0) {
18745d1ae027SRobert Watson 			ZONE_UNLOCK(zone);
18755d1ae027SRobert Watson 			goto zalloc_start;
18765d1ae027SRobert Watson 		}
18775d1ae027SRobert Watson 	}
18785d1ae027SRobert Watson 
1879a553d4b8SJeff Roberson 	/* Since we have locked the zone we may as well send back our stats */
1880a553d4b8SJeff Roberson 	zone->uz_allocs += cache->uc_allocs;
1881a553d4b8SJeff Roberson 	cache->uc_allocs = 0;
1882773df9abSRobert Watson 	zone->uz_frees += cache->uc_frees;
1883773df9abSRobert Watson 	cache->uc_frees = 0;
18848355f576SJeff Roberson 
1885a553d4b8SJeff Roberson 	/* Our old one is now a free bucket */
1886a553d4b8SJeff Roberson 	if (cache->uc_allocbucket) {
1887cae33c14SJeff Roberson 		KASSERT(cache->uc_allocbucket->ub_cnt == 0,
1888a553d4b8SJeff Roberson 		    ("uma_zalloc_arg: Freeing a non free bucket."));
1889a553d4b8SJeff Roberson 		LIST_INSERT_HEAD(&zone->uz_free_bucket,
1890a553d4b8SJeff Roberson 		    cache->uc_allocbucket, ub_link);
1891a553d4b8SJeff Roberson 		cache->uc_allocbucket = NULL;
1892a553d4b8SJeff Roberson 	}
18938355f576SJeff Roberson 
1894a553d4b8SJeff Roberson 	/* Check the free list for a new alloc bucket */
1895a553d4b8SJeff Roberson 	if ((bucket = LIST_FIRST(&zone->uz_full_bucket)) != NULL) {
1896cae33c14SJeff Roberson 		KASSERT(bucket->ub_cnt != 0,
1897a553d4b8SJeff Roberson 		    ("uma_zalloc_arg: Returning an empty bucket."));
18988355f576SJeff Roberson 
1899a553d4b8SJeff Roberson 		LIST_REMOVE(bucket, ub_link);
1900a553d4b8SJeff Roberson 		cache->uc_allocbucket = bucket;
1901a553d4b8SJeff Roberson 		ZONE_UNLOCK(zone);
19028355f576SJeff Roberson 		goto zalloc_start;
1903a553d4b8SJeff Roberson 	}
19045d1ae027SRobert Watson 	/* We are no longer associated with this CPU. */
19055d1ae027SRobert Watson 	critical_exit();
1906bbee39c6SJeff Roberson 
1907a553d4b8SJeff Roberson 	/* Bump up our uz_count so we get here less */
1908cae33c14SJeff Roberson 	if (zone->uz_count < BUCKET_MAX)
1909a553d4b8SJeff Roberson 		zone->uz_count++;
1910099a0e58SBosko Milekic 
19118355f576SJeff Roberson 	/*
1912a553d4b8SJeff Roberson 	 * Now lets just fill a bucket and put it on the free list.  If that
1913a553d4b8SJeff Roberson 	 * works we'll restart the allocation from the begining.
1914bbee39c6SJeff Roberson 	 */
1915bbee39c6SJeff Roberson 	if (uma_zalloc_bucket(zone, flags)) {
1916bbee39c6SJeff Roberson 		ZONE_UNLOCK(zone);
1917bbee39c6SJeff Roberson 		goto zalloc_restart;
1918bbee39c6SJeff Roberson 	}
1919bbee39c6SJeff Roberson 	ZONE_UNLOCK(zone);
1920bbee39c6SJeff Roberson 	/*
1921bbee39c6SJeff Roberson 	 * We may not be able to get a bucket so return an actual item.
1922bbee39c6SJeff Roberson 	 */
1923bbee39c6SJeff Roberson #ifdef UMA_DEBUG
1924bbee39c6SJeff Roberson 	printf("uma_zalloc_arg: Bucketzone returned NULL\n");
1925bbee39c6SJeff Roberson #endif
1926bbee39c6SJeff Roberson 
1927bbee39c6SJeff Roberson 	return (uma_zalloc_internal(zone, udata, flags));
1928bbee39c6SJeff Roberson }
1929bbee39c6SJeff Roberson 
1930bbee39c6SJeff Roberson static uma_slab_t
1931bbee39c6SJeff Roberson uma_zone_slab(uma_zone_t zone, int flags)
1932bbee39c6SJeff Roberson {
1933bbee39c6SJeff Roberson 	uma_slab_t slab;
1934099a0e58SBosko Milekic 	uma_keg_t keg;
1935099a0e58SBosko Milekic 
1936099a0e58SBosko Milekic 	keg = zone->uz_keg;
1937bbee39c6SJeff Roberson 
1938bbee39c6SJeff Roberson 	/*
1939bbee39c6SJeff Roberson 	 * This is to prevent us from recursively trying to allocate
1940bbee39c6SJeff Roberson 	 * buckets.  The problem is that if an allocation forces us to
1941bbee39c6SJeff Roberson 	 * grab a new bucket we will call page_alloc, which will go off
1942bbee39c6SJeff Roberson 	 * and cause the vm to allocate vm_map_entries.  If we need new
1943bbee39c6SJeff Roberson 	 * buckets there too we will recurse in kmem_alloc and bad
1944bbee39c6SJeff Roberson 	 * things happen.  So instead we return a NULL bucket, and make
1945bbee39c6SJeff Roberson 	 * the code that allocates buckets smart enough to deal with it
1946c5c1b16eSBosko Milekic 	 *
1947c5c1b16eSBosko Milekic 	 * XXX: While we want this protection for the bucket zones so that
1948c5c1b16eSBosko Milekic 	 * recursion from the VM is handled (and the calling code that
1949c5c1b16eSBosko Milekic 	 * allocates buckets knows how to deal with it), we do not want
1950c5c1b16eSBosko Milekic 	 * to prevent allocation from the slab header zones (slabzone
1951c5c1b16eSBosko Milekic 	 * and slabrefzone) if uk_recurse is not zero for them.  The
1952c5c1b16eSBosko Milekic 	 * reason is that it could lead to NULL being returned for
1953c5c1b16eSBosko Milekic 	 * slab header allocations even in the M_WAITOK case, and the
1954c5c1b16eSBosko Milekic 	 * caller can't handle that.
1955bbee39c6SJeff Roberson 	 */
1956099a0e58SBosko Milekic 	if (keg->uk_flags & UMA_ZFLAG_INTERNAL && keg->uk_recurse != 0)
1957c5c1b16eSBosko Milekic 		if ((zone != slabzone) && (zone != slabrefzone))
1958bbee39c6SJeff Roberson 			return (NULL);
1959bbee39c6SJeff Roberson 
1960bbee39c6SJeff Roberson 	slab = NULL;
1961bbee39c6SJeff Roberson 
1962bbee39c6SJeff Roberson 	for (;;) {
1963bbee39c6SJeff Roberson 		/*
1964bbee39c6SJeff Roberson 		 * Find a slab with some space.  Prefer slabs that are partially
1965bbee39c6SJeff Roberson 		 * used over those that are totally full.  This helps to reduce
1966bbee39c6SJeff Roberson 		 * fragmentation.
1967bbee39c6SJeff Roberson 		 */
1968099a0e58SBosko Milekic 		if (keg->uk_free != 0) {
1969099a0e58SBosko Milekic 			if (!LIST_EMPTY(&keg->uk_part_slab)) {
1970099a0e58SBosko Milekic 				slab = LIST_FIRST(&keg->uk_part_slab);
1971bbee39c6SJeff Roberson 			} else {
1972099a0e58SBosko Milekic 				slab = LIST_FIRST(&keg->uk_free_slab);
1973bbee39c6SJeff Roberson 				LIST_REMOVE(slab, us_link);
1974099a0e58SBosko Milekic 				LIST_INSERT_HEAD(&keg->uk_part_slab, slab,
1975bbee39c6SJeff Roberson 				    us_link);
1976bbee39c6SJeff Roberson 			}
1977bbee39c6SJeff Roberson 			return (slab);
1978bbee39c6SJeff Roberson 		}
1979bbee39c6SJeff Roberson 
1980bbee39c6SJeff Roberson 		/*
1981bbee39c6SJeff Roberson 		 * M_NOVM means don't ask at all!
1982bbee39c6SJeff Roberson 		 */
1983bbee39c6SJeff Roberson 		if (flags & M_NOVM)
1984bbee39c6SJeff Roberson 			break;
1985bbee39c6SJeff Roberson 
1986099a0e58SBosko Milekic 		if (keg->uk_maxpages &&
1987099a0e58SBosko Milekic 		    keg->uk_pages >= keg->uk_maxpages) {
1988099a0e58SBosko Milekic 			keg->uk_flags |= UMA_ZFLAG_FULL;
1989bbee39c6SJeff Roberson 
1990ebc85edfSJeff Roberson 			if (flags & M_NOWAIT)
1991bbee39c6SJeff Roberson 				break;
1992ebc85edfSJeff Roberson 			else
1993099a0e58SBosko Milekic 				msleep(keg, &keg->uk_lock, PVM,
199464f051e9SJeff Roberson 				    "zonelimit", 0);
1995bbee39c6SJeff Roberson 			continue;
1996bbee39c6SJeff Roberson 		}
1997099a0e58SBosko Milekic 		keg->uk_recurse++;
1998bbee39c6SJeff Roberson 		slab = slab_zalloc(zone, flags);
1999099a0e58SBosko Milekic 		keg->uk_recurse--;
2000099a0e58SBosko Milekic 
2001bbee39c6SJeff Roberson 		/*
2002bbee39c6SJeff Roberson 		 * If we got a slab here it's safe to mark it partially used
2003bbee39c6SJeff Roberson 		 * and return.  We assume that the caller is going to remove
2004bbee39c6SJeff Roberson 		 * at least one item.
2005bbee39c6SJeff Roberson 		 */
2006bbee39c6SJeff Roberson 		if (slab) {
2007099a0e58SBosko Milekic 			LIST_INSERT_HEAD(&keg->uk_part_slab, slab, us_link);
2008bbee39c6SJeff Roberson 			return (slab);
2009bbee39c6SJeff Roberson 		}
2010bbee39c6SJeff Roberson 		/*
2011bbee39c6SJeff Roberson 		 * We might not have been able to get a slab but another cpu
2012bbee39c6SJeff Roberson 		 * could have while we were unlocked.  Check again before we
2013bbee39c6SJeff Roberson 		 * fail.
2014bbee39c6SJeff Roberson 		 */
2015ebc85edfSJeff Roberson 		if (flags & M_NOWAIT)
2016bbee39c6SJeff Roberson 			flags |= M_NOVM;
2017bbee39c6SJeff Roberson 	}
2018bbee39c6SJeff Roberson 	return (slab);
2019bbee39c6SJeff Roberson }
2020bbee39c6SJeff Roberson 
2021d56368d7SBosko Milekic static void *
2022bbee39c6SJeff Roberson uma_slab_alloc(uma_zone_t zone, uma_slab_t slab)
2023bbee39c6SJeff Roberson {
2024099a0e58SBosko Milekic 	uma_keg_t keg;
2025ab14a3f7SBrian Feldman 	uma_slabrefcnt_t slabref;
2026bbee39c6SJeff Roberson 	void *item;
2027bbee39c6SJeff Roberson 	u_int8_t freei;
2028bbee39c6SJeff Roberson 
2029099a0e58SBosko Milekic 	keg = zone->uz_keg;
2030099a0e58SBosko Milekic 
2031bbee39c6SJeff Roberson 	freei = slab->us_firstfree;
2032ab14a3f7SBrian Feldman 	if (keg->uk_flags & UMA_ZONE_REFCNT) {
2033ab14a3f7SBrian Feldman 		slabref = (uma_slabrefcnt_t)slab;
2034ab14a3f7SBrian Feldman 		slab->us_firstfree = slabref->us_freelist[freei].us_item;
2035ab14a3f7SBrian Feldman 	} else {
2036099a0e58SBosko Milekic 		slab->us_firstfree = slab->us_freelist[freei].us_item;
2037ab14a3f7SBrian Feldman 	}
2038099a0e58SBosko Milekic 	item = slab->us_data + (keg->uk_rsize * freei);
2039bbee39c6SJeff Roberson 
2040bbee39c6SJeff Roberson 	slab->us_freecount--;
2041099a0e58SBosko Milekic 	keg->uk_free--;
2042bbee39c6SJeff Roberson #ifdef INVARIANTS
2043bbee39c6SJeff Roberson 	uma_dbg_alloc(zone, slab, item);
2044bbee39c6SJeff Roberson #endif
2045bbee39c6SJeff Roberson 	/* Move this slab to the full list */
2046bbee39c6SJeff Roberson 	if (slab->us_freecount == 0) {
2047bbee39c6SJeff Roberson 		LIST_REMOVE(slab, us_link);
2048099a0e58SBosko Milekic 		LIST_INSERT_HEAD(&keg->uk_full_slab, slab, us_link);
2049bbee39c6SJeff Roberson 	}
2050bbee39c6SJeff Roberson 
2051bbee39c6SJeff Roberson 	return (item);
2052bbee39c6SJeff Roberson }
2053bbee39c6SJeff Roberson 
2054bbee39c6SJeff Roberson static int
2055bbee39c6SJeff Roberson uma_zalloc_bucket(uma_zone_t zone, int flags)
2056bbee39c6SJeff Roberson {
2057bbee39c6SJeff Roberson 	uma_bucket_t bucket;
2058bbee39c6SJeff Roberson 	uma_slab_t slab;
2059099a0e58SBosko Milekic 	int16_t saved;
2060b23f72e9SBrian Feldman 	int max, origflags = flags;
2061bbee39c6SJeff Roberson 
2062bbee39c6SJeff Roberson 	/*
2063a553d4b8SJeff Roberson 	 * Try this zone's free list first so we don't allocate extra buckets.
20648355f576SJeff Roberson 	 */
2065bbee39c6SJeff Roberson 	if ((bucket = LIST_FIRST(&zone->uz_free_bucket)) != NULL) {
2066cae33c14SJeff Roberson 		KASSERT(bucket->ub_cnt == 0,
2067bbee39c6SJeff Roberson 		    ("uma_zalloc_bucket: Bucket on free list is not empty."));
2068a553d4b8SJeff Roberson 		LIST_REMOVE(bucket, ub_link);
2069bbee39c6SJeff Roberson 	} else {
207018aa2de5SJeff Roberson 		int bflags;
207118aa2de5SJeff Roberson 
2072cae33c14SJeff Roberson 		bflags = (flags & ~M_ZERO);
2073099a0e58SBosko Milekic 		if (zone->uz_keg->uk_flags & UMA_ZFLAG_CACHEONLY)
207418aa2de5SJeff Roberson 			bflags |= M_NOVM;
207518aa2de5SJeff Roberson 
2076bbee39c6SJeff Roberson 		ZONE_UNLOCK(zone);
2077cae33c14SJeff Roberson 		bucket = bucket_alloc(zone->uz_count, bflags);
2078bbee39c6SJeff Roberson 		ZONE_LOCK(zone);
2079bbee39c6SJeff Roberson 	}
2080bbee39c6SJeff Roberson 
2081bbee39c6SJeff Roberson 	if (bucket == NULL)
2082bbee39c6SJeff Roberson 		return (0);
2083bbee39c6SJeff Roberson 
2084bbee39c6SJeff Roberson #ifdef SMP
2085a553d4b8SJeff Roberson 	/*
2086bbee39c6SJeff Roberson 	 * This code is here to limit the number of simultaneous bucket fills
2087bbee39c6SJeff Roberson 	 * for any given zone to the number of per cpu caches in this zone. This
2088bbee39c6SJeff Roberson 	 * is done so that we don't allocate more memory than we really need.
2089a553d4b8SJeff Roberson 	 */
2090bbee39c6SJeff Roberson 	if (zone->uz_fills >= mp_ncpus)
2091bbee39c6SJeff Roberson 		goto done;
2092a553d4b8SJeff Roberson 
2093bbee39c6SJeff Roberson #endif
2094bbee39c6SJeff Roberson 	zone->uz_fills++;
2095bbee39c6SJeff Roberson 
209644eca34aSJeff Roberson 	max = MIN(bucket->ub_entries, zone->uz_count);
2097bbee39c6SJeff Roberson 	/* Try to keep the buckets totally full */
2098099a0e58SBosko Milekic 	saved = bucket->ub_cnt;
209944eca34aSJeff Roberson 	while (bucket->ub_cnt < max &&
2100d11e0ba5SJeff Roberson 	    (slab = uma_zone_slab(zone, flags)) != NULL) {
210144eca34aSJeff Roberson 		while (slab->us_freecount && bucket->ub_cnt < max) {
2102cae33c14SJeff Roberson 			bucket->ub_bucket[bucket->ub_cnt++] =
2103bbee39c6SJeff Roberson 			    uma_slab_alloc(zone, slab);
2104bbee39c6SJeff Roberson 		}
2105099a0e58SBosko Milekic 
2106bbee39c6SJeff Roberson 		/* Don't block on the next fill */
2107bbee39c6SJeff Roberson 		flags |= M_NOWAIT;
21088355f576SJeff Roberson 	}
21098355f576SJeff Roberson 
2110099a0e58SBosko Milekic 	/*
2111099a0e58SBosko Milekic 	 * We unlock here because we need to call the zone's init.
2112099a0e58SBosko Milekic 	 * It should be safe to unlock because the slab dealt with
2113099a0e58SBosko Milekic 	 * above is already on the appropriate list within the keg
2114099a0e58SBosko Milekic 	 * and the bucket we filled is not yet on any list, so we
2115099a0e58SBosko Milekic 	 * own it.
2116099a0e58SBosko Milekic 	 */
2117099a0e58SBosko Milekic 	if (zone->uz_init != NULL) {
2118099a0e58SBosko Milekic 		int i;
2119bbee39c6SJeff Roberson 
2120099a0e58SBosko Milekic 		ZONE_UNLOCK(zone);
2121099a0e58SBosko Milekic 		for (i = saved; i < bucket->ub_cnt; i++)
2122b23f72e9SBrian Feldman 			if (zone->uz_init(bucket->ub_bucket[i],
2123b23f72e9SBrian Feldman 			    zone->uz_keg->uk_size, origflags) != 0)
2124b23f72e9SBrian Feldman 				break;
2125b23f72e9SBrian Feldman 		/*
2126b23f72e9SBrian Feldman 		 * If we couldn't initialize the whole bucket, put the
2127b23f72e9SBrian Feldman 		 * rest back onto the freelist.
2128b23f72e9SBrian Feldman 		 */
2129b23f72e9SBrian Feldman 		if (i != bucket->ub_cnt) {
2130b23f72e9SBrian Feldman 			int j;
2131b23f72e9SBrian Feldman 
2132a5a262c6SBosko Milekic 			for (j = i; j < bucket->ub_cnt; j++) {
2133b23f72e9SBrian Feldman 				uma_zfree_internal(zone, bucket->ub_bucket[j],
21342019094aSRobert Watson 				    NULL, SKIP_FINI, 0);
2135a5a262c6SBosko Milekic #ifdef INVARIANTS
2136a5a262c6SBosko Milekic 				bucket->ub_bucket[j] = NULL;
2137a5a262c6SBosko Milekic #endif
2138a5a262c6SBosko Milekic 			}
2139b23f72e9SBrian Feldman 			bucket->ub_cnt = i;
2140b23f72e9SBrian Feldman 		}
2141099a0e58SBosko Milekic 		ZONE_LOCK(zone);
2142099a0e58SBosko Milekic 	}
2143099a0e58SBosko Milekic 
2144099a0e58SBosko Milekic 	zone->uz_fills--;
2145cae33c14SJeff Roberson 	if (bucket->ub_cnt != 0) {
2146bbee39c6SJeff Roberson 		LIST_INSERT_HEAD(&zone->uz_full_bucket,
2147bbee39c6SJeff Roberson 		    bucket, ub_link);
2148bbee39c6SJeff Roberson 		return (1);
2149bbee39c6SJeff Roberson 	}
2150bbee39c6SJeff Roberson #ifdef SMP
2151bbee39c6SJeff Roberson done:
2152bbee39c6SJeff Roberson #endif
2153cae33c14SJeff Roberson 	bucket_free(bucket);
2154bbee39c6SJeff Roberson 
2155bbee39c6SJeff Roberson 	return (0);
2156bbee39c6SJeff Roberson }
21578355f576SJeff Roberson /*
2158bbee39c6SJeff Roberson  * Allocates an item for an internal zone
21598355f576SJeff Roberson  *
21608355f576SJeff Roberson  * Arguments
21618355f576SJeff Roberson  *	zone   The zone to alloc for.
21628355f576SJeff Roberson  *	udata  The data to be passed to the constructor.
2163a163d034SWarner Losh  *	flags  M_WAITOK, M_NOWAIT, M_ZERO.
21648355f576SJeff Roberson  *
21658355f576SJeff Roberson  * Returns
21668355f576SJeff Roberson  *	NULL if there is no memory and M_NOWAIT is set
2167bbee39c6SJeff Roberson  *	An item if successful
21688355f576SJeff Roberson  */
21698355f576SJeff Roberson 
21708355f576SJeff Roberson static void *
2171bbee39c6SJeff Roberson uma_zalloc_internal(uma_zone_t zone, void *udata, int flags)
21728355f576SJeff Roberson {
2173099a0e58SBosko Milekic 	uma_keg_t keg;
21748355f576SJeff Roberson 	uma_slab_t slab;
21758355f576SJeff Roberson 	void *item;
21768355f576SJeff Roberson 
21778355f576SJeff Roberson 	item = NULL;
2178099a0e58SBosko Milekic 	keg = zone->uz_keg;
21798355f576SJeff Roberson 
21808355f576SJeff Roberson #ifdef UMA_DEBUG_ALLOC
21818355f576SJeff Roberson 	printf("INTERNAL: Allocating one item from %s(%p)\n", zone->uz_name, zone);
21828355f576SJeff Roberson #endif
21838355f576SJeff Roberson 	ZONE_LOCK(zone);
21848355f576SJeff Roberson 
2185bbee39c6SJeff Roberson 	slab = uma_zone_slab(zone, flags);
2186bbee39c6SJeff Roberson 	if (slab == NULL) {
21872019094aSRobert Watson 		zone->uz_fails++;
2188bce97791SJeff Roberson 		ZONE_UNLOCK(zone);
2189a553d4b8SJeff Roberson 		return (NULL);
2190bce97791SJeff Roberson 	}
2191a553d4b8SJeff Roberson 
2192bbee39c6SJeff Roberson 	item = uma_slab_alloc(zone, slab);
21938355f576SJeff Roberson 
21942c743d36SRobert Watson 	zone->uz_allocs++;
21952c743d36SRobert Watson 
21968355f576SJeff Roberson 	ZONE_UNLOCK(zone);
21978355f576SJeff Roberson 
2198099a0e58SBosko Milekic 	/*
2199099a0e58SBosko Milekic 	 * We have to call both the zone's init (not the keg's init)
2200099a0e58SBosko Milekic 	 * and the zone's ctor.  This is because the item is going from
2201099a0e58SBosko Milekic 	 * a keg slab directly to the user, and the user is expecting it
2202099a0e58SBosko Milekic 	 * to be both zone-init'd as well as zone-ctor'd.
2203099a0e58SBosko Milekic 	 */
2204b23f72e9SBrian Feldman 	if (zone->uz_init != NULL) {
2205b23f72e9SBrian Feldman 		if (zone->uz_init(item, keg->uk_size, flags) != 0) {
22062019094aSRobert Watson 			uma_zfree_internal(zone, item, udata, SKIP_FINI,
2207f4ff923bSRobert Watson 			    ZFREE_STATFAIL | ZFREE_STATFREE);
2208b23f72e9SBrian Feldman 			return (NULL);
2209b23f72e9SBrian Feldman 		}
2210b23f72e9SBrian Feldman 	}
2211b23f72e9SBrian Feldman 	if (zone->uz_ctor != NULL) {
2212b23f72e9SBrian Feldman 		if (zone->uz_ctor(item, keg->uk_size, udata, flags) != 0) {
22132019094aSRobert Watson 			uma_zfree_internal(zone, item, udata, SKIP_DTOR,
2214f4ff923bSRobert Watson 			    ZFREE_STATFAIL | ZFREE_STATFREE);
2215b23f72e9SBrian Feldman 			return (NULL);
2216b23f72e9SBrian Feldman 		}
2217b23f72e9SBrian Feldman 	}
22182cc35ff9SJeff Roberson 	if (flags & M_ZERO)
2219099a0e58SBosko Milekic 		bzero(item, keg->uk_size);
22208355f576SJeff Roberson 
22218355f576SJeff Roberson 	return (item);
22228355f576SJeff Roberson }
22238355f576SJeff Roberson 
22248355f576SJeff Roberson /* See uma.h */
22258355f576SJeff Roberson void
22268355f576SJeff Roberson uma_zfree_arg(uma_zone_t zone, void *item, void *udata)
22278355f576SJeff Roberson {
2228099a0e58SBosko Milekic 	uma_keg_t keg;
22298355f576SJeff Roberson 	uma_cache_t cache;
22308355f576SJeff Roberson 	uma_bucket_t bucket;
22314741dcbfSJeff Roberson 	int bflags;
22328355f576SJeff Roberson 	int cpu;
22338355f576SJeff Roberson 
2234099a0e58SBosko Milekic 	keg = zone->uz_keg;
2235099a0e58SBosko Milekic 
22368355f576SJeff Roberson #ifdef UMA_DEBUG_ALLOC_1
22378355f576SJeff Roberson 	printf("Freeing item %p to %s(%p)\n", item, zone->uz_name, zone);
22388355f576SJeff Roberson #endif
22393659f747SRobert Watson 	CTR2(KTR_UMA, "uma_zfree_arg thread %x zone %s", curthread,
22403659f747SRobert Watson 	    zone->uz_name);
22413659f747SRobert Watson 
22425d1ae027SRobert Watson 	if (zone->uz_dtor)
22435d1ae027SRobert Watson 		zone->uz_dtor(item, keg->uk_size, udata);
22445d1ae027SRobert Watson #ifdef INVARIANTS
22455d1ae027SRobert Watson 	ZONE_LOCK(zone);
22465d1ae027SRobert Watson 	if (keg->uk_flags & UMA_ZONE_MALLOC)
22475d1ae027SRobert Watson 		uma_dbg_free(zone, udata, item);
22485d1ae027SRobert Watson 	else
22495d1ae027SRobert Watson 		uma_dbg_free(zone, NULL, item);
22505d1ae027SRobert Watson 	ZONE_UNLOCK(zone);
22515d1ae027SRobert Watson #endif
2252af7f9b97SJeff Roberson 	/*
2253af7f9b97SJeff Roberson 	 * The race here is acceptable.  If we miss it we'll just have to wait
2254af7f9b97SJeff Roberson 	 * a little longer for the limits to be reset.
2255af7f9b97SJeff Roberson 	 */
2256099a0e58SBosko Milekic 	if (keg->uk_flags & UMA_ZFLAG_FULL)
2257af7f9b97SJeff Roberson 		goto zfree_internal;
2258af7f9b97SJeff Roberson 
22595d1ae027SRobert Watson 	/*
22605d1ae027SRobert Watson 	 * If possible, free to the per-CPU cache.  There are two
22615d1ae027SRobert Watson 	 * requirements for safe access to the per-CPU cache: (1) the thread
22625d1ae027SRobert Watson 	 * accessing the cache must not be preempted or yield during access,
22635d1ae027SRobert Watson 	 * and (2) the thread must not migrate CPUs without switching which
22645d1ae027SRobert Watson 	 * cache it accesses.  We rely on a critical section to prevent
22655d1ae027SRobert Watson 	 * preemption and migration.  We release the critical section in
22665d1ae027SRobert Watson 	 * order to acquire the zone mutex if we are unable to free to the
22675d1ae027SRobert Watson 	 * current cache; when we re-acquire the critical section, we must
22685d1ae027SRobert Watson 	 * detect and handle migration if it has occurred.
22695d1ae027SRobert Watson 	 */
2270a553d4b8SJeff Roberson zfree_restart:
22715d1ae027SRobert Watson 	critical_enter();
22725d1ae027SRobert Watson 	cpu = curcpu;
22738355f576SJeff Roberson 	cache = &zone->uz_cpu[cpu];
22748355f576SJeff Roberson 
22758355f576SJeff Roberson zfree_start:
22768355f576SJeff Roberson 	bucket = cache->uc_freebucket;
22778355f576SJeff Roberson 
22788355f576SJeff Roberson 	if (bucket) {
2279a553d4b8SJeff Roberson 		/*
2280a553d4b8SJeff Roberson 		 * Do we have room in our bucket? It is OK for this uz count
2281a553d4b8SJeff Roberson 		 * check to be slightly out of sync.
2282a553d4b8SJeff Roberson 		 */
2283a553d4b8SJeff Roberson 
2284cae33c14SJeff Roberson 		if (bucket->ub_cnt < bucket->ub_entries) {
2285cae33c14SJeff Roberson 			KASSERT(bucket->ub_bucket[bucket->ub_cnt] == NULL,
22868355f576SJeff Roberson 			    ("uma_zfree: Freeing to non free bucket index."));
2287cae33c14SJeff Roberson 			bucket->ub_bucket[bucket->ub_cnt] = item;
2288cae33c14SJeff Roberson 			bucket->ub_cnt++;
2289773df9abSRobert Watson 			cache->uc_frees++;
22905d1ae027SRobert Watson 			critical_exit();
22918355f576SJeff Roberson 			return;
22928355f576SJeff Roberson 		} else if (cache->uc_allocbucket) {
22938355f576SJeff Roberson #ifdef UMA_DEBUG_ALLOC
22948355f576SJeff Roberson 			printf("uma_zfree: Swapping buckets.\n");
22958355f576SJeff Roberson #endif
22968355f576SJeff Roberson 			/*
22978355f576SJeff Roberson 			 * We have run out of space in our freebucket.
22988355f576SJeff Roberson 			 * See if we can switch with our alloc bucket.
22998355f576SJeff Roberson 			 */
2300cae33c14SJeff Roberson 			if (cache->uc_allocbucket->ub_cnt <
2301cae33c14SJeff Roberson 			    cache->uc_freebucket->ub_cnt) {
2302b983089aSJeff Roberson 				bucket = cache->uc_freebucket;
23038355f576SJeff Roberson 				cache->uc_freebucket = cache->uc_allocbucket;
2304b983089aSJeff Roberson 				cache->uc_allocbucket = bucket;
23058355f576SJeff Roberson 				goto zfree_start;
23068355f576SJeff Roberson 			}
23078355f576SJeff Roberson 		}
23088355f576SJeff Roberson 	}
23098355f576SJeff Roberson 	/*
2310a553d4b8SJeff Roberson 	 * We can get here for two reasons:
23118355f576SJeff Roberson 	 *
23128355f576SJeff Roberson 	 * 1) The buckets are NULL
2313a553d4b8SJeff Roberson 	 * 2) The alloc and free buckets are both somewhat full.
23145d1ae027SRobert Watson 	 *
23155d1ae027SRobert Watson 	 * We must go back the zone, which requires acquiring the zone lock,
23165d1ae027SRobert Watson 	 * which in turn means we must release and re-acquire the critical
23175d1ae027SRobert Watson 	 * section.  Since the critical section is released, we may be
23185d1ae027SRobert Watson 	 * preempted or migrate.  As such, make sure not to maintain any
23195d1ae027SRobert Watson 	 * thread-local state specific to the cache from prior to releasing
23205d1ae027SRobert Watson 	 * the critical section.
23218355f576SJeff Roberson 	 */
23225d1ae027SRobert Watson 	critical_exit();
23238355f576SJeff Roberson 	ZONE_LOCK(zone);
23245d1ae027SRobert Watson 	critical_enter();
23255d1ae027SRobert Watson 	cpu = curcpu;
23265d1ae027SRobert Watson 	cache = &zone->uz_cpu[cpu];
23275d1ae027SRobert Watson 	if (cache->uc_freebucket != NULL) {
23285d1ae027SRobert Watson 		if (cache->uc_freebucket->ub_cnt <
23295d1ae027SRobert Watson 		    cache->uc_freebucket->ub_entries) {
23305d1ae027SRobert Watson 			ZONE_UNLOCK(zone);
23315d1ae027SRobert Watson 			goto zfree_start;
23325d1ae027SRobert Watson 		}
23335d1ae027SRobert Watson 		if (cache->uc_allocbucket != NULL &&
23345d1ae027SRobert Watson 		    (cache->uc_allocbucket->ub_cnt <
23355d1ae027SRobert Watson 		    cache->uc_freebucket->ub_cnt)) {
23365d1ae027SRobert Watson 			ZONE_UNLOCK(zone);
23375d1ae027SRobert Watson 			goto zfree_start;
23385d1ae027SRobert Watson 		}
23395d1ae027SRobert Watson 	}
23408355f576SJeff Roberson 
2341f4ff923bSRobert Watson 	/* Since we have locked the zone we may as well send back our stats */
2342f4ff923bSRobert Watson 	zone->uz_allocs += cache->uc_allocs;
2343f4ff923bSRobert Watson 	cache->uc_allocs = 0;
2344f4ff923bSRobert Watson 	zone->uz_frees += cache->uc_frees;
2345f4ff923bSRobert Watson 	cache->uc_frees = 0;
2346f4ff923bSRobert Watson 
23478355f576SJeff Roberson 	bucket = cache->uc_freebucket;
23488355f576SJeff Roberson 	cache->uc_freebucket = NULL;
23498355f576SJeff Roberson 
23508355f576SJeff Roberson 	/* Can we throw this on the zone full list? */
23518355f576SJeff Roberson 	if (bucket != NULL) {
23528355f576SJeff Roberson #ifdef UMA_DEBUG_ALLOC
23538355f576SJeff Roberson 		printf("uma_zfree: Putting old bucket on the free list.\n");
23548355f576SJeff Roberson #endif
2355cae33c14SJeff Roberson 		/* ub_cnt is pointing to the last free item */
2356cae33c14SJeff Roberson 		KASSERT(bucket->ub_cnt != 0,
23578355f576SJeff Roberson 		    ("uma_zfree: Attempting to insert an empty bucket onto the full list.\n"));
23588355f576SJeff Roberson 		LIST_INSERT_HEAD(&zone->uz_full_bucket,
23598355f576SJeff Roberson 		    bucket, ub_link);
23608355f576SJeff Roberson 	}
2361a553d4b8SJeff Roberson 	if ((bucket = LIST_FIRST(&zone->uz_free_bucket)) != NULL) {
2362a553d4b8SJeff Roberson 		LIST_REMOVE(bucket, ub_link);
2363a553d4b8SJeff Roberson 		ZONE_UNLOCK(zone);
2364a553d4b8SJeff Roberson 		cache->uc_freebucket = bucket;
2365a553d4b8SJeff Roberson 		goto zfree_start;
2366a553d4b8SJeff Roberson 	}
23675d1ae027SRobert Watson 	/* We are no longer associated with this CPU. */
23685d1ae027SRobert Watson 	critical_exit();
2369a553d4b8SJeff Roberson 
2370a553d4b8SJeff Roberson 	/* And the zone.. */
2371a553d4b8SJeff Roberson 	ZONE_UNLOCK(zone);
2372a553d4b8SJeff Roberson 
23738355f576SJeff Roberson #ifdef UMA_DEBUG_ALLOC
23748355f576SJeff Roberson 	printf("uma_zfree: Allocating new free bucket.\n");
23758355f576SJeff Roberson #endif
23764741dcbfSJeff Roberson 	bflags = M_NOWAIT;
23774741dcbfSJeff Roberson 
2378099a0e58SBosko Milekic 	if (keg->uk_flags & UMA_ZFLAG_CACHEONLY)
23794741dcbfSJeff Roberson 		bflags |= M_NOVM;
2380cae33c14SJeff Roberson 	bucket = bucket_alloc(zone->uz_count, bflags);
23814741dcbfSJeff Roberson 	if (bucket) {
2382a553d4b8SJeff Roberson 		ZONE_LOCK(zone);
2383a553d4b8SJeff Roberson 		LIST_INSERT_HEAD(&zone->uz_free_bucket,
2384a553d4b8SJeff Roberson 		    bucket, ub_link);
23858355f576SJeff Roberson 		ZONE_UNLOCK(zone);
2386a553d4b8SJeff Roberson 		goto zfree_restart;
23878355f576SJeff Roberson 	}
23888355f576SJeff Roberson 
2389a553d4b8SJeff Roberson 	/*
2390a553d4b8SJeff Roberson 	 * If nothing else caught this, we'll just do an internal free.
2391a553d4b8SJeff Roberson 	 */
2392af7f9b97SJeff Roberson zfree_internal:
23934f538c74SRobert Watson 	uma_zfree_internal(zone, item, udata, SKIP_DTOR, ZFREE_STATFREE);
23948355f576SJeff Roberson 
23958355f576SJeff Roberson 	return;
23968355f576SJeff Roberson }
23978355f576SJeff Roberson 
23988355f576SJeff Roberson /*
23998355f576SJeff Roberson  * Frees an item to an INTERNAL zone or allocates a free bucket
24008355f576SJeff Roberson  *
24018355f576SJeff Roberson  * Arguments:
24028355f576SJeff Roberson  *	zone   The zone to free to
24038355f576SJeff Roberson  *	item   The item we're freeing
24048355f576SJeff Roberson  *	udata  User supplied data for the dtor
2405b23f72e9SBrian Feldman  *	skip   Skip dtors and finis
24068355f576SJeff Roberson  */
24078355f576SJeff Roberson static void
2408b23f72e9SBrian Feldman uma_zfree_internal(uma_zone_t zone, void *item, void *udata,
24092019094aSRobert Watson     enum zfreeskip skip, int flags)
24108355f576SJeff Roberson {
24118355f576SJeff Roberson 	uma_slab_t slab;
2412ab14a3f7SBrian Feldman 	uma_slabrefcnt_t slabref;
2413099a0e58SBosko Milekic 	uma_keg_t keg;
24148355f576SJeff Roberson 	u_int8_t *mem;
24158355f576SJeff Roberson 	u_int8_t freei;
24168355f576SJeff Roberson 
2417099a0e58SBosko Milekic 	keg = zone->uz_keg;
2418099a0e58SBosko Milekic 
2419b23f72e9SBrian Feldman 	if (skip < SKIP_DTOR && zone->uz_dtor)
2420099a0e58SBosko Milekic 		zone->uz_dtor(item, keg->uk_size, udata);
2421b23f72e9SBrian Feldman 	if (skip < SKIP_FINI && zone->uz_fini)
2422099a0e58SBosko Milekic 		zone->uz_fini(item, keg->uk_size);
2423bba739abSJeff Roberson 
24248355f576SJeff Roberson 	ZONE_LOCK(zone);
24258355f576SJeff Roberson 
24262019094aSRobert Watson 	if (flags & ZFREE_STATFAIL)
24272019094aSRobert Watson 		zone->uz_fails++;
2428f4ff923bSRobert Watson 	if (flags & ZFREE_STATFREE)
2429f4ff923bSRobert Watson 		zone->uz_frees++;
24302019094aSRobert Watson 
2431099a0e58SBosko Milekic 	if (!(keg->uk_flags & UMA_ZONE_MALLOC)) {
24328355f576SJeff Roberson 		mem = (u_int8_t *)((unsigned long)item & (~UMA_SLAB_MASK));
2433099a0e58SBosko Milekic 		if (keg->uk_flags & UMA_ZONE_HASH)
2434099a0e58SBosko Milekic 			slab = hash_sfind(&keg->uk_hash, mem);
24358355f576SJeff Roberson 		else {
2436099a0e58SBosko Milekic 			mem += keg->uk_pgoff;
24378355f576SJeff Roberson 			slab = (uma_slab_t)mem;
24388355f576SJeff Roberson 		}
24398355f576SJeff Roberson 	} else {
24408355f576SJeff Roberson 		slab = (uma_slab_t)udata;
24418355f576SJeff Roberson 	}
24428355f576SJeff Roberson 
24438355f576SJeff Roberson 	/* Do we need to remove from any lists? */
2444099a0e58SBosko Milekic 	if (slab->us_freecount+1 == keg->uk_ipers) {
24458355f576SJeff Roberson 		LIST_REMOVE(slab, us_link);
2446099a0e58SBosko Milekic 		LIST_INSERT_HEAD(&keg->uk_free_slab, slab, us_link);
24478355f576SJeff Roberson 	} else if (slab->us_freecount == 0) {
24488355f576SJeff Roberson 		LIST_REMOVE(slab, us_link);
2449099a0e58SBosko Milekic 		LIST_INSERT_HEAD(&keg->uk_part_slab, slab, us_link);
24508355f576SJeff Roberson 	}
24518355f576SJeff Roberson 
24528355f576SJeff Roberson 	/* Slab management stuff */
24538355f576SJeff Roberson 	freei = ((unsigned long)item - (unsigned long)slab->us_data)
2454099a0e58SBosko Milekic 		/ keg->uk_rsize;
24558355f576SJeff Roberson 
2456639c9550SJeff Roberson #ifdef INVARIANTS
2457639c9550SJeff Roberson 	if (!skip)
2458639c9550SJeff Roberson 		uma_dbg_free(zone, slab, item);
24598355f576SJeff Roberson #endif
2460639c9550SJeff Roberson 
2461ab14a3f7SBrian Feldman 	if (keg->uk_flags & UMA_ZONE_REFCNT) {
2462ab14a3f7SBrian Feldman 		slabref = (uma_slabrefcnt_t)slab;
2463ab14a3f7SBrian Feldman 		slabref->us_freelist[freei].us_item = slab->us_firstfree;
2464ab14a3f7SBrian Feldman 	} else {
2465099a0e58SBosko Milekic 		slab->us_freelist[freei].us_item = slab->us_firstfree;
2466ab14a3f7SBrian Feldman 	}
24678355f576SJeff Roberson 	slab->us_firstfree = freei;
24688355f576SJeff Roberson 	slab->us_freecount++;
24698355f576SJeff Roberson 
24708355f576SJeff Roberson 	/* Zone statistics */
2471099a0e58SBosko Milekic 	keg->uk_free++;
24728355f576SJeff Roberson 
2473099a0e58SBosko Milekic 	if (keg->uk_flags & UMA_ZFLAG_FULL) {
2474099a0e58SBosko Milekic 		if (keg->uk_pages < keg->uk_maxpages)
2475099a0e58SBosko Milekic 			keg->uk_flags &= ~UMA_ZFLAG_FULL;
2476af7f9b97SJeff Roberson 
247777380291SMohan Srinivasan 		/*
247877380291SMohan Srinivasan 		 * We can handle one more allocation. Since we're clearing ZFLAG_FULL,
247977380291SMohan Srinivasan 		 * wake up all procs blocked on pages. This should be uncommon, so
248077380291SMohan Srinivasan 		 * keeping this simple for now (rather than adding count of blocked
248177380291SMohan Srinivasan 		 * threads etc).
248277380291SMohan Srinivasan 		 */
248377380291SMohan Srinivasan 		wakeup(keg);
2484af7f9b97SJeff Roberson 	}
2485af7f9b97SJeff Roberson 
2486605cbd6aSJeff Roberson 	ZONE_UNLOCK(zone);
24878355f576SJeff Roberson }
24888355f576SJeff Roberson 
24898355f576SJeff Roberson /* See uma.h */
24908355f576SJeff Roberson void
2491736ee590SJeff Roberson uma_zone_set_max(uma_zone_t zone, int nitems)
2492736ee590SJeff Roberson {
2493099a0e58SBosko Milekic 	uma_keg_t keg;
2494099a0e58SBosko Milekic 
2495099a0e58SBosko Milekic 	keg = zone->uz_keg;
2496736ee590SJeff Roberson 	ZONE_LOCK(zone);
2497099a0e58SBosko Milekic 	if (keg->uk_ppera > 1)
2498099a0e58SBosko Milekic 		keg->uk_maxpages = nitems * keg->uk_ppera;
2499736ee590SJeff Roberson 	else
2500099a0e58SBosko Milekic 		keg->uk_maxpages = nitems / keg->uk_ipers;
250128bc4419SJeff Roberson 
2502099a0e58SBosko Milekic 	if (keg->uk_maxpages * keg->uk_ipers < nitems)
2503099a0e58SBosko Milekic 		keg->uk_maxpages++;
250428bc4419SJeff Roberson 
2505736ee590SJeff Roberson 	ZONE_UNLOCK(zone);
2506736ee590SJeff Roberson }
2507736ee590SJeff Roberson 
2508736ee590SJeff Roberson /* See uma.h */
2509736ee590SJeff Roberson void
2510099a0e58SBosko Milekic uma_zone_set_init(uma_zone_t zone, uma_init uminit)
2511099a0e58SBosko Milekic {
2512099a0e58SBosko Milekic 	ZONE_LOCK(zone);
2513099a0e58SBosko Milekic 	KASSERT(zone->uz_keg->uk_pages == 0,
2514099a0e58SBosko Milekic 	    ("uma_zone_set_init on non-empty keg"));
2515099a0e58SBosko Milekic 	zone->uz_keg->uk_init = uminit;
2516099a0e58SBosko Milekic 	ZONE_UNLOCK(zone);
2517099a0e58SBosko Milekic }
2518099a0e58SBosko Milekic 
2519099a0e58SBosko Milekic /* See uma.h */
2520099a0e58SBosko Milekic void
2521099a0e58SBosko Milekic uma_zone_set_fini(uma_zone_t zone, uma_fini fini)
2522099a0e58SBosko Milekic {
2523099a0e58SBosko Milekic 	ZONE_LOCK(zone);
2524099a0e58SBosko Milekic 	KASSERT(zone->uz_keg->uk_pages == 0,
2525099a0e58SBosko Milekic 	    ("uma_zone_set_fini on non-empty keg"));
2526099a0e58SBosko Milekic 	zone->uz_keg->uk_fini = fini;
2527099a0e58SBosko Milekic 	ZONE_UNLOCK(zone);
2528099a0e58SBosko Milekic }
2529099a0e58SBosko Milekic 
2530099a0e58SBosko Milekic /* See uma.h */
2531099a0e58SBosko Milekic void
2532099a0e58SBosko Milekic uma_zone_set_zinit(uma_zone_t zone, uma_init zinit)
2533099a0e58SBosko Milekic {
2534099a0e58SBosko Milekic 	ZONE_LOCK(zone);
2535099a0e58SBosko Milekic 	KASSERT(zone->uz_keg->uk_pages == 0,
2536099a0e58SBosko Milekic 	    ("uma_zone_set_zinit on non-empty keg"));
2537099a0e58SBosko Milekic 	zone->uz_init = zinit;
2538099a0e58SBosko Milekic 	ZONE_UNLOCK(zone);
2539099a0e58SBosko Milekic }
2540099a0e58SBosko Milekic 
2541099a0e58SBosko Milekic /* See uma.h */
2542099a0e58SBosko Milekic void
2543099a0e58SBosko Milekic uma_zone_set_zfini(uma_zone_t zone, uma_fini zfini)
2544099a0e58SBosko Milekic {
2545099a0e58SBosko Milekic 	ZONE_LOCK(zone);
2546099a0e58SBosko Milekic 	KASSERT(zone->uz_keg->uk_pages == 0,
2547099a0e58SBosko Milekic 	    ("uma_zone_set_zfini on non-empty keg"));
2548099a0e58SBosko Milekic 	zone->uz_fini = zfini;
2549099a0e58SBosko Milekic 	ZONE_UNLOCK(zone);
2550099a0e58SBosko Milekic }
2551099a0e58SBosko Milekic 
2552099a0e58SBosko Milekic /* See uma.h */
2553b23f72e9SBrian Feldman /* XXX uk_freef is not actually used with the zone locked */
2554099a0e58SBosko Milekic void
25558355f576SJeff Roberson uma_zone_set_freef(uma_zone_t zone, uma_free freef)
25568355f576SJeff Roberson {
25578355f576SJeff Roberson 	ZONE_LOCK(zone);
2558099a0e58SBosko Milekic 	zone->uz_keg->uk_freef = freef;
25598355f576SJeff Roberson 	ZONE_UNLOCK(zone);
25608355f576SJeff Roberson }
25618355f576SJeff Roberson 
25628355f576SJeff Roberson /* See uma.h */
2563b23f72e9SBrian Feldman /* XXX uk_allocf is not actually used with the zone locked */
25648355f576SJeff Roberson void
25658355f576SJeff Roberson uma_zone_set_allocf(uma_zone_t zone, uma_alloc allocf)
25668355f576SJeff Roberson {
25678355f576SJeff Roberson 	ZONE_LOCK(zone);
2568099a0e58SBosko Milekic 	zone->uz_keg->uk_flags |= UMA_ZFLAG_PRIVALLOC;
2569099a0e58SBosko Milekic 	zone->uz_keg->uk_allocf = allocf;
25708355f576SJeff Roberson 	ZONE_UNLOCK(zone);
25718355f576SJeff Roberson }
25728355f576SJeff Roberson 
25738355f576SJeff Roberson /* See uma.h */
25748355f576SJeff Roberson int
25758355f576SJeff Roberson uma_zone_set_obj(uma_zone_t zone, struct vm_object *obj, int count)
25768355f576SJeff Roberson {
2577099a0e58SBosko Milekic 	uma_keg_t keg;
25788355f576SJeff Roberson 	vm_offset_t kva;
2579099a0e58SBosko Milekic 	int pages;
25808355f576SJeff Roberson 
2581099a0e58SBosko Milekic 	keg = zone->uz_keg;
2582099a0e58SBosko Milekic 	pages = count / keg->uk_ipers;
25838355f576SJeff Roberson 
2584099a0e58SBosko Milekic 	if (pages * keg->uk_ipers < count)
25858355f576SJeff Roberson 		pages++;
2586a553d4b8SJeff Roberson 
25875285558aSAlan Cox 	kva = kmem_alloc_nofault(kernel_map, pages * UMA_SLAB_SIZE);
25888355f576SJeff Roberson 
2589d1f42ac2SAlan Cox 	if (kva == 0)
25908355f576SJeff Roberson 		return (0);
259164f051e9SJeff Roberson 	if (obj == NULL) {
2592a553d4b8SJeff Roberson 		obj = vm_object_allocate(OBJT_DEFAULT,
2593c7173f58SJeff Roberson 		    pages);
259464f051e9SJeff Roberson 	} else {
25955285558aSAlan Cox 		VM_OBJECT_LOCK_INIT(obj, "uma object");
25968355f576SJeff Roberson 		_vm_object_allocate(OBJT_DEFAULT,
2597c7173f58SJeff Roberson 		    pages, obj);
259882774d80SAlan Cox 	}
2599a553d4b8SJeff Roberson 	ZONE_LOCK(zone);
2600099a0e58SBosko Milekic 	keg->uk_kva = kva;
2601099a0e58SBosko Milekic 	keg->uk_obj = obj;
2602099a0e58SBosko Milekic 	keg->uk_maxpages = pages;
2603099a0e58SBosko Milekic 	keg->uk_allocf = obj_alloc;
2604099a0e58SBosko Milekic 	keg->uk_flags |= UMA_ZONE_NOFREE | UMA_ZFLAG_PRIVALLOC;
26058355f576SJeff Roberson 	ZONE_UNLOCK(zone);
26068355f576SJeff Roberson 	return (1);
26078355f576SJeff Roberson }
26088355f576SJeff Roberson 
26098355f576SJeff Roberson /* See uma.h */
26108355f576SJeff Roberson void
26118355f576SJeff Roberson uma_prealloc(uma_zone_t zone, int items)
26128355f576SJeff Roberson {
26138355f576SJeff Roberson 	int slabs;
26148355f576SJeff Roberson 	uma_slab_t slab;
2615099a0e58SBosko Milekic 	uma_keg_t keg;
26168355f576SJeff Roberson 
2617099a0e58SBosko Milekic 	keg = zone->uz_keg;
26188355f576SJeff Roberson 	ZONE_LOCK(zone);
2619099a0e58SBosko Milekic 	slabs = items / keg->uk_ipers;
2620099a0e58SBosko Milekic 	if (slabs * keg->uk_ipers < items)
26218355f576SJeff Roberson 		slabs++;
26228355f576SJeff Roberson 	while (slabs > 0) {
2623a163d034SWarner Losh 		slab = slab_zalloc(zone, M_WAITOK);
2624099a0e58SBosko Milekic 		LIST_INSERT_HEAD(&keg->uk_free_slab, slab, us_link);
26258355f576SJeff Roberson 		slabs--;
26268355f576SJeff Roberson 	}
26278355f576SJeff Roberson 	ZONE_UNLOCK(zone);
26288355f576SJeff Roberson }
26298355f576SJeff Roberson 
26308355f576SJeff Roberson /* See uma.h */
2631099a0e58SBosko Milekic u_int32_t *
2632099a0e58SBosko Milekic uma_find_refcnt(uma_zone_t zone, void *item)
2633099a0e58SBosko Milekic {
2634ab14a3f7SBrian Feldman 	uma_slabrefcnt_t slabref;
2635099a0e58SBosko Milekic 	uma_keg_t keg;
2636099a0e58SBosko Milekic 	u_int32_t *refcnt;
2637099a0e58SBosko Milekic 	int idx;
2638099a0e58SBosko Milekic 
2639099a0e58SBosko Milekic 	keg = zone->uz_keg;
2640ab14a3f7SBrian Feldman 	slabref = (uma_slabrefcnt_t)vtoslab((vm_offset_t)item &
2641ab14a3f7SBrian Feldman 	    (~UMA_SLAB_MASK));
2642ab14a3f7SBrian Feldman 	KASSERT(slabref != NULL && slabref->us_keg->uk_flags & UMA_ZONE_REFCNT,
2643099a0e58SBosko Milekic 	    ("uma_find_refcnt(): zone possibly not UMA_ZONE_REFCNT"));
2644ab14a3f7SBrian Feldman 	idx = ((unsigned long)item - (unsigned long)slabref->us_data)
2645099a0e58SBosko Milekic 	    / keg->uk_rsize;
2646ab14a3f7SBrian Feldman 	refcnt = &slabref->us_freelist[idx].us_refcnt;
2647099a0e58SBosko Milekic 	return refcnt;
2648099a0e58SBosko Milekic }
2649099a0e58SBosko Milekic 
2650099a0e58SBosko Milekic /* See uma.h */
26518355f576SJeff Roberson void
26528355f576SJeff Roberson uma_reclaim(void)
26538355f576SJeff Roberson {
26548355f576SJeff Roberson #ifdef UMA_DEBUG
26558355f576SJeff Roberson 	printf("UMA: vm asked us to release pages!\n");
26568355f576SJeff Roberson #endif
265786bbae32SJeff Roberson 	bucket_enable();
26588355f576SJeff Roberson 	zone_foreach(zone_drain);
26598355f576SJeff Roberson 	/*
26608355f576SJeff Roberson 	 * Some slabs may have been freed but this zone will be visited early
26618355f576SJeff Roberson 	 * we visit again so that we can free pages that are empty once other
26628355f576SJeff Roberson 	 * zones are drained.  We have to do the same for buckets.
26638355f576SJeff Roberson 	 */
26649643769aSJeff Roberson 	zone_drain(slabzone);
2665099a0e58SBosko Milekic 	zone_drain(slabrefzone);
2666cae33c14SJeff Roberson 	bucket_zone_drain();
26678355f576SJeff Roberson }
26688355f576SJeff Roberson 
2669663b416fSJohn Baldwin /* See uma.h */
2670663b416fSJohn Baldwin int
2671663b416fSJohn Baldwin uma_zone_exhausted(uma_zone_t zone)
2672663b416fSJohn Baldwin {
2673663b416fSJohn Baldwin 	int full;
2674663b416fSJohn Baldwin 
2675663b416fSJohn Baldwin 	ZONE_LOCK(zone);
2676663b416fSJohn Baldwin 	full = (zone->uz_keg->uk_flags & UMA_ZFLAG_FULL);
2677663b416fSJohn Baldwin 	ZONE_UNLOCK(zone);
2678663b416fSJohn Baldwin 	return (full);
2679663b416fSJohn Baldwin }
2680663b416fSJohn Baldwin 
26816c125b8dSMohan Srinivasan int
26826c125b8dSMohan Srinivasan uma_zone_exhausted_nolock(uma_zone_t zone)
26836c125b8dSMohan Srinivasan {
26846c125b8dSMohan Srinivasan 	return (zone->uz_keg->uk_flags & UMA_ZFLAG_FULL);
26856c125b8dSMohan Srinivasan }
26866c125b8dSMohan Srinivasan 
26878355f576SJeff Roberson void *
26888355f576SJeff Roberson uma_large_malloc(int size, int wait)
26898355f576SJeff Roberson {
26908355f576SJeff Roberson 	void *mem;
26918355f576SJeff Roberson 	uma_slab_t slab;
26928355f576SJeff Roberson 	u_int8_t flags;
26938355f576SJeff Roberson 
2694bbee39c6SJeff Roberson 	slab = uma_zalloc_internal(slabzone, NULL, wait);
26958355f576SJeff Roberson 	if (slab == NULL)
26968355f576SJeff Roberson 		return (NULL);
26978355f576SJeff Roberson 	mem = page_alloc(NULL, size, &flags, wait);
26988355f576SJeff Roberson 	if (mem) {
269999571dc3SJeff Roberson 		vsetslab((vm_offset_t)mem, slab);
27008355f576SJeff Roberson 		slab->us_data = mem;
27018355f576SJeff Roberson 		slab->us_flags = flags | UMA_SLAB_MALLOC;
27028355f576SJeff Roberson 		slab->us_size = size;
27038355f576SJeff Roberson 	} else {
27042019094aSRobert Watson 		uma_zfree_internal(slabzone, slab, NULL, SKIP_NONE,
2705f4ff923bSRobert Watson 		    ZFREE_STATFAIL | ZFREE_STATFREE);
27068355f576SJeff Roberson 	}
27078355f576SJeff Roberson 
27088355f576SJeff Roberson 	return (mem);
27098355f576SJeff Roberson }
27108355f576SJeff Roberson 
27118355f576SJeff Roberson void
27128355f576SJeff Roberson uma_large_free(uma_slab_t slab)
27138355f576SJeff Roberson {
271499571dc3SJeff Roberson 	vsetobj((vm_offset_t)slab->us_data, kmem_object);
27158355f576SJeff Roberson 	page_free(slab->us_data, slab->us_size, slab->us_flags);
2716f4ff923bSRobert Watson 	uma_zfree_internal(slabzone, slab, NULL, SKIP_NONE, ZFREE_STATFREE);
27178355f576SJeff Roberson }
27188355f576SJeff Roberson 
27198355f576SJeff Roberson void
27208355f576SJeff Roberson uma_print_stats(void)
27218355f576SJeff Roberson {
27228355f576SJeff Roberson 	zone_foreach(uma_print_zone);
27238355f576SJeff Roberson }
27248355f576SJeff Roberson 
2725504d5de3SJeff Roberson static void
2726504d5de3SJeff Roberson slab_print(uma_slab_t slab)
2727504d5de3SJeff Roberson {
2728099a0e58SBosko Milekic 	printf("slab: keg %p, data %p, freecount %d, firstfree %d\n",
2729099a0e58SBosko Milekic 		slab->us_keg, slab->us_data, slab->us_freecount,
2730504d5de3SJeff Roberson 		slab->us_firstfree);
2731504d5de3SJeff Roberson }
2732504d5de3SJeff Roberson 
2733504d5de3SJeff Roberson static void
2734504d5de3SJeff Roberson cache_print(uma_cache_t cache)
2735504d5de3SJeff Roberson {
2736504d5de3SJeff Roberson 	printf("alloc: %p(%d), free: %p(%d)\n",
2737504d5de3SJeff Roberson 		cache->uc_allocbucket,
2738504d5de3SJeff Roberson 		cache->uc_allocbucket?cache->uc_allocbucket->ub_cnt:0,
2739504d5de3SJeff Roberson 		cache->uc_freebucket,
2740504d5de3SJeff Roberson 		cache->uc_freebucket?cache->uc_freebucket->ub_cnt:0);
2741504d5de3SJeff Roberson }
2742504d5de3SJeff Roberson 
27438355f576SJeff Roberson void
27448355f576SJeff Roberson uma_print_zone(uma_zone_t zone)
27458355f576SJeff Roberson {
2746504d5de3SJeff Roberson 	uma_cache_t cache;
2747099a0e58SBosko Milekic 	uma_keg_t keg;
2748504d5de3SJeff Roberson 	uma_slab_t slab;
2749504d5de3SJeff Roberson 	int i;
2750504d5de3SJeff Roberson 
2751099a0e58SBosko Milekic 	keg = zone->uz_keg;
27528355f576SJeff Roberson 	printf("%s(%p) size %d(%d) flags %d ipers %d ppera %d out %d free %d\n",
2753099a0e58SBosko Milekic 	    zone->uz_name, zone, keg->uk_size, keg->uk_rsize, keg->uk_flags,
2754099a0e58SBosko Milekic 	    keg->uk_ipers, keg->uk_ppera,
2755099a0e58SBosko Milekic 	    (keg->uk_ipers * keg->uk_pages) - keg->uk_free, keg->uk_free);
2756504d5de3SJeff Roberson 	printf("Part slabs:\n");
2757099a0e58SBosko Milekic 	LIST_FOREACH(slab, &keg->uk_part_slab, us_link)
2758504d5de3SJeff Roberson 		slab_print(slab);
2759504d5de3SJeff Roberson 	printf("Free slabs:\n");
2760099a0e58SBosko Milekic 	LIST_FOREACH(slab, &keg->uk_free_slab, us_link)
2761504d5de3SJeff Roberson 		slab_print(slab);
2762504d5de3SJeff Roberson 	printf("Full slabs:\n");
2763099a0e58SBosko Milekic 	LIST_FOREACH(slab, &keg->uk_full_slab, us_link)
2764504d5de3SJeff Roberson 		slab_print(slab);
2765b6c71225SJohn Baldwin 	for (i = 0; i <= mp_maxid; i++) {
2766504d5de3SJeff Roberson 		if (CPU_ABSENT(i))
2767504d5de3SJeff Roberson 			continue;
2768504d5de3SJeff Roberson 		cache = &zone->uz_cpu[i];
2769504d5de3SJeff Roberson 		printf("CPU %d Cache:\n", i);
2770504d5de3SJeff Roberson 		cache_print(cache);
2771504d5de3SJeff Roberson 	}
27728355f576SJeff Roberson }
27738355f576SJeff Roberson 
2774a0d4b0aeSRobert Watson #ifdef DDB
27758355f576SJeff Roberson /*
27767a52a97eSRobert Watson  * Generate statistics across both the zone and its per-cpu cache's.  Return
27777a52a97eSRobert Watson  * desired statistics if the pointer is non-NULL for that statistic.
27787a52a97eSRobert Watson  *
27797a52a97eSRobert Watson  * Note: does not update the zone statistics, as it can't safely clear the
27807a52a97eSRobert Watson  * per-CPU cache statistic.
27817a52a97eSRobert Watson  *
27827a52a97eSRobert Watson  * XXXRW: Following the uc_allocbucket and uc_freebucket pointers here isn't
27837a52a97eSRobert Watson  * safe from off-CPU; we should modify the caches to track this information
27847a52a97eSRobert Watson  * directly so that we don't have to.
27857a52a97eSRobert Watson  */
27867a52a97eSRobert Watson static void
27877a52a97eSRobert Watson uma_zone_sumstat(uma_zone_t z, int *cachefreep, u_int64_t *allocsp,
27887a52a97eSRobert Watson     u_int64_t *freesp)
27897a52a97eSRobert Watson {
27907a52a97eSRobert Watson 	uma_cache_t cache;
27917a52a97eSRobert Watson 	u_int64_t allocs, frees;
27927a52a97eSRobert Watson 	int cachefree, cpu;
27937a52a97eSRobert Watson 
27947a52a97eSRobert Watson 	allocs = frees = 0;
27957a52a97eSRobert Watson 	cachefree = 0;
27967a52a97eSRobert Watson 	for (cpu = 0; cpu <= mp_maxid; cpu++) {
27977a52a97eSRobert Watson 		if (CPU_ABSENT(cpu))
27987a52a97eSRobert Watson 			continue;
27997a52a97eSRobert Watson 		cache = &z->uz_cpu[cpu];
28007a52a97eSRobert Watson 		if (cache->uc_allocbucket != NULL)
28017a52a97eSRobert Watson 			cachefree += cache->uc_allocbucket->ub_cnt;
28027a52a97eSRobert Watson 		if (cache->uc_freebucket != NULL)
28037a52a97eSRobert Watson 			cachefree += cache->uc_freebucket->ub_cnt;
28047a52a97eSRobert Watson 		allocs += cache->uc_allocs;
28057a52a97eSRobert Watson 		frees += cache->uc_frees;
28067a52a97eSRobert Watson 	}
28077a52a97eSRobert Watson 	allocs += z->uz_allocs;
28087a52a97eSRobert Watson 	frees += z->uz_frees;
28097a52a97eSRobert Watson 	if (cachefreep != NULL)
28107a52a97eSRobert Watson 		*cachefreep = cachefree;
28117a52a97eSRobert Watson 	if (allocsp != NULL)
28127a52a97eSRobert Watson 		*allocsp = allocs;
28137a52a97eSRobert Watson 	if (freesp != NULL)
28147a52a97eSRobert Watson 		*freesp = frees;
28157a52a97eSRobert Watson }
2816a0d4b0aeSRobert Watson #endif /* DDB */
28177a52a97eSRobert Watson 
28187a52a97eSRobert Watson static int
28197a52a97eSRobert Watson sysctl_vm_zone_count(SYSCTL_HANDLER_ARGS)
28207a52a97eSRobert Watson {
28217a52a97eSRobert Watson 	uma_keg_t kz;
28227a52a97eSRobert Watson 	uma_zone_t z;
28237a52a97eSRobert Watson 	int count;
28247a52a97eSRobert Watson 
28257a52a97eSRobert Watson 	count = 0;
28267a52a97eSRobert Watson 	mtx_lock(&uma_mtx);
28277a52a97eSRobert Watson 	LIST_FOREACH(kz, &uma_kegs, uk_link) {
28287a52a97eSRobert Watson 		LIST_FOREACH(z, &kz->uk_zones, uz_link)
28297a52a97eSRobert Watson 			count++;
28307a52a97eSRobert Watson 	}
28317a52a97eSRobert Watson 	mtx_unlock(&uma_mtx);
28327a52a97eSRobert Watson 	return (sysctl_handle_int(oidp, &count, 0, req));
28337a52a97eSRobert Watson }
28347a52a97eSRobert Watson 
28357a52a97eSRobert Watson static int
28367a52a97eSRobert Watson sysctl_vm_zone_stats(SYSCTL_HANDLER_ARGS)
28377a52a97eSRobert Watson {
28387a52a97eSRobert Watson 	struct uma_stream_header ush;
28397a52a97eSRobert Watson 	struct uma_type_header uth;
28407a52a97eSRobert Watson 	struct uma_percpu_stat ups;
28417a52a97eSRobert Watson 	uma_bucket_t bucket;
28427a52a97eSRobert Watson 	struct sbuf sbuf;
28437a52a97eSRobert Watson 	uma_cache_t cache;
28447a52a97eSRobert Watson 	uma_keg_t kz;
28457a52a97eSRobert Watson 	uma_zone_t z;
28467a52a97eSRobert Watson 	char *buffer;
28477a52a97eSRobert Watson 	int buflen, count, error, i;
28487a52a97eSRobert Watson 
28497a52a97eSRobert Watson 	mtx_lock(&uma_mtx);
28507a52a97eSRobert Watson restart:
28517a52a97eSRobert Watson 	mtx_assert(&uma_mtx, MA_OWNED);
28527a52a97eSRobert Watson 	count = 0;
28537a52a97eSRobert Watson 	LIST_FOREACH(kz, &uma_kegs, uk_link) {
28547a52a97eSRobert Watson 		LIST_FOREACH(z, &kz->uk_zones, uz_link)
28557a52a97eSRobert Watson 			count++;
28567a52a97eSRobert Watson 	}
28577a52a97eSRobert Watson 	mtx_unlock(&uma_mtx);
28587a52a97eSRobert Watson 
28597a52a97eSRobert Watson 	buflen = sizeof(ush) + count * (sizeof(uth) + sizeof(ups) *
2860ab3a57c0SRobert Watson 	    (mp_maxid + 1)) + 1;
28617a52a97eSRobert Watson 	buffer = malloc(buflen, M_TEMP, M_WAITOK | M_ZERO);
28627a52a97eSRobert Watson 
28637a52a97eSRobert Watson 	mtx_lock(&uma_mtx);
28647a52a97eSRobert Watson 	i = 0;
28657a52a97eSRobert Watson 	LIST_FOREACH(kz, &uma_kegs, uk_link) {
28667a52a97eSRobert Watson 		LIST_FOREACH(z, &kz->uk_zones, uz_link)
28677a52a97eSRobert Watson 			i++;
28687a52a97eSRobert Watson 	}
28697a52a97eSRobert Watson 	if (i > count) {
28707a52a97eSRobert Watson 		free(buffer, M_TEMP);
28717a52a97eSRobert Watson 		goto restart;
28727a52a97eSRobert Watson 	}
28737a52a97eSRobert Watson 	count =  i;
28747a52a97eSRobert Watson 
28757a52a97eSRobert Watson 	sbuf_new(&sbuf, buffer, buflen, SBUF_FIXEDLEN);
28767a52a97eSRobert Watson 
28777a52a97eSRobert Watson 	/*
28787a52a97eSRobert Watson 	 * Insert stream header.
28797a52a97eSRobert Watson 	 */
28807a52a97eSRobert Watson 	bzero(&ush, sizeof(ush));
28817a52a97eSRobert Watson 	ush.ush_version = UMA_STREAM_VERSION;
2882ab3a57c0SRobert Watson 	ush.ush_maxcpus = (mp_maxid + 1);
28837a52a97eSRobert Watson 	ush.ush_count = count;
28847a52a97eSRobert Watson 	if (sbuf_bcat(&sbuf, &ush, sizeof(ush)) < 0) {
28857a52a97eSRobert Watson 		mtx_unlock(&uma_mtx);
28867a52a97eSRobert Watson 		error = ENOMEM;
28877a52a97eSRobert Watson 		goto out;
28887a52a97eSRobert Watson 	}
28897a52a97eSRobert Watson 
28907a52a97eSRobert Watson 	LIST_FOREACH(kz, &uma_kegs, uk_link) {
28917a52a97eSRobert Watson 		LIST_FOREACH(z, &kz->uk_zones, uz_link) {
28927a52a97eSRobert Watson 			bzero(&uth, sizeof(uth));
28937a52a97eSRobert Watson 			ZONE_LOCK(z);
2894cbbb4a00SRobert Watson 			strlcpy(uth.uth_name, z->uz_name, UTH_MAX_NAME);
28957a52a97eSRobert Watson 			uth.uth_align = kz->uk_align;
28967a52a97eSRobert Watson 			uth.uth_pages = kz->uk_pages;
28977a52a97eSRobert Watson 			uth.uth_keg_free = kz->uk_free;
28987a52a97eSRobert Watson 			uth.uth_size = kz->uk_size;
28997a52a97eSRobert Watson 			uth.uth_rsize = kz->uk_rsize;
29007a52a97eSRobert Watson 			uth.uth_maxpages = kz->uk_maxpages;
29017a52a97eSRobert Watson 			if (kz->uk_ppera > 1)
29027a52a97eSRobert Watson 				uth.uth_limit = kz->uk_maxpages /
29037a52a97eSRobert Watson 				    kz->uk_ppera;
29047a52a97eSRobert Watson 			else
29057a52a97eSRobert Watson 				uth.uth_limit = kz->uk_maxpages *
29067a52a97eSRobert Watson 				    kz->uk_ipers;
2907cbbb4a00SRobert Watson 
2908cbbb4a00SRobert Watson 			/*
2909cbbb4a00SRobert Watson 			 * A zone is secondary is it is not the first entry
2910cbbb4a00SRobert Watson 			 * on the keg's zone list.
2911cbbb4a00SRobert Watson 			 */
2912cbbb4a00SRobert Watson 			if ((kz->uk_flags & UMA_ZONE_SECONDARY) &&
2913cbbb4a00SRobert Watson 			    (LIST_FIRST(&kz->uk_zones) != z))
2914cbbb4a00SRobert Watson 				uth.uth_zone_flags = UTH_ZONE_SECONDARY;
2915cbbb4a00SRobert Watson 
29167a52a97eSRobert Watson 			LIST_FOREACH(bucket, &z->uz_full_bucket, ub_link)
29177a52a97eSRobert Watson 				uth.uth_zone_free += bucket->ub_cnt;
29187a52a97eSRobert Watson 			uth.uth_allocs = z->uz_allocs;
29197a52a97eSRobert Watson 			uth.uth_frees = z->uz_frees;
29202019094aSRobert Watson 			uth.uth_fails = z->uz_fails;
29217a52a97eSRobert Watson 			if (sbuf_bcat(&sbuf, &uth, sizeof(uth)) < 0) {
29222450bbb8SRobert Watson 				ZONE_UNLOCK(z);
29237a52a97eSRobert Watson 				mtx_unlock(&uma_mtx);
29247a52a97eSRobert Watson 				error = ENOMEM;
29257a52a97eSRobert Watson 				goto out;
29267a52a97eSRobert Watson 			}
29277a52a97eSRobert Watson 			/*
29282450bbb8SRobert Watson 			 * While it is not normally safe to access the cache
29292450bbb8SRobert Watson 			 * bucket pointers while not on the CPU that owns the
29302450bbb8SRobert Watson 			 * cache, we only allow the pointers to be exchanged
29312450bbb8SRobert Watson 			 * without the zone lock held, not invalidated, so
29322450bbb8SRobert Watson 			 * accept the possible race associated with bucket
29332450bbb8SRobert Watson 			 * exchange during monitoring.
29347a52a97eSRobert Watson 			 */
2935ab3a57c0SRobert Watson 			for (i = 0; i < (mp_maxid + 1); i++) {
29367a52a97eSRobert Watson 				bzero(&ups, sizeof(ups));
29377a52a97eSRobert Watson 				if (kz->uk_flags & UMA_ZFLAG_INTERNAL)
29387a52a97eSRobert Watson 					goto skip;
2939082dc776SRobert Watson 				if (CPU_ABSENT(i))
2940082dc776SRobert Watson 					goto skip;
29417a52a97eSRobert Watson 				cache = &z->uz_cpu[i];
29427a52a97eSRobert Watson 				if (cache->uc_allocbucket != NULL)
29437a52a97eSRobert Watson 					ups.ups_cache_free +=
29447a52a97eSRobert Watson 					    cache->uc_allocbucket->ub_cnt;
29457a52a97eSRobert Watson 				if (cache->uc_freebucket != NULL)
29467a52a97eSRobert Watson 					ups.ups_cache_free +=
29477a52a97eSRobert Watson 					    cache->uc_freebucket->ub_cnt;
29487a52a97eSRobert Watson 				ups.ups_allocs = cache->uc_allocs;
29497a52a97eSRobert Watson 				ups.ups_frees = cache->uc_frees;
29507a52a97eSRobert Watson skip:
29517a52a97eSRobert Watson 				if (sbuf_bcat(&sbuf, &ups, sizeof(ups)) < 0) {
29522450bbb8SRobert Watson 					ZONE_UNLOCK(z);
29537a52a97eSRobert Watson 					mtx_unlock(&uma_mtx);
29547a52a97eSRobert Watson 					error = ENOMEM;
29557a52a97eSRobert Watson 					goto out;
29567a52a97eSRobert Watson 				}
29577a52a97eSRobert Watson 			}
29582450bbb8SRobert Watson 			ZONE_UNLOCK(z);
29597a52a97eSRobert Watson 		}
29607a52a97eSRobert Watson 	}
29617a52a97eSRobert Watson 	mtx_unlock(&uma_mtx);
29627a52a97eSRobert Watson 	sbuf_finish(&sbuf);
29637a52a97eSRobert Watson 	error = SYSCTL_OUT(req, sbuf_data(&sbuf), sbuf_len(&sbuf));
29647a52a97eSRobert Watson out:
29657a52a97eSRobert Watson 	free(buffer, M_TEMP);
29667a52a97eSRobert Watson 	return (error);
29677a52a97eSRobert Watson }
296848c5777eSRobert Watson 
296948c5777eSRobert Watson #ifdef DDB
297048c5777eSRobert Watson DB_SHOW_COMMAND(uma, db_show_uma)
297148c5777eSRobert Watson {
297248c5777eSRobert Watson 	u_int64_t allocs, frees;
297348c5777eSRobert Watson 	uma_bucket_t bucket;
297448c5777eSRobert Watson 	uma_keg_t kz;
297548c5777eSRobert Watson 	uma_zone_t z;
297648c5777eSRobert Watson 	int cachefree;
297748c5777eSRobert Watson 
2978ae4e9636SRobert Watson 	db_printf("%18s %8s %8s %8s %12s\n", "Zone", "Size", "Used", "Free",
2979ae4e9636SRobert Watson 	    "Requests");
298048c5777eSRobert Watson 	LIST_FOREACH(kz, &uma_kegs, uk_link) {
298148c5777eSRobert Watson 		LIST_FOREACH(z, &kz->uk_zones, uz_link) {
298248c5777eSRobert Watson 			if (kz->uk_flags & UMA_ZFLAG_INTERNAL) {
298348c5777eSRobert Watson 				allocs = z->uz_allocs;
298448c5777eSRobert Watson 				frees = z->uz_frees;
298548c5777eSRobert Watson 				cachefree = 0;
298648c5777eSRobert Watson 			} else
298748c5777eSRobert Watson 				uma_zone_sumstat(z, &cachefree, &allocs,
298848c5777eSRobert Watson 				    &frees);
298948c5777eSRobert Watson 			if (!((kz->uk_flags & UMA_ZONE_SECONDARY) &&
299048c5777eSRobert Watson 			    (LIST_FIRST(&kz->uk_zones) != z)))
299148c5777eSRobert Watson 				cachefree += kz->uk_free;
299248c5777eSRobert Watson 			LIST_FOREACH(bucket, &z->uz_full_bucket, ub_link)
299348c5777eSRobert Watson 				cachefree += bucket->ub_cnt;
2994ae4e9636SRobert Watson 			db_printf("%18s %8ju %8jd %8d %12ju\n", z->uz_name,
2995ae4e9636SRobert Watson 			    (uintmax_t)kz->uk_size,
2996ae4e9636SRobert Watson 			    (intmax_t)(allocs - frees), cachefree,
2997ae4e9636SRobert Watson 			    (uintmax_t)allocs);
299848c5777eSRobert Watson 		}
299948c5777eSRobert Watson 	}
300048c5777eSRobert Watson }
300148c5777eSRobert Watson #endif
3002