cregit-Linux how code gets into the kernel

Release 4.15 mm/slab.c

Directory: mm
// SPDX-License-Identifier: GPL-2.0
/*
 * linux/mm/slab.c
 * Written by Mark Hemment, 1996/97.
 * (markhe@nextd.demon.co.uk)
 *
 * kmem_cache_destroy() + some cleanup - 1999 Andrea Arcangeli
 *
 * Major cleanup, different bufctl logic, per-cpu arrays
 *      (c) 2000 Manfred Spraul
 *
 * Cleanup, make the head arrays unconditional, preparation for NUMA
 *      (c) 2002 Manfred Spraul
 *
 * An implementation of the Slab Allocator as described in outline in;
 *      UNIX Internals: The New Frontiers by Uresh Vahalia
 *      Pub: Prentice Hall      ISBN 0-13-101908-2
 * or with a little more detail in;
 *      The Slab Allocator: An Object-Caching Kernel Memory Allocator
 *      Jeff Bonwick (Sun Microsystems).
 *      Presented at: USENIX Summer 1994 Technical Conference
 *
 * The memory is organized in caches, one cache for each object type.
 * (e.g. inode_cache, dentry_cache, buffer_head, vm_area_struct)
 * Each cache consists out of many slabs (they are small (usually one
 * page long) and always contiguous), and each slab contains multiple
 * initialized objects.
 *
 * This means, that your constructor is used only for newly allocated
 * slabs and you must pass objects with the same initializations to
 * kmem_cache_free.
 *
 * Each cache can only support one memory type (GFP_DMA, GFP_HIGHMEM,
 * normal). If you need a special memory type, then must create a new
 * cache for that memory type.
 *
 * In order to reduce fragmentation, the slabs are sorted in 3 groups:
 *   full slabs with 0 free objects
 *   partial slabs
 *   empty slabs with no allocated objects
 *
 * If partial slabs exist, then new allocations come from these slabs,
 * otherwise from empty slabs or new slabs are allocated.
 *
 * kmem_cache_destroy() CAN CRASH if you try to allocate from the cache
 * during kmem_cache_destroy(). The caller must prevent concurrent allocs.
 *
 * Each cache has a short per-cpu head array, most allocs
 * and frees go into that array, and if that array overflows, then 1/2
 * of the entries in the array are given back into the global cache.
 * The head array is strictly LIFO and should improve the cache hit rates.
 * On SMP, it additionally reduces the spinlock operations.
 *
 * The c_cpuarray may not be read with enabled local interrupts -
 * it's changed with a smp_call_function().
 *
 * SMP synchronization:
 *  constructors and destructors are called without any locking.
 *  Several members in struct kmem_cache and struct slab never change, they
 *      are accessed without any locking.
 *  The per-cpu arrays are never accessed from the wrong cpu, no locking,
 *      and local interrupts are disabled so slab code is preempt-safe.
 *  The non-constant members are protected with a per-cache irq spinlock.
 *
 * Many thanks to Mark Hemment, who wrote another per-cpu slab patch
 * in 2000 - many ideas in the current implementation are derived from
 * his patch.
 *
 * Further notes from the original documentation:
 *
 * 11 April '97.  Started multi-threading - markhe
 *      The global cache-chain is protected by the mutex 'slab_mutex'.
 *      The sem is only needed when accessing/extending the cache-chain, which
 *      can never happen inside an interrupt (kmem_cache_create(),
 *      kmem_cache_shrink() and kmem_cache_reap()).
 *
 *      At present, each engine can be growing a cache.  This should be blocked.
 *
 * 15 March 2005. NUMA slab allocator.
 *      Shai Fultheim <shai@scalex86.org>.
 *      Shobhit Dayal <shobhit@calsoftinc.com>
 *      Alok N Kataria <alokk@calsoftinc.com>
 *      Christoph Lameter <christoph@lameter.com>
 *
 *      Modified the slab allocator to be node aware on NUMA systems.
 *      Each node has its own list of partial, free and full slabs.
 *      All object allocations for a node occur from node specific slab lists.
 */

#include	<linux/slab.h>
#include	<linux/mm.h>
#include	<linux/poison.h>
#include	<linux/swap.h>
#include	<linux/cache.h>
#include	<linux/interrupt.h>
#include	<linux/init.h>
#include	<linux/compiler.h>
#include	<linux/cpuset.h>
#include	<linux/proc_fs.h>
#include	<linux/seq_file.h>
#include	<linux/notifier.h>
#include	<linux/kallsyms.h>
#include	<linux/cpu.h>
#include	<linux/sysctl.h>
#include	<linux/module.h>
#include	<linux/rcupdate.h>
#include	<linux/string.h>
#include	<linux/uaccess.h>
#include	<linux/nodemask.h>
#include	<linux/kmemleak.h>
#include	<linux/mempolicy.h>
#include	<linux/mutex.h>
#include	<linux/fault-inject.h>
#include	<linux/rtmutex.h>
#include	<linux/reciprocal_div.h>
#include	<linux/debugobjects.h>
#include	<linux/memory.h>
#include	<linux/prefetch.h>
#include	<linux/sched/task_stack.h>

#include	<net/sock.h>

#include	<asm/cacheflush.h>
#include	<asm/tlbflush.h>
#include	<asm/page.h>

#include <trace/events/kmem.h>

#include	"internal.h"

#include	"slab.h"

/*
 * DEBUG        - 1 for kmem_cache_create() to honour; SLAB_RED_ZONE & SLAB_POISON.
 *                0 for faster, smaller code (especially in the critical paths).
 *
 * STATS        - 1 to collect stats for /proc/slabinfo.
 *                0 for faster, smaller code (especially in the critical paths).
 *
 * FORCED_DEBUG - 1 enables SLAB_RED_ZONE and SLAB_POISON (if possible)
 */

#ifdef CONFIG_DEBUG_SLAB

#define	DEBUG		1

#define	STATS		1

#define	FORCED_DEBUG	1
#else

#define	DEBUG		0

#define	STATS		0

#define	FORCED_DEBUG	0
#endif

/* Shouldn't this be in a header file somewhere? */

#define	BYTES_PER_WORD		sizeof(void *)

#define	REDZONE_ALIGN		max(BYTES_PER_WORD, __alignof__(unsigned long long))

#ifndef ARCH_KMALLOC_FLAGS

#define ARCH_KMALLOC_FLAGS SLAB_HWCACHE_ALIGN
#endif


#define FREELIST_BYTE_INDEX (((PAGE_SIZE >> BITS_PER_BYTE) \
                                <= SLAB_OBJ_MIN_SIZE) ? 1 : 0)

#if FREELIST_BYTE_INDEX

typedef unsigned char freelist_idx_t;
#else

typedef unsigned short freelist_idx_t;
#endif


#define SLAB_OBJ_MAX_NUM ((1 << sizeof(freelist_idx_t) * BITS_PER_BYTE) - 1)

/*
 * struct array_cache
 *
 * Purpose:
 * - LIFO ordering, to hand out cache-warm objects from _alloc
 * - reduce the number of linked list operations
 * - reduce spinlock operations
 *
 * The limit is stored in the per-cpu structure to reduce the data cache
 * footprint.
 *
 */

struct array_cache {
	
unsigned int avail;
	
unsigned int limit;
	
unsigned int batchcount;
	
unsigned int touched;
	
void *entry[];	/*
                         * Must have this definition in here for the proper
                         * alignment of array_cache. Also simplifies accessing
                         * the entries.
                         */
};


struct alien_cache {
	
spinlock_t lock;
	
struct array_cache ac;
};

/*
 * Need this for bootstrapping a per node allocator.
 */

#define NUM_INIT_LISTS (2 * MAX_NUMNODES)

static struct kmem_cache_node __initdata init_kmem_cache_node[NUM_INIT_LISTS];

#define	CACHE_CACHE 0

#define	SIZE_NODE (MAX_NUMNODES)

static int drain_freelist(struct kmem_cache *cache,
			struct kmem_cache_node *n, int tofree);
static void free_block(struct kmem_cache *cachep, void **objpp, int len,
			int node, struct list_head *list);
static void slabs_destroy(struct kmem_cache *cachep, struct list_head *list);
static int enable_cpucache(struct kmem_cache *cachep, gfp_t gfp);
static void cache_reap(struct work_struct *unused);

static inline void fixup_objfreelist_debug(struct kmem_cache *cachep,
						void **list);
static inline void fixup_slab_list(struct kmem_cache *cachep,
				struct kmem_cache_node *n, struct page *page,
				void **list);

static int slab_early_init = 1;


#define INDEX_NODE kmalloc_index(sizeof(struct kmem_cache_node))


static void kmem_cache_node_init(struct kmem_cache_node *parent) { INIT_LIST_HEAD(&parent->slabs_full); INIT_LIST_HEAD(&parent->slabs_partial); INIT_LIST_HEAD(&parent->slabs_free); parent->total_slabs = 0; parent->free_slabs = 0; parent->shared = NULL; parent->alien = NULL; parent->colour_next = 0; spin_lock_init(&parent->list_lock); parent->free_objects = 0; parent->free_touched = 0; }

Contributors

PersonTokensPropCommitsCommitProp
Christoph Lameter6778.82%350.00%
Greg Thelen1112.94%116.67%
Ravikiran G. Thirumalai67.06%116.67%
David Rientjes11.18%116.67%
Total85100.00%6100.00%

#define MAKE_LIST(cachep, listp, slab, nodeid) \ do { \ INIT_LIST_HEAD(listp); \ list_splice(&get_node(cachep, nodeid)->slab, listp); \ } while (0) #define MAKE_ALL_LISTS(cachep, ptr, nodeid) \ do { \ MAKE_LIST((cachep), (&(ptr)->slabs_full), slabs_full, nodeid); \ MAKE_LIST((cachep), (&(ptr)->slabs_partial), slabs_partial, nodeid); \ MAKE_LIST((cachep), (&(ptr)->slabs_free), slabs_free, nodeid); \ } while (0) #define CFLGS_OBJFREELIST_SLAB ((slab_flags_t __force)0x40000000U) #define CFLGS_OFF_SLAB ((slab_flags_t __force)0x80000000U) #define OBJFREELIST_SLAB(x) ((x)->flags & CFLGS_OBJFREELIST_SLAB) #define OFF_SLAB(x) ((x)->flags & CFLGS_OFF_SLAB) #define BATCHREFILL_LIMIT 16 /* * Optimization question: fewer reaps means less probability for unnessary * cpucache drain/refill cycles. * * OTOH the cpuarrays can contain lots of objects, * which could lock up otherwise freeable slabs. */ #define REAPTIMEOUT_AC (2*HZ) #define REAPTIMEOUT_NODE (4*HZ) #if STATS #define STATS_INC_ACTIVE(x) ((x)->num_active++) #define STATS_DEC_ACTIVE(x) ((x)->num_active--) #define STATS_INC_ALLOCED(x) ((x)->num_allocations++) #define STATS_INC_GROWN(x) ((x)->grown++) #define STATS_ADD_REAPED(x,y) ((x)->reaped += (y)) #define STATS_SET_HIGH(x) \ do { \ if ((x)->num_active > (x)->high_mark) \ (x)->high_mark = (x)->num_active; \ } while (0) #define STATS_INC_ERR(x) ((x)->errors++) #define STATS_INC_NODEALLOCS(x) ((x)->node_allocs++) #define STATS_INC_NODEFREES(x) ((x)->node_frees++) #define STATS_INC_ACOVERFLOW(x) ((x)->node_overflow++) #define STATS_SET_FREEABLE(x, i) \ do { \ if ((x)->max_freeable < i) \ (x)->max_freeable = i; \ } while (0) #define STATS_INC_ALLOCHIT(x) atomic_inc(&(x)->allochit) #define STATS_INC_ALLOCMISS(x) atomic_inc(&(x)->allocmiss) #define STATS_INC_FREEHIT(x) atomic_inc(&(x)->freehit) #define STATS_INC_FREEMISS(x) atomic_inc(&(x)->freemiss) #else #define STATS_INC_ACTIVE(x) do { } while (0) #define STATS_DEC_ACTIVE(x) do { } while (0) #define STATS_INC_ALLOCED(x) do { } while (0) #define STATS_INC_GROWN(x) do { } while (0) #define STATS_ADD_REAPED(x,y) do { (void)(y); } while (0) #define STATS_SET_HIGH(x) do { } while (0) #define STATS_INC_ERR(x) do { } while (0) #define STATS_INC_NODEALLOCS(x) do { } while (0) #define STATS_INC_NODEFREES(x) do { } while (0) #define STATS_INC_ACOVERFLOW(x) do { } while (0) #define STATS_SET_FREEABLE(x, i) do { } while (0) #define STATS_INC_ALLOCHIT(x) do { } while (0) #define STATS_INC_ALLOCMISS(x) do { } while (0) #define STATS_INC_FREEHIT(x) do { } while (0) #define STATS_INC_FREEMISS(x) do { } while (0) #endif #if DEBUG /* * memory layout of objects: * 0 : objp * 0 .. cachep->obj_offset - BYTES_PER_WORD - 1: padding. This ensures that * the end of an object is aligned with the end of the real * allocation. Catches writes behind the end of the allocation. * cachep->obj_offset - BYTES_PER_WORD .. cachep->obj_offset - 1: * redzone word. * cachep->obj_offset: The real object. * cachep->size - 2* BYTES_PER_WORD: redzone word [BYTES_PER_WORD long] * cachep->size - 1* BYTES_PER_WORD: last caller address * [BYTES_PER_WORD long] */
static int obj_offset(struct kmem_cache *cachep) { return cachep->obj_offset; }

Contributors

PersonTokensPropCommitsCommitProp
Andrew Morton1275.00%250.00%
Manfred Spraul212.50%125.00%
Pekka J Enberg212.50%125.00%
Total16100.00%4100.00%


static unsigned long long *dbg_redzone1(struct kmem_cache *cachep, void *objp) { BUG_ON(!(cachep->flags & SLAB_RED_ZONE)); return (unsigned long long*) (objp + obj_offset(cachep) - sizeof(unsigned long long)); }

Contributors

PersonTokensPropCommitsCommitProp
Andrew Morton4279.25%240.00%
David Woodhouse815.09%120.00%
Pekka J Enberg23.77%120.00%
Manfred Spraul11.89%120.00%
Total53100.00%5100.00%


static unsigned long long *dbg_redzone2(struct kmem_cache *cachep, void *objp) { BUG_ON(!(cachep->flags & SLAB_RED_ZONE)); if (cachep->flags & SLAB_STORE_USER) return (unsigned long long *)(objp + cachep->size - sizeof(unsigned long long) - REDZONE_ALIGN); return (unsigned long long *) (objp + cachep->size - sizeof(unsigned long long)); }

Contributors

PersonTokensPropCommitsCommitProp
Andrew Morton6375.00%233.33%
David Woodhouse1720.24%233.33%
Christoph Lameter22.38%116.67%
Pekka J Enberg22.38%116.67%
Total84100.00%6100.00%


static void **dbg_userword(struct kmem_cache *cachep, void *objp) { BUG_ON(!(cachep->flags & SLAB_STORE_USER)); return (void **)(objp + cachep->size - BYTES_PER_WORD); }

Contributors

PersonTokensPropCommitsCommitProp
Andrew Morton4293.33%250.00%
Pekka J Enberg24.44%125.00%
Christoph Lameter12.22%125.00%
Total45100.00%4100.00%

#else #define obj_offset(x) 0 #define dbg_redzone1(cachep, objp) ({BUG(); (unsigned long long *)NULL;}) #define dbg_redzone2(cachep, objp) ({BUG(); (unsigned long long *)NULL;}) #define dbg_userword(cachep, objp) ({BUG(); (void **)NULL;}) #endif #ifdef CONFIG_DEBUG_SLAB_LEAK
static inline bool is_store_user_clean(struct kmem_cache *cachep) { return atomic_read(&cachep->store_user_clean) == 1; }

Contributors

PersonTokensPropCommitsCommitProp
JoonSoo Kim23100.00%2100.00%
Total23100.00%2100.00%


static inline void set_store_user_clean(struct kmem_cache *cachep) { atomic_set(&cachep->store_user_clean, 1); }

Contributors

PersonTokensPropCommitsCommitProp
JoonSoo Kim22100.00%2100.00%
Total22100.00%2100.00%


static inline void set_store_user_dirty(struct kmem_cache *cachep) { if (is_store_user_clean(cachep)) atomic_set(&cachep->store_user_clean, 0); }

Contributors

PersonTokensPropCommitsCommitProp
JoonSoo Kim29100.00%2100.00%
Total29100.00%2100.00%

#else
static inline void set_store_user_dirty(struct kmem_cache *cachep) {}

Contributors

PersonTokensPropCommitsCommitProp
JoonSoo Kim11100.00%1100.00%
Total11100.00%1100.00%

#endif /* * Do not go above this order unless 0 objects fit into the slab or * overridden on the command line. */ #define SLAB_MAX_ORDER_HI 1 #define SLAB_MAX_ORDER_LO 0 static int slab_max_order = SLAB_MAX_ORDER_LO; static bool slab_max_order_set __initdata;
static inline struct kmem_cache *virt_to_cache(const void *obj) { struct page *page = virt_to_head_page(obj); return page->slab_cache; }

Contributors

PersonTokensPropCommitsCommitProp
Pekka J Enberg2689.66%133.33%
Christoph Lameter310.34%266.67%
Total29100.00%3100.00%


static inline void *index_to_obj(struct kmem_cache *cache, struct page *page, unsigned int idx) { return page->s_mem + cache->size * idx; }

Contributors

PersonTokensPropCommitsCommitProp
Pekka J Enberg2987.88%133.33%
JoonSoo Kim39.09%133.33%
Christoph Lameter13.03%133.33%
Total33100.00%3100.00%

/* * We want to avoid an expensive divide : (offset / cache->size) * Using the fact that size is a constant for a particular cache, * we can replace (offset / cache->size) by * reciprocal_divide(offset, cache->reciprocal_buffer_size) */
static inline unsigned int obj_to_index(const struct kmem_cache *cache, const struct page *page, void *obj) { u32 offset = (obj - page->s_mem); return reciprocal_divide(offset, cache->reciprocal_buffer_size); }

Contributors

PersonTokensPropCommitsCommitProp
Pekka J Enberg2760.00%133.33%
Eric Dumazet1533.33%133.33%
JoonSoo Kim36.67%133.33%
Total45100.00%3100.00%

#define BOOT_CPUCACHE_ENTRIES 1 /* internal cache of cache description objs */ static struct kmem_cache kmem_cache_boot = { .batchcount = 1, .limit = BOOT_CPUCACHE_ENTRIES, .shared = 1, .size = sizeof(struct kmem_cache), .name = "kmem_cache", }; static DEFINE_PER_CPU(struct delayed_work, slab_reap_work);
static inline struct array_cache *cpu_cache_get(struct kmem_cache *cachep) { return this_cpu_ptr(cachep->cpu_cache); }

Contributors

PersonTokensPropCommitsCommitProp
Rusty Russell1568.18%125.00%
JoonSoo Kim418.18%125.00%
Pekka J Enberg313.64%250.00%
Total22100.00%4100.00%

/* * Calculate the number of objects and left-over bytes for a given buffer size. */
static unsigned int cache_estimate(unsigned long gfporder, size_t buffer_size, slab_flags_t flags, size_t *left_over) { unsigned int num; size_t slab_size = PAGE_SIZE << gfporder; /* * The slab management structure can be either off the slab or * on it. For the latter case, the memory allocated for a * slab is used for: * * - @buffer_size bytes for each object * - One freelist_idx_t for each object * * We don't need to consider alignment of freelist because * freelist will be at the end of slab page. The objects will be * at the correct alignment. * * If the slab management structure is off the slab, then the * alignment will already be calculated into the size. Because * the slabs are all pages aligned, the objects will be at the * correct alignment when allocated. */ if (flags & (CFLGS_OBJFREELIST_SLAB | CFLGS_OFF_SLAB)) { num = slab_size / buffer_size; *left_over = slab_size % buffer_size; } else { num = slab_size / (buffer_size + sizeof(freelist_idx_t)); *left_over = slab_size % (buffer_size + sizeof(freelist_idx_t)); } return num; }

Contributors

PersonTokensPropCommitsCommitProp
JoonSoo Kim3740.66%433.33%
Linus Torvalds (pre-git)3639.56%541.67%
Steven Rostedt1617.58%18.33%
Andrew Morton11.10%18.33%
Alexey Dobriyan11.10%18.33%
Total91100.00%12100.00%

#if DEBUG #define slab_error(cachep, msg) __slab_error(__func__, cachep, msg)
static void __slab_error(const char *function, struct kmem_cache *cachep, char *msg) { pr_err("slab error in %s(): cache `%s': %s\n", function, cachep->name, msg); dump_stack(); add_taint(TAINT_BAD_PAGE, LOCKDEP_NOW_UNRELIABLE); }

Contributors

PersonTokensPropCommitsCommitProp
Andrew Morton3274.42%116.67%
Dave Jones511.63%116.67%
Rusty Russell24.65%116.67%
Pekka J Enberg24.65%116.67%
Joe Perches12.33%116.67%
Zwane Mwaikambo12.33%116.67%
Total43100.00%6100.00%

#endif /* * By default on NUMA we use alien caches to stage the freeing of * objects allocated from other nodes. This causes massive memory * inefficiencies when using fake NUMA setup to split memory into a * large number of small nodes, so it can be disabled on the command * line */ static int use_alien_caches __read_mostly = 1;
static int __init noaliencache_setup(char *s) { use_alien_caches = 0; return 1; }

Contributors

PersonTokensPropCommitsCommitProp
Paul Menage18100.00%1100.00%
Total18100.00%1100.00%

__setup("noaliencache", noaliencache_setup);
static int __init slab_max_order_setup(char *str) { get_option(&str, &slab_max_order); slab_max_order = slab_max_order < 0 ? 0 : min(slab_max_order, MAX_ORDER - 1); slab_max_order_set = true; return 1; }

Contributors

PersonTokensPropCommitsCommitProp
David Rientjes44100.00%1100.00%
Total44100.00%1100.00%

__setup("slab_max_order=", slab_max_order_setup); #ifdef CONFIG_NUMA /* * Special reaping functions for NUMA systems called from cache_reap(). * These take care of doing round robin flushing of alien caches (containing * objects freed on different nodes from which they were allocated) and the * flushing of remote pcps by calling drain_node_pages. */ static DEFINE_PER_CPU(unsigned long, slab_reap_node);
static void init_reap_node(int cpu) { per_cpu(slab_reap_node, cpu) = next_node_in(cpu_to_mem(cpu), node_online_map); }

Contributors

PersonTokensPropCommitsCommitProp
Christoph Lameter1869.23%133.33%
Andrew Morton726.92%133.33%
Lee Schermerhorn13.85%133.33%
Total26100.00%3100.00%


static void next_reap_node(void) { int node = __this_cpu_read(slab_reap_node); node = next_node_in(node, node_online_map); __this_cpu_write(slab_reap_node, node); }

Contributors

PersonTokensPropCommitsCommitProp
Christoph Lameter2990.62%250.00%
Tejun Heo26.25%125.00%
Andrew Morton13.12%125.00%
Total32100.00%4100.00%

#else #define init_reap_node(cpu) do { } while (0) #define next_reap_node(void) do { } while (0) #endif /* * Initiate the reap timer running on the target CPU. We run at around 1 to 2Hz * via the workqueue/eventd. * Add the CPU number into the expiration time to minimize the possibility of * the CPUs getting into lockstep and contending for the global cache chain * lock. */
static void start_cpu_timer(int cpu) { struct delayed_work *reap_work = &per_cpu(slab_reap_work, cpu); if (reap_work->work.func == NULL) { init_reap_node(cpu); INIT_DEFERRABLE_WORK(reap_work, cache_reap); schedule_delayed_work_on(cpu, reap_work, __round_jiffies_relative(HZ, cpu)); } }

Contributors

PersonTokensPropCommitsCommitProp
Andrew Morton2643.33%327.27%
Dimitri Sivanich1220.00%19.09%
Rusty Russell813.33%218.18%
Christoph Lameter58.33%19.09%
Arjan van de Ven46.67%19.09%
David Howells35.00%19.09%
Tejun Heo23.33%218.18%
Total60100.00%11100.00%


static void init_arraycache(struct array_cache *ac, int limit, int batch) { /* * The array_cache structures contain pointers to free object. * However, when such objects are allocated or transferred to another * cache the pointers are not cleared and they could be counted as * valid references during a kmemleak scan. Therefore, kmemleak must * not scan such objects. */ kmemleak_no_scan(ac); if (ac) { ac->avail = 0; ac->limit = limit; ac->batchcount = batch; ac->touched = 0; } }

Contributors

PersonTokensPropCommitsCommitProp
JoonSoo Kim3260.38%266.67%
Mel Gorman2139.62%133.33%
Total53100.00%3100.00%


static struct array_cache *alloc_arraycache(int node, int entries, int batchcount, gfp_t gfp) { size_t memsize = sizeof(void *) * entries + sizeof(struct array_cache); struct array_cache *ac = NULL; ac = kmalloc_node(memsize, gfp, node); init_arraycache(ac, entries, batchcount); return ac; }

Contributors

PersonTokensPropCommitsCommitProp
JoonSoo Kim4668.66%120.00%
Mel Gorman1420.90%240.00%
Andrew Morton45.97%120.00%
Christoph Lameter34.48%120.00%
Total67100.00%5100.00%


static noinline void cache_free_pfmemalloc(struct kmem_cache *cachep, struct page *page, void *objp) { struct kmem_cache_node *n; int page_node; LIST_HEAD(list); page_node = page_to_nid(page); n = get_node(cachep, page_node); spin_lock(&n->list_lock); free_block(cachep, &objp, 1, page_node, &list); spin_unlock(&n->list_lock); slabs_destroy(cachep, &list); }

Contributors

PersonTokensPropCommitsCommitProp
JoonSoo Kim6067.42%125.00%
Mel Gorman2831.46%250.00%
Andrew Morton11.12%125.00%
Total89100.00%4100.00%

/* * Transfer objects in one arraycache to another. * Locking must be handled by the caller. * * Return the number of entries transferred. */
static int transfer_objects(struct array_cache *to, struct array_cache *from, unsigned int max) { /* Figure out how many entries to transfer */ int nr = min3(from->avail, max, to->limit - to->avail); if (!nr) return 0; memcpy(to->entry + to->avail, from->entry + from->avail -nr, sizeof(void *) *nr); from->avail -= nr; to->avail += nr; return nr; }

Contributors

PersonTokensPropCommitsCommitProp
Christoph Lameter9298.92%150.00%
Hagen Paul Pfeifer11.08%150.00%
Total93100.00%2100.00%

#ifndef CONFIG_NUMA #define drain_alien_cache(cachep, alien) do { } while (0) #define reap_alien(cachep, n) do { } while (0)
static inline struct alien_cache **alloc_alien_cache(int node, int limit, gfp_t gfp) { return NULL; }

Contributors

PersonTokensPropCommitsCommitProp
Christoph Lameter1777.27%125.00%
Pekka J Enberg313.64%125.00%
JoonSoo Kim29.09%250.00%
Total22100.00%4100.00%


static inline void free_alien_cache(struct alien_cache **ac_ptr) { }

Contributors

PersonTokensPropCommitsCommitProp
Christoph Lameter1191.67%150.00%
JoonSoo Kim18.33%150.00%
Total12100.00%2100.00%


static inline int cache_free_alien(struct kmem_cache *cachep, void *objp) { return 0; }

Contributors

PersonTokensPropCommitsCommitProp
Christoph Lameter19100.00%1100.00%
Total19100.00%1100.00%


static inline void *alternate_node_alloc(struct kmem_cache *cachep, gfp_t flags) { return NULL; }

Contributors

PersonTokensPropCommitsCommitProp
Christoph Lameter19100.00%1100.00%
Total19100.00%1100.00%


static inline void *____cache_alloc_node(struct kmem_cache *cachep, gfp_t flags, int nodeid) { return NULL; }

Contributors

PersonTokensPropCommitsCommitProp
Christoph Lameter2195.45%150.00%
Christoph Hellwig14.55%150.00%
Total22100.00%2100.00%


static inline gfp_t gfp_exact_node(gfp_t flags) { return flags & ~__GFP_NOFAIL; }

Contributors

PersonTokensPropCommitsCommitProp
David Rientjes1381.25%150.00%
Mel Gorman318.75%150.00%
Total16100.00%2100.00%

#else /* CONFIG_NUMA */ static void *____cache_alloc_node(struct kmem_cache *, gfp_t, int); static void *alternate_node_alloc(struct kmem_cache *, gfp_t);
static struct alien_cache *__alloc_alien_cache(int node, int entries, int batch, gfp_t gfp) { size_t memsize = sizeof(void *) * entries + sizeof(struct alien_cache); struct alien_cache *alc = NULL; alc = kmalloc_node(memsize, gfp, node); init_arraycache(&alc->ac, entries, batch); spin_lock_init(&alc->lock); return alc; }

Contributors

PersonTokensPropCommitsCommitProp
JoonSoo Kim78100.00%3100.00%
Total78100.00%3100.00%


static struct alien_cache **alloc_alien_cache(int node, int limit, gfp_t gfp) { struct alien_cache **alc_ptr; size_t memsize = sizeof(void *) * nr_node_ids; int i; if (limit > 1) limit = 12; alc_ptr = kzalloc_node(memsize, gfp, node); if (!alc_ptr) return NULL; for_each_node(i) { if (i == node || !node_online(i)) continue; alc_ptr[i] = __alloc_alien_cache(node, limit, 0xbaadf00d, gfp); if (!alc_ptr[i]) { for (i--; i >= 0; i--) kfree(alc_ptr[i]); kfree(alc_ptr); return NULL; } } return alc_ptr; }

Contributors

PersonTokensPropCommitsCommitProp
Christoph Lameter8559.44%216.67%
Andrew Morton3323.08%433.33%
JoonSoo Kim1611.19%216.67%
Pekka J Enberg64.20%18.33%
Akinobu Mita10.70%18.33%
Rusty Russell10.70%18.33%
Haicheng Li10.70%18.33%
Total143100.00%12100.00%


static void free_alien_cache(struct alien_cache **alc_ptr) { int i; if (!alc_ptr) return; for_each_node(i) kfree(alc_ptr[i]); kfree(alc_ptr); }

Contributors

PersonTokensPropCommitsCommitProp
Christoph Lameter2565.79%125.00%
Andrew Morton821.05%250.00%
JoonSoo Kim513.16%125.00%
Total38100.00%4100.00%


static void __drain_alien_cache(struct kmem_cache *cachep, struct array_cache *ac, int node, struct list_head *list) { struct kmem_cache_node *n = get_node(cachep, node); if (ac->avail) { spin_lock(&n->list_lock); /* * Stuff objects into the remote nodes shared array first. * That way we could avoid the overhead of putting the objects * into the free lists and getting them back later. */ if (n->shared) transfer_objects(n->shared, ac, ac->limit); free_block(cachep, ac->entry, ac->avail, node, list); ac->avail = 0; spin_unlock(&n->list_lock); } }

Contributors

PersonTokensPropCommitsCommitProp
Christoph Lameter6563.11%646.15%
Rusty Russell1312.62%17.69%
Andrew Morton1110.68%215.38%
JoonSoo Kim76.80%215.38%
Jacob Shin54.85%17.69%
Pekka J Enberg21.94%17.69%
Total103100.00%13100.00%

/* * Called from cache_reap() to regularly drain alien caches round robin. */
static void reap_alien(struct kmem_cache *cachep, struct kmem_cache_node *n) { int node = __this_cpu_read(slab_reap_node); if (n->alien) { struct alien_cache *alc = n->alien[node]; struct array_cache *ac; if (alc) { ac = &alc->ac; if (ac->avail && spin_trylock_irq(&alc->lock)) { LIST_HEAD(list); __drain_alien_cache(cachep, ac, node, &list); spin_unlock_irq(&alc->lock); slabs_destroy(cachep, &list); } } } }

Contributors

PersonTokensPropCommitsCommitProp
Christoph Lameter7365.77%555.56%
JoonSoo Kim3733.33%333.33%
Tejun Heo10.90%111.11%
Total111100.00%9100.00%


static void drain_alien_cache(struct kmem_cache *cachep, struct alien_cache **alien) { int i = 0; struct alien_cache *alc; struct array_cache *ac; unsigned long flags; for_each_online_node(i) { alc = alien[i]; if (alc) { LIST_HEAD(list); ac = &alc->ac; spin_lock_irqsave(&alc->lock, flags); __drain_alien_cache(cachep, ac, i, &list); spin_unlock_irqrestore(&alc->lock, flags); slabs_destroy(cachep, &list); } } }

Contributors

PersonTokensPropCommitsCommitProp
Christoph Lameter5854.21%19.09%
JoonSoo Kim3330.84%327.27%
Andrew Morton98.41%218.18%
Linus Torvalds (pre-git)32.80%327.27%
Ravikiran G. Thirumalai21.87%19.09%
Pekka J Enberg21.87%19.09%
Total107100.00%11100.00%


static int __cache_free_alien(struct kmem_cache *cachep, void *objp, int node, int page_node) { struct kmem_cache_node *n; struct alien_cache *alien = NULL; struct array_cache *ac; LIST_HEAD(list); n = get_node(cachep, node); STATS_INC_NODEFREES(cachep); if (n->alien && n->alien[page_node]) { alien = n->alien[page_node]; ac = &alien->ac; spin_lock(&alien->lock); if (unlikely(ac->avail == ac->limit)) { STATS_INC_ACOVERFLOW(cachep); __drain_alien_cache(cachep, ac, page_node, &list); } ac->entry[ac->avail++] = objp; spin_unlock(&alien->lock); slabs_destroy(cachep, &list); } else { n = get_node(cachep, page_node); spin_lock(&n->list_lock); free_block(cachep, &objp, 1, page_node, &list); spin_unlock(&n->list_lock); slabs_destroy(cachep, &list); } return 1; }

Contributors

PersonTokensPropCommitsCommitProp
Pekka J Enberg12157.62%216.67%
JoonSoo Kim6731.90%650.00%
Christoph Lameter2110.00%325.00%
Ingo Molnar10.48%18.33%
Total210100.00%12100.00%


static inline int cache_free_alien(struct kmem_cache *cachep, void *objp) { int page_node = page_to_nid(virt_to_page(objp)); int node = numa_mem_id(); /* * Make sure we are not freeing a object from another node to the array * cache on this cpu. */ if (likely(node == page_node)) return 0; return __cache_free_alien(cachep, objp, node, page_node); }

Contributors

PersonTokensPropCommitsCommitProp
JoonSoo Kim58100.00%1100.00%
Total58100.00%1100.00%

/* * Construct gfp mask to allocate from a specific node but do not reclaim or * warn about failures. */
static inline gfp_t gfp_exact_node(gfp_t flags) { return (flags | __GFP_THISNODE | __GFP_NOWARN) & ~(__GFP_RECLAIM|__GFP_NOFAIL); }

Contributors

PersonTokensPropCommitsCommitProp
David Rientjes2180.77%150.00%
Mel Gorman519.23%150.00%
Total26100.00%2100.00%

#endif
static int init_cache_node(struct kmem_cache *cachep, int node, gfp_t gfp) { struct kmem_cache_node *n; /* * Set up the kmem_cache_node for cpu before we can * begin anything. Make sure some other cpu on this * node has not already allocated this */ n = get_node(cachep, node); if (n) { spin_lock_irq(&n->list_lock); n->free_limit = (1 + nr_cpus_node(node)) * cachep->batchcount + cachep->num; spin_unlock_irq(&n->list_lock); return 0; } n = kmalloc_node(sizeof(struct kmem_cache_node), gfp, node); if (!n) return -ENOMEM; kmem_cache_node_init(n); n->next_reap = jiffies + REAPTIMEOUT_NODE + ((unsigned long)cachep) % REAPTIMEOUT_NODE; n->free_limit = (1 + nr_cpus_node(node)) * cachep->batchcount + cachep->num; /* * The kmem_cache_nodes don't come and go as CPUs * come and go. slab_mutex is sufficient * protection here. */ cachep->node[node] = n; return 0; }

Contributors

PersonTokensPropCommitsCommitProp
JoonSoo Kim7044.03%116.67%
David Rientjes6943.40%116.67%
Christoph Lameter1811.32%350.00%
Jianyu Zhan21.26%116.67%
Total159100.00%6100.00%

#if (defined(CONFIG_NUMA) && defined(CONFIG_MEMORY_HOTPLUG)) || defined(CONFIG_SMP) /* * Allocates and initializes node for a node on each slab cache, used for * either memory or cpu hotplug. If memory is being hot-added, the kmem_cache_node * will be allocated off-node since memory is not yet online for the new node. * When hotplugging memory or a cpu, existing node are not replaced if * already in use. * * Must hold slab_mutex. */
static int init_cache_node_node(int node) { int ret; struct kmem_cache *cachep; list_for_each_entry(cachep, &slab_caches, list) { ret = init_cache_node(cachep, node, GFP_KERNEL); if (ret) return ret; } return 0; }

Contributors

PersonTokensPropCommitsCommitProp
JoonSoo Kim4185.42%150.00%
David Rientjes714.58%150.00%
Total48100.00%2100.00%

#endif
static int setup_kmem_cache_node(struct kmem_cache *cachep, int node, gfp_t gfp, bool force_change) { int ret = -ENOMEM; struct kmem_cache_node *n; struct array_cache *old_shared = NULL; struct array_cache *new_shared = NULL; struct alien_cache **new_alien = NULL; LIST_HEAD(list); if (use_alien_caches) { new_alien = alloc_alien_cache(node, cachep->limit, gfp); if (!new_alien) goto fail; } if (cachep->shared) { new_shared = alloc_arraycache(node, cachep->shared * cachep->batchcount, 0xbaadf00d, gfp); if (!new_shared) goto fail; } ret = init_cache_node(cachep, node, gfp); if (ret) goto fail; n = get_node(cachep, node); spin_lock_irq(&n->list_lock); if (n->shared && force_change) { free_block(cachep, n->shared->entry, n->shared->avail, node, &list); n->shared->avail = 0; } if (!n->shared || force_change) { old_shared = n->shared; n->shared = new_shared; new_shared = NULL; } if (!n->alien) { n->alien = new_alien; new_alien = NULL; } spin_unlock_irq(&n->list_lock); slabs_destroy(cachep, &list); /* * To protect lockless access to n->shared during irq disabled context. * If n->shared isn't NULL in irq disabled context, accessing to it is * guaranteed to be valid until irq is re-enabled, because it will be * freed after synchronize_sched(). */ if (old_shared && force_change) synchronize_sched(); fail: kfree(old_shared); kfree(new_shared); free_alien_cache(new_alien); return ret; }

Contributors

PersonTokensPropCommitsCommitProp
JoonSoo Kim17460.63%654.55%
Akinobu Mita9834.15%19.09%
Christoph Lameter124.18%327.27%
Rusty Russell31.05%19.09%
Total287100.00%11100.00%

#ifdef CONFIG_SMP
static void cpuup_canceled(long cpu) { struct kmem_cache *cachep; struct kmem_cache_node *n = NULL; int node = cpu_to_mem(cpu); const struct cpumask *mask = cpumask_of_node(node); list_for_each_entry(cachep, &slab_caches, list) { struct array_cache *nc; struct array_cache *shared; struct alien_cache **alien; LIST_HEAD(list); n = get_node(cachep, node); if (!n) continue; spin_lock_irq(&n->list_lock); /* Free limit for this kmem_cache_node */ n->free_limit -= cachep->batchcount; /* cpu is dead; no one can alloc from it. */ nc = per_cpu_ptr(cachep->cpu_cache, cpu); if (nc) { free_block(cachep, nc->entry, nc->avail, node, &list); nc->avail = 0; } if (!cpumask_empty(mask)) { spin_unlock_irq(&n->list_lock); goto free_slab; } shared = n->shared; if (shared) { free_block(cachep, shared->entry, shared->avail, node, &list); n->shared = NULL; } alien = n->alien; n->alien = NULL; spin_unlock_irq(&n->list_lock); kfree(shared); if (alien) { drain_alien_cache(cachep, alien); free_alien_cache(alien); } free_slab: slabs_destroy(cachep, &list); } /* * In the previous loop, all the objects were freed to * the respective cache's slabs, now we can go ahead and * shrink each nodelist to its limit. */ list_for_each_entry(cachep, &slab_caches, list) { n = get_node(cachep, node); if (!n) continue; drain_freelist(cachep, n, INT_MAX); } }

Contributors

PersonTokensPropCommitsCommitProp
JoonSoo Kim16857.93%212.50%
Ravikiran G. Thirumalai5619.31%16.25%
Christoph Lameter4816.55%637.50%
Akinobu Mita93.10%212.50%
Pekka J Enberg41.38%212.50%
Tobias Klauser31.03%16.25%
Paul Menage10.34%16.25%
Lee Schermerhorn10.34%16.25%
Total290100.00%16100.00%


static int cpuup_prepare(long cpu) { struct kmem_cache *cachep; int node = cpu_to_mem(cpu); int err; /* * We need to do this right in the beginning since * alloc_arraycache's are going to use this list. * kmalloc_node allows us to add the slab to the right * kmem_cache_node and not this cpu's kmem_cache_node */ err = init_cache_node_node(node); if (err < 0) goto bad; /* * Now we can go ahead with allocating the shared arrays and * array caches */ list_for_each_entry(cachep, &slab_caches, list) { err = setup_kmem_cache_node(cachep, node, GFP_KERNEL, false); if (err) goto bad; } return 0; bad: cpuup_canceled(cpu); return -ENOMEM; }

Contributors

PersonTokensPropCommitsCommitProp
JoonSoo Kim7282.76%133.33%
Akinobu Mita1517.24%266.67%
Total87100.00%3100.00%


int slab_prepare_cpu(unsigned int cpu) { int err; mutex_lock(&slab_mutex); err = cpuup_prepare(cpu); mutex_unlock(&slab_mutex); return err; }

Contributors

PersonTokensPropCommitsCommitProp
Akinobu Mita1852.94%120.00%
Sebastian Andrzej Siewior720.59%120.00%
Gautham R. Shenoy514.71%120.00%
Christoph Lameter25.88%120.00%
Ravikiran G. Thirumalai25.88%120.00%
Total34100.00%5100.00%

/* * This is called for a failed online attempt and for a successful * offline. * * Even if all the cpus of a node are down, we don't free the * kmem_list3 of any cache. This to avoid a race between cpu_down, and * a kmalloc allocation from another cpu for memory from the node of * the cpu going down. The list3 structure is usually allocated from * kmem_cache_create() and gets destroyed at kmem_cache_destroy(). */
int slab_dead_cpu(unsigned int cpu) { mutex_lock(&slab_mutex); cpuup_canceled(cpu); mutex_unlock(&slab_mutex); return 0; }

Contributors

PersonTokensPropCommitsCommitProp
Sebastian Andrzej Siewior29100.00%1100.00%
Total29100.00%1100.00%

#endif
static int slab_online_cpu(unsigned int cpu) { start_cpu_timer(cpu); return 0; }

Contributors

PersonTokensPropCommitsCommitProp
Sebastian Andrzej Siewior1372.22%150.00%
Christoph Lameter527.78%150.00%
Total18100.00%2100.00%


static int slab_offline_cpu(unsigned int cpu) { /* * Shutdown cache reaper. Note that the slab_mutex is held so * that if cache_reap() is invoked it cannot do anything * expensive but will only modify reap_work and reschedule the * timer. */ cancel_delayed_work_sync(&per_cpu(slab_reap_work, cpu)); /* Now the cache_reaper is guaranteed to be not running. */ per_cpu(slab_reap_work, cpu).work.func = NULL; return 0; }

Contributors

PersonTokensPropCommitsCommitProp
Christoph Lameter2564.10%240.00%
Sebastian Andrzej Siewior1128.21%120.00%
Tejun Heo37.69%240.00%
Total39100.00%5100.00%

#if defined(CONFIG_NUMA) && defined(CONFIG_MEMORY_HOTPLUG) /* * Drains freelist for a node on each slab cache, used for memory hot-remove. * Returns -EBUSY if all objects cannot be drained so that the node is not * removed. * * Must hold slab_mutex. */
static int __meminit drain_cache_node_node(int node) { struct kmem_cache *cachep; int ret = 0; list_for_each_entry(cachep, &slab_caches, list) { struct kmem_cache_node *n; n = get_node(cachep, node); if (!n) continue; drain_freelist(cachep, n, INT_MAX); if (!list_empty(&n->slabs_full) || !list_empty(&n->slabs_partial)) { ret = -EBUSY; break; } } return ret; }

Contributors

PersonTokensPropCommitsCommitProp
David Rientjes7583.33%112.50%
Christoph Lameter1415.56%675.00%
JoonSoo Kim11.11%112.50%
Total90100.00%8100.00%


static int __meminit slab_memory_callback(struct notifier_block *self, unsigned long action, void *arg) { struct memory_notify *mnb = arg; int ret = 0; int nid; nid = mnb->status_change_nid; if (nid < 0) goto out; switch (action) { case MEM_GOING_ONLINE: mutex_lock(&slab_mutex); ret = init_cache_node_node(nid); mutex_unlock(&slab_mutex); break; case MEM_GOING_OFFLINE: mutex_lock(&slab_mutex); ret = drain_cache_node_node(nid); mutex_unlock(&slab_mutex); break; case MEM_ONLINE: case MEM_OFFLINE: case MEM_CANCEL_ONLINE: case MEM_CANCEL_OFFLINE: break; } out: return notifier_from_errno(ret); }

Contributors

PersonTokensPropCommitsCommitProp
David Rientjes6351.22%110.00%
Christoph Lameter2318.70%440.00%
Akinobu Mita2016.26%110.00%
Ravikiran G. Thirumalai75.69%220.00%
Gautham R. Shenoy54.07%110.00%
Rafael J. Wysocki54.07%110.00%
Total123100.00%10100.00%

#endif /* CONFIG_NUMA && CONFIG_MEMORY_HOTPLUG */ /* * swap the static kmem_cache_node with kmalloced memory */
static void __init init_list(struct kmem_cache *cachep, struct kmem_cache_node *list, int nodeid) { struct kmem_cache_node *ptr; ptr = kmalloc_node(sizeof(struct kmem_cache_node), GFP_NOWAIT, nodeid); BUG_ON(!ptr); memcpy(ptr, list, sizeof(struct kmem_cache_node)); /* * Do not assume that spinlocks can be initialized via memcpy: */ spin_lock_init(&ptr->list_lock); MAKE_ALL_LISTS(cachep, ptr, nodeid); cachep->node[nodeid] = ptr; }

Contributors

PersonTokensPropCommitsCommitProp
Christoph Lameter7384.88%342.86%
Ingo Molnar910.47%114.29%
Pekka J Enberg33.49%228.57%
David Rientjes11.16%114.29%
Total86100.00%7100.00%

/* * For setting up all the kmem_cache_node for cache whose buffer_size is same as * size of kmem_cache_node. */
static void __init set_up_node(struct kmem_cache *cachep, int index) { int node; for_each_online_node(node) { cachep->node[node] = &init_kmem_cache_node[index + node]; cachep->node[node]->next_reap = jiffies + REAPTIMEOUT_NODE + ((unsigned long)cachep) % REAPTIMEOUT_NODE; } }

Contributors

PersonTokensPropCommitsCommitProp
Pekka J Enberg5690.32%125.00%
Christoph Lameter46.45%250.00%
Jianyu Zhan23.23%125.00%
Total62100.00%4100.00%

/* * Initialisation. Called after the page allocator have been initialised and * before smp_init(). */
void __init kmem_cache_init(void) { int i; BUILD_BUG_ON(sizeof(((struct page *)NULL)->lru) < sizeof(struct rcu_head)); kmem_cache = &kmem_cache_boot; if (!IS_ENABLED(CONFIG_NUMA) || num_possible_nodes() == 1) use_alien_caches = 0; for (i = 0; i < NUM_INIT_LISTS; i++) kmem_cache_node_init(&init_kmem_cache_node[i]); /* * Fragmentation resistance on low memory - only use bigger * page orders on machines with more than 32MB of memory if * not overridden on the command line. */ if (!slab_max_order_set && totalram_pages > (32 << 20) >> PAGE_SHIFT) slab_max_order = SLAB_MAX_ORDER_HI; /* Bootstrap is tricky, because several objects are allocated * from caches that do not exist yet: * 1) initialize the kmem_cache cache: it contains the struct * kmem_cache structures of all caches, except kmem_cache itself: * kmem_cache is statically allocated. * Initially an __init data area is used for the head array and the * kmem_cache_node structures, it's replaced with a kmalloc allocated * array at the end of the bootstrap. * 2) Create the first kmalloc cache. * The struct kmem_cache for the new cache is allocated normally. * An __init data area is used for the head array. * 3) Create the remaining kmalloc caches, with minimally sized * head arrays. * 4) Replace the __init data head arrays for kmem_cache and the first * kmalloc cache with kmalloc allocated arrays. * 5) Replace the __init data for kmem_cache_node for kmem_cache and * the other cache's with kmalloc allocated memory. * 6) Resize the head arrays of the kmalloc caches to their final sizes. */ /* 1) create the kmem_cache */ /* * struct kmem_cache size depends on nr_node_ids & nr_cpu_ids */ create_boot_cache(kmem_cache, "kmem_cache", offsetof(struct kmem_cache, node) + nr_node_ids * sizeof(struct kmem_cache_node *), SLAB_HWCACHE_ALIGN); list_add(&kmem_cache->list, &slab_caches); slab_state = PARTIAL; /* * Initialize the caches that provide memory for the kmem_cache_node * structures first. Without this, further allocations will bug. */ kmalloc_caches[INDEX_NODE] = create_kmalloc_cache( kmalloc_info[INDEX_NODE].name, kmalloc_size(INDEX_NODE), ARCH_KMALLOC_FLAGS); slab_state = PARTIAL_NODE; setup_kmalloc_cache_index_table(); slab_early_init = 0; /* 5) Replace the bootstrap kmem_cache_node */ { int nid; for_each_online_node(nid) { init_list(kmem_cache, &init_kmem_cache_node[CACHE_CACHE + nid], nid); init_list(kmalloc_caches[INDEX_NODE], &init_kmem_cache_node[SIZE_NODE + nid], nid); } } create_kmalloc_caches(ARCH_KMALLOC_FLAGS); }

Contributors

PersonTokensPropCommitsCommitProp
Christoph Lameter11450.44%828.57%
JoonSoo Kim3716.37%310.71%
Eric Dumazet146.19%13.57%
Andrew Morton135.75%414.29%
Pekka J Enberg114.87%310.71%
Suresh B. Siddha114.87%13.57%
Linus Torvalds (pre-git)83.54%27.14%
Vlastimil Babka62.65%13.57%
David Rientjes62.65%27.14%
Daniel Sanders31.33%13.57%
Daniel Yeisley20.88%13.57%
Jan Beulich10.44%13.57%
Total226100.00%28100.00%


void __init kmem_cache_init_late(void) { struct kmem_cache *cachep; slab_state = UP; /* 6) resize the head arrays to their final sizes */ mutex_lock(&slab_mutex); list_for_each_entry(cachep, &slab_caches, list) if (enable_cpucache(cachep, GFP_NOWAIT)) BUG(); mutex_unlock(&slab_mutex); /* Done! */ slab_state = FULL; #ifdef CONFIG_NUMA /* * Register a memory hotplug callback that initializes and frees * node. */ hotplug_memory_notifier(slab_memory_callback, SLAB_CALLBACK_PRI); #endif /* * The reap timers are started later, with a module init call: That part * of the kernel is not yet operational. */ }

Contributors

PersonTokensPropCommitsCommitProp
Andrew Morton2536.23%426.67%
Christoph Lameter1724.64%533.33%
David Rientjes1217.39%16.67%
Pekka J Enberg1115.94%320.00%
Ingo Molnar22.90%16.67%
Peter Zijlstra22.90%16.67%
Total69100.00%15100.00%


static int __init cpucache_init(void) { int ret; /* * Register the timers that return unneeded pages to the page allocator */ ret = cpuhp_setup_state(CPUHP_AP_ONLINE_DYN, "SLAB online", slab_online_cpu, slab_offline_cpu); WARN_ON(ret < 0); /* Done! */ slab_state = FULL; return 0; }

Contributors

PersonTokensPropCommitsCommitProp
Andrew Morton1946.34%450.00%
Sebastian Andrzej Siewior1639.02%112.50%
Glauber de Oliveira Costa49.76%112.50%
Christoph Hellwig12.44%112.50%
Christoph Lameter12.44%112.50%
Total41100.00%8100.00%

__initcall(cpucache_init);
static noinline void slab_out_of_memory(struct kmem_cache *cachep, gfp_t gfpflags, int nodeid) { #if DEBUG struct kmem_cache_node *n; unsigned long flags; int node; static DEFINE_RATELIMIT_STATE(slab_oom_rs, DEFAULT_RATELIMIT_INTERVAL, DEFAULT_RATELIMIT_BURST); if ((gfpflags & __GFP_NOWARN) || !__ratelimit(&slab_oom_rs)) return; pr_warn("SLAB: Unable to allocate memory on node %d, gfp=%#x(%pGg)\n", nodeid, gfpflags, &gfpflags); pr_warn(" cache: %s, object size: %d, order: %d\n", cachep->name, cachep->size, cachep->gfporder); for_each_kmem_cache_node(cachep, node, n) { unsigned long total_slabs, free_slabs, free_objs; spin_lock_irqsave(&n->list_lock, flags); total_slabs = n->total_slabs; free_slabs = n->free_slabs; free_objs = n->free_objects; spin_unlock_irqrestore(&n->list_lock, flags); pr_warn(" node %d: slabs: %ld/%ld, objs: %ld/%ld\n", node, total_slabs - free_slabs, total_slabs, (total_slabs * cachep->num) - free_objs, total_slabs * cachep->num); } #endif }

Contributors

PersonTokensPropCommitsCommitProp
Rafael Aquini9051.43%110.00%
David Rientjes5330.29%220.00%
Greg Thelen116.29%110.00%
Christoph Lameter116.29%440.00%
Vlastimil Babka74.00%110.00%
Aruna Ramakrishna31.71%110.00%
Total175100.00%10100.00%

/* * Interface to system's page allocator. No need to hold the * kmem_cache_node ->list_lock. * * If we requested dmaable memory, we will get it. Even if we * did not request dmaable memory, we might get it, but that * would be relatively rare and ignorable. */
static struct page *kmem_getpages(struct kmem_cache *cachep, gfp_t flags, int nodeid) { struct page *page; int nr_pages; flags |= cachep->allocflags; page = __alloc_pages_node(nodeid, flags, cachep->gfporder); if (!page) { slab_out_of_memory(cachep, flags, nodeid); return NULL; } if (memcg_charge_slab(page, flags, cachep->gfporder, cachep)) { __free_pages(page, cachep->gfporder); return NULL; } nr_pages = (1 << cachep->gfporder); if (cachep->flags & SLAB_RECLAIM_ACCOUNT) mod_lruvec_page_state(page, NR_SLAB_RECLAIMABLE, nr_pages); else mod_lruvec_page_state(page, NR_SLAB_UNRECLAIMABLE, nr_pages); __SetPageSlab(page); /* Record if ALLOC_NO_WATERMARKS was set when allocating the slab */ if (sk_memalloc_socks() && page_is_pfmemalloc(page)) SetPageSlabPfmemalloc(page); return page; }

Contributors

PersonTokensPropCommitsCommitProp
Andrew Morton5334.19%520.83%
Vladimir Davydov3220.65%28.33%
Luke Yang127.74%14.17%
Christoph Lameter106.45%28.33%
Rafael Aquini85.16%14.17%
Linus Torvalds (pre-git)74.52%14.17%
Christoph Hellwig74.52%14.17%
Mel Gorman74.52%14.17%
JoonSoo Kim63.87%28.33%
Pekka J Enberg42.58%28.33%
Michal Hocko31.94%14.17%
Johannes Weiner21.29%14.17%
Al Viro10.65%14.17%
Vlastimil Babka10.65%14.17%
Nicholas Piggin10.65%14.17%
Glauber de Oliveira Costa10.65%14.17%
Total155100.00%24100.00%

/* * Interface to system's page release. */
static void kmem_freepages(struct kmem_cache *cachep, struct page *page) { int order = cachep->gfporder; unsigned long nr_freed = (1 << order); if (cachep->flags & SLAB_RECLAIM_ACCOUNT) mod_lruvec_page_state(page, NR_SLAB_RECLAIMABLE, -nr_freed); else mod_lruvec_page_state(page, NR_SLAB_UNRECLAIMABLE, -nr_freed); BUG_ON(!PageSlab(page)); __ClearPageSlabPfmemalloc(page); __ClearPageSlab(page); page_mapcount_reset(page); page->mapping = NULL; if (current->reclaim_state) current->reclaim_state->reclaimed_slab += nr_freed; memcg_uncharge_slab(page, order, cachep); __free_pages(page, order); }

Contributors

PersonTokensPropCommitsCommitProp
Linus Torvalds (pre-git)2923.77%213.33%
Christoph Lameter2318.85%213.33%
Vladimir Davydov1814.75%16.67%
Andrew Morton1613.11%213.33%
JoonSoo Kim1411.48%320.00%
Nicholas Piggin97.38%16.67%
Mel Gorman54.10%16.67%
Johannes Weiner43.28%16.67%
Pekka J Enberg43.28%213.33%
Total122100.00%15100.00%


static void kmem_rcu_free(struct rcu_head *head) { struct kmem_cache *cachep; struct page *page; page = container_of(head, struct page, rcu_head); cachep = page->slab_cache; kmem_freepages(cachep, page); }

Contributors

PersonTokensPropCommitsCommitProp
Hugh Dickins2656.52%120.00%
JoonSoo Kim1941.30%360.00%
Pekka J Enberg12.17%120.00%
Total46100.00%5100.00%

#if DEBUG
static bool is_debug_pagealloc_cache(struct kmem_cache *cachep) { if (debug_pagealloc_enabled() && OFF_SLAB(cachep) && (cachep->size % PAGE_SIZE) == 0) return true; return false; }

Contributors

PersonTokensPropCommitsCommitProp
JoonSoo Kim37100.00%1100.00%
Total37100.00%1100.00%

#ifdef CONFIG_DEBUG_PAGEALLOC
static void store_stackinfo(struct kmem_cache *cachep, unsigned long *addr, unsigned long caller) { int size = cachep->object_size; addr = (unsigned long *)&((char *)addr)[obj_offset(cachep)]; if (size < 5 * sizeof(unsigned long)) return; *addr++ = 0x12345678; *addr++ = caller; *addr++ = smp_processor_id(); size -= 3 * sizeof(unsigned long); { unsigned long *sptr = &caller; unsigned long svalue; while (!kstack_end(sptr)) { svalue = *sptr++; if (kernel_text_address(svalue)) { *addr++ = svalue; size -= sizeof(unsigned long); if (size <= sizeof(unsigned long)) break; } } } *addr++ = 0x87654321; }

Contributors

PersonTokensPropCommitsCommitProp
Andrew Morton12678.26%436.36%
Linus Torvalds (pre-git)2616.15%327.27%
Manfred Spraul53.11%218.18%
Pekka J Enberg21.24%19.09%
Christoph Lameter21.24%19.09%
Total161100.00%11100.00%


static void slab_kernel_map(struct kmem_cache *cachep, void *objp, int map, unsigned long caller) { if (!is_debug_pagealloc_cache(cachep)) return; if (caller) store_stackinfo(cachep, objp, caller); kernel_map_pages(virt_to_page(objp), cachep->size / PAGE_SIZE, map); }

Contributors

PersonTokensPropCommitsCommitProp
JoonSoo Kim60100.00%1100.00%
Total60100.00%1100.00%

#else
static inline void slab_kernel_map(struct kmem_cache *cachep, void *objp, int map, unsigned long caller) {}

Contributors

PersonTokensPropCommitsCommitProp
JoonSoo Kim22100.00%1100.00%
Total22100.00%1100.00%

#endif
static void poison_obj(struct kmem_cache *cachep, void *addr, unsigned char val) { int size = cachep->object_size; addr = &((char *)addr)[obj_offset(cachep)]; memset(addr, val, size); *(unsigned char *)(addr + size - 1) = POISON_END; }

Contributors

PersonTokensPropCommitsCommitProp
Andrew Morton6392.65%125.00%
Christoph Lameter22.94%125.00%
Pekka J Enberg22.94%125.00%
Manfred Spraul11.47%125.00%
Total68100.00%4100.00%


static void dump_line(char *data, int offset, int limit) { int i; unsigned char error = 0; int bad_count = 0; pr_err("%03x: ", offset); for (i = 0; i < limit; i++) { if (data[offset + i] != POISON_FREE) { error = data[offset + i]; bad_count++; } } print_hex_dump(KERN_CONT, "", 0, 16, 1, &data[offset], limit, 1); if (bad_count == 1) { error ^= POISON_FREE; if (!(error & (error - 1))) { pr_err("Single bit error detected. Probably bad RAM.\n"); #ifdef CONFIG_X86 pr_err("Run memtest86+ or a similar memory test tool.\n"); #else pr_err("Run a memory test tool.\n"); #endif } } }

Contributors

PersonTokensPropCommitsCommitProp
Dave Jones8154.36%114.29%
Andrew Morton4530.20%342.86%
Sebastian Andrzej Siewior1711.41%114.29%
Joe Perches64.03%228.57%
Total149100.00%7100.00%

#endif #if DEBUG
static void print_objinfo(struct kmem_cache *cachep, void *objp, int lines) { int i, size; char *realobj; if (cachep->flags & SLAB_RED_ZONE) { pr_err("Redzone: 0x%llx/0x%llx\n", *dbg_redzone1(cachep, objp), *dbg_redzone2(cachep, objp)); } if (cachep->flags & SLAB_STORE_USER) pr_err("Last user: (%pSR)\n", *dbg_userword(cachep, objp)); realobj = (char *)objp + obj_offset(cachep); size = cachep->object_size; for (i = 0; i < size && lines; i += 16, lines--) { int limit; limit = 16; if (i + limit > size) limit = size - i; dump_line(realobj, i, limit); } }

Contributors

PersonTokensPropCommitsCommitProp
Andrew Morton14093.96%228.57%
Joe Perches32.01%114.29%
Christoph Lameter21.34%114.29%
Pekka J Enberg21.34%114.29%
Geert Uytterhoeven10.67%114.29%
Manfred Spraul10.67%114.29%
Total149100.00%7100.00%


static void check_poison_obj(struct kmem_cache *cachep, void *objp) { char *realobj; int size, i; int lines = 0; if (is_debug_pagealloc_cache(cachep)) return; realobj = (char *)objp + obj_offset(cachep); size = cachep->object_size; for (i = 0; i < size; i++) { char exp = POISON_FREE; if (i == size - 1) exp = POISON_END; if (realobj[i] != exp) { int limit; /* Mismatch ! */ /* Print header */ if (lines == 0) { pr_err("Slab corruption (%s): %s start=%px, len=%d\n", print_tainted(), cachep->name, realobj, size); print_objinfo(cachep, objp, 0); } /* Hexdump the affected line */ i = (i / 16) * 16; limit = 16; if (i + limit > size) limit = size - i; dump_line(realobj, i, limit); i += 16; lines++; /* Limit to 5 lines */ if (lines > 5) break; } } if (lines != 0) { /* Print some data about the neighboring objects, if they * exist: */ struct page *page = virt_to_head_page(objp); unsigned int objnr; objnr = obj_to_index(cachep, page, objp); if (objnr) { objp = index_to_obj(cachep, page, objnr - 1); realobj = (char *)objp + obj_offset(cachep); pr_err("Prev obj: start=%px, len=%d\n", realobj, size); print_objinfo(cachep, objp, 2); } if (objnr + 1 < cachep->num) { objp = index_to_obj(cachep, page, objnr + 1); realobj = (char *)objp + obj_offset(cachep); pr_err("Next obj: start=%px, len=%d\n", realobj, size); print_objinfo(cachep, objp, 2); } } }

Contributors

PersonTokensPropCommitsCommitProp
Andrew Morton25878.18%836.36%
Pekka J Enberg206.06%29.09%
Linus Torvalds (pre-git)185.45%313.64%
JoonSoo Kim144.24%29.09%
David Howells41.21%14.55%
Dave Jones30.91%14.55%
Joe Perches30.91%14.55%
Geert Uytterhoeven30.91%14.55%
Manfred Spraul30.91%14.55%
Christoph Lameter20.61%14.55%
Benjamin LaHaise20.61%14.55%
Total330100.00%22100.00%

#endif #if DEBUG
static void slab_destroy_debugcheck(struct kmem_cache *cachep, struct page *page) { int i; if (OBJFREELIST_SLAB(cachep) && cachep->flags & SLAB_POISON) { poison_obj(cachep, page->freelist - obj_offset(cachep), POISON_FREE); } for (i = 0; i < cachep->num; i++) { void *objp = index_to_obj(cachep, page, i); if (cachep->flags & SLAB_POISON) { check_poison_obj(cachep, objp); slab_kernel_map(cachep, objp, 1, 0); } if (cachep->flags & SLAB_RED_ZONE) { if (*dbg_redzone1(cachep, objp) != RED_INACTIVE) slab_error(cachep, "start of a freed object was overwritten"); if (*dbg_redzone2(cachep, objp) != RED_INACTIVE) slab_error(cachep, "end of a freed object was overwritten"); } } }

Contributors

PersonTokensPropCommitsCommitProp
Linus Torvalds (pre-git)5736.54%317.65%
Andrew Morton4931.41%635.29%
JoonSoo Kim3925.00%317.65%
Pekka J Enberg74.49%211.76%
Joe Perches21.28%15.88%
Rabin Vincent10.64%15.88%
Matthew Dobson10.64%15.88%
Total156100.00%17100.00%

#else
static void slab_destroy_debugcheck(struct kmem_cache *cachep, struct page *page) { }

Contributors

PersonTokensPropCommitsCommitProp
Matthew Dobson960.00%120.00%
Pekka J Enberg213.33%120.00%
JoonSoo Kim213.33%120.00%
Rabin Vincent16.67%120.00%
Christoph Lameter16.67%120.00%
Total15100.00%5100.00%

#endif /** * slab_destroy - destroy and release all objects in a slab * @cachep: cache pointer being destroyed * @page: page pointer being destroyed * * Destroy all the objs in a slab page, and release the mem back to the system. * Before calling the slab page must have been unlinked from the cache. The * kmem_cache_node ->list_lock is not held/needed. */
static void slab_destroy(struct kmem_cache *cachep, struct page *page) { void *freelist; freelist = page->freelist; slab_destroy_debugcheck(cachep, page); if (unlikely(cachep->flags & SLAB_TYPESAFE_BY_RCU)) call_rcu(&page->rcu_head, kmem_rcu_free); else kmem_freepages(cachep, page); /* * From now on, we don't use freelist * although actual page can be freed in rcu context */ if (OFF_SLAB(cachep)) kmem_cache_free(cachep->freelist_cache, freelist); }

Contributors

PersonTokensPropCommitsCommitProp
Matthew Dobson2025.32%17.69%
Linus Torvalds (pre-git)1924.05%323.08%
Hugh Dickins1721.52%17.69%
JoonSoo Kim1620.25%323.08%
Pekka J Enberg22.53%17.69%
Kirill A. Shutemov22.53%17.69%
Ingo Molnar11.27%17.69%
Paul E. McKenney11.27%17.69%
Rabin Vincent11.27%17.69%
Total79100.00%13100.00%


static void slabs_destroy(struct kmem_cache *cachep, struct list_head *list) { struct page *page, *n; list_for_each_entry_safe(page, n, list, lru) { list_del(&page->lru); slab_destroy(cachep, page); } }

Contributors

PersonTokensPropCommitsCommitProp
JoonSoo Kim51100.00%1100.00%
Total51100.00%1100.00%

/** * calculate_slab_order - calculate size (page order) of slabs * @cachep: pointer to the cache that is being created * @size: size of objects to be created in this cache. * @flags: slab allocation flags * * Also calculates the number of objects per slab. * * This could be made much more intelligent. For now, try to avoid using * high order pages for slabs. When the gfp() functions are more friendly * towards high-order requests, this should be changed. */
static size_t calculate_slab_order(struct kmem_cache *cachep, size_t size, slab_flags_t flags) { size_t left_over = 0; int gfporder; for (gfporder = 0; gfporder <= KMALLOC_MAX_ORDER; gfporder++) { unsigned int num; size_t remainder; num = cache_estimate(gfporder, size, flags, &remainder); if (!num) continue; /* Can't handle number of objects more than SLAB_OBJ_MAX_NUM */ if (num > SLAB_OBJ_MAX_NUM) break; if (flags & CFLGS_OFF_SLAB) { struct kmem_cache *freelist_cache; size_t freelist_size; freelist_size = num * sizeof(freelist_idx_t); freelist_cache = kmalloc_slab(freelist_size, 0u); if (!freelist_cache) continue; /* * Needed to avoid possible looping condition * in cache_grow_begin() */ if (OFF_SLAB(freelist_cache)) continue; /* check if off slab has enough benefit */ if (freelist_cache->size > cachep->size / 2) continue; } /* Found something acceptable - save it away */ cachep->num = num; cachep->gfporder = gfporder; left_over = remainder; /* * A VFS-reclaimable slab tends to have most allocations * as GFP_NOFS and we really don't want to have to be allocating * higher-order pages when we are unable to shrink dcache. */ if (flags & SLAB_RECLAIM_ACCOUNT) break; /* * Large number of objects is good, but very large slabs are * currently bad for the gfp()s. */ if (gfporder >= slab_max_order) break; /* * Acceptable internal fragmentation? */ if (left_over * 8 <= (PAGE_SIZE << gfporder)) break; } return left_over; }

Contributors

PersonTokensPropCommitsCommitProp
Pekka J Enberg9550.53%215.38%
JoonSoo Kim5931.38%538.46%
Linus Torvalds2412.77%215.38%
Ingo Molnar73.72%17.69%
David Rientjes10.53%17.69%
Christoph Lameter10.53%17.69%
Alexey Dobriyan10.53%17.69%
Total188100.00%13100.00%


static struct array_cache __percpu *alloc_kmem_cache_cpus( struct kmem_cache *cachep, int entries, int batchcount) { int cpu; size_t size; struct array_cache __percpu *cpu_cache; size = sizeof(void *) * entries + sizeof(struct array_cache); cpu_cache = __alloc_percpu(size, sizeof(void *)); if (!cpu_cache) return NULL; for_each_possible_cpu(cpu) { init_arraycache(per_cpu_ptr(cpu_cache, cpu), entries, batchcount); } return cpu_cache; }

Contributors

PersonTokensPropCommitsCommitProp
JoonSoo Kim92100.00%2100.00%
Total92100.00%2100.00%


static int __ref setup_cpu_cache(struct kmem_cache *cachep, gfp_t gfp) { if (slab_state >= FULL) return enable_cpucache(cachep, gfp); cachep->cpu_cache = alloc_kmem_cache_cpus(cachep, 1, 1); if (!cachep->cpu_cache) return 1; if (slab_state == DOWN) { /* Creation of first cache (kmem_cache). */ set_up_node(kmem_cache, CACHE_CACHE); } else if (slab_state == PARTIAL) { /* For kmem_cache_node */ set_up_node(cachep, SIZE_NODE); } else { int node; for_each_online_node(node) { cachep->node[node] = kmalloc_node( sizeof(struct kmem_cache_node), gfp, node); BUG_ON(!cachep->node[node]); kmem_cache_node_init(cachep->node[node]); } } cachep->node[numa_mem_id()]->next_reap = jiffies + REAPTIMEOUT_NODE + ((unsigned long)cachep) % REAPTIMEOUT_NODE; cpu_cache_get(cachep)->avail = 0; cpu_cache_get(cachep)->limit = BOOT_CPUCACHE_ENTRIES; cpu_cache_get(cachep)->batchcount = 1; cpu_cache_get(cachep)->touched = 0; cachep->batchcount = 1; cachep->limit = BOOT_CPUCACHE_ENTRIES; return 0; }

Contributors

PersonTokensPropCommitsCommitProp
Pekka J Enberg16276.06%426.67%
JoonSoo Kim2612.21%16.67%
Christoph Lameter209.39%640.00%
Jianyu Zhan20.94%16.67%
Lee Schermerhorn10.47%16.67%
Fabian Frederick10.47%16.67%
Glauber de Oliveira Costa10.47%16.67%
Total213100.00%15100.00%


slab_flags_t kmem_cache_flags(unsigned long object_size, slab_flags_t flags, const char *name, void (*ctor)(void *)) { return flags; }

Contributors

PersonTokensPropCommitsCommitProp
JoonSoo Kim2893.33%150.00%
Alexey Dobriyan26.67%150.00%
Total30100.00%2100.00%


struct kmem_cache * __kmem_cache_alias(const char *name, size_t size, size_t align, slab_flags_t flags, void (*ctor)(void *)) { struct kmem_cache *cachep; cachep = find_mergeable(size, align, flags, name, ctor); if (cachep) { cachep->refcount++; /* * Adjust the object sizes so that we clear * the complete object on kzalloc. */ cachep->object_size = max_t(int, cachep->object_size, size); } return cachep; }

Contributors

PersonTokensPropCommitsCommitProp
JoonSoo Kim8098.77%150.00%
Alexey Dobriyan11.23%150.00%
Total81100.00%2100.00%


static bool set_objfreelist_slab_cache(struct kmem_cache *cachep, size_t size, slab_flags_t flags) { size_t left; cachep->num = 0; if (cachep->ctor || flags & SLAB_TYPESAFE_BY_RCU) return false; left = calculate_slab_order(cachep, size, flags | CFLGS_OBJFREELIST_SLAB); if (!cachep->num) return false; if (cachep->num * sizeof(freelist_idx_t) > cachep->object_size) return false; cachep->colour = left / cachep->colour_off; return true; }

Contributors

PersonTokensPropCommitsCommitProp
JoonSoo Kim9197.85%133.33%
Alexey Dobriyan11.08%133.33%
Paul E. McKenney11.08%133.33%
Total93100.00%3100.00%


static bool set_off_slab_cache(struct kmem_cache *cachep, size_t size, slab_flags_t flags) { size_t left; cachep->num = 0; /* * Always use on-slab management when SLAB_NOLEAKTRACE * to avoid recursive calls into kmemleak. */ if (flags & SLAB_NOLEAKTRACE) return false; /* * Size is large, assume best to place the slab management obj * off-slab (should allow better packing of objs). */ left = calculate_slab_order(cachep, size, flags | CFLGS_OFF_SLAB); if (!cachep->num) return false; /* * If the slab has been placed off-slab, and we have enough space then * move it on-slab. This is at the expense of any extra colouring. */ if (left >= cachep->num * sizeof(freelist_idx_t)) return false; cachep->colour = left / cachep->colour_off; return true; }

Contributors

PersonTokensPropCommitsCommitProp
JoonSoo Kim8998.89%266.67%
Alexey Dobriyan11.11%133.33%
Total90100.00%3100.00%


static bool set_on_slab_cache(struct kmem_cache *cachep, size_t size, slab_flags_t flags) { size_t left; cachep->num = 0; left = calculate_slab_order(cachep, size, flags); if (!cachep->num) return false; cachep->colour = left / cachep->colour_off; return true; }

Contributors

PersonTokensPropCommitsCommitProp
JoonSoo Kim5998.33%150.00%
Alexey Dobriyan11.67%150.00%
Total60100.00%2100.00%

/** * __kmem_cache_create - Create a cache. * @cachep: cache management descriptor * @flags: SLAB flags * * Returns a ptr to the cache on success, NULL on failure. * Cannot be called within a int, but can be interrupted. * The @ctor is run when new pages are allocated by the cache. * * The flags are * * %SLAB_POISON - Poison the slab with a known test pattern (a5a5a5a5) * to catch references to uninitialised memory. * * %SLAB_RED_ZONE - Insert `Red' zones around the allocated memory to check * for buffer overruns. * * %SLAB_HWCACHE_ALIGN - Align the objects in this cache to a hardware * cacheline. This can be beneficial if you're counting cycles as closely * as davem. */
int __kmem_cache_create(struct kmem_cache *cachep, slab_flags_t flags) { size_t ralign = BYTES_PER_WORD; gfp_t gfp; int err; size_t size = cachep->size; #if DEBUG #if FORCED_DEBUG /* * Enable redzoning and last user accounting, except for caches with * large objects, if the increased size would increase the object size * above the next power of two: caches with object sizes just above a * power of two have a significant amount of internal fragmentation. */ if (size < 4096 || fls(size - 1) == fls(size-1 + REDZONE_ALIGN + 2 * sizeof(unsigned long long))) flags |= SLAB_RED_ZONE | SLAB_STORE_USER; if (!(flags & SLAB_TYPESAFE_BY_RCU)) flags |= SLAB_POISON; #endif #endif /* * Check that size is in terms of words. This is needed to avoid * unaligned accesses for some archs when redzoning is used, and makes * sure any on-slab bufctl's are also correctly aligned. */ size = ALIGN(size, BYTES_PER_WORD); if (flags & SLAB_RED_ZONE) { ralign = REDZONE_ALIGN; /* If redzoning, ensure that the second redzone is suitably * aligned, by adjusting the object size accordingly. */ size = ALIGN(size, REDZONE_ALIGN); } /* 3) caller mandated alignment */ if (ralign < cachep->align) { ralign = cachep->align; } /* disable debug if necessary */ if (ralign > __alignof__(unsigned long long)) flags &= ~(SLAB_RED_ZONE | SLAB_STORE_USER); /* * 4) Store it. */ cachep->align = ralign; cachep->colour_off = cache_line_size(); /* Offset must be a multiple of the alignment. */ if (cachep->colour_off < cachep->align) cachep->colour_off = cachep->align; if (slab_is_available()) gfp = GFP_KERNEL; else gfp = GFP_NOWAIT; #if DEBUG /* * Both debugging options require word-alignment which is calculated * into align above. */ if (flags & SLAB_RED_ZONE) { /* add space for red zone words */ cachep->obj_offset += sizeof(unsigned long long); size += 2 * sizeof(unsigned long long); } if (flags & SLAB_STORE_USER) { /* user store requires one word storage behind the end of * the real object. But if the second red zone needs to be * aligned to 64 bits, we must allow that much space. */ if (flags & SLAB_RED_ZONE) size += REDZONE_ALIGN; else size += BYTES_PER_WORD; } #endif kasan_cache_create(cachep, &size, &flags); size = ALIGN(size, cachep->align); /* * We should restrict the number of objects in a slab to implement * byte sized index. Refer comment on SLAB_OBJ_MIN_SIZE definition. */ if (FREELIST_BYTE_INDEX && size < SLAB_OBJ_MIN_SIZE) size = ALIGN(SLAB_OBJ_MIN_SIZE, cachep->align); #if DEBUG /* * To activate debug pagealloc, off-slab management is necessary * requirement. In early phase of initialization, small sized slab * doesn't get initialized so it would not be possible. So, we need * to check size >= 256. It guarantees that all necessary small * sized slab is initialized in current slab initialization sequence. */ if (debug_pagealloc_enabled() && (flags & SLAB_POISON) && size >= 256 && cachep->object_size > cache_line_size()) { if (size < PAGE_SIZE || size % PAGE_SIZE == 0) { size_t tmp_size = ALIGN(size, PAGE_SIZE); if (set_off_slab_cache(cachep, tmp_size, flags)) { flags |= CFLGS_OFF_SLAB; cachep->obj_offset += tmp_size - size; size = tmp_size; goto done; } } } #endif if (set_objfreelist_slab_cache(cachep, size, flags)) { flags |= CFLGS_OBJFREELIST_SLAB; goto done; } if (set_off_slab_cache(cachep, size, flags)) { flags |= CFLGS_OFF_SLAB; goto done; } if (set_on_slab_cache(cachep, size, flags)) goto done; return -E2BIG; done: cachep->freelist_size = cachep->num * sizeof(freelist_idx_t); cachep->flags = flags; cachep->allocflags = __GFP_COMP; if (flags & SLAB_CACHE_DMA) cachep->allocflags |= GFP_DMA; if (flags & SLAB_RECLAIM_ACCOUNT) cachep->allocflags |= __GFP_RECLAIMABLE; cachep->size = size; cachep->reciprocal_buffer_size = reciprocal_value(size); #if DEBUG /* * If we're going to use the generic kernel_map_pages() * poisoning, then it's going to smash the contents of * the redzone and userword anyhow, so switch them off. */ if (IS_ENABLED(CONFIG_PAGE_POISONING) && (cachep->flags & SLAB_POISON) && is_debug_pagealloc_cache(cachep)) cachep->flags &= ~(SLAB_RED_ZONE | SLAB_STORE_USER); #endif if (OFF_SLAB(cachep)) { cachep->freelist_cache = kmalloc_slab(cachep->freelist_size, 0u); } err = setup_cpu_cache(cachep, gfp); if (err) { __kmem_cache_release(cachep); return err; } return 0; }

Contributors

PersonTokensPropCommitsCommitProp
JoonSoo Kim20934.55%1121.57%
Linus Torvalds (pre-git)10918.02%47.84%
Andrew Morton6110.08%611.76%
Christoph Lameter477.77%713.73%
David Woodhouse426.94%23.92%
Pekka J Enberg386.28%47.84%
Manfred Spraul345.62%23.92%
David Rientjes142.31%23.92%
Alexander Potapenko111.82%11.96%
Canjiang Lu101.65%11.96%
Eric Dumazet91.49%11.96%
Hugh Dickins81.32%11.96%
Glauber de Oliveira Costa20.33%11.96%
Ravikiran G. Thirumalai20.33%11.96%
Kevin Hilman20.33%11.96%
Alexey Dobriyan20.33%11.96%
Paul E. McKenney10.17%11.96%
Dmitry Safonov10.17%11.96%
Catalin Marinas10.17%11.96%
Victor Fusco10.17%11.96%
Andi Kleen10.17%11.96%
Total605100.00%51100.00%

#if DEBUG
static void check_irq_off(void) { BUG_ON(!irqs_disabled()); }

Contributors

PersonTokensPropCommitsCommitProp
Andrew Morton15100.00%1100.00%
Total15100.00%1100.00%


static void check_irq_on(void) { BUG_ON(irqs_disabled()); }

Contributors

PersonTokensPropCommitsCommitProp
Andrew Morton14100.00%1100.00%
Total14100.00%1100.00%


static void check_mutex_acquired(void) { BUG_ON(!mutex_is_locked(&slab_mutex)); }

Contributors

PersonTokensPropCommitsCommitProp
JoonSoo Kim18100.00%1100.00%
Total18100.00%1100.00%


static void check_spinlock_acquired(struct kmem_cache *cachep) { #ifdef CONFIG_SMP check_irq_off(); assert_spin_locked(&get_node(cachep, numa_mem_id())->list_lock); #endif }

Contributors

PersonTokensPropCommitsCommitProp
Christoph Lameter1236.36%233.33%
Andrew Morton927.27%116.67%
Linus Torvalds927.27%116.67%
Pekka J Enberg26.06%116.67%
Lee Schermerhorn13.03%116.67%
Total33100.00%6100.00%


static void check_spinlock_acquired_node(struct kmem_cache *cachep, int node) { #ifdef CONFIG_SMP check_irq_off(); assert_spin_locked(&get_node(cachep, node)->list_lock); #endif }

Contributors

PersonTokensPropCommitsCommitProp
Christoph Lameter2880.00%240.00%
Linus Torvalds411.43%120.00%
Pekka J Enberg25.71%120.00%
Andrew Morton12.86%120.00%
Total35100.00%5100.00%

#else #define check_irq_off() do { } while(0) #define check_irq_on() do { } while(0) #define check_mutex_acquired() do { } while(0) #define check_spinlock_acquired(x) do { } while(0) #define check_spinlock_acquired_node(x, y) do { } while(0) #endif
static void drain_array_locked(struct kmem_cache *cachep, struct array_cache *ac, int node, bool free_all, struct list_head *list) { int tofree; if (!ac || !ac->avail) return; tofree = free_all ? ac->avail : (ac->limit + 4) / 5; if (tofree > ac->avail) tofree = (ac->avail + 1) / 2; free_block(cachep, ac->entry, tofree, node, list); ac->avail -= tofree; memmove(ac->entry, &(ac->entry[tofree]), sizeof(void *) * ac->avail); }

Contributors

PersonTokensPropCommitsCommitProp
JoonSoo Kim11086.61%133.33%
Christoph Lameter1511.81%133.33%
Linus Torvalds (pre-git)21.57%133.33%
Total127100.00%3100.00%


static void do_drain(void *arg) { struct kmem_cache *cachep = arg; struct array_cache *ac; int node = numa_mem_id(); struct kmem_cache_node *n; LIST_HEAD(list); check_irq_off(); ac = cpu_cache_get(cachep); n = get_node(cachep, node); spin_lock(&n->list_lock); free_block(cachep, ac->entry, ac->avail, node, &list); spin_unlock(&n->list_lock); slabs_destroy(cachep, &list); ac->avail = 0; }

Contributors

PersonTokensPropCommitsCommitProp
Andrew Morton3028.57%426.67%
Christoph Lameter3028.57%320.00%
Linus Torvalds (pre-git)2523.81%426.67%
JoonSoo Kim1615.24%16.67%
Pekka J Enberg32.86%213.33%
Lee Schermerhorn10.95%16.67%
Total105100.00%15100.00%


static void drain_cpu_caches(struct kmem_cache *cachep) { struct kmem_cache_node *n; int node; LIST_HEAD(list); on_each_cpu(do_drain, cachep, 1); check_irq_on(); for_each_kmem_cache_node(cachep, node, n) if (n->alien) drain_alien_cache(cachep, n->alien); for_each_kmem_cache_node(cachep, node, n) { spin_lock_irq(&n->list_lock); drain_array_locked(cachep, n->shared, node, true, &list); spin_unlock_irq(&n->list_lock); slabs_destroy(cachep, &list); } }

Contributors

PersonTokensPropCommitsCommitProp
Christoph Lameter4036.70%433.33%
JoonSoo Kim3733.94%18.33%
Roland Dreier1412.84%18.33%
Andrew Morton1412.84%325.00%
Pekka J Enberg21.83%18.33%
Ravikiran G. Thirumalai10.92%18.33%
Linus Torvalds (pre-git)10.92%18.33%
Total109100.00%12100.00%

/* * Remove slabs from the list of free slabs. * Specify the number of slabs to drain in tofree. * * Returns the actual number of slabs released. */
static int drain_freelist(struct kmem_cache *cache, struct kmem_cache_node *n, int tofree) { struct list_head *p; int nr_freed; struct page *page; nr_freed = 0; while (nr_freed < tofree && !list_empty(&n->slabs_free)) { spin_lock_irq(&n->list_lock); p = n->slabs_free.prev; if (p == &n->slabs_free) { spin_unlock_irq(&n->list_lock); goto out; } page = list_entry(p, struct page, lru); list_del(&page->lru); n->free_slabs--; n->total_slabs--; /* * Safe to drop the lock. The slab is no longer linked * to the cache. */ n->free_objects -= cache->num; spin_unlock_irq(&n->list_lock); slab_destroy(cache, page); nr_freed++; } out: return nr_freed; }

Contributors

PersonTokensPropCommitsCommitProp
Christoph Lameter7448.37%423.53%
Linus Torvalds (pre-git)4932.03%423.53%
JoonSoo Kim85.23%15.88%
Andrew Morton85.23%317.65%
David Rientjes53.27%15.88%
Aruna Ramakrishna42.61%15.88%
Linus Torvalds21.31%15.88%
Pekka J Enberg21.31%15.88%
Greg Thelen10.65%15.88%
Total153100.00%17100.00%


int __kmem_cache_shrink(struct kmem_cache *cachep) { int ret = 0; int node; struct kmem_cache_node *n; drain_cpu_caches(cachep); check_irq_on(); for_each_kmem_cache_node(cachep, node, n) { drain_freelist(cachep, n, INT_MAX); ret += !list_empty(&n->slabs_full) || !list_empty(&n->slabs_partial); } return (ret ? 1 : 0); }

Contributors

PersonTokensPropCommitsCommitProp
Christoph Lameter6784.81%550.00%
Linus Torvalds (pre-git)810.13%220.00%
Pekka J Enberg22.53%110.00%
Vladimir Davydov11.27%110.00%
JoonSoo Kim11.27%110.00%
Total79100.00%10100.00%

#ifdef CONFIG_MEMCG
void __kmemcg_cache_deactivate(struct kmem_cache *cachep) { __kmem_cache_shrink(cachep); }

Contributors

PersonTokensPropCommitsCommitProp
Tejun Heo15100.00%1100.00%
Total15100.00%1100.00%

#endif
int __kmem_cache_shutdown(struct kmem_cache *cachep) { return __kmem_cache_shrink(cachep); }

Contributors

PersonTokensPropCommitsCommitProp
Dmitry Safonov743.75%125.00%
Linus Torvalds (pre-git)531.25%125.00%
Pekka J Enberg212.50%125.00%
Christoph Lameter212.50%125.00%
Total16100.00%4100.00%


void __kmem_cache_release(struct kmem_cache *cachep) { int i; struct kmem_cache_node *n; cache_random_seq_destroy(cachep); free_percpu(cachep->cpu_cache); /* NUMA: free the node structures */ for_each_kmem_cache_node(cachep, i, n) { kfree(n->shared); free_alien_cache(n->alien); kfree(n); cachep->node[i] = NULL; } }

Contributors

PersonTokensPropCommitsCommitProp
Christoph Lameter3550.72%430.77%
Linus Torvalds (pre-git)1014.49%215.38%
Dmitry Safonov913.04%17.69%
Thomas Garnier57.25%17.69%
Hugh Dickins45.80%17.69%
Andrew Morton22.90%215.38%
Ravikiran G. Thirumalai22.90%17.69%
JoonSoo Kim22.90%17.69%
Total69100.00%13100.00%

/* * Get the memory for a slab management obj. * * For a slab cache when the slab descriptor is off-slab, the * slab descriptor can't come from the same cache which is being created, * Because if it is the case, that means we defer the creation of * the kmalloc_{dma,}_cache of size sizeof(slab descriptor) to this point. * And we eventually call down to __kmem_cache_create(), which * in turn looks up in the kmalloc_{dma,}_caches for the disired-size one. * This is a "chicken-and-egg" problem. * * So the off-slab slab descriptor shall come from the kmalloc_{dma,}_caches, * which are all initialized during kmem_cache_init(). */
static void *alloc_slabmgmt(struct kmem_cache *cachep, struct page *page, int colour_off, gfp_t local_flags, int nodeid) { void *freelist; void *addr = page_address(page); page->s_mem = addr + colour_off; page->active = 0; if (OBJFREELIST_SLAB(cachep)) freelist = NULL; else if (OFF_SLAB(cachep)) { /* Slab management obj is off-slab. */ freelist = kmem_cache_alloc_node(cachep->freelist_cache, local_flags, nodeid); if (!freelist) return NULL; } else { /* We will use last bytes at the slab for freelist */ freelist = addr + (PAGE_SIZE << cachep->gfporder) - cachep->freelist_size; } return freelist; }

Contributors

PersonTokensPropCommitsCommitProp
JoonSoo Kim5747.90%538.46%
Linus Torvalds (pre-git)5243.70%430.77%
Ravikiran G. Thirumalai65.04%17.69%
Pekka J Enberg21.68%17.69%
Andrew Morton10.84%17.69%
Al Viro10.84%17.69%
Total119100.00%13100.00%


static inline freelist_idx_t get_free_obj(struct page *page, unsigned int idx) { return ((freelist_idx_t *)page->freelist)[idx]; }

Contributors

PersonTokensPropCommitsCommitProp
JoonSoo Kim1653.33%466.67%
Andrew Morton1240.00%116.67%
Linus Torvalds (pre-git)26.67%116.67%
Total30100.00%6100.00%


static inline void set_free_obj(struct page *page, unsigned int idx, freelist_idx_t val) { ((freelist_idx_t *)(page->freelist))[idx] = val; }

Contributors

PersonTokensPropCommitsCommitProp
JoonSoo Kim3186.11%583.33%
Andrew Morton513.89%116.67%
Total36100.00%6100.00%


static void cache_init_objs_debug(struct kmem_cache *cachep, struct page *page) { #if DEBUG int i; for (i = 0; i < cachep->num; i++) { void *objp = index_to_obj(cachep, page, i); if (cachep->flags & SLAB_STORE_USER) *dbg_userword(cachep, objp) = NULL; if (cachep->flags & SLAB_RED_ZONE) { *dbg_redzone1(cachep, objp) = RED_INACTIVE; *dbg_redzone2(cachep, objp) = RED_INACTIVE; } /* * Constructors are not allowed to allocate memory from the same * cache which they are a constructor for. Otherwise, deadlock. * They must also be threaded. */ if (cachep->ctor && !(cachep->flags & SLAB_POISON)) { kasan_unpoison_object_data(cachep, objp + obj_offset(cachep)); cachep->ctor(objp + obj_offset(cachep)); kasan_poison_object_data( cachep, objp + obj_offset(cachep)); } if (cachep->flags & SLAB_RED_ZONE) { if (*dbg_redzone2(cachep, objp) != RED_INACTIVE) slab_error(cachep, "constructor overwrote the end of an object"); if (*dbg_redzone1(cachep, objp) != RED_INACTIVE) slab_error(cachep, "constructor overwrote the start of an object"); } /* need to poison the objs? */ if (cachep->flags & SLAB_POISON) { poison_obj(cachep, objp, POISON_FREE); slab_kernel_map(cachep, objp, 0, 0); } } #endif }

Contributors

PersonTokensPropCommitsCommitProp
Thomas Garnier18377.87%111.11%
Linus Torvalds (pre-git)3615.32%333.33%
Pekka J Enberg72.98%222.22%
JoonSoo Kim72.98%222.22%
Andrew Morton20.85%111.11%
Total235100.00%9100.00%

#ifdef CONFIG_SLAB_FREELIST_RANDOM /* Hold information during a freelist initialization */ union freelist_init_state { struct { unsigned int pos; unsigned int *list; unsigned int count; }; struct rnd_state rnd_state; }; /* * Initialize the state based on the randomization methode available. * return true if the pre-computed list is available, false otherwize. */
static bool freelist_state_initialize(union freelist_init_state *state, struct kmem_cache *cachep, unsigned int count) { bool ret; unsigned int rand; /* Use best entropy available to define a random shift */ rand = get_random_int(); /* Use a random state if the pre-computed list is not available */ if (!cachep->random_seq) { prandom_seed_state(&state->rnd_state, rand); ret = false; } else { state->list = cachep->random_seq; state->count = count; state->pos = rand % count; ret = true; } return ret; }

Contributors

PersonTokensPropCommitsCommitProp
Thomas Garnier8797.75%266.67%
John Sperbeck22.25%133.33%
Total89100.00%3100.00%

/* Get the next entry on the list and randomize it using a random shift */
static freelist_idx_t next_random_slot(union freelist_init_state *state) { if (state->pos >= state->count) state->pos = 0; return state->list[state->pos++]; }

Contributors

PersonTokensPropCommitsCommitProp
Thomas Garnier2257.89%150.00%
John Sperbeck1642.11%150.00%
Total38100.00%2100.00%

/* Swap two freelist entries */
static void swap_free_obj(struct page *page, unsigned int a, unsigned int b) { swap(((freelist_idx_t *)page->freelist)[a], ((freelist_idx_t *)page->freelist)[b]); }

Contributors

PersonTokensPropCommitsCommitProp
Thomas Garnier48100.00%1100.00%
Total48100.00%1100.00%

/* * Shuffle the freelist initialization state based on pre-computed lists. * return true if the list was successfully shuffled, false otherwise. */
static bool shuffle_freelist(struct kmem_cache *cachep, struct page *page) { unsigned int objfreelist = 0, i, rand, count = cachep->num; union freelist_init_state state; bool precomputed; if (count < 2) return false; precomputed = freelist_state_initialize(&state, cachep, count); /* Take a random entry as the objfreelist */ if (OBJFREELIST_SLAB(cachep)) { if (!precomputed) objfreelist = count - 1; else objfreelist = next_random_slot(&state); page->freelist = index_to_obj(cachep, page, objfreelist) + obj_offset(cachep); count--; } /* * On early boot, generate the list dynamically. * Later use a pre-computed list for speed. */ if (!precomputed) { for (i = 0; i < count; i++) set_free_obj(page, i, i); /* Fisher-Yates shuffle */ for (i = count - 1; i > 0; i--) { rand = prandom_u32_state(&state.rnd_state); rand %= (i + 1); swap_free_obj(page, i, rand); } } else { for (i = 0; i < count; i++) set_free_obj(page, i, next_random_slot(&state)); } if (OBJFREELIST_SLAB(cachep)) set_free_obj(page, cachep->num - 1, objfreelist); return true; }

Contributors

PersonTokensPropCommitsCommitProp
Thomas Garnier18477.31%216.67%
Andrew Morton2510.50%541.67%
Linus Torvalds (pre-git)135.46%325.00%
Alexander Potapenko114.62%18.33%
JoonSoo Kim52.10%18.33%
Total238100.00%12100.00%

#else
static inline bool shuffle_freelist(struct kmem_cache *cachep, struct page *page) { return false; }

Contributors

PersonTokensPropCommitsCommitProp
Thomas Garnier1995.00%150.00%
JoonSoo Kim15.00%150.00%
Total20100.00%2100.00%

#endif /* CONFIG_SLAB_FREELIST_RANDOM */
static void cache_init_objs(struct kmem_cache *cachep, struct page *page) { int i; void *objp; bool shuffled; cache_init_objs_debug(cachep, page); /* Try to randomize the freelist if enabled */ shuffled = shuffle_freelist(cachep, page); if (!shuffled && OBJFREELIST_SLAB(cachep)) { page->freelist = index_to_obj(cachep, page, cachep->num - 1) + obj_offset(cachep); } for (i = 0; i < cachep->num; i++) { objp = index_to_obj(cachep, page, i); kasan_init_slab_obj(cachep, objp); /* constructor could break poison info */ if (DEBUG == 0 && cachep->ctor) { kasan_unpoison_object_data(cachep, objp); cachep->ctor(objp); kasan_poison_object_data(cachep, objp); } if (!shuffled) set_free_obj(page, i, i); } }

Contributors

PersonTokensPropCommitsCommitProp
JoonSoo Kim8251.25%436.36%
Alexander Potapenko2515.62%19.09%
Thomas Garnier2113.12%19.09%
Andrey Ryabinin1811.25%19.09%
Andrew Morton85.00%19.09%
Linus Torvalds (pre-git)63.75%327.27%
Total160100.00%11100.00%


static void *slab_get_obj(struct kmem_cache *cachep, struct page *page) { void *objp; objp = index_to_obj(cachep, page, get_free_obj(page, page->active)); page->active++; #if DEBUG if (cachep->flags & SLAB_STORE_USER) set_store_user_dirty(cachep); #endif return objp; }

Contributors

PersonTokensPropCommitsCommitProp
JoonSoo Kim3350.77%562.50%
Matthew Dobson2538.46%112.50%
Pekka J Enberg710.77%225.00%
Total65100.00%8100.00%


static void slab_put_obj(struct kmem_cache *cachep, struct page *page, void *objp) { unsigned int objnr = obj_to_index(cachep, page, objp); #if DEBUG unsigned int i; /* Verify double free bug */ for (i = page->active; i < cachep->num; i++) { if (get_free_obj(page, i) == objnr) { pr_err("slab: double free detected in cache '%s', objp %px\n", cachep->name, objp); BUG(); } } #endif page->active--; if (!page->freelist) page->freelist = objp + obj_offset(cachep); set_free_obj(page, page->active, objnr); }

Contributors

PersonTokensPropCommitsCommitProp
JoonSoo Kim6452.03%654.55%
Matthew Dobson5040.65%19.09%
Pekka J Enberg75.69%218.18%
Geert Uytterhoeven10.81%19.09%
Joe Perches10.81%19.09%
Total123100.00%11100.00%

/* * Map pages beginning at addr to the given cache and slab. This is required * for the slab allocator to be able to lookup the cache and slab of a * virtual address for kfree, ksize, and slab debugging. */
static void slab_map_pages(struct kmem_cache *cache, struct page *page, void *freelist) { page->slab_cache = cache; page->freelist = freelist; }

Contributors

PersonTokensPropCommitsCommitProp
Andrew Morton1753.12%342.86%
JoonSoo Kim515.62%114.29%
Christoph Lameter515.62%114.29%
Pekka J Enberg515.62%228.57%
Total32100.00%7100.00%

/* * Grow (by 1) the number of slabs within a cache. This is called by * kmem_cache_alloc() when there are no active objs left in a cache. */
static struct page *cache_grow_begin(struct kmem_cache *cachep, gfp_t flags, int nodeid) { void *freelist; size_t offset; gfp_t local_flags; int page_node; struct kmem_cache_node *n; struct page *page; /* * Be lazy and only check for valid flags here, keeping it out of the * critical path in kmem_cache_alloc(). */ if (unlikely(flags & GFP_SLAB_BUG_MASK)) { gfp_t invalid_mask = flags & GFP_SLAB_BUG_MASK; flags &= ~GFP_SLAB_BUG_MASK; pr_warn("Unexpected gfp: %#x (%pGg). Fixing up to gfp: %#x (%pGg). Fix your code!\n", invalid_mask, &invalid_mask, flags, &flags); dump_stack(); } local_flags = flags & (GFP_CONSTRAINT_MASK|GFP_RECLAIM_MASK); check_irq_off(); if (gfpflags_allow_blocking(local_flags)) local_irq_enable(); /* * Get mem for the objs. Attempt to allocate a physical page from * 'nodeid'. */ page = kmem_getpages(cachep, local_flags, nodeid); if (!page) goto failed; page_node = page_to_nid(page); n = get_node(cachep, page_node); /* Get colour for the slab, and cal the next value. */ n->colour_next++; if (n->colour_next >= cachep->colour) n->colour_next = 0; offset = n->colour_next; if (offset >= cachep->colour) offset = 0; offset *= cachep->colour_off; /* Get slab management. */ freelist = alloc_slabmgmt(cachep, page, offset, local_flags & ~GFP_CONSTRAINT_MASK, page_node); if (OFF_SLAB(cachep) && !freelist) goto opps1; slab_map_pages(cachep, page, freelist); kasan_poison_slab(page); cache_init_objs(cachep, page); if (gfpflags_allow_blocking(local_flags)) local_irq_disable(); return page; opps1: kmem_freepages(cachep, page); failed: if (gfpflags_allow_blocking(local_flags)) local_irq_disable(); return NULL; }

Contributors

PersonTokensPropCommitsCommitProp
JoonSoo Kim11842.29%721.21%
Andrew Morton5519.71%618.18%
Linus Torvalds (pre-git)4817.20%412.12%
Michal Hocko238.24%26.06%
Christoph Lameter124.30%515.15%
Mel Gorman62.15%13.03%
Alexander Potapenko51.79%13.03%
Manfred Spraul41.43%13.03%
Pekka J Enberg31.08%26.06%
Eric Sesterhenn / Snakebyte20.72%13.03%
Al Viro20.72%26.06%
Ravikiran G. Thirumalai10.36%13.03%
Total279100.00%33100.00%


static void cache_grow_end(struct kmem_cache *cachep, struct page *page) { struct kmem_cache_node *n; void *list = NULL; check_irq_off(); if (!page) return; INIT_LIST_HEAD(&page->lru); n = get_node(cachep, page_to_nid(page)); spin_lock(&n->list_lock); n->total_slabs++; if (!page->active) { list_add_tail(&page->lru, &(n->slabs_free)); n->free_slabs++; } else fixup_slab_list(cachep, n, page, &list); STATS_INC_GROWN(cachep); n->free_objects += cachep->num - page->active; spin_unlock(&n->list_lock); fixup_objfreelist_debug(cachep, &list); }

Contributors

PersonTokensPropCommitsCommitProp
JoonSoo Kim8156.25%214.29%
Linus Torvalds (pre-git)2819.44%321.43%
Andrew Morton1510.42%321.43%
Greg Thelen74.86%17.14%
Christoph Lameter64.17%214.29%
David Rientjes53.47%17.14%
Mel Gorman10.69%17.14%
Linus Torvalds10.69%17.14%
Total144100.00%14100.00%

#if DEBUG /* * Perform extra freeing checks: * - detect bad pointers. * - POISON/RED_ZONE checking */
static void kfree_debugcheck(const void *objp) { if (!virt_addr_valid(objp)) { pr_err("kfree_debugcheck: out of range ptr %lxh\n", (unsigned long)objp); BUG(); } }

Contributors

PersonTokensPropCommitsCommitProp
Andrew Morton1851.43%120.00%
Linus Torvalds (pre-git)1542.86%360.00%
Joe Perches25.71%120.00%
Total35100.00%5100.00%


static inline void verify_redzone_free(struct kmem_cache *cache, void *obj) { unsigned long long redzone1, redzone2; redzone1 = *dbg_redzone1(cache, obj); redzone2 = *dbg_redzone2(cache, obj); /* * Redzone is ok. */ if (redzone1 == RED_ACTIVE && redzone2 == RED_ACTIVE) return; if (redzone1 == RED_INACTIVE && redzone2 == RED_INACTIVE) slab_error(cache, "double free detected"); else slab_error(cache, "memory outside object was overwritten"); pr_err("%px: redzone 1:0x%llx, redzone 2:0x%llx\n", obj, redzone1, redzone2); }

Contributors

PersonTokensPropCommitsCommitProp
Pekka J Enberg8896.70%125.00%
David Woodhouse11.10%125.00%
Geert Uytterhoeven11.10%125.00%
Joe Perches11.10%125.00%
Total91100.00%4100.00%


static void *cache_free_debugcheck(struct kmem_cache *cachep, void *objp, unsigned long caller) { unsigned int objnr; struct page *page; BUG_ON(virt_to_cache(objp) != cachep); objp -= obj_offset(cachep); kfree_debugcheck(objp); page = virt_to_head_page(objp); if (cachep->flags & SLAB_RED_ZONE) { verify_redzone_free(cachep, objp); *dbg_redzone1(cachep, objp) = RED_INACTIVE; *dbg_redzone2(cachep, objp) = RED_INACTIVE; } if (cachep->flags & SLAB_STORE_USER) { set_store_user_dirty(cachep); *dbg_userword(cachep, objp) = (void *)caller; } objnr = obj_to_index(cachep, page, objp); BUG_ON(objnr >= cachep->num); BUG_ON(objp != index_to_obj(cachep, page, objnr)); if (cachep->flags & SLAB_POISON) { poison_obj(cachep, objp, POISON_FREE); slab_kernel_map(cachep, objp, 0, caller); } return objp; }

Contributors

PersonTokensPropCommitsCommitProp
Andrew Morton11258.64%939.13%
Linus Torvalds (pre-git)3015.71%313.04%
JoonSoo Kim157.85%313.04%
Pekka J Enberg147.33%313.04%
Matthew Wilcox105.24%14.35%
Ezequiel García63.14%14.35%
Benjamin LaHaise21.05%14.35%
Christoph Lameter10.52%14.35%
Manfred Spraul10.52%14.35%
Total191100.00%23100.00%

#else #define kfree_debugcheck(x) do { } while(0) #define cache_free_debugcheck(x,objp,z) (objp) #endif
static inline void fixup_objfreelist_debug(struct kmem_cache *cachep, void **list) { #if DEBUG void *next = *list; void *objp; while (next) { objp = next - obj_offset(cachep); next = *(void **)next; poison_obj(cachep, objp, POISON_FREE); } #endif }

Contributors

PersonTokensPropCommitsCommitProp
JoonSoo Kim67100.00%1100.00%
Total67100.00%1100.00%


static inline void fixup_slab_list(struct kmem_cache *cachep, struct kmem_cache_node *n, struct page *page, void **list) { /* move slabp to correct slabp list: */ list_del(&page->lru); if (page->active == cachep->num) { list_add(&page->lru, &n->slabs_full); if (OBJFREELIST_SLAB(cachep)) { #if DEBUG /* Poisoning will be done without holding the lock */ if (cachep->flags & SLAB_POISON) { void **objp = page->freelist; *objp = *list; *list = objp; } #endif page->freelist = NULL; } } else list_add(&page->lru, &n->slabs_partial); }

Contributors

PersonTokensPropCommitsCommitProp
JoonSoo Kim126100.00%2100.00%
Total126100.00%2100.00%

/* Try to find non-pfmemalloc slab if needed */ static noinline struct page *get_valid_first_slab(struct kmem_cache_node *n, struct page *page, bool pfmemalloc) { if (!page) return NULL; if (pfmemalloc) return page; if (!PageSlabPfmemalloc(page)) return page; /* No need to keep pfmemalloc slab if we have enough free objects */ if (n->free_objects > n->free_limit) { ClearPageSlabPfmemalloc(page); return page; } /* Move pfmemalloc slab to the end of list to speed up next search */ list_del(&page->lru); if (!page->active) { list_add_tail(&page->lru, &n->slabs_free); n->free_slabs++; } else list_add_tail(&page->lru, &n->slabs_partial); list_for_each_entry(page, &n->slabs_partial, lru) { if (!PageSlabPfmemalloc(page)) return page; } n->free_touched = 1; list_for_each_entry(page, &n->slabs_free, lru) { if (!PageSlabPfmemalloc(page)) { n->free_slabs--; return page; } } return NULL;
} static struct page *get_first_slab(struct kmem_cache_node *n, bool pfmemalloc) { struct page *page; assert_spin_locked(&n->list_lock); page = list_first_entry_or_null(&n->slabs_partial, struct page, lru); if (!page) { n->free_touched = 1; page = list_first_entry_or_null(&n->slabs_free, struct page, lru); if (page) n->free_slabs--; } if (sk_memalloc_socks()) page = get_valid_first_slab(n, page, pfmemalloc); return page; }

Contributors

PersonTokensPropCommitsCommitProp
JoonSoo Kim7777.00%125.00%
Greg Thelen1616.00%125.00%
David Rientjes44.00%125.00%
Geliang Tang33.00%125.00%
Total100100.00%4100.00%


static noinline void *cache_alloc_pfmemalloc(struct kmem_cache *cachep, struct kmem_cache_node *n, gfp_t flags) { struct page *page; void *obj; void *list = NULL; if (!gfp_pfmemalloc_allowed(flags)) return NULL; spin_lock(&n->list_lock); page = get_first_slab(n, true); if (!page) { spin_unlock(&n->list_lock); return NULL; } obj = slab_get_obj(cachep, page); n->free_objects--; fixup_slab_list(cachep, n, page, &list); spin_unlock(&n->list_lock); fixup_objfreelist_debug(cachep, &list); return obj; }

Contributors

PersonTokensPropCommitsCommitProp
JoonSoo Kim8667.72%150.00%
Geliang Tang4132.28%150.00%
Total127100.00%2100.00%

/* * Slab list should be fixed up by fixup_slab_list() for existing slab * or cache_grow_end() for new slab */
static __always_inline int alloc_block(struct kmem_cache *cachep, struct array_cache *ac, struct page *page, int batchcount) { /* * There must be at least one object available for * allocation. */ BUG_ON(page->active >= cachep->num); while (page->active < cachep->num && batchcount--) { STATS_INC_ALLOCED(cachep); STATS_INC_ACTIVE(cachep); STATS_SET_HIGH(cachep); ac->entry[ac->avail++] = slab_get_obj(cachep, page); } return batchcount; }

Contributors

PersonTokensPropCommitsCommitProp
JoonSoo Kim87100.00%1100.00%
Total87100.00%1100.00%


static void *cache_alloc_refill(struct kmem_cache *cachep, gfp_t flags) { int batchcount; struct kmem_cache_node *n; struct array_cache *ac, *shared; int node; void *list = NULL; struct page *page; check_irq_off(); node = numa_mem_id(); ac = cpu_cache_get(cachep); batchcount = ac->batchcount; if (!ac->touched && batchcount > BATCHREFILL_LIMIT) { /* * If there was little recent activity on this cache, then * perform only a partial refill. Otherwise we could generate * refill bouncing. */ batchcount = BATCHREFILL_LIMIT; } n = get_node(cachep, node); BUG_ON(ac->avail > 0 || !n); shared = READ_ONCE(n->shared); if (!n->free_objects && (!shared || !shared->avail)) goto direct_grow; spin_lock(&n->list_lock); shared = READ_ONCE(n->shared); /* See if we can refill from the shared array */ if (shared && transfer_objects(ac, shared, batchcount)) { shared->touched = 1; goto alloc_done; } while (batchcount > 0) { /* Get slab alloc is to come from. */ page = get_first_slab(n, false); if (!page) goto must_grow; check_spinlock_acquired(cachep); batchcount = alloc_block(cachep, ac, page, batchcount); fixup_slab_list(cachep, n, page, &list); } must_grow: n->free_objects -= ac->avail; alloc_done: spin_unlock(&n->list_lock); fixup_objfreelist_debug(cachep, &list); direct_grow: if (unlikely(!ac->avail)) { /* Check if we can use obj in pfmemalloc slab */ if (sk_memalloc_socks()) { void *obj = cache_alloc_pfmemalloc(cachep, n, flags); if (obj) return obj; } page = cache_grow_begin(cachep, gfp_exact_node(flags), node); /* * cache_grow_begin() can reenable interrupts, * then ac could change. */ ac = cpu_cache_get(cachep); if (!ac->avail && page) alloc_block(cachep, ac, page, batchcount); cache_grow_end(cachep, page); if (!ac->avail) return NULL; } ac->touched = 1; return ac->entry[--ac->avail]; }

Contributors

PersonTokensPropCommitsCommitProp
Andrew Morton14738.89%615.79%
JoonSoo Kim14037.04%821.05%
Christoph Lameter246.35%615.79%
Linus Torvalds133.44%37.89%
Pekka J Enberg133.44%37.89%
Geliang Tang112.91%25.26%
Linus Torvalds (pre-git)112.91%37.89%
Nicholas Piggin82.12%12.63%
Joe Korty30.79%12.63%
David Rientjes30.79%12.63%
Matthew Dobson20.53%12.63%
Al Viro10.26%12.63%
Lee Schermerhorn10.26%12.63%
Manfred Spraul10.26%12.63%
Total378100.00%38100.00%


static inline void cache_alloc_debugcheck_before(struct kmem_cache *cachep, gfp_t flags) { might_sleep_if(gfpflags_allow_blocking(flags)); }

Contributors

PersonTokensPropCommitsCommitProp
Andrew Morton1669.57%342.86%
Mel Gorman313.04%114.29%
Pekka J Enberg28.70%114.29%
Al Viro14.35%114.29%
Linus Torvalds14.35%114.29%
Total23100.00%7100.00%

#if DEBUG
static void *cache_alloc_debugcheck_after(struct kmem_cache *cachep, gfp_t flags, void *objp, unsigned long caller) { if (!objp) return objp; if (cachep->flags & SLAB_POISON) { check_poison_obj(cachep, objp); slab_kernel_map(cachep, objp, 1, 0); poison_obj(cachep, objp, POISON_INUSE); } if (cachep->flags & SLAB_STORE_USER) *dbg_userword(cachep, objp) = (void *)caller; if (cachep->flags & SLAB_RED_ZONE) { if (*dbg_redzone1(cachep, objp) != RED_INACTIVE || *dbg_redzone2(cachep, objp) != RED_INACTIVE) { slab_error(cachep, "double free, or memory outside object was overwritten"); pr_err("%px: redzone 1:0x%llx, redzone 2:0x%llx\n", objp, *dbg_redzone1(cachep, objp), *dbg_redzone2(cachep, objp)); } *dbg_redzone1(cachep, objp) = RED_ACTIVE; *dbg_redzone2(cachep, objp) = RED_ACTIVE; } objp += obj_offset(cachep); if (cachep->ctor && cachep->flags & SLAB_POISON) cachep->ctor(objp); if (ARCH_SLAB_MINALIGN && ((unsigned long)objp & (ARCH_SLAB_MINALIGN-1))) { pr_err("0x%px: not aligned to ARCH_SLAB_MINALIGN=%d\n", objp, (int)ARCH_SLAB_MINALIGN); } return objp; }

Contributors

PersonTokensPropCommitsCommitProp
Andrew Morton17072.34%733.33%
Kevin Hilman229.36%14.76%
Linus Torvalds (pre-git)145.96%29.52%
Ezequiel García62.55%14.76%
JoonSoo Kim52.13%14.76%
Hugh Dickins52.13%14.76%
Tetsuo Handa31.28%14.76%
Joe Perches31.28%29.52%
Pekka J Enberg20.85%14.76%
Geert Uytterhoeven20.85%14.76%
Manfred Spraul10.43%14.76%
Christoph Lameter10.43%14.76%
Al Viro10.43%14.76%
Total235100.00%21100.00%

#else #define cache_alloc_debugcheck_after(a,b,objp,d) (objp) #endif
static inline void *____cache_alloc(struct kmem_cache *cachep, gfp_t flags) { void *objp; struct array_cache *ac; check_irq_off(); ac = cpu_cache_get(cachep); if (likely(ac->avail)) { ac->touched = 1; objp = ac->entry[--ac->avail]; STATS_INC_ALLOCHIT(cachep); goto out; } STATS_INC_ALLOCMISS(cachep); objp = cache_alloc_refill(cachep, flags); /* * the 'ac' may be updated by cache_alloc_refill(), * and kmemleak_erase() requires its correct value. */ ac = cpu_cache_get(cachep); out: /* * To avoid a false negative, if an object that is in one of the * per-CPU caches is leaked, we need to make sure kmemleak doesn't * treat the array pointers as a reference to the object. */ if (objp) kmemleak_erase(&ac->entry[ac->avail]); return objp; }

Contributors

PersonTokensPropCommitsCommitProp
Christoph Lameter4135.04%17.14%
Linus Torvalds (pre-git)1512.82%214.29%
Catalin Marinas1411.97%17.14%
Mel Gorman1210.26%17.14%
Junjiro R. Okajima119.40%214.29%
JoonSoo Kim86.84%17.14%
Alok N Kataria75.98%17.14%
Andrew Morton54.27%214.29%
Pekka J Enberg32.56%214.29%
Al Viro10.85%17.14%
Total117100.00%14100.00%

#ifdef CONFIG_NUMA /* * Try allocating on another node if PFA_SPREAD_SLAB is a mempolicy is set. * * If we are in_interrupt, then process context, including cpusets and * mempolicy, may not apply and should not be used for allocation policy. */
static void *alternate_node_alloc(struct kmem_cache *cachep, gfp_t flags) { int nid_alloc, nid_here; if (in_interrupt() || (flags & __GFP_THISNODE)) return NULL; nid_alloc = nid_here = numa_mem_id(); if (cpuset_do_slab_mem_spread() && (cachep->flags & SLAB_MEM_SPREAD)) nid_alloc = cpuset_slab_spread_node(); else if (current->mempolicy) nid_alloc = mempolicy_slab_node(); if (nid_alloc != nid_here) return ____cache_alloc_node(cachep, flags, nid_alloc); return NULL; }

Contributors

PersonTokensPropCommitsCommitProp
Paul Jackson7987.78%114.29%
Christoph Lameter66.67%114.29%
David Rientjes11.11%114.29%
Lee Schermerhorn11.11%114.29%
Jack Steiner11.11%114.29%
Christoph Hellwig11.11%114.29%
Andi Kleen11.11%114.29%
Total90100.00%7100.00%

/* * Fallback function if there was no memory available and no objects on a * certain node and fall back is permitted. First we scan all the * available node for available objects. If that fails then we * perform an allocation without specifying a node. This allows the page * allocator to do its reclaim / fallback magic. We then insert the * slab into the proper nodelist and then allocate from it. */
static void *fallback_alloc(struct kmem_cache *cache, gfp_t flags) { struct zonelist *zonelist; struct zoneref *z; struct zone *zone; enum zone_type high_zoneidx = gfp_zone(flags); void *obj = NULL; struct page *page; int nid; unsigned int cpuset_mems_cookie; if (flags & __GFP_THISNODE) return NULL; retry_cpuset: cpuset_mems_cookie = read_mems_allowed_begin(); zonelist = node_zonelist(mempolicy_slab_node(), flags); retry: /* * Look through allowed nodes for objects available * from existing per node queues. */ for_each_zone_zonelist(zone, z, zonelist, high_zoneidx) { nid = zone_to_nid(zone); if (cpuset_zone_allowed(zone, flags) && get_node(cache, nid) && get_node(cache, nid)->free_objects) { obj = ____cache_alloc_node(cache, gfp_exact_node(flags), nid); if (obj) break; } } if (!obj) { /* * This allocation will be performed within the constraints * of the current cpuset / memory policy requirements. * We may trigger various forms of reclaim on the allowed * set and go into memory reserves if necessary. */ page = cache_grow_begin(cache, flags, numa_mem_id()); cache_grow_end(cache, page); if (page) { nid = page_to_nid(page); obj = ____cache_alloc_node(cache, gfp_exact_node(flags), nid); /* * Another processor may allocate the objects in * the slab since we are not holding any locks. */ if (!obj) goto retry; } } if (unlikely(!obj && read_mems_allowed_retry(cpuset_mems_cookie))) goto retry_cpuset; return obj; }

Contributors

PersonTokensPropCommitsCommitProp
Christoph Lameter11549.36%523.81%
Mel Gorman5523.61%628.57%
Pekka J Enberg2611.16%14.76%
JoonSoo Kim2410.30%29.52%
David Rientjes73.00%29.52%
Miao Xie20.86%14.76%
Lee Schermerhorn10.43%14.76%
Vladimir Davydov10.43%14.76%
Christoph Hellwig10.43%14.76%
Andi Kleen10.43%14.76%
Total233100.00%21100.00%

/* * A interface to enable slab creation on nodeid */
static void *____cache_alloc_node(struct kmem_cache *cachep, gfp_t flags, int nodeid) { struct page *page; struct kmem_cache_node *n; void *obj = NULL; void *list = NULL; VM_BUG_ON(nodeid < 0 || nodeid >= MAX_NUMNODES); n = get_node(cachep, nodeid); BUG_ON(!n); check_irq_off(); spin_lock(&n->list_lock); page = get_first_slab(n, false); if (!page) goto must_grow; check_spinlock_acquired_node(cachep, nodeid); STATS_INC_NODEALLOCS(cachep); STATS_INC_ACTIVE(cachep); STATS_SET_HIGH(cachep); BUG_ON(page->active == cachep->num); obj = slab_get_obj(cachep, page); n->free_objects--; fixup_slab_list(cachep, n, page, &list); spin_unlock(&n->list_lock); fixup_objfreelist_debug(cachep, &list); return obj; must_grow: spin_unlock(&n->list_lock); page = cache_grow_begin(cachep, gfp_exact_node(flags), nodeid); if (page) { /* This slab isn't counted yet so don't update free_objects */ obj = slab_get_obj(cachep, page); } cache_grow_end(cachep, page); return obj ? obj : fallback_alloc(cachep, flags); }

Contributors

PersonTokensPropCommitsCommitProp
Christoph Lameter8034.63%414.81%
JoonSoo Kim6126.41%829.63%
Pekka J Enberg4017.32%27.41%
Linus Torvalds (pre-git)125.19%27.41%
Geliang Tang114.76%27.41%
Paul Mackerras62.60%13.70%
Andrew Morton52.16%27.41%
Aaron Tomlin52.16%13.70%
Ravikiran G. Thirumalai31.30%13.70%
David Rientjes31.30%13.70%
Matthew Dobson31.30%13.70%
Christoph Hellwig10.43%13.70%
Al Viro10.43%13.70%
Total231100.00%27100.00%


static __always_inline void * slab_alloc_node(struct kmem_cache *cachep, gfp_t flags, int nodeid, unsigned long caller) { unsigned long save_flags; void *ptr; int slab_node = numa_mem_id(); flags &= gfp_allowed_mask; cachep = slab_pre_alloc_hook(cachep, flags); if (unlikely(!cachep)) return NULL; cache_alloc_debugcheck_before(cachep, flags); local_irq_save(save_flags); if (nodeid == NUMA_NO_NODE) nodeid = slab_node; if (unlikely(!get_node(cachep, nodeid))) { /* Node not bootstrapped yet */ ptr = fallback_alloc(cachep, flags); goto out; } if (nodeid == slab_node) { /* * Use the locally cached objects if possible. * However ____cache_alloc does not allow fallback * to other nodes. It may fail while we still have * objects on other nodes available. */ ptr = ____cache_alloc(cachep, flags); if (ptr) goto out; } /* ___cache_alloc_node can fall back to other nodes */ ptr = ____cache_alloc_node(cachep, flags, nodeid); out: local_irq_restore(save_flags); ptr = cache_alloc_debugcheck_after(cachep, flags, ptr, caller); if (unlikely(flags & __GFP_ZERO) && ptr) memset(ptr, 0, cachep->object_size); slab_post_alloc_hook(cachep, flags, 1, &ptr); return ptr; }

Contributors

PersonTokensPropCommitsCommitProp
Pekka J Enberg13666.34%318.75%
Christoph Lameter2210.73%318.75%
Jesper Dangaard Brouer178.29%212.50%
Akinobu Mita94.39%16.25%
Lee Schermerhorn83.90%16.25%
Vladimir Davydov41.95%16.25%
Nicholas Piggin41.95%16.25%
Ezequiel García31.46%212.50%
Andrew Morton10.49%16.25%
Benjamin Herrenschmidt10.49%16.25%
Total205100.00%16100.00%


static __always_inline void * __do_cache_alloc(struct kmem_cache *cache, gfp_t flags) { void *objp; if (current->mempolicy || cpuset_do_slab_mem_spread()) { objp = alternate_node_alloc(cache, flags); if (objp) goto out; } objp = ____cache_alloc(cache, flags); /* * We may just have run out of memory on the local node. * ____cache_alloc_node() knows how to locate memory on other nodes */ if (!objp) objp = ____cache_alloc_node(cache, flags, numa_mem_id()); out: return objp; }

Contributors

PersonTokensPropCommitsCommitProp
Pekka J Enberg7291.14%125.00%
David Rientjes45.06%125.00%
Li Zefan22.53%125.00%
Lee Schermerhorn11.27%125.00%
Total79100.00%4100.00%

#else
static __always_inline void * __do_cache_alloc(struct kmem_cache *cachep, gfp_t flags) { return ____cache_alloc(cachep, flags); }

Contributors

PersonTokensPropCommitsCommitProp
Pekka J Enberg24100.00%1100.00%
Total24100.00%1100.00%

#endif /* CONFIG_NUMA */
static __always_inline void * slab_alloc(struct kmem_cache *cachep, gfp_t flags, unsigned long caller) { unsigned long save_flags; void *objp; flags &= gfp_allowed_mask; cachep = slab_pre_alloc_hook(cachep, flags); if (unlikely(!cachep)) return NULL; cache_alloc_debugcheck_before(cachep, flags); local_irq_save(save_flags); objp = __do_cache_alloc(cachep, flags); local_irq_restore(save_flags); objp = cache_alloc_debugcheck_after(cachep, flags, objp, caller); prefetchw(objp); if (unlikely(flags & __GFP_ZERO) && objp) memset(objp, 0, cachep->object_size); slab_post_alloc_hook(cachep, flags, 1, &objp); return objp; }

Contributors

PersonTokensPropCommitsCommitProp
Pekka J Enberg4936.84%210.53%
Christoph Lameter3627.07%526.32%
Jesper Dangaard Brouer1712.78%210.53%
Akinobu Mita96.77%15.26%
Andrew Morton64.51%210.53%
Vladimir Davydov43.01%15.26%
Nicholas Piggin43.01%15.26%
Eric Dumazet32.26%15.26%
Ezequiel García32.26%210.53%
Benjamin Herrenschmidt10.75%15.26%
Linus Torvalds (pre-git)10.75%15.26%
Total133100.00%19100.00%

/* * Caller needs to acquire correct kmem_cache_node's list_lock * @list: List of detached free slabs should be freed by caller */
static void free_block(struct kmem_cache *cachep, void **objpp, int nr_objects, int node, struct list_head *list) { int i; struct kmem_cache_node *n = get_node(cachep, node); struct page *page; n->free_objects += nr_objects; for (i = 0; i < nr_objects; i++) { void *objp; struct page *page; objp = objpp[i]; page = virt_to_head_page(objp); list_del(&page->lru); check_spinlock_acquired_node(cachep, node); slab_put_obj(cachep, page, objp); STATS_DEC_ACTIVE(cachep); /* fixup slab chains */ if (page->active == 0) { list_add(&page->lru, &n->slabs_free); n->free_slabs++; } else { /* Unconditionally move a slab to the end of the * partial list on free - maximum time for the * other objects to be freed, too. */ list_add_tail(&page->lru, &n->slabs_partial); } } while (n->free_objects > n->free_limit && !list_empty(&n->slabs_free)) { n->free_objects -= cachep->num; page = list_last_entry(&n->slabs_free, struct page, lru); list_move(&page->lru, list); n->free_slabs--; n->total_slabs--; } }

Contributors

PersonTokensPropCommitsCommitProp
JoonSoo Kim8737.83%518.52%
Andrew Morton5021.74%622.22%
Linus Torvalds (pre-git)4017.39%311.11%
Christoph Lameter187.83%414.81%
Greg Thelen83.48%13.70%
Mel Gorman73.04%13.70%
David Rientjes52.17%13.70%
Linus Torvalds52.17%27.41%
Aruna Ramakrishna41.74%13.70%
Matthew Dobson31.30%13.70%
Pekka J Enberg20.87%13.70%
Wei Yongjun10.43%13.70%
Total230100.00%27100.00%


static void cache_flusharray(struct kmem_cache *cachep, struct array_cache *ac) { int batchcount; struct kmem_cache_node *n; int node = numa_mem_id(); LIST_HEAD(list); batchcount = ac->batchcount; check_irq_off(); n = get_node(cachep, node); spin_lock(&n->list_lock); if (n->shared) { struct array_cache *shared_array = n->shared; int max = shared_array->limit - shared_array->avail; if (max) { if (batchcount > max) batchcount = max; memcpy(&(shared_array->entry[shared_array->avail]), ac->entry, sizeof(void *) * batchcount); shared_array->avail += batchcount; goto free_done; } } free_block(cachep, ac->entry, batchcount, node, &list); free_done: #if STATS { int i = 0; struct page *page; list_for_each_entry(page, &n->slabs_free, lru) { BUG_ON(page->active); i++; } STATS_SET_FREEABLE(cachep, i); } #endif spin_unlock(&n->list_lock); slabs_destroy(cachep, &list); ac->avail -= batchcount; memmove(ac->entry, &(ac->entry[batchcount]), sizeof(void *)*ac->avail); }

Contributors

PersonTokensPropCommitsCommitProp
Andrew Morton13352.78%422.22%
Christoph Lameter7830.95%527.78%
JoonSoo Kim207.94%316.67%
Linus Torvalds (pre-git)124.76%211.11%
Geliang Tang51.98%15.56%
Pekka J Enberg20.79%15.56%
Lee Schermerhorn10.40%15.56%
Ingo Molnar10.40%15.56%
Total252100.00%18100.00%

/* * Release an obj back to its cache. If the obj has a constructed state, it must * be in this state _before_ it is released. Called with disabled ints. */
static inline void __cache_free(struct kmem_cache *cachep, void *objp, unsigned long caller) { /* Put the object into the quarantine, don't touch it for now. */ if (kasan_slab_free(cachep, objp)) return; ___cache_free(cachep, objp, caller); }

Contributors

PersonTokensPropCommitsCommitProp
Alexander Potapenko2152.50%116.67%
Christoph Lameter1230.00%116.67%
Suleiman Souhlal25.00%116.67%
Pekka J Enberg25.00%116.67%
Ezequiel García25.00%116.67%
Ingo Molnar12.50%116.67%
Total40100.00%6100.00%


void ___cache_free(struct kmem_cache *cachep, void *objp, unsigned long caller) { struct array_cache *ac = cpu_cache_get(cachep); check_irq_off(); kmemleak_free_recursive(objp, cachep->flags); objp = cache_free_debugcheck(cachep, objp, caller); /* * Skip calling cache_free_alien() when the platform is not numa. * This will avoid cache misses that happen while accessing slabp (which * is per page memory reference) to get nodeid. Instead use a global * variable to skip the call, which is mostly likely to be present in * the cache. */ if (nr_online_nodes > 1 && cache_free_alien(cachep, objp)) return; if (ac->avail < ac->limit) { STATS_INC_FREEHIT(cachep); } else { STATS_INC_FREEMISS(cachep); cache_flusharray(cachep, ac); } if (sk_memalloc_socks()) { struct page *page = virt_to_head_page(objp); if (unlikely(PageSlabPfmemalloc(page))) { cache_free_pfmemalloc(cachep, page, objp); return; } } ac->entry[ac->avail++] = objp; }

Contributors

PersonTokensPropCommitsCommitProp
JoonSoo Kim4429.53%17.14%
Linus Torvalds (pre-git)2919.46%17.14%
Christoph Lameter2919.46%17.14%
Alexander Potapenko1711.41%17.14%
Catalin Marinas96.04%17.14%
Mel Gorman85.37%214.29%
Andrew Morton64.03%214.29%
Pekka J Enberg32.01%214.29%
Suresh B. Siddha21.34%17.14%
Zhao Jin10.67%17.14%
Suleiman Souhlal10.67%17.14%
Total149100.00%14100.00%

/** * kmem_cache_alloc - Allocate an object * @cachep: The cache to allocate from. * @flags: See kmalloc(). * * Allocate an object from this cache. The flags are only relevant * if the cache has no available objects. */
void *kmem_cache_alloc(struct kmem_cache *cachep, gfp_t flags) { void *ret = slab_alloc(cachep, flags, _RET_IP_); kasan_slab_alloc(cachep, ret, flags); trace_kmem_cache_alloc(_RET_IP_, ret, cachep->object_size, cachep->size, flags); return ret; }

Contributors

PersonTokensPropCommitsCommitProp
Eduard - Gabriel Munteanu2137.50%215.38%
Linus Torvalds (pre-git)1730.36%215.38%
Alexander Potapenko916.07%215.38%
Christoph Lameter35.36%215.38%
Pekka J Enberg35.36%215.38%
Ezequiel García23.57%215.38%
Al Viro11.79%17.69%
Total56100.00%13100.00%

EXPORT_SYMBOL(kmem_cache_alloc);
static __always_inline void cache_alloc_debugcheck_after_bulk(struct kmem_cache *s, gfp_t flags, size_t size, void **p, unsigned long caller) { size_t i; for (i = 0; i < size; i++) p[i] = cache_alloc_debugcheck_after(s, flags, p[i], caller); }

Contributors

PersonTokensPropCommitsCommitProp
Jesper Dangaard Brouer62100.00%1100.00%
Total62100.00%1100.00%


int kmem_cache_alloc_bulk(struct kmem_cache *s, gfp_t flags, size_t size, void **p) { size_t i; s = slab_pre_alloc_hook(s, flags); if (!s) return 0; cache_alloc_debugcheck_before(s, flags); local_irq_disable(); for (i = 0; i < size; i++) { void *objp = __do_cache_alloc(s, flags); if (unlikely(!objp)) goto error; p[i] = objp; } local_irq_enable(); cache_alloc_debugcheck_after_bulk(s, flags, size, p, _RET_IP_); /* Clear memory outside IRQ disabled section */ if (unlikely(flags & __GFP_ZERO)) for (i = 0; i < size; i++) memset(p[i], 0, s->object_size); slab_post_alloc_hook(s, flags, size, p); /* FIXME: Trace call missing. Christoph would like a bulk variant */ return size; error: local_irq_enable(); cache_alloc_debugcheck_after_bulk(s, flags, i, p, _RET_IP_); slab_post_alloc_hook(s, flags, i, p); __kmem_cache_free_bulk(s, i, p); return 0; }

Contributors

PersonTokensPropCommitsCommitProp
Jesper Dangaard Brouer17384.80%375.00%
Christoph Lameter3115.20%125.00%
Total204100.00%4100.00%

EXPORT_SYMBOL(kmem_cache_alloc_bulk); #ifdef CONFIG_TRACING
void * kmem_cache_alloc_trace(struct kmem_cache *cachep, gfp_t flags, size_t size) { void *ret; ret = slab_alloc(cachep, flags, _RET_IP_); kasan_kmalloc(cachep, ret, size, flags); trace_kmalloc(_RET_IP_, ret, size, cachep->size, flags); return ret; }

Contributors

PersonTokensPropCommitsCommitProp
Steven Rostedt2337.70%112.50%
Eduard - Gabriel Munteanu2032.79%112.50%
Alexander Potapenko1118.03%225.00%
Ezequiel García711.48%450.00%
Total61100.00%8100.00%

EXPORT_SYMBOL(kmem_cache_alloc_trace); #endif #ifdef CONFIG_NUMA /** * kmem_cache_alloc_node - Allocate an object on the specified node * @cachep: The cache to allocate from. * @flags: See kmalloc(). * @nodeid: node number of the target node. * * Identical to kmem_cache_alloc but it will allocate memory on the given * node, which can improve the performance for cpu bound structures. * * Fallback to other node is possible if __GFP_THISNODE is not set. */
void *kmem_cache_alloc_node(struct kmem_cache *cachep, gfp_t flags, int nodeid) { void *ret = slab_alloc_node(cachep, flags, nodeid, _RET_IP_); kasan_slab_alloc(cachep, ret, flags); trace_kmem_cache_alloc_node(_RET_IP_, ret, cachep->object_size, cachep->size, flags, nodeid); return ret; }

Contributors

PersonTokensPropCommitsCommitProp
Eduard - Gabriel Munteanu2336.51%218.18%
Christoph Hellwig2336.51%19.09%
Alexander Potapenko914.29%218.18%
Christoph Lameter46.35%327.27%
Ezequiel García23.17%218.18%
Linus Torvalds23.17%19.09%
Total63100.00%11100.00%

EXPORT_SYMBOL(kmem_cache_alloc_node); #ifdef CONFIG_TRACING
void *kmem_cache_alloc_node_trace(struct kmem_cache *cachep, gfp_t flags, int nodeid, size_t size) { void *ret; ret = slab_alloc_node(cachep, flags, nodeid, _RET_IP_); kasan_kmalloc(cachep, ret, size, flags); trace_kmalloc_node(_RET_IP_, ret, size, cachep->size, flags, nodeid); return ret; }

Contributors

PersonTokensPropCommitsCommitProp
Steven Rostedt2536.76%112.50%
Eduard - Gabriel Munteanu2536.76%112.50%
Alexander Potapenko1116.18%225.00%
Ezequiel García710.29%450.00%
Total68100.00%8100.00%

EXPORT_SYMBOL(kmem_cache_alloc_node_trace); #endif
static __always_inline void * __do_kmalloc_node(size_t size, gfp_t flags, int node, unsigned long caller) { struct kmem_cache *cachep; void *ret; cachep = kmalloc_slab(size, flags); if (unlikely(ZERO_OR_NULL_PTR(cachep))) return cachep; ret = kmem_cache_alloc_node_trace(cachep, flags, node, size); kasan_kmalloc(cachep, ret, size, flags); return ret; }

Contributors

PersonTokensPropCommitsCommitProp
Christoph Lameter3544.30%425.00%
Alexander Potapenko2025.32%212.50%
Linus Torvalds (pre-git)78.86%212.50%
Christoph Hellwig56.33%16.25%
Ezequiel García45.06%212.50%
Manfred Spraul33.80%16.25%
Pekka J Enberg22.53%16.25%
Andrew Morton11.27%16.25%
Al Viro11.27%16.25%
Steven Rostedt11.27%16.25%
Total79100.00%16100.00%


void *__kmalloc_node(size_t size, gfp_t flags, int node) { return __do_kmalloc_node(size, flags, node, _RET_IP_); }

Contributors

PersonTokensPropCommitsCommitProp
Christoph Hellwig2696.30%150.00%
Ezequiel García13.70%150.00%
Total27100.00%2100.00%

EXPORT_SYMBOL(__kmalloc_node);
void *__kmalloc_node_track_caller(size_t size, gfp_t flags, int node, unsigned long caller) { return __do_kmalloc_node(size, flags, node, caller); }

Contributors

PersonTokensPropCommitsCommitProp
Christoph Hellwig2993.55%150.00%
Eduard - Gabriel Munteanu26.45%150.00%
Total31100.00%2100.00%

EXPORT_SYMBOL(__kmalloc_node_track_caller); #endif /* CONFIG_NUMA */ /** * __do_kmalloc - allocate memory * @size: how many bytes of memory are required. * @flags: the type of memory to allocate (see kmalloc). * @caller: function caller for debug tracking of the caller */
static __always_inline void *__do_kmalloc(size_t size, gfp_t flags, unsigned long caller) { struct kmem_cache *cachep; void *ret; cachep = kmalloc_slab(size, flags); if (unlikely(ZERO_OR_NULL_PTR(cachep))) return cachep; ret = slab_alloc(cachep, flags, caller); kasan_kmalloc(cachep, ret, size, flags); trace_kmalloc(caller, ret, size, cachep->size, flags); return ret; }

Contributors

PersonTokensPropCommitsCommitProp
Eduard - Gabriel Munteanu2325.84%212.50%
Christoph Lameter2022.47%318.75%
Pekka J Enberg1213.48%212.50%
Alexander Potapenko1112.36%212.50%
Andrew Morton88.99%212.50%
Manfred Spraul77.87%16.25%
Linus Torvalds44.49%16.25%
Ezequiel García33.37%212.50%
Al Viro11.12%16.25%
Total89100.00%16100.00%


void *__kmalloc(size_t size, gfp_t flags) { return __do_kmalloc(size, flags, _RET_IP_); }

Contributors

PersonTokensPropCommitsCommitProp
Pekka J Enberg1150.00%125.00%
Al Viro940.91%125.00%
Christoph Lameter14.55%125.00%
Ezequiel García14.55%125.00%
Total22100.00%4100.00%

EXPORT_SYMBOL(__kmalloc);
void *__kmalloc_track_caller(size_t size, gfp_t flags, unsigned long caller) { return __do_kmalloc(size, flags, caller); }

Contributors

PersonTokensPropCommitsCommitProp
Pekka J Enberg2492.31%150.00%
Eduard - Gabriel Munteanu27.69%150.00%
Total26100.00%2100.00%

EXPORT_SYMBOL(__kmalloc_track_caller); /** * kmem_cache_free - Deallocate an object * @cachep: The cache the allocation was from. * @objp: The previously allocated object. * * Free an object which was previously allocated from this * cache. */
void kmem_cache_free(struct kmem_cache *cachep, void *objp) { unsigned long flags; cachep = cache_from_obj(cachep, objp); if (!cachep) return; local_irq_save(flags); debug_check_no_locks_freed(objp, cachep->object_size); if (!(cachep->flags & SLAB_DEBUG_OBJECTS)) debug_check_no_obj_freed(objp, cachep->object_size); __cache_free(cachep, objp, _RET_IP_); local_irq_restore(flags); trace_kmem_cache_free(_RET_IP_, objp); }

Contributors

PersonTokensPropCommitsCommitProp
Christoph Lameter2022.73%216.67%
Thomas Gleixner1820.45%18.33%
Manfred Spraul1618.18%18.33%
Glauber de Oliveira Costa1517.05%18.33%
Ingo Molnar77.95%18.33%
Eduard - Gabriel Munteanu77.95%216.67%
Pekka J Enberg22.27%18.33%
Feng Tang11.14%18.33%
Ezequiel García11.14%18.33%
Suleiman Souhlal11.14%18.33%
Total88100.00%12100.00%

EXPORT_SYMBOL(kmem_cache_free);
void kmem_cache_free_bulk(struct kmem_cache *orig_s, size_t size, void **p) { struct kmem_cache *s; size_t i; local_irq_disable(); for (i = 0; i < size; i++) { void *objp = p[i]; if (!orig_s) /* called via kfree_bulk */ s = virt_to_cache(objp); else s = cache_from_obj(orig_s, objp); debug_check_no_locks_freed(objp, s->object_size); if (!(s->flags & SLAB_DEBUG_OBJECTS)) debug_check_no_obj_freed(objp, s->object_size); __cache_free(s, objp, _RET_IP_); } local_irq_enable(); /* FIXME: add tracing */ }

Contributors

PersonTokensPropCommitsCommitProp
Jesper Dangaard Brouer118100.00%2100.00%
Total118100.00%2100.00%

EXPORT_SYMBOL(kmem_cache_free_bulk); /** * kfree - free previously allocated memory * @objp: pointer returned by kmalloc. * * If @objp is NULL, no operation is performed. * * Don't free memory not originally allocated by kmalloc() * or you will run into trouble. */
void kfree(const void *objp) { struct kmem_cache *c; unsigned long flags; trace_kfree(_RET_IP_, objp); if (unlikely(ZERO_OR_NULL_PTR(objp))) return; local_irq_save(flags); kfree_debugcheck(objp); c = virt_to_cache(objp); debug_check_no_locks_freed(objp, c->object_size); debug_check_no_obj_freed(objp, c->object_size); __cache_free(c, (void *)objp, _RET_IP_); local_irq_restore(flags); }

Contributors

PersonTokensPropCommitsCommitProp
Christoph Lameter4550.00%321.43%
Andrew Morton1921.11%321.43%
Pekka J Enberg1011.11%321.43%
Thomas Gleixner77.78%17.14%
Ingo Molnar77.78%214.29%
Suleiman Souhlal11.11%17.14%
Ezequiel García11.11%17.14%
Total90100.00%14100.00%

EXPORT_SYMBOL(kfree); /* * This initializes kmem_cache_node or resizes various caches for all nodes. */
static int setup_kmem_cache_nodes(struct kmem_cache *cachep, gfp_t gfp) { int ret; int node; struct kmem_cache_node *n; for_each_online_node(node) { ret = setup_kmem_cache_node(cachep, node, gfp, true); if (ret) goto fail; } return 0; fail: if (!cachep->list.next) { /* Cache is not active yet. Roll back what we did */ node--; while (node >= 0) { n = get_node(cachep, node); if (n) { kfree(n->shared); free_alien_cache(n->alien); kfree(n); cachep->node[node] = NULL; } node--; } } return -ENOMEM; }

Contributors

PersonTokensPropCommitsCommitProp
Christoph Lameter10178.29%947.37%
JoonSoo Kim96.98%210.53%
Pekka J Enberg64.65%210.53%
Jaroslav Kysela53.88%15.26%
Andrew Morton43.10%210.53%
Arnaldo Carvalho de Melo21.55%15.26%
Mel Gorman10.78%15.26%
Christoph Hellwig10.78%15.26%
Total129100.00%19100.00%

/* Always called with the slab_mutex held */
static int __do_tune_cpucache(struct kmem_cache *cachep, int limit, int batchcount, int shared, gfp_t gfp) { struct array_cache __percpu *cpu_cache, *prev; int cpu; cpu_cache = alloc_kmem_cache_cpus(cachep, limit, batchcount); if (!cpu_cache) return -ENOMEM; prev = cachep->cpu_cache; cachep->cpu_cache = cpu_cache; /* * Without a previous cpu_cache there's no need to synchronize remote * cpus, so skip the IPIs. */ if (prev) kick_all_cpus_sync(); check_irq_on(); cachep->batchcount = batchcount; cachep->limit = limit; cachep->shared = shared; if (!prev) goto setup_node; for_each_online_cpu(cpu) { LIST_HEAD(list); int node; struct kmem_cache_node *n; struct array_cache *ac = per_cpu_ptr(prev, cpu); node = cpu_to_mem(cpu); n = get_node(cachep, node); spin_lock_irq(&n->list_lock); free_block(cachep, ac->entry, ac->avail, node, &list); spin_unlock_irq(&n->list_lock); slabs_destroy(cachep, &list); } free_percpu(prev); setup_node: return setup_kmem_cache_nodes(cachep, gfp); }

Contributors

PersonTokensPropCommitsCommitProp
JoonSoo Kim6631.73%313.64%
Christoph Lameter4421.15%522.73%
Andrew Morton3918.75%418.18%
Linus Torvalds (pre-git)3617.31%313.64%
Pekka J Enberg73.37%29.09%
Greg Thelen52.40%14.55%
Suresh B. Siddha52.40%14.55%
Rusty Russell41.92%14.55%
Lee Schermerhorn10.48%14.55%
Glauber de Oliveira Costa10.48%14.55%
Total208100.00%22100.00%


static int do_tune_cpucache(struct kmem_cache *cachep, int limit, int batchcount, int shared, gfp_t gfp) { int ret; struct kmem_cache *c; ret = __do_tune_cpucache(cachep, limit, batchcount, shared, gfp); if (slab_state < FULL) return ret; if ((ret < 0) || !is_root_cache(cachep)) return ret; lockdep_assert_held(&slab_mutex); for_each_memcg_cache(c, cachep) { /* return value determined by the root cache only */ __do_tune_cpucache(c, limit, batchcount, shared, gfp); } return ret; }

Contributors

PersonTokensPropCommitsCommitProp
Glauber de Oliveira Costa9794.17%266.67%
Vladimir Davydov65.83%133.33%
Total103100.00%3100.00%

/* Called with slab_mutex held always */
static int enable_cpucache(struct kmem_cache *cachep, gfp_t gfp) { int err; int limit = 0; int shared = 0; int batchcount = 0; err = cache_random_seq_create(cachep, cachep->num, gfp); if (err) goto end; if (!is_root_cache(cachep)) { struct kmem_cache *root = memcg_root_cache(cachep); limit = root->limit; shared = root->shared; batchcount = root->batchcount; } if (limit && shared && batchcount) goto skip_setup; /* * The head array serves three purposes: * - create a LIFO ordering, i.e. return objects that are cache-warm * - reduce the number of spinlock operations. * - reduce the number of linked list operations on the slab and * bufctl chains: array operations are cheaper. * The numbers are guessed, we should auto-tune as described by * Bonwick. */ if (cachep->size > 131072) limit = 1; else if (cachep->size > PAGE_SIZE) limit = 8; else if (cachep->size > 1024) limit = 24; else if (cachep->size > 256) limit = 54; else limit = 120; /* * CPU bound tasks (e.g. network routing) can exhibit cpu bound * allocation behaviour: Most allocs on one cpu, most free operations * on another cpu. For these cases, an efficient object passing between * cpus is necessary. This is provided by a shared array. The array * replaces Bonwick's magazine layer. * On uniprocessor, it's functionally equivalent (but less efficient) * to a larger limit. Thus disabled by default. */ shared = 0; if (cachep->size <= PAGE_SIZE && num_possible_cpus() > 1) shared = 8; #if DEBUG /* * With debugging enabled, large batchcount lead to excessively long * periods with disabled local interrupts. Limit the batchcount */ if (limit > 32) limit = 32; #endif batchcount = (limit + 1) / 2; skip_setup: err = do_tune_cpucache(cachep, limit, batchcount, shared, gfp); end: if (err) pr_err("enable_cpucache failed for %s, error %d\n", cachep->name, -err); return err; }

Contributors

PersonTokensPropCommitsCommitProp
Andrew Morton8233.61%423.53%
Glauber de Oliveira Costa7329.92%15.88%
Linus Torvalds (pre-git)4418.03%423.53%
Thomas Garnier229.02%211.76%
Christoph Lameter93.69%211.76%
Pekka J Enberg72.87%211.76%
Eric Dumazet52.05%15.88%
Joe Perches20.82%15.88%
Total244100.00%17100.00%

/* * Drain an array if it contains any elements taking the node lock only if * necessary. Note that the node listlock also protects the array_cache * if drain_array() is used on the shared array. */
static void drain_array(struct kmem_cache *cachep, struct kmem_cache_node *n, struct array_cache *ac, int node) { LIST_HEAD(list); /* ac from n->shared can be freed if we don't hold the slab_mutex. */ check_mutex_acquired(); if (!ac || !ac->avail) return; if (ac->touched) { ac->touched = 0; return; } spin_lock_irq(&n->list_lock); drain_array_locked(cachep, ac, node, false, &list); spin_unlock_irq(&n->list_lock); slabs_destroy(cachep, &list); }

Contributors

PersonTokensPropCommitsCommitProp
Christoph Lameter3738.14%642.86%
Andrew Morton3030.93%214.29%
JoonSoo Kim2222.68%214.29%
Linus Torvalds (pre-git)55.15%214.29%
Pekka J Enberg22.06%17.14%
H Hartley Sweeten11.03%17.14%
Total97100.00%14100.00%

/** * cache_reap - Reclaim memory from caches. * @w: work descriptor * * Called from workqueue/eventd every few seconds. * Purpose: * - clear the per-cpu caches for this CPU. * - return freeable pages to the main free memory pool. * * If we cannot acquire the cache chain mutex then just give up - we'll try * again on the next iteration. */
static void cache_reap(struct work_struct *w) { struct kmem_cache *searchp; struct kmem_cache_node *n; int node = numa_mem_id(); struct delayed_work *work = to_delayed_work(w); if (!mutex_trylock(&slab_mutex)) /* Give up. Setup the next iteration. */ goto out; list_for_each_entry(searchp, &slab_caches, list) { check_irq_on(); /* * We only take the node lock if absolutely necessary and we * have established with reasonable certainty that * we can do some work if the lock was obtained. */ n = get_node(searchp, node); reap_alien(searchp, n); drain_array(searchp, n, cpu_cache_get(searchp), node); /* * These are racy checks but it does not matter * if we skip one check or scan twice. */ if (time_after(n->next_reap, jiffies)) goto next; n->next_reap = jiffies + REAPTIMEOUT_NODE; drain_array(searchp, n, n->shared, node); if (n->free_touched) n->free_touched = 0; else { int freed; freed = drain_freelist(searchp, n, (n->free_limit + 5 * searchp->num - 1) / (5 * searchp->num)); STATS_ADD_REAPED(searchp, freed); } next: cond_resched(); } check_irq_on(); mutex_unlock(&slab_mutex); next_reap_node(); out: /* Set up the next iteration */ schedule_delayed_work(work, round_jiffies_relative(REAPTIMEOUT_AC)); }

Contributors

PersonTokensPropCommitsCommitProp
Christoph Lameter8338.43%1238.71%
Andrew Morton6329.17%619.35%
Linus Torvalds (pre-git)4219.44%13.23%
Ingo Molnar62.78%26.45%
Dimitri Sivanich52.31%26.45%
Christoph Hellwig52.31%13.23%
Arjan van de Ven31.39%13.23%
Linus Torvalds20.93%13.23%
Jianyu Zhan20.93%13.23%
David Howells20.93%13.23%
Pekka J Enberg10.46%13.23%
Lee Schermerhorn10.46%13.23%
Jean Delvare10.46%13.23%
Total216100.00%31100.00%


void get_slabinfo(struct kmem_cache *cachep, struct slabinfo *sinfo) { unsigned long active_objs, num_objs, active_slabs; unsigned long total_slabs = 0, free_objs = 0, shared_avail = 0; unsigned long free_slabs = 0; int node; struct kmem_cache_node *n; for_each_kmem_cache_node(cachep, node, n) { check_irq_on(); spin_lock_irq(&n->list_lock); total_slabs += n->total_slabs; free_slabs += n->free_slabs; free_objs += n->free_objects; if (n->shared) shared_avail += n->shared->avail; spin_unlock_irq(&n->list_lock); } num_objs = total_slabs * cachep->num; active_slabs = total_slabs - free_slabs; active_objs = num_objs - free_objs; sinfo->active_objs = active_objs; sinfo->num_objs = num_objs; sinfo->active_slabs = active_slabs; sinfo->num_slabs = total_slabs; sinfo->shared_avail = shared_avail; sinfo->limit = cachep->limit; sinfo->batchcount = cachep->batchcount; sinfo->shared = cachep->shared; sinfo->objects_per_slab = cachep->num; sinfo->cache_order = cachep->gfporder; }

Contributors

PersonTokensPropCommitsCommitProp
Glauber de Oliveira Costa6029.70%16.25%
Christoph Lameter4924.26%425.00%
Aruna Ramakrishna2210.89%16.25%
Linus Torvalds (pre-git)199.41%16.25%
Andrew Morton157.43%318.75%
Ravikiran G. Thirumalai104.95%212.50%
Greg Thelen94.46%16.25%
David Rientjes94.46%16.25%
Al Viro62.97%16.25%
Linus Torvalds31.49%16.25%
Total202100.00%16100.00%


void slabinfo_show_stats(struct seq_file *m, struct kmem_cache *cachep) { #if STATS { /* node stats */ unsigned long high = cachep->high_mark; unsigned long allocs = cachep->num_allocations; unsigned long grown = cachep->grown; unsigned long reaped = cachep->reaped; unsigned long errors = cachep->errors; unsigned long max_freeable = cachep->max_freeable; unsigned long node_allocs = cachep->node_allocs; unsigned long node_frees = cachep->node_frees; unsigned long overflows = cachep->node_overflow; seq_printf(m, " : globalstat %7lu %6lu %5lu %4lu %4lu %4lu %4lu %4lu %4lu", allocs, high, grown, reaped, errors, max_freeable, node_allocs, node_frees, overflows); } /* cpu stats */ { unsigned long allochit = atomic_read(&cachep->allochit); unsigned long allocmiss = atomic_read(&cachep->allocmiss); unsigned long freehit = atomic_read(&cachep->freehit); unsigned long freemiss = atomic_read(&cachep->freemiss); seq_printf(m, " : cpustat %6lu %6lu %6lu %6lu", allochit, allocmiss, freehit, freemiss); } #endif }

Contributors

PersonTokensPropCommitsCommitProp
Linus Torvalds (pre-git)11863.44%218.18%
Andrew Morton2513.44%218.18%
Glauber de Oliveira Costa147.53%19.09%
Ravikiran G. Thirumalai105.38%19.09%
Christoph Lameter73.76%218.18%
Manfred Spraul73.76%19.09%
Al Viro42.15%19.09%
Joe Perches10.54%19.09%
Total186100.00%11100.00%

#define MAX_SLABINFO_WRITE 128 /** * slabinfo_write - Tuning for the slab allocator * @file: unused * @buffer: user buffer * @count: data length * @ppos: unused */
ssize_t slabinfo_write(struct file *file, const char __user *buffer, size_t count, loff_t *ppos) { char kbuf[MAX_SLABINFO_WRITE + 1], *tmp; int limit, batchcount, shared, res; struct kmem_cache *cachep; if (count > MAX_SLABINFO_WRITE) return -EINVAL; if (copy_from_user(&kbuf, buffer, count)) return -EFAULT; kbuf[MAX_SLABINFO_WRITE] = '\0'; tmp = strchr(kbuf, ' '); if (!tmp) return -EINVAL; *tmp = '\0'; tmp++; if (sscanf(tmp, " %d %d %d", &limit, &batchcount, &shared) != 3) return -EINVAL; /* Find the cache in the chain of caches. */ mutex_lock(&slab_mutex); res = -EINVAL; list_for_each_entry(cachep, &slab_caches, list) { if (!strcmp(cachep->name, kbuf)) { if (limit < 1 || batchcount < 1 || batchcount > limit || shared < 0) { res = 0; } else { res = do_tune_cpucache(cachep, limit, batchcount, shared, GFP_KERNEL); } break; } } mutex_unlock(&slab_mutex); if (res >= 0) res = count; return res; }

Contributors

PersonTokensPropCommitsCommitProp
Linus Torvalds (pre-git)15467.25%426.67%
Andrew Morton4620.09%213.33%
Linus Torvalds104.37%213.33%
Christoph Lameter52.18%320.00%
Christoph Hellwig52.18%16.67%
Al Viro52.18%16.67%
Pekka J Enberg20.87%16.67%
Ingo Molnar20.87%16.67%
Total229100.00%15100.00%

#ifdef CONFIG_DEBUG_SLAB_LEAK
static inline int add_caller(unsigned long *n, unsigned long v) { unsigned long *p; int l; if (!v) return 1; l = n[1]; p = n + 2; while (l) { int i = l/2; unsigned long *q = p + 2 * i; if (*q == v) { q[1]++; return 1; } if (*q > v) { l = i; } else { p = q + 2; l -= i + 1; } } if (++n[1] == n[0]) return 0; memmove(p + 2, p, n[1] * 2 * sizeof(unsigned long) - ((void *)p - (void *)n)); p[0] = v; p[1] = 1; return 1; }

Contributors

PersonTokensPropCommitsCommitProp
Al Viro184100.00%1100.00%
Total184100.00%1100.00%


static void handle_slab(unsigned long *n, struct kmem_cache *c, struct page *page) { void *p; int i, j; unsigned long v; if (n[0] == n[1]) return; for (i = 0, p = page->s_mem; i < c->num; i++, p += c->size) { bool active = true; for (j = page->active; j < c->num; j++) { if (get_free_obj(page, j) == i) { active = false; break; } } if (!active) continue; /* * probe_kernel_read() is used for DEBUG_PAGEALLOC. page table * mapping is established when actual object allocation and * we could mistakenly access the unmapped object in the cpu * cache. */ if (probe_kernel_read(&v, dbg_userword(c, p), sizeof(v))) continue; if (!add_caller(n, v)) return; } }

Contributors

PersonTokensPropCommitsCommitProp
Al Viro8453.50%116.67%
JoonSoo Kim7245.86%466.67%
Christoph Lameter10.64%116.67%
Total157100.00%6100.00%


static void show_symbol(struct seq_file *m, unsigned long address) { #ifdef CONFIG_KALLSYMS unsigned long offset, size; char modname[MODULE_NAME_LEN], name[KSYM_NAME_LEN]; if (lookup_symbol_attrs(address, &size, &offset, modname, name) == 0) { seq_printf(m, "%s+%#lx/%#lx", name, offset, size); if (modname[0]) seq_printf(m, " [%s]", modname); return; } #endif seq_printf(m, "%px", (void *)address); }

Contributors

PersonTokensPropCommitsCommitProp
Al Viro8584.16%133.33%
Alexey Dobriyan1514.85%133.33%
Geert Uytterhoeven10.99%133.33%
Total101100.00%3100.00%


static int leaks_show(struct seq_file *m, void *p) { struct kmem_cache *cachep = list_entry(p, struct kmem_cache, list); struct page *page; struct kmem_cache_node *n; const char *name; unsigned long *x = m->private; int node; int i; if (!(cachep->flags & SLAB_STORE_USER)) return 0; if (!(cachep->flags & SLAB_RED_ZONE)) return 0; /* * Set store_user_clean and start to grab stored user information * for all objects on this cache. If some alloc/free requests comes * during the processing, information would be wrong so restart * whole processing. */ do { set_store_user_clean(cachep); drain_cpu_caches(cachep); x[1] = 0; for_each_kmem_cache_node(cachep, node, n) { check_irq_on(); spin_lock_irq(&n->list_lock); list_for_each_entry(page, &n->slabs_full, lru) handle_slab(x, cachep, page); list_for_each_entry(page, &n->slabs_partial, lru) handle_slab(x, cachep, page); spin_unlock_irq(&n->list_lock); } } while (!is_store_user_clean(cachep)); name = cachep->name; if (x[0] == x[1]) { /* Increase the buffer size */ mutex_unlock(&slab_mutex); m->private = kzalloc(x[0] * 4 * sizeof(unsigned long), GFP_KERNEL); if (!m->private) { /* Too bad, we are really out */ m->private = x; mutex_lock(&slab_mutex); return -ENOMEM; } *(unsigned long *)m->private = x[0] * 2; kfree(x); mutex_lock(&slab_mutex); /* Now make sure this entry will be retried */ m->count = m->size; return 0; } for (i = 0; i < x[1]; i++) { seq_printf(m, "%s: %lu ", name, x[2*i+3]); show_symbol(m, x[2*i+2]); seq_putc(m, '\n'); } return 0; }

Contributors

PersonTokensPropCommitsCommitProp
Al Viro28880.90%19.09%
JoonSoo Kim318.71%218.18%
Christoph Lameter277.58%545.45%
Pavel Emelyanov71.97%19.09%
Christoph Hellwig20.56%19.09%
Thierry Reding10.28%19.09%
Total356100.00%11100.00%

static const struct seq_operations slabstats_op = { .start = slab_start, .next = slab_next, .stop = slab_stop, .show = leaks_show, };
static int slabstats_open(struct inode *inode, struct file *file) { unsigned long *n; n = __seq_open_private(file, &slabstats_op, PAGE_SIZE); if (!n) return -ENOMEM; *n = PAGE_SIZE / (2 * sizeof(unsigned long)); return 0; }

Contributors

PersonTokensPropCommitsCommitProp
Alexey Dobriyan5185.00%150.00%
Rob Jones915.00%150.00%
Total60100.00%2100.00%

static const struct file_operations proc_slabstats_operations = { .open = slabstats_open, .read = seq_read, .llseek = seq_lseek, .release = seq_release_private, }; #endif
static int __init slab_proc_init(void) { #ifdef CONFIG_DEBUG_SLAB_LEAK proc_create("slab_allocators", 0, NULL, &proc_slabstats_operations); #endif return 0; }

Contributors

PersonTokensPropCommitsCommitProp
Alexey Dobriyan29100.00%1100.00%
Total29100.00%1100.00%

module_init(slab_proc_init); #ifdef CONFIG_HARDENED_USERCOPY /* * Rejects objects that are incorrectly sized. * * Returns NULL if check passes, otherwise const char * to name of cache * to indicate an error. */
const char *__check_heap_object(const void *ptr, unsigned long n, struct page *page) { struct kmem_cache *cachep; unsigned int objnr; unsigned long offset; /* Find and validate object. */ cachep = page->slab_cache; objnr = obj_to_index(cachep, page, (void *)ptr); BUG_ON(objnr >= cachep->num); /* Find offset within object. */ offset = ptr - index_to_obj(cachep, page, objnr) - obj_offset(cachep); /* Allow address range falling entirely within object size. */ if (offset <= cachep->object_size && n <= cachep->object_size - offset) return NULL; return cachep->name; }

Contributors

PersonTokensPropCommitsCommitProp
Kees Cook109100.00%1100.00%
Total109100.00%1100.00%

#endif /* CONFIG_HARDENED_USERCOPY */ /** * ksize - get the actual amount of memory allocated for a given object * @objp: Pointer to the object * * kmalloc may internally round up allocations and return more memory * than requested. ksize() can be used to determine the actual amount of * memory allocated. The caller may use this additional memory, even though * a smaller amount of memory was initially specified with the kmalloc call. * The caller must guarantee that objp points to a valid object previously * allocated with either kmalloc() or kmem_cache_alloc(). The object * must not be freed during the duration of the call. */
size_t ksize(const void *objp) { size_t size; BUG_ON(!objp); if (unlikely(objp == ZERO_SIZE_PTR)) return 0; size = virt_to_cache(objp)->object_size; /* We assume that ksize callers could use the whole allocated area, * so we need to unpoison this area. */ kasan_unpoison_shadow(objp, size); return size; }

Contributors

PersonTokensPropCommitsCommitProp
Christoph Hellwig1937.25%112.50%
Alexander Potapenko1631.37%225.00%
Christoph Lameter1019.61%225.00%
Manfred Spraul47.84%112.50%
Pekka J Enberg23.92%225.00%
Total51100.00%8100.00%

EXPORT_SYMBOL(ksize);

Overall Contributors

PersonTokensPropCommitsCommitProp
JoonSoo Kim417223.28%5411.79%
Christoph Lameter268114.96%5912.88%
Andrew Morton265114.79%5512.01%
Linus Torvalds (pre-git)14398.03%173.71%
Pekka J Enberg12907.20%235.02%
Al Viro7083.95%40.87%
Thomas Garnier6283.50%20.44%
David Rientjes4702.62%102.18%
Jesper Dangaard Brouer3922.19%71.53%
Glauber de Oliveira Costa2711.51%61.31%
Mel Gorman1831.02%122.62%
Akinobu Mita1821.02%51.09%
Alexander Potapenko1770.99%40.87%
Alexey Dobriyan1440.80%40.87%
Christoph Hellwig1440.80%71.53%
Eduard - Gabriel Munteanu1390.78%30.66%
Ravikiran G. Thirumalai1220.68%71.53%
Sebastian Andrzej Siewior1190.66%20.44%
Kees Cook1160.65%10.22%
Matthew Dobson1160.65%20.44%
Manfred Spraul1130.63%61.31%
Linus Torvalds1110.62%122.62%
Rafael Aquini980.55%10.22%
Paul Jackson940.52%20.44%
Dave Jones890.50%30.66%
Greg Thelen790.44%20.44%
David Woodhouse740.41%20.44%
Geliang Tang710.40%30.66%
Steven Rostedt700.39%30.66%
Hugh Dickins690.38%30.66%
Vladimir Davydov670.37%81.75%
Ingo Molnar570.32%112.40%
Rusty Russell550.31%71.53%
Eric Dumazet500.28%40.87%
Ezequiel García490.27%51.09%
Paul Menage340.19%10.22%
Aruna Ramakrishna330.18%10.22%
Tejun Heo300.17%40.87%
Thomas Gleixner280.16%10.22%
Catalin Marinas270.15%20.44%
Nicholas Piggin270.15%40.87%
Michal Hocko260.15%30.66%
Joe Perches250.14%20.44%
Kevin Hilman240.13%10.22%
Lee Schermerhorn200.11%10.22%
Suresh B. Siddha180.10%30.66%
Dimitri Sivanich180.10%20.44%
Andrey Ryabinin180.10%10.22%
John Sperbeck180.10%10.22%
Dmitry Safonov170.09%10.22%
Roland Dreier140.08%10.22%
Vlastimil Babka140.08%30.66%
David Howells120.07%30.66%
Luke Yang120.07%10.22%
Junjiro R. Okajima110.06%20.44%
Jianyu Zhan110.06%10.22%
Matthew Wilcox100.06%10.22%
Gautham R. Shenoy100.06%10.22%
Canjiang Lu100.06%10.22%
Geert Uytterhoeven90.05%10.22%
Rob Jones90.05%10.22%
Pavel Emelyanov70.04%10.22%
Alok N Kataria70.04%10.22%
Arjan van de Ven70.04%10.22%
Kirill A. Shutemov70.04%20.44%
Arnaldo Carvalho de Melo70.04%20.44%
Johannes Weiner60.03%10.22%
Paul Mackerras60.03%10.22%
Jacob Shin50.03%10.22%
Suleiman Souhlal50.03%10.22%
Aaron Tomlin50.03%10.22%
Rafael J. Wysocki50.03%10.22%
Randy Dunlap50.03%30.66%
Jaroslav Kysela50.03%10.22%
Li Zefan50.03%20.44%
Benjamin LaHaise40.02%10.22%
Andi Kleen40.02%30.66%
Tobias Klauser30.02%10.22%
Paul E. McKenney30.02%10.22%
Daniel Sanders30.02%10.22%
Paulo Marques30.02%10.22%
Joe Korty30.02%10.22%
Rabin Vincent30.02%10.22%
Tetsuo Handa30.02%10.22%
Dave Hansen30.02%10.22%
Daniel Yeisley20.01%10.22%
Wanpeng Li20.01%10.22%
Peter Zijlstra20.01%10.22%
Wang Sheng-Hui20.01%10.22%
Miao Xie20.01%10.22%
Eric Sesterhenn / Snakebyte20.01%10.22%
H Hartley Sweeten20.01%10.22%
Benjamin Herrenschmidt20.01%10.22%
Feng Tang10.01%10.22%
Harvey Harrison10.01%10.22%
Wei Yongjun10.01%10.22%
Zhouping Liu10.01%10.22%
Zwane Mwaikambo10.01%10.22%
Fabian Frederick10.01%10.22%
Helge Deller10.01%10.22%
Jan Beulich10.01%10.22%
Hagen Paul Pfeifer10.01%10.22%
Victor Fusco10.01%10.22%
Thierry Reding10.01%10.22%
Greg Kroah-Hartman10.01%10.22%
Jean Delvare10.01%10.22%
Zhao Jin10.01%10.22%
Robert P. J. Day10.01%10.22%
David S. Miller10.01%10.22%
Jack Steiner10.01%10.22%
Paul Drynoff10.01%10.22%
Haicheng Li10.01%10.22%
Total17924100.00%458100.00%
Directory: mm
Information contained on this website is for historical information purposes only and does not indicate or represent copyright ownership.
Created with cregit.