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