summaryrefslogtreecommitdiff
path: root/examples/redis-unstable/deps/jemalloc/test/unit/tsd.c
diff options
context:
space:
mode:
Diffstat (limited to 'examples/redis-unstable/deps/jemalloc/test/unit/tsd.c')
-rw-r--r--examples/redis-unstable/deps/jemalloc/test/unit/tsd.c274
1 files changed, 0 insertions, 274 deletions
diff --git a/examples/redis-unstable/deps/jemalloc/test/unit/tsd.c b/examples/redis-unstable/deps/jemalloc/test/unit/tsd.c
deleted file mode 100644
index 205d870..0000000
--- a/examples/redis-unstable/deps/jemalloc/test/unit/tsd.c
+++ /dev/null
@@ -1,274 +0,0 @@
-#include "test/jemalloc_test.h"
-
-/*
- * If we're e.g. in debug mode, we *never* enter the fast path, and so shouldn't
- * be asserting that we're on one.
- */
-static bool originally_fast;
-static int data_cleanup_count;
-
-void
-data_cleanup(int *data) {
- if (data_cleanup_count == 0) {
- expect_x_eq(*data, MALLOC_TSD_TEST_DATA_INIT,
- "Argument passed into cleanup function should match tsd "
- "value");
- }
- ++data_cleanup_count;
-
- /*
- * Allocate during cleanup for two rounds, in order to assure that
- * jemalloc's internal tsd reinitialization happens.
- */
- bool reincarnate = false;
- switch (*data) {
- case MALLOC_TSD_TEST_DATA_INIT:
- *data = 1;
- reincarnate = true;
- break;
- case 1:
- *data = 2;
- reincarnate = true;
- break;
- case 2:
- return;
- default:
- not_reached();
- }
-
- if (reincarnate) {
- void *p = mallocx(1, 0);
- expect_ptr_not_null(p, "Unexpeced mallocx() failure");
- dallocx(p, 0);
- }
-}
-
-static void *
-thd_start(void *arg) {
- int d = (int)(uintptr_t)arg;
- void *p;
-
- /*
- * Test free before tsd init -- the free fast path (which does not
- * explicitly check for NULL) has to tolerate this case, and fall back
- * to free_default.
- */
- free(NULL);
-
- tsd_t *tsd = tsd_fetch();
- expect_x_eq(tsd_test_data_get(tsd), MALLOC_TSD_TEST_DATA_INIT,
- "Initial tsd get should return initialization value");
-
- p = malloc(1);
- expect_ptr_not_null(p, "Unexpected malloc() failure");
-
- tsd_test_data_set(tsd, d);
- expect_x_eq(tsd_test_data_get(tsd), d,
- "After tsd set, tsd get should return value that was set");
-
- d = 0;
- expect_x_eq(tsd_test_data_get(tsd), (int)(uintptr_t)arg,
- "Resetting local data should have no effect on tsd");
-
- tsd_test_callback_set(tsd, &data_cleanup);
-
- free(p);
- return NULL;
-}
-
-TEST_BEGIN(test_tsd_main_thread) {
- thd_start((void *)(uintptr_t)0xa5f3e329);
-}
-TEST_END
-
-TEST_BEGIN(test_tsd_sub_thread) {
- thd_t thd;
-
- data_cleanup_count = 0;
- thd_create(&thd, thd_start, (void *)MALLOC_TSD_TEST_DATA_INIT);
- thd_join(thd, NULL);
- /*
- * We reincarnate twice in the data cleanup, so it should execute at
- * least 3 times.
- */
- expect_x_ge(data_cleanup_count, 3,
- "Cleanup function should have executed multiple times.");
-}
-TEST_END
-
-static void *
-thd_start_reincarnated(void *arg) {
- tsd_t *tsd = tsd_fetch();
- assert(tsd);
-
- void *p = malloc(1);
- expect_ptr_not_null(p, "Unexpected malloc() failure");
-
- /* Manually trigger reincarnation. */
- expect_ptr_not_null(tsd_arena_get(tsd),
- "Should have tsd arena set.");
- tsd_cleanup((void *)tsd);
- expect_ptr_null(*tsd_arenap_get_unsafe(tsd),
- "TSD arena should have been cleared.");
- expect_u_eq(tsd_state_get(tsd), tsd_state_purgatory,
- "TSD state should be purgatory\n");
-
- free(p);
- expect_u_eq(tsd_state_get(tsd), tsd_state_reincarnated,
- "TSD state should be reincarnated\n");
- p = mallocx(1, MALLOCX_TCACHE_NONE);
- expect_ptr_not_null(p, "Unexpected malloc() failure");
- expect_ptr_null(*tsd_arenap_get_unsafe(tsd),
- "Should not have tsd arena set after reincarnation.");
-
- free(p);
- tsd_cleanup((void *)tsd);
- expect_ptr_null(*tsd_arenap_get_unsafe(tsd),
- "TSD arena should have been cleared after 2nd cleanup.");
-
- return NULL;
-}
-
-TEST_BEGIN(test_tsd_reincarnation) {
- thd_t thd;
- thd_create(&thd, thd_start_reincarnated, NULL);
- thd_join(thd, NULL);
-}
-TEST_END
-
-typedef struct {
- atomic_u32_t phase;
- atomic_b_t error;
-} global_slow_data_t;
-
-static void *
-thd_start_global_slow(void *arg) {
- /* PHASE 0 */
- global_slow_data_t *data = (global_slow_data_t *)arg;
- free(mallocx(1, 0));
-
- tsd_t *tsd = tsd_fetch();
- /*
- * No global slowness has happened yet; there was an error if we were
- * originally fast but aren't now.
- */
- atomic_store_b(&data->error, originally_fast && !tsd_fast(tsd),
- ATOMIC_SEQ_CST);
- atomic_store_u32(&data->phase, 1, ATOMIC_SEQ_CST);
-
- /* PHASE 2 */
- while (atomic_load_u32(&data->phase, ATOMIC_SEQ_CST) != 2) {
- }
- free(mallocx(1, 0));
- atomic_store_b(&data->error, tsd_fast(tsd), ATOMIC_SEQ_CST);
- atomic_store_u32(&data->phase, 3, ATOMIC_SEQ_CST);
-
- /* PHASE 4 */
- while (atomic_load_u32(&data->phase, ATOMIC_SEQ_CST) != 4) {
- }
- free(mallocx(1, 0));
- atomic_store_b(&data->error, tsd_fast(tsd), ATOMIC_SEQ_CST);
- atomic_store_u32(&data->phase, 5, ATOMIC_SEQ_CST);
-
- /* PHASE 6 */
- while (atomic_load_u32(&data->phase, ATOMIC_SEQ_CST) != 6) {
- }
- free(mallocx(1, 0));
- /* Only one decrement so far. */
- atomic_store_b(&data->error, tsd_fast(tsd), ATOMIC_SEQ_CST);
- atomic_store_u32(&data->phase, 7, ATOMIC_SEQ_CST);
-
- /* PHASE 8 */
- while (atomic_load_u32(&data->phase, ATOMIC_SEQ_CST) != 8) {
- }
- free(mallocx(1, 0));
- /*
- * Both decrements happened; we should be fast again (if we ever
- * were)
- */
- atomic_store_b(&data->error, originally_fast && !tsd_fast(tsd),
- ATOMIC_SEQ_CST);
- atomic_store_u32(&data->phase, 9, ATOMIC_SEQ_CST);
-
- return NULL;
-}
-
-TEST_BEGIN(test_tsd_global_slow) {
- global_slow_data_t data = {ATOMIC_INIT(0), ATOMIC_INIT(false)};
- /*
- * Note that the "mallocx" here (vs. malloc) is important, since the
- * compiler is allowed to optimize away free(malloc(1)) but not
- * free(mallocx(1)).
- */
- free(mallocx(1, 0));
- tsd_t *tsd = tsd_fetch();
- originally_fast = tsd_fast(tsd);
-
- thd_t thd;
- thd_create(&thd, thd_start_global_slow, (void *)&data.phase);
- /* PHASE 1 */
- while (atomic_load_u32(&data.phase, ATOMIC_SEQ_CST) != 1) {
- /*
- * We don't have a portable condvar/semaphore mechanism.
- * Spin-wait.
- */
- }
- expect_false(atomic_load_b(&data.error, ATOMIC_SEQ_CST), "");
- tsd_global_slow_inc(tsd_tsdn(tsd));
- free(mallocx(1, 0));
- expect_false(tsd_fast(tsd), "");
- atomic_store_u32(&data.phase, 2, ATOMIC_SEQ_CST);
-
- /* PHASE 3 */
- while (atomic_load_u32(&data.phase, ATOMIC_SEQ_CST) != 3) {
- }
- expect_false(atomic_load_b(&data.error, ATOMIC_SEQ_CST), "");
- /* Increase again, so that we can test multiple fast/slow changes. */
- tsd_global_slow_inc(tsd_tsdn(tsd));
- atomic_store_u32(&data.phase, 4, ATOMIC_SEQ_CST);
- free(mallocx(1, 0));
- expect_false(tsd_fast(tsd), "");
-
- /* PHASE 5 */
- while (atomic_load_u32(&data.phase, ATOMIC_SEQ_CST) != 5) {
- }
- expect_false(atomic_load_b(&data.error, ATOMIC_SEQ_CST), "");
- tsd_global_slow_dec(tsd_tsdn(tsd));
- atomic_store_u32(&data.phase, 6, ATOMIC_SEQ_CST);
- /* We only decreased once; things should still be slow. */
- free(mallocx(1, 0));
- expect_false(tsd_fast(tsd), "");
-
- /* PHASE 7 */
- while (atomic_load_u32(&data.phase, ATOMIC_SEQ_CST) != 7) {
- }
- expect_false(atomic_load_b(&data.error, ATOMIC_SEQ_CST), "");
- tsd_global_slow_dec(tsd_tsdn(tsd));
- atomic_store_u32(&data.phase, 8, ATOMIC_SEQ_CST);
- /* We incremented and then decremented twice; we should be fast now. */
- free(mallocx(1, 0));
- expect_true(!originally_fast || tsd_fast(tsd), "");
-
- /* PHASE 9 */
- while (atomic_load_u32(&data.phase, ATOMIC_SEQ_CST) != 9) {
- }
- expect_false(atomic_load_b(&data.error, ATOMIC_SEQ_CST), "");
-
- thd_join(thd, NULL);
-}
-TEST_END
-
-int
-main(void) {
- /* Ensure tsd bootstrapped. */
- if (nallocx(1, 0) == 0) {
- malloc_printf("Initialization error");
- return test_status_fail;
- }
-
- return test_no_reentrancy(
- test_tsd_main_thread,
- test_tsd_sub_thread,
- test_tsd_reincarnation,
- test_tsd_global_slow);
-}