[redis.git] / deps / jemalloc / src / tcache.c

#define	JEMALLOC_TCACHE_C_
#include "jemalloc/internal/jemalloc_internal.h"

/******************************************************************************/
/* Data. */

malloc_tsd_data(, tcache, tcache_t *, NULL)
malloc_tsd_data(, tcache_enabled, tcache_enabled_t, tcache_enabled_default)

bool	opt_tcache = true;
ssize_t	opt_lg_tcache_max = LG_TCACHE_MAXCLASS_DEFAULT;

tcache_bin_info_t	*tcache_bin_info;
static unsigned		stack_nelms; /* Total stack elms per tcache. */

size_t			nhbins;
size_t			tcache_maxclass;

/******************************************************************************/

size_t	tcache_salloc(const void *ptr)
{

	return (arena_salloc(ptr, false));
}

void
tcache_event_hard(tcache_t *tcache)
{
	size_t binind = tcache->next_gc_bin;
	tcache_bin_t *tbin = &tcache->tbins[binind];
	tcache_bin_info_t *tbin_info = &tcache_bin_info[binind];

	if (tbin->low_water > 0) {
		/*
		 * Flush (ceiling) 3/4 of the objects below the low water mark.
		 */
		if (binind < NBINS) {
			tcache_bin_flush_small(tbin, binind, tbin->ncached -
			    tbin->low_water + (tbin->low_water >> 2), tcache);
		} else {
			tcache_bin_flush_large(tbin, binind, tbin->ncached -
			    tbin->low_water + (tbin->low_water >> 2), tcache);
		}
		/*
		 * Reduce fill count by 2X.  Limit lg_fill_div such that the
		 * fill count is always at least 1.
		 */
		if ((tbin_info->ncached_max >> (tbin->lg_fill_div+1)) >= 1)
			tbin->lg_fill_div++;
	} else if (tbin->low_water < 0) {
		/*
		 * Increase fill count by 2X.  Make sure lg_fill_div stays
		 * greater than 0.
		 */
		if (tbin->lg_fill_div > 1)
			tbin->lg_fill_div--;
	}
	tbin->low_water = tbin->ncached;

	tcache->next_gc_bin++;
	if (tcache->next_gc_bin == nhbins)
		tcache->next_gc_bin = 0;
	tcache->ev_cnt = 0;
}

void *
tcache_alloc_small_hard(tcache_t *tcache, tcache_bin_t *tbin, size_t binind)
{
	void *ret;

	arena_tcache_fill_small(tcache->arena, tbin, binind,
	    config_prof ? tcache->prof_accumbytes : 0);
	if (config_prof)
		tcache->prof_accumbytes = 0;
	ret = tcache_alloc_easy(tbin);

	return (ret);
}

void
tcache_bin_flush_small(tcache_bin_t *tbin, size_t binind, unsigned rem,
    tcache_t *tcache)
{
	void *ptr;
	unsigned i, nflush, ndeferred;
	bool merged_stats = false;

	assert(binind < NBINS);
	assert(rem <= tbin->ncached);

	for (nflush = tbin->ncached - rem; nflush > 0; nflush = ndeferred) {
		/* Lock the arena bin associated with the first object. */
		arena_chunk_t *chunk = (arena_chunk_t *)CHUNK_ADDR2BASE(
		    tbin->avail[0]);
		arena_t *arena = chunk->arena;
		arena_bin_t *bin = &arena->bins[binind];

		if (config_prof && arena == tcache->arena) {
			malloc_mutex_lock(&arena->lock);
			arena_prof_accum(arena, tcache->prof_accumbytes);
			malloc_mutex_unlock(&arena->lock);
			tcache->prof_accumbytes = 0;
		}

		malloc_mutex_lock(&bin->lock);
		if (config_stats && arena == tcache->arena) {
			assert(merged_stats == false);
			merged_stats = true;
			bin->stats.nflushes++;
			bin->stats.nrequests += tbin->tstats.nrequests;
			tbin->tstats.nrequests = 0;
		}
		ndeferred = 0;
		for (i = 0; i < nflush; i++) {
			ptr = tbin->avail[i];
			assert(ptr != NULL);
			chunk = (arena_chunk_t *)CHUNK_ADDR2BASE(ptr);
			if (chunk->arena == arena) {
				size_t pageind = ((uintptr_t)ptr -
				    (uintptr_t)chunk) >> LG_PAGE;
				arena_chunk_map_t *mapelm =
				    arena_mapp_get(chunk, pageind);
				if (config_fill && opt_junk) {
					arena_alloc_junk_small(ptr,
					    &arena_bin_info[binind], true);
				}
				arena_dalloc_bin_locked(arena, chunk, ptr,
				    mapelm);
			} else {
				/*
				 * This object was allocated via a different
				 * arena bin than the one that is currently
				 * locked.  Stash the object, so that it can be
				 * handled in a future pass.
				 */
				tbin->avail[ndeferred] = ptr;
				ndeferred++;
			}
		}
		malloc_mutex_unlock(&bin->lock);
	}
	if (config_stats && merged_stats == false) {
		/*
		 * The flush loop didn't happen to flush to this thread's
		 * arena, so the stats didn't get merged.  Manually do so now.
		 */
		arena_bin_t *bin = &tcache->arena->bins[binind];
		malloc_mutex_lock(&bin->lock);
		bin->stats.nflushes++;
		bin->stats.nrequests += tbin->tstats.nrequests;
		tbin->tstats.nrequests = 0;
		malloc_mutex_unlock(&bin->lock);
	}

	memmove(tbin->avail, &tbin->avail[tbin->ncached - rem],
	    rem * sizeof(void *));
	tbin->ncached = rem;
	if ((int)tbin->ncached < tbin->low_water)
		tbin->low_water = tbin->ncached;
}

void
tcache_bin_flush_large(tcache_bin_t *tbin, size_t binind, unsigned rem,
    tcache_t *tcache)
{
	void *ptr;
	unsigned i, nflush, ndeferred;
	bool merged_stats = false;

	assert(binind < nhbins);
	assert(rem <= tbin->ncached);

	for (nflush = tbin->ncached - rem; nflush > 0; nflush = ndeferred) {
		/* Lock the arena associated with the first object. */
		arena_chunk_t *chunk = (arena_chunk_t *)CHUNK_ADDR2BASE(
		    tbin->avail[0]);
		arena_t *arena = chunk->arena;

		malloc_mutex_lock(&arena->lock);
		if ((config_prof || config_stats) && arena == tcache->arena) {
			if (config_prof) {
				arena_prof_accum(arena,
				    tcache->prof_accumbytes);
				tcache->prof_accumbytes = 0;
			}
			if (config_stats) {
				merged_stats = true;
				arena->stats.nrequests_large +=
				    tbin->tstats.nrequests;
				arena->stats.lstats[binind - NBINS].nrequests +=
				    tbin->tstats.nrequests;
				tbin->tstats.nrequests = 0;
			}
		}
		ndeferred = 0;
		for (i = 0; i < nflush; i++) {
			ptr = tbin->avail[i];
			assert(ptr != NULL);
			chunk = (arena_chunk_t *)CHUNK_ADDR2BASE(ptr);
			if (chunk->arena == arena)
				arena_dalloc_large_locked(arena, chunk, ptr);
			else {
				/*
				 * This object was allocated via a different
				 * arena than the one that is currently locked.
				 * Stash the object, so that it can be handled
				 * in a future pass.
				 */
				tbin->avail[ndeferred] = ptr;
				ndeferred++;
			}
		}
		malloc_mutex_unlock(&arena->lock);
	}
	if (config_stats && merged_stats == false) {
		/*
		 * The flush loop didn't happen to flush to this thread's
		 * arena, so the stats didn't get merged.  Manually do so now.
		 */
		arena_t *arena = tcache->arena;
		malloc_mutex_lock(&arena->lock);
		arena->stats.nrequests_large += tbin->tstats.nrequests;
		arena->stats.lstats[binind - NBINS].nrequests +=
		    tbin->tstats.nrequests;
		tbin->tstats.nrequests = 0;
		malloc_mutex_unlock(&arena->lock);
	}

	memmove(tbin->avail, &tbin->avail[tbin->ncached - rem],
	    rem * sizeof(void *));
	tbin->ncached = rem;
	if ((int)tbin->ncached < tbin->low_water)
		tbin->low_water = tbin->ncached;
}

void
tcache_arena_associate(tcache_t *tcache, arena_t *arena)
{

	if (config_stats) {
		/* Link into list of extant tcaches. */
		malloc_mutex_lock(&arena->lock);
		ql_elm_new(tcache, link);
		ql_tail_insert(&arena->tcache_ql, tcache, link);
		malloc_mutex_unlock(&arena->lock);
	}
	tcache->arena = arena;
}

void
tcache_arena_dissociate(tcache_t *tcache)
{

	if (config_stats) {
		/* Unlink from list of extant tcaches. */
		malloc_mutex_lock(&tcache->arena->lock);
		ql_remove(&tcache->arena->tcache_ql, tcache, link);
		malloc_mutex_unlock(&tcache->arena->lock);
		tcache_stats_merge(tcache, tcache->arena);
	}
}

tcache_t *
tcache_create(arena_t *arena)
{
	tcache_t *tcache;
	size_t size, stack_offset;
	unsigned i;

	size = offsetof(tcache_t, tbins) + (sizeof(tcache_bin_t) * nhbins);
	/* Naturally align the pointer stacks. */
	size = PTR_CEILING(size);
	stack_offset = size;
	size += stack_nelms * sizeof(void *);
	/*
	 * Round up to the nearest multiple of the cacheline size, in order to
	 * avoid the possibility of false cacheline sharing.
	 *
	 * That this works relies on the same logic as in ipalloc(), but we
	 * cannot directly call ipalloc() here due to tcache bootstrapping
	 * issues.
	 */
	size = (size + CACHELINE_MASK) & (-CACHELINE);

	if (size <= SMALL_MAXCLASS)
		tcache = (tcache_t *)arena_malloc_small(arena, size, true);
	else if (size <= tcache_maxclass)
		tcache = (tcache_t *)arena_malloc_large(arena, size, true);
	else
		tcache = (tcache_t *)icalloc(size);

	if (tcache == NULL)
		return (NULL);

	tcache_arena_associate(tcache, arena);

	assert((TCACHE_NSLOTS_SMALL_MAX & 1U) == 0);
	for (i = 0; i < nhbins; i++) {
		tcache->tbins[i].lg_fill_div = 1;
		tcache->tbins[i].avail = (void **)((uintptr_t)tcache +
		    (uintptr_t)stack_offset);
		stack_offset += tcache_bin_info[i].ncached_max * sizeof(void *);
	}

	tcache_tsd_set(&tcache);

	return (tcache);
}

void
tcache_destroy(tcache_t *tcache)
{
	unsigned i;
	size_t tcache_size;

	tcache_arena_dissociate(tcache);

	for (i = 0; i < NBINS; i++) {
		tcache_bin_t *tbin = &tcache->tbins[i];
		tcache_bin_flush_small(tbin, i, 0, tcache);

		if (config_stats && tbin->tstats.nrequests != 0) {
			arena_t *arena = tcache->arena;
			arena_bin_t *bin = &arena->bins[i];
			malloc_mutex_lock(&bin->lock);
			bin->stats.nrequests += tbin->tstats.nrequests;
			malloc_mutex_unlock(&bin->lock);
		}
	}

	for (; i < nhbins; i++) {
		tcache_bin_t *tbin = &tcache->tbins[i];
		tcache_bin_flush_large(tbin, i, 0, tcache);

		if (config_stats && tbin->tstats.nrequests != 0) {
			arena_t *arena = tcache->arena;
			malloc_mutex_lock(&arena->lock);
			arena->stats.nrequests_large += tbin->tstats.nrequests;
			arena->stats.lstats[i - NBINS].nrequests +=
			    tbin->tstats.nrequests;
			malloc_mutex_unlock(&arena->lock);
		}
	}

	if (config_prof && tcache->prof_accumbytes > 0) {
		malloc_mutex_lock(&tcache->arena->lock);
		arena_prof_accum(tcache->arena, tcache->prof_accumbytes);
		malloc_mutex_unlock(&tcache->arena->lock);
	}

	tcache_size = arena_salloc(tcache, false);
	if (tcache_size <= SMALL_MAXCLASS) {
		arena_chunk_t *chunk = CHUNK_ADDR2BASE(tcache);
		arena_t *arena = chunk->arena;
		size_t pageind = ((uintptr_t)tcache - (uintptr_t)chunk) >>
		    LG_PAGE;
		arena_chunk_map_t *mapelm = arena_mapp_get(chunk, pageind);

		arena_dalloc_bin(arena, chunk, tcache, pageind, mapelm);
	} else if (tcache_size <= tcache_maxclass) {
		arena_chunk_t *chunk = CHUNK_ADDR2BASE(tcache);
		arena_t *arena = chunk->arena;

		arena_dalloc_large(arena, chunk, tcache);
	} else
		idalloc(tcache);
}

void
tcache_thread_cleanup(void *arg)
{
	tcache_t *tcache = *(tcache_t **)arg;

	if (tcache == TCACHE_STATE_DISABLED) {
		/* Do nothing. */
	} else if (tcache == TCACHE_STATE_REINCARNATED) {
		/*
		 * Another destructor called an allocator function after this
		 * destructor was called.  Reset tcache to
		 * TCACHE_STATE_PURGATORY in order to receive another callback.
		 */
		tcache = TCACHE_STATE_PURGATORY;
		tcache_tsd_set(&tcache);
	} else if (tcache == TCACHE_STATE_PURGATORY) {
		/*
		 * The previous time this destructor was called, we set the key
		 * to TCACHE_STATE_PURGATORY so that other destructors wouldn't
		 * cause re-creation of the tcache.  This time, do nothing, so
		 * that the destructor will not be called again.
		 */
	} else if (tcache != NULL) {
		assert(tcache != TCACHE_STATE_PURGATORY);
		tcache_destroy(tcache);
		tcache = TCACHE_STATE_PURGATORY;
		tcache_tsd_set(&tcache);
	}
}

void
tcache_stats_merge(tcache_t *tcache, arena_t *arena)
{
	unsigned i;

	/* Merge and reset tcache stats. */
	for (i = 0; i < NBINS; i++) {
		arena_bin_t *bin = &arena->bins[i];
		tcache_bin_t *tbin = &tcache->tbins[i];
		malloc_mutex_lock(&bin->lock);
		bin->stats.nrequests += tbin->tstats.nrequests;
		malloc_mutex_unlock(&bin->lock);
		tbin->tstats.nrequests = 0;
	}

	for (; i < nhbins; i++) {
		malloc_large_stats_t *lstats = &arena->stats.lstats[i - NBINS];
		tcache_bin_t *tbin = &tcache->tbins[i];
		arena->stats.nrequests_large += tbin->tstats.nrequests;
		lstats->nrequests += tbin->tstats.nrequests;
		tbin->tstats.nrequests = 0;
	}
}

bool
tcache_boot0(void)
{
	unsigned i;

	/*
	 * If necessary, clamp opt_lg_tcache_max, now that arena_maxclass is
	 * known.
	 */
	if (opt_lg_tcache_max < 0 || (1U << opt_lg_tcache_max) < SMALL_MAXCLASS)
		tcache_maxclass = SMALL_MAXCLASS;
	else if ((1U << opt_lg_tcache_max) > arena_maxclass)
		tcache_maxclass = arena_maxclass;
	else
		tcache_maxclass = (1U << opt_lg_tcache_max);

	nhbins = NBINS + (tcache_maxclass >> LG_PAGE);

	/* Initialize tcache_bin_info. */
	tcache_bin_info = (tcache_bin_info_t *)base_alloc(nhbins *
	    sizeof(tcache_bin_info_t));
	if (tcache_bin_info == NULL)
		return (true);
	stack_nelms = 0;
	for (i = 0; i < NBINS; i++) {
		if ((arena_bin_info[i].nregs << 1) <= TCACHE_NSLOTS_SMALL_MAX) {
			tcache_bin_info[i].ncached_max =
			    (arena_bin_info[i].nregs << 1);
		} else {
			tcache_bin_info[i].ncached_max =
			    TCACHE_NSLOTS_SMALL_MAX;
		}
		stack_nelms += tcache_bin_info[i].ncached_max;
	}
	for (; i < nhbins; i++) {
		tcache_bin_info[i].ncached_max = TCACHE_NSLOTS_LARGE;
		stack_nelms += tcache_bin_info[i].ncached_max;
	}

	return (false);
}

bool
tcache_boot1(void)
{

	if (tcache_tsd_boot() || tcache_enabled_tsd_boot())
		return (true);

	return (false);
}
Commit	Line	Data
a78e148b	1	#define JEMALLOC_TCACHE_C_
a78e148b	2	#include "jemalloc/internal/jemalloc_internal.h"
ad4c0b41	3
a78e148b	4	/******************************************************************************/
	5	/* Data. */
	6
ad4c0b41	7	malloc_tsd_data(, tcache, tcache_t *, NULL)
	8	malloc_tsd_data(, tcache_enabled, tcache_enabled_t, tcache_enabled_default)
	9
a78e148b	10	bool opt_tcache = true;
a78e148b	11	ssize_t opt_lg_tcache_max = LG_TCACHE_MAXCLASS_DEFAULT;
a78e148b	12
	13	tcache_bin_info_t *tcache_bin_info;
	14	static unsigned stack_nelms; /* Total stack elms per tcache. */
	15
ad4c0b41	16	size_t nhbins;
ad4c0b41	17	size_t tcache_maxclass;
a78e148b	18
ad4c0b41	19	/******************************************************************************/
a78e148b	20
ad4c0b41	21	size_t tcache_salloc(const void *ptr)
ad4c0b41	22	{
a78e148b	23
ad4c0b41	24	return (arena_salloc(ptr, false));
ad4c0b41	25	}
a78e148b	26
ad4c0b41	27	void
	28	tcache_event_hard(tcache_t *tcache)
	29	{
	30	size_t binind = tcache->next_gc_bin;
	31	tcache_bin_t *tbin = &tcache->tbins[binind];
	32	tcache_bin_info_t *tbin_info = &tcache_bin_info[binind];
a78e148b	33
ad4c0b41	34	if (tbin->low_water > 0) {
	35	/*
	36	* Flush (ceiling) 3/4 of the objects below the low water mark.
	37	*/
	38	if (binind < NBINS) {
	39	tcache_bin_flush_small(tbin, binind, tbin->ncached -
	40	tbin->low_water + (tbin->low_water >> 2), tcache);
	41	} else {
	42	tcache_bin_flush_large(tbin, binind, tbin->ncached -
	43	tbin->low_water + (tbin->low_water >> 2), tcache);
	44	}
	45	/*
	46	* Reduce fill count by 2X. Limit lg_fill_div such that the
	47	* fill count is always at least 1.
	48	*/
	49	if ((tbin_info->ncached_max >> (tbin->lg_fill_div+1)) >= 1)
	50	tbin->lg_fill_div++;
	51	} else if (tbin->low_water < 0) {
	52	/*
	53	* Increase fill count by 2X. Make sure lg_fill_div stays
	54	* greater than 0.
	55	*/
	56	if (tbin->lg_fill_div > 1)
	57	tbin->lg_fill_div--;
	58	}
	59	tbin->low_water = tbin->ncached;
	60
	61	tcache->next_gc_bin++;
	62	if (tcache->next_gc_bin == nhbins)
	63	tcache->next_gc_bin = 0;
	64	tcache->ev_cnt = 0;
	65	}
a78e148b	66
	67	void *
	68	tcache_alloc_small_hard(tcache_t tcache, tcache_bin_t tbin, size_t binind)
	69	{
	70	void *ret;
	71
ad4c0b41	72	arena_tcache_fill_small(tcache->arena, tbin, binind,
	73	config_prof ? tcache->prof_accumbytes : 0);
	74	if (config_prof)
	75	tcache->prof_accumbytes = 0;
a78e148b	76	ret = tcache_alloc_easy(tbin);
	77
	78	return (ret);
	79	}
	80
	81	void
ad4c0b41	82	tcache_bin_flush_small(tcache_bin_t *tbin, size_t binind, unsigned rem,
ad4c0b41	83	tcache_t *tcache)
a78e148b	84	{
	85	void *ptr;
	86	unsigned i, nflush, ndeferred;
a78e148b	87	bool merged_stats = false;
a78e148b	88
ad4c0b41	89	assert(binind < NBINS);
a78e148b	90	assert(rem <= tbin->ncached);
	91
	92	for (nflush = tbin->ncached - rem; nflush > 0; nflush = ndeferred) {
	93	/* Lock the arena bin associated with the first object. */
	94	arena_chunk_t chunk = (arena_chunk_t )CHUNK_ADDR2BASE(
	95	tbin->avail[0]);
	96	arena_t *arena = chunk->arena;
	97	arena_bin_t *bin = &arena->bins[binind];
	98
ad4c0b41	99	if (config_prof && arena == tcache->arena) {
a78e148b	100	malloc_mutex_lock(&arena->lock);
	101	arena_prof_accum(arena, tcache->prof_accumbytes);
	102	malloc_mutex_unlock(&arena->lock);
	103	tcache->prof_accumbytes = 0;
	104	}
a78e148b	105
a78e148b	106	malloc_mutex_lock(&bin->lock);
ad4c0b41	107	if (config_stats && arena == tcache->arena) {
a78e148b	108	assert(merged_stats == false);
	109	merged_stats = true;
	110	bin->stats.nflushes++;
	111	bin->stats.nrequests += tbin->tstats.nrequests;
	112	tbin->tstats.nrequests = 0;
	113	}
a78e148b	114	ndeferred = 0;
	115	for (i = 0; i < nflush; i++) {
	116	ptr = tbin->avail[i];
	117	assert(ptr != NULL);
	118	chunk = (arena_chunk_t *)CHUNK_ADDR2BASE(ptr);
	119	if (chunk->arena == arena) {
	120	size_t pageind = ((uintptr_t)ptr -
ad4c0b41	121	(uintptr_t)chunk) >> LG_PAGE;
a78e148b	122	arena_chunk_map_t *mapelm =
ad4c0b41	123	arena_mapp_get(chunk, pageind);
	124	if (config_fill && opt_junk) {
	125	arena_alloc_junk_small(ptr,
	126	&arena_bin_info[binind], true);
	127	}
	128	arena_dalloc_bin_locked(arena, chunk, ptr,
	129	mapelm);
a78e148b	130	} else {
	131	/*
	132	* This object was allocated via a different
	133	* arena bin than the one that is currently
	134	* locked. Stash the object, so that it can be
	135	* handled in a future pass.
	136	*/
	137	tbin->avail[ndeferred] = ptr;
	138	ndeferred++;
	139	}
	140	}
	141	malloc_mutex_unlock(&bin->lock);
	142	}
ad4c0b41	143	if (config_stats && merged_stats == false) {
a78e148b	144	/*
	145	* The flush loop didn't happen to flush to this thread's
	146	* arena, so the stats didn't get merged. Manually do so now.
	147	*/
	148	arena_bin_t *bin = &tcache->arena->bins[binind];
	149	malloc_mutex_lock(&bin->lock);
	150	bin->stats.nflushes++;
	151	bin->stats.nrequests += tbin->tstats.nrequests;
	152	tbin->tstats.nrequests = 0;
	153	malloc_mutex_unlock(&bin->lock);
	154	}
a78e148b	155
	156	memmove(tbin->avail, &tbin->avail[tbin->ncached - rem],
	157	rem * sizeof(void *));
	158	tbin->ncached = rem;
	159	if ((int)tbin->ncached < tbin->low_water)
	160	tbin->low_water = tbin->ncached;
	161	}
	162
	163	void
ad4c0b41	164	tcache_bin_flush_large(tcache_bin_t *tbin, size_t binind, unsigned rem,
ad4c0b41	165	tcache_t *tcache)
a78e148b	166	{
	167	void *ptr;
	168	unsigned i, nflush, ndeferred;
a78e148b	169	bool merged_stats = false;
a78e148b	170
	171	assert(binind < nhbins);
	172	assert(rem <= tbin->ncached);
	173
	174	for (nflush = tbin->ncached - rem; nflush > 0; nflush = ndeferred) {
	175	/* Lock the arena associated with the first object. */
	176	arena_chunk_t chunk = (arena_chunk_t )CHUNK_ADDR2BASE(
	177	tbin->avail[0]);
	178	arena_t *arena = chunk->arena;
	179
	180	malloc_mutex_lock(&arena->lock);
ad4c0b41	181	if ((config_prof \|\| config_stats) && arena == tcache->arena) {
	182	if (config_prof) {
	183	arena_prof_accum(arena,
	184	tcache->prof_accumbytes);
	185	tcache->prof_accumbytes = 0;
	186	}
	187	if (config_stats) {
	188	merged_stats = true;
	189	arena->stats.nrequests_large +=
	190	tbin->tstats.nrequests;
	191	arena->stats.lstats[binind - NBINS].nrequests +=
	192	tbin->tstats.nrequests;
	193	tbin->tstats.nrequests = 0;
	194	}
a78e148b	195	}
a78e148b	196	ndeferred = 0;
	197	for (i = 0; i < nflush; i++) {
	198	ptr = tbin->avail[i];
	199	assert(ptr != NULL);
	200	chunk = (arena_chunk_t *)CHUNK_ADDR2BASE(ptr);
	201	if (chunk->arena == arena)
ad4c0b41	202	arena_dalloc_large_locked(arena, chunk, ptr);
a78e148b	203	else {
	204	/*
	205	* This object was allocated via a different
	206	* arena than the one that is currently locked.
	207	* Stash the object, so that it can be handled
	208	* in a future pass.
	209	*/
	210	tbin->avail[ndeferred] = ptr;
	211	ndeferred++;
	212	}
	213	}
	214	malloc_mutex_unlock(&arena->lock);
	215	}
ad4c0b41	216	if (config_stats && merged_stats == false) {
a78e148b	217	/*
	218	* The flush loop didn't happen to flush to this thread's
	219	* arena, so the stats didn't get merged. Manually do so now.
	220	*/
	221	arena_t *arena = tcache->arena;
	222	malloc_mutex_lock(&arena->lock);
	223	arena->stats.nrequests_large += tbin->tstats.nrequests;
ad4c0b41	224	arena->stats.lstats[binind - NBINS].nrequests +=
a78e148b	225	tbin->tstats.nrequests;
	226	tbin->tstats.nrequests = 0;
	227	malloc_mutex_unlock(&arena->lock);
	228	}
a78e148b	229
	230	memmove(tbin->avail, &tbin->avail[tbin->ncached - rem],
	231	rem * sizeof(void *));
	232	tbin->ncached = rem;
	233	if ((int)tbin->ncached < tbin->low_water)
	234	tbin->low_water = tbin->ncached;
	235	}
	236
ad4c0b41	237	void
	238	tcache_arena_associate(tcache_t tcache, arena_t arena)
	239	{
	240
	241	if (config_stats) {
	242	/* Link into list of extant tcaches. */
	243	malloc_mutex_lock(&arena->lock);
	244	ql_elm_new(tcache, link);
	245	ql_tail_insert(&arena->tcache_ql, tcache, link);
	246	malloc_mutex_unlock(&arena->lock);
	247	}
	248	tcache->arena = arena;
	249	}
	250
	251	void
	252	tcache_arena_dissociate(tcache_t *tcache)
	253	{
	254
	255	if (config_stats) {
	256	/* Unlink from list of extant tcaches. */
	257	malloc_mutex_lock(&tcache->arena->lock);
	258	ql_remove(&tcache->arena->tcache_ql, tcache, link);
	259	malloc_mutex_unlock(&tcache->arena->lock);
	260	tcache_stats_merge(tcache, tcache->arena);
	261	}
	262	}
	263
a78e148b	264	tcache_t *
	265	tcache_create(arena_t *arena)
	266	{
	267	tcache_t *tcache;
	268	size_t size, stack_offset;
	269	unsigned i;
	270
	271	size = offsetof(tcache_t, tbins) + (sizeof(tcache_bin_t) * nhbins);
	272	/* Naturally align the pointer stacks. */
	273	size = PTR_CEILING(size);
	274	stack_offset = size;
	275	size += stack_nelms * sizeof(void *);
	276	/*
	277	* Round up to the nearest multiple of the cacheline size, in order to
	278	* avoid the possibility of false cacheline sharing.
	279	*
	280	* That this works relies on the same logic as in ipalloc(), but we
	281	* cannot directly call ipalloc() here due to tcache bootstrapping
	282	* issues.
	283	*/
	284	size = (size + CACHELINE_MASK) & (-CACHELINE);
	285
ad4c0b41	286	if (size <= SMALL_MAXCLASS)
a78e148b	287	tcache = (tcache_t *)arena_malloc_small(arena, size, true);
	288	else if (size <= tcache_maxclass)
	289	tcache = (tcache_t *)arena_malloc_large(arena, size, true);
	290	else
	291	tcache = (tcache_t *)icalloc(size);
	292
	293	if (tcache == NULL)
	294	return (NULL);
	295
ad4c0b41	296	tcache_arena_associate(tcache, arena);
a78e148b	297
a78e148b	298	assert((TCACHE_NSLOTS_SMALL_MAX & 1U) == 0);
	299	for (i = 0; i < nhbins; i++) {
	300	tcache->tbins[i].lg_fill_div = 1;
	301	tcache->tbins[i].avail = (void **)((uintptr_t)tcache +
	302	(uintptr_t)stack_offset);
	303	stack_offset += tcache_bin_info[i].ncached_max * sizeof(void *);
	304	}
	305
ad4c0b41	306	tcache_tsd_set(&tcache);
a78e148b	307
	308	return (tcache);
	309	}
	310
	311	void
	312	tcache_destroy(tcache_t *tcache)
	313	{
	314	unsigned i;
	315	size_t tcache_size;
	316
ad4c0b41	317	tcache_arena_dissociate(tcache);
a78e148b	318
ad4c0b41	319	for (i = 0; i < NBINS; i++) {
a78e148b	320	tcache_bin_t *tbin = &tcache->tbins[i];
ad4c0b41	321	tcache_bin_flush_small(tbin, i, 0, tcache);
	322
	323	if (config_stats && tbin->tstats.nrequests != 0) {
a78e148b	324	arena_t *arena = tcache->arena;
	325	arena_bin_t *bin = &arena->bins[i];
	326	malloc_mutex_lock(&bin->lock);
	327	bin->stats.nrequests += tbin->tstats.nrequests;
	328	malloc_mutex_unlock(&bin->lock);
	329	}
a78e148b	330	}
	331
	332	for (; i < nhbins; i++) {
	333	tcache_bin_t *tbin = &tcache->tbins[i];
ad4c0b41	334	tcache_bin_flush_large(tbin, i, 0, tcache);
	335
	336	if (config_stats && tbin->tstats.nrequests != 0) {
a78e148b	337	arena_t *arena = tcache->arena;
	338	malloc_mutex_lock(&arena->lock);
	339	arena->stats.nrequests_large += tbin->tstats.nrequests;
ad4c0b41	340	arena->stats.lstats[i - NBINS].nrequests +=
a78e148b	341	tbin->tstats.nrequests;
	342	malloc_mutex_unlock(&arena->lock);
	343	}
a78e148b	344	}
a78e148b	345
ad4c0b41	346	if (config_prof && tcache->prof_accumbytes > 0) {
a78e148b	347	malloc_mutex_lock(&tcache->arena->lock);
	348	arena_prof_accum(tcache->arena, tcache->prof_accumbytes);
	349	malloc_mutex_unlock(&tcache->arena->lock);
	350	}
a78e148b	351
ad4c0b41	352	tcache_size = arena_salloc(tcache, false);
ad4c0b41	353	if (tcache_size <= SMALL_MAXCLASS) {
a78e148b	354	arena_chunk_t *chunk = CHUNK_ADDR2BASE(tcache);
	355	arena_t *arena = chunk->arena;
	356	size_t pageind = ((uintptr_t)tcache - (uintptr_t)chunk) >>
ad4c0b41	357	LG_PAGE;
ad4c0b41	358	arena_chunk_map_t *mapelm = arena_mapp_get(chunk, pageind);
a78e148b	359
ad4c0b41	360	arena_dalloc_bin(arena, chunk, tcache, pageind, mapelm);
a78e148b	361	} else if (tcache_size <= tcache_maxclass) {
	362	arena_chunk_t *chunk = CHUNK_ADDR2BASE(tcache);
	363	arena_t *arena = chunk->arena;
	364
a78e148b	365	arena_dalloc_large(arena, chunk, tcache);
a78e148b	366	} else
	367	idalloc(tcache);
	368	}
	369
ad4c0b41	370	void
a78e148b	371	tcache_thread_cleanup(void *arg)
a78e148b	372	{
ad4c0b41	373	tcache_t tcache = (tcache_t **)arg;
a78e148b	374
ad4c0b41	375	if (tcache == TCACHE_STATE_DISABLED) {
	376	/* Do nothing. */
	377	} else if (tcache == TCACHE_STATE_REINCARNATED) {
a78e148b	378	/*
ad4c0b41	379	* Another destructor called an allocator function after this
	380	* destructor was called. Reset tcache to
	381	* TCACHE_STATE_PURGATORY in order to receive another callback.
a78e148b	382	*/
ad4c0b41	383	tcache = TCACHE_STATE_PURGATORY;
	384	tcache_tsd_set(&tcache);
	385	} else if (tcache == TCACHE_STATE_PURGATORY) {
a78e148b	386	/*
ad4c0b41	387	* The previous time this destructor was called, we set the key
	388	* to TCACHE_STATE_PURGATORY so that other destructors wouldn't
	389	* cause re-creation of the tcache. This time, do nothing, so
	390	* that the destructor will not be called again.
a78e148b	391	*/
a78e148b	392	} else if (tcache != NULL) {
ad4c0b41	393	assert(tcache != TCACHE_STATE_PURGATORY);
a78e148b	394	tcache_destroy(tcache);
ad4c0b41	395	tcache = TCACHE_STATE_PURGATORY;
ad4c0b41	396	tcache_tsd_set(&tcache);
a78e148b	397	}
	398	}
	399
a78e148b	400	void
	401	tcache_stats_merge(tcache_t tcache, arena_t arena)
	402	{
	403	unsigned i;
	404
	405	/* Merge and reset tcache stats. */
ad4c0b41	406	for (i = 0; i < NBINS; i++) {
a78e148b	407	arena_bin_t *bin = &arena->bins[i];
	408	tcache_bin_t *tbin = &tcache->tbins[i];
	409	malloc_mutex_lock(&bin->lock);
	410	bin->stats.nrequests += tbin->tstats.nrequests;
	411	malloc_mutex_unlock(&bin->lock);
	412	tbin->tstats.nrequests = 0;
	413	}
	414
	415	for (; i < nhbins; i++) {
ad4c0b41	416	malloc_large_stats_t *lstats = &arena->stats.lstats[i - NBINS];
a78e148b	417	tcache_bin_t *tbin = &tcache->tbins[i];
	418	arena->stats.nrequests_large += tbin->tstats.nrequests;
	419	lstats->nrequests += tbin->tstats.nrequests;
	420	tbin->tstats.nrequests = 0;
	421	}
	422	}
a78e148b	423
a78e148b	424	bool
ad4c0b41	425	tcache_boot0(void)
a78e148b	426	{
ad4c0b41	427	unsigned i;
a78e148b	428
ad4c0b41	429	/*
	430	* If necessary, clamp opt_lg_tcache_max, now that arena_maxclass is
	431	* known.
	432	*/
	433	if (opt_lg_tcache_max < 0 \|\| (1U << opt_lg_tcache_max) < SMALL_MAXCLASS)
	434	tcache_maxclass = SMALL_MAXCLASS;
	435	else if ((1U << opt_lg_tcache_max) > arena_maxclass)
	436	tcache_maxclass = arena_maxclass;
	437	else
	438	tcache_maxclass = (1U << opt_lg_tcache_max);
	439
	440	nhbins = NBINS + (tcache_maxclass >> LG_PAGE);
	441
	442	/* Initialize tcache_bin_info. */
	443	tcache_bin_info = (tcache_bin_info_t )base_alloc(nhbins
	444	sizeof(tcache_bin_info_t));
	445	if (tcache_bin_info == NULL)
	446	return (true);
	447	stack_nelms = 0;
	448	for (i = 0; i < NBINS; i++) {
	449	if ((arena_bin_info[i].nregs << 1) <= TCACHE_NSLOTS_SMALL_MAX) {
	450	tcache_bin_info[i].ncached_max =
	451	(arena_bin_info[i].nregs << 1);
	452	} else {
	453	tcache_bin_info[i].ncached_max =
	454	TCACHE_NSLOTS_SMALL_MAX;
a78e148b	455	}
ad4c0b41	456	stack_nelms += tcache_bin_info[i].ncached_max;
	457	}
	458	for (; i < nhbins; i++) {
	459	tcache_bin_info[i].ncached_max = TCACHE_NSLOTS_LARGE;
	460	stack_nelms += tcache_bin_info[i].ncached_max;
a78e148b	461	}
	462
	463	return (false);
	464	}
ad4c0b41	465
	466	bool
	467	tcache_boot1(void)
	468	{
	469
	470	if (tcache_tsd_boot() \|\| tcache_enabled_tsd_boot())
	471	return (true);
	472
	473	return (false);
	474	}