Delete the mutex_pool module.
This commit is contained in:
parent
03d95cba88
commit
7dc77527ba
@ -128,7 +128,6 @@ C_SRCS := $(srcroot)src/jemalloc.c \
|
|||||||
$(srcroot)src/log.c \
|
$(srcroot)src/log.c \
|
||||||
$(srcroot)src/malloc_io.c \
|
$(srcroot)src/malloc_io.c \
|
||||||
$(srcroot)src/mutex.c \
|
$(srcroot)src/mutex.c \
|
||||||
$(srcroot)src/mutex_pool.c \
|
|
||||||
$(srcroot)src/nstime.c \
|
$(srcroot)src/nstime.c \
|
||||||
$(srcroot)src/pa.c \
|
$(srcroot)src/pa.c \
|
||||||
$(srcroot)src/pa_extra.c \
|
$(srcroot)src/pa_extra.c \
|
||||||
|
@ -2,7 +2,6 @@
|
|||||||
#define JEMALLOC_INTERNAL_EMAP_H
|
#define JEMALLOC_INTERNAL_EMAP_H
|
||||||
|
|
||||||
#include "jemalloc/internal/base.h"
|
#include "jemalloc/internal/base.h"
|
||||||
#include "jemalloc/internal/mutex_pool.h"
|
|
||||||
#include "jemalloc/internal/rtree.h"
|
#include "jemalloc/internal/rtree.h"
|
||||||
|
|
||||||
/*
|
/*
|
||||||
@ -17,8 +16,6 @@
|
|||||||
typedef struct emap_s emap_t;
|
typedef struct emap_s emap_t;
|
||||||
struct emap_s {
|
struct emap_s {
|
||||||
rtree_t rtree;
|
rtree_t rtree;
|
||||||
/* Keyed by the address of the edata_t being protected. */
|
|
||||||
mutex_pool_t mtx_pool;
|
|
||||||
};
|
};
|
||||||
|
|
||||||
/* Used to pass rtree lookup context down the path. */
|
/* Used to pass rtree lookup context down the path. */
|
||||||
|
@ -1,94 +0,0 @@
|
|||||||
#ifndef JEMALLOC_INTERNAL_MUTEX_POOL_H
|
|
||||||
#define JEMALLOC_INTERNAL_MUTEX_POOL_H
|
|
||||||
|
|
||||||
#include "jemalloc/internal/hash.h"
|
|
||||||
#include "jemalloc/internal/mutex.h"
|
|
||||||
#include "jemalloc/internal/witness.h"
|
|
||||||
|
|
||||||
/* We do mod reductions by this value, so it should be kept a power of 2. */
|
|
||||||
#define MUTEX_POOL_SIZE 256
|
|
||||||
|
|
||||||
typedef struct mutex_pool_s mutex_pool_t;
|
|
||||||
struct mutex_pool_s {
|
|
||||||
malloc_mutex_t mutexes[MUTEX_POOL_SIZE];
|
|
||||||
};
|
|
||||||
|
|
||||||
bool mutex_pool_init(mutex_pool_t *pool, const char *name, witness_rank_t rank);
|
|
||||||
|
|
||||||
/* Internal helper - not meant to be called outside this module. */
|
|
||||||
static inline malloc_mutex_t *
|
|
||||||
mutex_pool_mutex(mutex_pool_t *pool, uintptr_t key) {
|
|
||||||
size_t hash_result[2];
|
|
||||||
hash(&key, sizeof(key), 0xd50dcc1b, hash_result);
|
|
||||||
return &pool->mutexes[hash_result[0] % MUTEX_POOL_SIZE];
|
|
||||||
}
|
|
||||||
|
|
||||||
static inline void
|
|
||||||
mutex_pool_assert_not_held(tsdn_t *tsdn, mutex_pool_t *pool) {
|
|
||||||
for (int i = 0; i < MUTEX_POOL_SIZE; i++) {
|
|
||||||
malloc_mutex_assert_not_owner(tsdn, &pool->mutexes[i]);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/*
|
|
||||||
* Note that a mutex pool doesn't work exactly the way an embdedded mutex would.
|
|
||||||
* You're not allowed to acquire mutexes in the pool one at a time. You have to
|
|
||||||
* acquire all the mutexes you'll need in a single function call, and then
|
|
||||||
* release them all in a single function call.
|
|
||||||
*/
|
|
||||||
|
|
||||||
static inline void
|
|
||||||
mutex_pool_lock(tsdn_t *tsdn, mutex_pool_t *pool, uintptr_t key) {
|
|
||||||
mutex_pool_assert_not_held(tsdn, pool);
|
|
||||||
|
|
||||||
malloc_mutex_t *mutex = mutex_pool_mutex(pool, key);
|
|
||||||
malloc_mutex_lock(tsdn, mutex);
|
|
||||||
}
|
|
||||||
|
|
||||||
static inline void
|
|
||||||
mutex_pool_unlock(tsdn_t *tsdn, mutex_pool_t *pool, uintptr_t key) {
|
|
||||||
malloc_mutex_t *mutex = mutex_pool_mutex(pool, key);
|
|
||||||
malloc_mutex_unlock(tsdn, mutex);
|
|
||||||
|
|
||||||
mutex_pool_assert_not_held(tsdn, pool);
|
|
||||||
}
|
|
||||||
|
|
||||||
static inline void
|
|
||||||
mutex_pool_lock2(tsdn_t *tsdn, mutex_pool_t *pool, uintptr_t key1,
|
|
||||||
uintptr_t key2) {
|
|
||||||
mutex_pool_assert_not_held(tsdn, pool);
|
|
||||||
|
|
||||||
malloc_mutex_t *mutex1 = mutex_pool_mutex(pool, key1);
|
|
||||||
malloc_mutex_t *mutex2 = mutex_pool_mutex(pool, key2);
|
|
||||||
if ((uintptr_t)mutex1 < (uintptr_t)mutex2) {
|
|
||||||
malloc_mutex_lock(tsdn, mutex1);
|
|
||||||
malloc_mutex_lock(tsdn, mutex2);
|
|
||||||
} else if ((uintptr_t)mutex1 == (uintptr_t)mutex2) {
|
|
||||||
malloc_mutex_lock(tsdn, mutex1);
|
|
||||||
} else {
|
|
||||||
malloc_mutex_lock(tsdn, mutex2);
|
|
||||||
malloc_mutex_lock(tsdn, mutex1);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
static inline void
|
|
||||||
mutex_pool_unlock2(tsdn_t *tsdn, mutex_pool_t *pool, uintptr_t key1,
|
|
||||||
uintptr_t key2) {
|
|
||||||
malloc_mutex_t *mutex1 = mutex_pool_mutex(pool, key1);
|
|
||||||
malloc_mutex_t *mutex2 = mutex_pool_mutex(pool, key2);
|
|
||||||
if (mutex1 == mutex2) {
|
|
||||||
malloc_mutex_unlock(tsdn, mutex1);
|
|
||||||
} else {
|
|
||||||
malloc_mutex_unlock(tsdn, mutex1);
|
|
||||||
malloc_mutex_unlock(tsdn, mutex2);
|
|
||||||
}
|
|
||||||
|
|
||||||
mutex_pool_assert_not_held(tsdn, pool);
|
|
||||||
}
|
|
||||||
|
|
||||||
static inline void
|
|
||||||
mutex_pool_assert_owner(tsdn_t *tsdn, mutex_pool_t *pool, uintptr_t key) {
|
|
||||||
malloc_mutex_assert_owner(tsdn, mutex_pool_mutex(pool, key));
|
|
||||||
}
|
|
||||||
|
|
||||||
#endif /* JEMALLOC_INTERNAL_MUTEX_POOL_H */
|
|
@ -57,7 +57,6 @@ enum witness_rank_e {
|
|||||||
|
|
||||||
WITNESS_RANK_EDATA_CACHE,
|
WITNESS_RANK_EDATA_CACHE,
|
||||||
|
|
||||||
WITNESS_RANK_EMAP,
|
|
||||||
WITNESS_RANK_RTREE,
|
WITNESS_RANK_RTREE,
|
||||||
WITNESS_RANK_BASE,
|
WITNESS_RANK_BASE,
|
||||||
WITNESS_RANK_ARENA_LARGE,
|
WITNESS_RANK_ARENA_LARGE,
|
||||||
|
@ -69,7 +69,6 @@
|
|||||||
<ClCompile Include="..\..\..\..\src\log.c" />
|
<ClCompile Include="..\..\..\..\src\log.c" />
|
||||||
<ClCompile Include="..\..\..\..\src\malloc_io.c" />
|
<ClCompile Include="..\..\..\..\src\malloc_io.c" />
|
||||||
<ClCompile Include="..\..\..\..\src\mutex.c" />
|
<ClCompile Include="..\..\..\..\src\mutex.c" />
|
||||||
<ClCompile Include="..\..\..\..\src\mutex_pool.c" />
|
|
||||||
<ClCompile Include="..\..\..\..\src\nstime.c" />
|
<ClCompile Include="..\..\..\..\src\nstime.c" />
|
||||||
<ClCompile Include="..\..\..\..\src\pa.c" />
|
<ClCompile Include="..\..\..\..\src\pa.c" />
|
||||||
<ClCompile Include="..\..\..\..\src\pa_extra.c" />
|
<ClCompile Include="..\..\..\..\src\pa_extra.c" />
|
||||||
|
@ -91,9 +91,6 @@
|
|||||||
<ClCompile Include="..\..\..\..\src\mutex.c">
|
<ClCompile Include="..\..\..\..\src\mutex.c">
|
||||||
<Filter>Source Files</Filter>
|
<Filter>Source Files</Filter>
|
||||||
</ClCompile>
|
</ClCompile>
|
||||||
<ClCompile Include="..\..\..\..\src\mutex_pool.c">
|
|
||||||
<Filter>Source Files</Filter>
|
|
||||||
</ClCompile>
|
|
||||||
<ClCompile Include="..\..\..\..\src\nstime.c">
|
<ClCompile Include="..\..\..\..\src\nstime.c">
|
||||||
<Filter>Source Files</Filter>
|
<Filter>Source Files</Filter>
|
||||||
</ClCompile>
|
</ClCompile>
|
||||||
|
@ -69,7 +69,6 @@
|
|||||||
<ClCompile Include="..\..\..\..\src\log.c" />
|
<ClCompile Include="..\..\..\..\src\log.c" />
|
||||||
<ClCompile Include="..\..\..\..\src\malloc_io.c" />
|
<ClCompile Include="..\..\..\..\src\malloc_io.c" />
|
||||||
<ClCompile Include="..\..\..\..\src\mutex.c" />
|
<ClCompile Include="..\..\..\..\src\mutex.c" />
|
||||||
<ClCompile Include="..\..\..\..\src\mutex_pool.c" />
|
|
||||||
<ClCompile Include="..\..\..\..\src\nstime.c" />
|
<ClCompile Include="..\..\..\..\src\nstime.c" />
|
||||||
<ClCompile Include="..\..\..\..\src\pa.c" />
|
<ClCompile Include="..\..\..\..\src\pa.c" />
|
||||||
<ClCompile Include="..\..\..\..\src\pa_extra.c" />
|
<ClCompile Include="..\..\..\..\src\pa_extra.c" />
|
||||||
|
@ -91,9 +91,6 @@
|
|||||||
<ClCompile Include="..\..\..\..\src\mutex.c">
|
<ClCompile Include="..\..\..\..\src\mutex.c">
|
||||||
<Filter>Source Files</Filter>
|
<Filter>Source Files</Filter>
|
||||||
</ClCompile>
|
</ClCompile>
|
||||||
<ClCompile Include="..\..\..\..\src\mutex_pool.c">
|
|
||||||
<Filter>Source Files</Filter>
|
|
||||||
</ClCompile>
|
|
||||||
<ClCompile Include="..\..\..\..\src\nstime.c">
|
<ClCompile Include="..\..\..\..\src\nstime.c">
|
||||||
<Filter>Source Files</Filter>
|
<Filter>Source Files</Filter>
|
||||||
</ClCompile>
|
</ClCompile>
|
||||||
|
12
src/emap.c
12
src/emap.c
@ -12,17 +12,7 @@ typedef enum emap_lock_result_e emap_lock_result_t;
|
|||||||
|
|
||||||
bool
|
bool
|
||||||
emap_init(emap_t *emap, base_t *base, bool zeroed) {
|
emap_init(emap_t *emap, base_t *base, bool zeroed) {
|
||||||
bool err;
|
return rtree_new(&emap->rtree, base, zeroed);
|
||||||
err = rtree_new(&emap->rtree, base, zeroed);
|
|
||||||
if (err) {
|
|
||||||
return true;
|
|
||||||
}
|
|
||||||
err = mutex_pool_init(&emap->mtx_pool, "emap_mutex_pool",
|
|
||||||
WITNESS_RANK_EMAP);
|
|
||||||
if (err) {
|
|
||||||
return true;
|
|
||||||
}
|
|
||||||
return false;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
void
|
void
|
||||||
|
@ -1,17 +0,0 @@
|
|||||||
|
|
||||||
#include "jemalloc/internal/jemalloc_preamble.h"
|
|
||||||
#include "jemalloc/internal/jemalloc_internal_includes.h"
|
|
||||||
|
|
||||||
#include "jemalloc/internal/mutex.h"
|
|
||||||
#include "jemalloc/internal/mutex_pool.h"
|
|
||||||
|
|
||||||
bool
|
|
||||||
mutex_pool_init(mutex_pool_t *pool, const char *name, witness_rank_t rank) {
|
|
||||||
for (int i = 0; i < MUTEX_POOL_SIZE; ++i) {
|
|
||||||
if (malloc_mutex_init(&pool->mutexes[i], name, rank,
|
|
||||||
malloc_mutex_address_ordered)) {
|
|
||||||
return true;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return false;
|
|
||||||
}
|
|
Loading…
Reference in New Issue
Block a user