Go to the source code of this file.
|
static void | consumer (void *v) |
|
static void | inc (void *v) |
|
static void | inc_by_turns (void *v) |
|
static void | inc_with_1ms_delay (void *v) |
|
static void | inc_with_1ms_delay_event (void *v) |
|
static void | inctry (void *v) |
|
int | main (int argc, char *argv[]) |
|
static void | many_producers (void *v) |
|
static void | mark_thread_done (struct test *m) |
|
void | queue_append (queue *q, int x) |
|
void | queue_destroy (queue *q) |
|
void | queue_init (queue *q) |
|
int | queue_remove (queue *q, int *head, gpr_timespec abs_deadline) |
|
int | queue_try_append (queue *q, int x) |
|
static void | refcheck (void *v) |
|
static void | refinc (void *v) |
|
static void | statsinc (void *v) |
|
static void | test (const char *name, void(*body)(void *m), void(*extra)(void *m), int timeout_s, int incr_step) |
|
static void | test_create_threads (struct test *m, void(*body)(void *arg)) |
|
static void | test_destroy (struct test *m) |
|
static struct test * | test_new (int nthreads, int64_t iterations, int incr_step) |
|
static void | test_wait (struct test *m) |
|
static int | thread_id (struct test *m) |
|
◆ queue
◆ consumer()
static void consumer |
( |
void * |
v | ) |
|
|
static |
◆ inc()
static void inc |
( |
void * |
v | ) |
|
|
static |
◆ inc_by_turns()
static void inc_by_turns |
( |
void * |
v | ) |
|
|
static |
◆ inc_with_1ms_delay()
static void inc_with_1ms_delay |
( |
void * |
v | ) |
|
|
static |
◆ inc_with_1ms_delay_event()
static void inc_with_1ms_delay_event |
( |
void * |
v | ) |
|
|
static |
◆ inctry()
static void inctry |
( |
void * |
v | ) |
|
|
static |
◆ main()
int main |
( |
int |
argc, |
|
|
char * |
argv[] |
|
) |
| |
◆ many_producers()
static void many_producers |
( |
void * |
v | ) |
|
|
static |
◆ mark_thread_done()
static void mark_thread_done |
( |
struct test * |
m | ) |
|
|
static |
◆ queue_append()
◆ queue_destroy()
void queue_destroy |
( |
queue * |
q | ) |
|
◆ queue_init()
void queue_init |
( |
queue * |
q | ) |
|
◆ queue_remove()
◆ queue_try_append()
◆ refcheck()
static void refcheck |
( |
void * |
v | ) |
|
|
static |
◆ refinc()
static void refinc |
( |
void * |
v | ) |
|
|
static |
◆ statsinc()
static void statsinc |
( |
void * |
v | ) |
|
|
static |
◆ test()
static void test |
( |
const char * |
name, |
|
|
void(*)(void *m) |
body, |
|
|
void(*)(void *m) |
extra, |
|
|
int |
timeout_s, |
|
|
int |
incr_step |
|
) |
| |
|
static |
◆ test_create_threads()
static void test_create_threads |
( |
struct test * |
m, |
|
|
void(*)(void *arg) |
body |
|
) |
| |
|
static |
◆ test_destroy()
static void test_destroy |
( |
struct test * |
m | ) |
|
|
static |
◆ test_new()
◆ test_wait()
static void test_wait |
( |
struct test * |
m | ) |
|
|
static |
◆ thread_id()
static int thread_id |
( |
struct test * |
m | ) |
|
|
static |