Lines Matching refs:barrier
29 uv_barrier_t barrier; member
43 c->worker_barrier_wait_rval = uv_barrier_wait(&c->barrier); in worker()
53 ASSERT(0 == uv_barrier_init(&wc.barrier, 2)); in TEST_IMPL()
57 wc.main_barrier_wait_rval = uv_barrier_wait(&wc.barrier); in TEST_IMPL()
60 uv_barrier_destroy(&wc.barrier); in TEST_IMPL()
75 ASSERT(0 == uv_barrier_init(&wc.barrier, 2)); in TEST_IMPL()
78 wc.main_barrier_wait_rval = uv_barrier_wait(&wc.barrier); in TEST_IMPL()
81 uv_barrier_destroy(&wc.barrier); in TEST_IMPL()
95 ASSERT(0 == uv_barrier_init(&wc.barrier, 2)); in TEST_IMPL()
98 wc.main_barrier_wait_rval = uv_barrier_wait(&wc.barrier); in TEST_IMPL()
101 uv_barrier_destroy(&wc.barrier); in TEST_IMPL()
109 uv_barrier_t* barrier; in serial_worker() local
111 barrier = data; in serial_worker()
112 if (uv_barrier_wait(barrier) > 0) in serial_worker()
113 uv_barrier_destroy(barrier); in serial_worker()
123 uv_barrier_t barrier; in TEST_IMPL() local
126 ASSERT(0 == uv_barrier_init(&barrier, ARRAY_SIZE(threads) + 1)); in TEST_IMPL()
129 ASSERT(0 == uv_thread_create(&threads[i], serial_worker, &barrier)); in TEST_IMPL()
131 if (uv_barrier_wait(&barrier) > 0) in TEST_IMPL()
132 uv_barrier_destroy(&barrier); in TEST_IMPL()
142 uv_barrier_t barrier; in TEST_IMPL() local
144 ASSERT(0 == uv_barrier_init(&barrier, 1)); in TEST_IMPL()
145 ASSERT(0 < uv_barrier_wait(&barrier)); in TEST_IMPL()
146 uv_barrier_destroy(&barrier); in TEST_IMPL()