Blame jemalloc/test/unit/mtx.c
|
Packit Service |
724aca |
#include "test/jemalloc_test.h"
|
|
Packit Service |
724aca |
|
|
Packit Service |
724aca |
#define NTHREADS 2
|
|
Packit Service |
724aca |
#define NINCRS 2000000
|
|
Packit Service |
724aca |
|
|
Packit Service |
724aca |
TEST_BEGIN(test_mtx_basic) {
|
|
Packit Service |
724aca |
mtx_t mtx;
|
|
Packit Service |
724aca |
|
|
Packit Service |
724aca |
assert_false(mtx_init(&mtx), "Unexpected mtx_init() failure");
|
|
Packit Service |
724aca |
mtx_lock(&mtx);
|
|
Packit Service |
724aca |
mtx_unlock(&mtx);
|
|
Packit Service |
724aca |
mtx_fini(&mtx);
|
|
Packit Service |
724aca |
}
|
|
Packit Service |
724aca |
TEST_END
|
|
Packit Service |
724aca |
|
|
Packit Service |
724aca |
typedef struct {
|
|
Packit Service |
724aca |
mtx_t mtx;
|
|
Packit Service |
724aca |
unsigned x;
|
|
Packit Service |
724aca |
} thd_start_arg_t;
|
|
Packit Service |
724aca |
|
|
Packit Service |
724aca |
static void *
|
|
Packit Service |
724aca |
thd_start(void *varg) {
|
|
Packit Service |
724aca |
thd_start_arg_t *arg = (thd_start_arg_t *)varg;
|
|
Packit Service |
724aca |
unsigned i;
|
|
Packit Service |
724aca |
|
|
Packit Service |
724aca |
for (i = 0; i < NINCRS; i++) {
|
|
Packit Service |
724aca |
mtx_lock(&arg->mtx);
|
|
Packit Service |
724aca |
arg->x++;
|
|
Packit Service |
724aca |
mtx_unlock(&arg->mtx);
|
|
Packit Service |
724aca |
}
|
|
Packit Service |
724aca |
return NULL;
|
|
Packit Service |
724aca |
}
|
|
Packit Service |
724aca |
|
|
Packit Service |
724aca |
TEST_BEGIN(test_mtx_race) {
|
|
Packit Service |
724aca |
thd_start_arg_t arg;
|
|
Packit Service |
724aca |
thd_t thds[NTHREADS];
|
|
Packit Service |
724aca |
unsigned i;
|
|
Packit Service |
724aca |
|
|
Packit Service |
724aca |
assert_false(mtx_init(&arg.mtx), "Unexpected mtx_init() failure");
|
|
Packit Service |
724aca |
arg.x = 0;
|
|
Packit Service |
724aca |
for (i = 0; i < NTHREADS; i++) {
|
|
Packit Service |
724aca |
thd_create(&thds[i], thd_start, (void *)&arg;;
|
|
Packit Service |
724aca |
}
|
|
Packit Service |
724aca |
for (i = 0; i < NTHREADS; i++) {
|
|
Packit Service |
724aca |
thd_join(thds[i], NULL);
|
|
Packit Service |
724aca |
}
|
|
Packit Service |
724aca |
assert_u_eq(arg.x, NTHREADS * NINCRS,
|
|
Packit Service |
724aca |
"Race-related counter corruption");
|
|
Packit Service |
724aca |
}
|
|
Packit Service |
724aca |
TEST_END
|
|
Packit Service |
724aca |
|
|
Packit Service |
724aca |
int
|
|
Packit Service |
724aca |
main(void) {
|
|
Packit Service |
724aca |
return test(
|
|
Packit Service |
724aca |
test_mtx_basic,
|
|
Packit Service |
724aca |
test_mtx_race);
|
|
Packit Service |
724aca |
}
|