romenskiy2012/jemalloc
1
0
Fork 0
mirror of https://github.com/jemalloc/jemalloc.git synced 2026-06-01 17:54:16 +03:00
Code Issues Projects Releases Packages Wiki Activity

Drop redundant tcache_t param from tcache_arena_{associate,dissociate,reassociate}

Browse source 
After tcache_init runs, tcache_slow->tcache == tcache always holds, so
the tcache_t parameter to the three association helpers is derivable
from tcache_slow.
This commit is contained in:
Slobodan Predolac 2026-05-08 10:10:04 -07:00
parent 0a158af398
commit 46e57a6237
3 changed files with 23 additions and 23 deletions
Download patch file Download diff file Expand all files Collapse all files

11
include/jemalloc/internal/jemalloc_internal_inlines_b.h
View file

@ -9,11 +9,13 @@
static inline void
thread_migrate_arena(tsd_t *tsd, arena_t *oldarena, arena_t *newarena) {
assert(oldarena != NULL);
assert(newarena != NULL);
arena_migrate(tsd, oldarena, newarena);
if (tcache_available(tsd)) {
tcache_arena_reassociate(tsd_tsdn(tsd),
tsd_tcache_slowp_get(tsd), tsd_tcachep_get(tsd),
newarena);
tsd_tcache_slowp_get(tsd), newarena);
}
}
@ -53,18 +55,17 @@ arena_choose_impl(tsd_t *tsd, arena_t *arena, bool internal) {
assert(ret);
if (tcache_available(tsd)) {
tcache_slow_t *tcache_slow = tsd_tcache_slowp_get(tsd);
tcache_t *tcache = tsd_tcachep_get(tsd);
if (tcache_slow->arena != NULL) {
/* See comments in tsd_tcache_data_init().*/
assert(tcache_slow->arena
== arena_get(tsd_tsdn(tsd), 0, false));
if (tcache_slow->arena != ret) {
tcache_arena_reassociate(tsd_tsdn(tsd),
tcache_slow, tcache, ret);
tcache_slow, ret);
}
} else {
tcache_arena_associate(
tsd_tsdn(tsd), tcache_slow, tcache, ret);
tsd_tsdn(tsd), tcache_slow, ret);
}
}
}

4
include/jemalloc/internal/tcache_externs.h
View file

@ -62,7 +62,7 @@ bool tcache_bins_ncached_max_write(tsd_t *tsd, char *settings, size_t len);
bool tcache_bin_ncached_max_read(
tsd_t *tsd, size_t bin_size, cache_bin_sz_t *ncached_max);
void tcache_arena_reassociate(
tsdn_t *tsdn, tcache_slow_t *tcache_slow, tcache_t *tcache, arena_t *arena);
tsdn_t *tsdn, tcache_slow_t *tcache_slow, arena_t *arena);
tcache_t *tcache_create_explicit(tsd_t *tsd);
bool thread_tcache_max_set(tsd_t *tsd, size_t tcache_max);
void tcache_cleanup(tsd_t *tsd);
@ -73,7 +73,7 @@ void tcaches_flush(tsd_t *tsd, unsigned ind);
void tcaches_destroy(tsd_t *tsd, unsigned ind);
bool tcache_boot(tsdn_t *tsdn, base_t *base);
void tcache_arena_associate(
tsdn_t *tsdn, tcache_slow_t *tcache_slow, tcache_t *tcache, arena_t *arena);
tsdn_t *tsdn, tcache_slow_t *tcache_slow, arena_t *arena);
void tcache_arena_postfork_child(tsdn_t *tsdn, arena_t *arena);
void tcache_prefork(tsdn_t *tsdn);
void tcache_postfork_parent(tsdn_t *tsdn);

31
src/tcache.c
View file

@ -725,30 +725,30 @@ tcache_bin_ncached_max_read(
* (single-threaded, mutex re-init pending).
*/
static void
tcache_arena_link(arena_t *arena, tcache_slow_t *tcache_slow,
tcache_t *tcache) {
tcache_arena_link(arena_t *arena, tcache_slow_t *tcache_slow) {
assert(tcache_slow->tcache != NULL);
cache_bin_array_descriptor_init(
&tcache_slow->cache_bin_array_descriptor, tcache->bins);
&tcache_slow->cache_bin_array_descriptor,
tcache_slow->tcache->bins);
ql_tail_insert(&arena->cache_bin_array_descriptor_ql,
&tcache_slow->cache_bin_array_descriptor, link);
}
void
tcache_arena_associate(tsdn_t *tsdn, tcache_slow_t *tcache_slow,
tcache_t *tcache, arena_t *arena) {
arena_t *arena) {
assert(tcache_slow->arena == NULL);
tcache_slow->arena = arena;
if (config_stats) {
malloc_mutex_lock(tsdn, &arena->cache_bin_array_descriptor_ql_mtx);
tcache_arena_link(arena, tcache_slow, tcache);
tcache_arena_link(arena, tcache_slow);
malloc_mutex_unlock(tsdn, &arena->cache_bin_array_descriptor_ql_mtx);
}
}
static void
tcache_arena_dissociate(
tsdn_t *tsdn, tcache_slow_t *tcache_slow, tcache_t *tcache) {
tcache_arena_dissociate(tsdn_t *tsdn, tcache_slow_t *tcache_slow) {
arena_t *arena = tcache_slow->arena;
assert(arena != NULL);
if (config_stats) {
@ -777,9 +777,9 @@ tcache_arena_dissociate(
void
tcache_arena_reassociate(tsdn_t *tsdn, tcache_slow_t *tcache_slow,
tcache_t *tcache, arena_t *arena) {
tcache_arena_dissociate(tsdn, tcache_slow, tcache);
tcache_arena_associate(tsdn, tcache_slow, tcache, arena);
arena_t *arena) {
tcache_arena_dissociate(tsdn, tcache_slow);
tcache_arena_associate(tsdn, tcache_slow, arena);
}
void
@ -790,7 +790,7 @@ tcache_arena_postfork_child(tsdn_t *tsdn, arena_t *arena) {
ql_new(&arena->cache_bin_array_descriptor_ql);
tcache_slow_t *tcache_slow = tcache_slow_get(tsdn_tsd(tsdn));
if (tcache_slow != NULL && tcache_slow->arena == arena) {
tcache_arena_link(arena, tcache_slow, tcache_slow->tcache);
tcache_arena_link(arena, tcache_slow);
}
}
@ -981,8 +981,7 @@ tsd_tcache_data_init_impl(
if (!malloc_initialized()) {
/* If in initialization, assign to a0. */
arena = arena_get(tsd_tsdn(tsd), 0, false);
tcache_arena_associate(
tsd_tsdn(tsd), tcache_slow, tcache, arena);
tcache_arena_associate(tsd_tsdn(tsd), tcache_slow, arena);
} else {
if (arena == NULL) {
arena = arena_choose(tsd, NULL);
@ -990,7 +989,7 @@ tsd_tcache_data_init_impl(
/* This may happen if thread.tcache.enabled is used. */
if (tcache_slow->arena == NULL) {
tcache_arena_associate(
tsd_tsdn(tsd), tcache_slow, tcache, arena);
tsd_tsdn(tsd), tcache_slow, arena);
}
}
assert(arena == tcache_slow->arena);
@ -1050,7 +1049,7 @@ tcache_create_explicit(tsd_t *tsd) {
tsd, tcache_slow, tcache, mem, tcache_get_default_ncached_max());
tcache_arena_associate(
tsd_tsdn(tsd), tcache_slow, tcache, arena_ichoose(tsd, NULL));
tsd_tsdn(tsd), tcache_slow, arena_ichoose(tsd, NULL));
return tcache;
}
@ -1222,7 +1221,7 @@ tcache_destroy(tsd_t *tsd, tcache_t *tcache, bool tsd_tcache) {
tcache_slow_t *tcache_slow = tcache->tcache_slow;
tcache_flush_cache(tsd, tcache);
arena_t *arena = tcache_slow->arena;
tcache_arena_dissociate(tsd_tsdn(tsd), tcache_slow, tcache);
tcache_arena_dissociate(tsd_tsdn(tsd), tcache_slow);
if (tsd_tcache) {
cache_bin_t *cache_bin = &tcache->bins[0];