Lines Matching refs:barrier
29 uv_barrier_t barrier; member
45 c->worker_barrier_wait_rval += uv_barrier_wait(&c->barrier); in worker()
56 ASSERT_OK(uv_barrier_init(&wc.barrier, 2)); in TEST_IMPL()
60 wc.main_barrier_wait_rval = uv_barrier_wait(&wc.barrier); in TEST_IMPL()
63 uv_barrier_destroy(&wc.barrier); in TEST_IMPL()
79 ASSERT_OK(uv_barrier_init(&wc.barrier, 2)); in TEST_IMPL()
82 wc.main_barrier_wait_rval = uv_barrier_wait(&wc.barrier); in TEST_IMPL()
85 uv_barrier_destroy(&wc.barrier); in TEST_IMPL()
101 ASSERT_OK(uv_barrier_init(&wc.barrier, 2)); in TEST_IMPL()
105 wc.main_barrier_wait_rval += uv_barrier_wait(&wc.barrier); in TEST_IMPL()
108 uv_barrier_destroy(&wc.barrier); in TEST_IMPL()
116 uv_barrier_t* barrier; in serial_worker() local
119 barrier = data; in serial_worker()
121 uv_barrier_wait(barrier); in serial_worker()
122 if (uv_barrier_wait(barrier) > 0) in serial_worker()
123 uv_barrier_destroy(barrier); in serial_worker()
133 uv_barrier_t barrier; in TEST_IMPL() local
136 ASSERT_OK(uv_barrier_init(&barrier, ARRAY_SIZE(threads) + 1)); in TEST_IMPL()
139 ASSERT_OK(uv_thread_create(&threads[i], serial_worker, &barrier)); in TEST_IMPL()
142 uv_barrier_wait(&barrier); in TEST_IMPL()
143 if (uv_barrier_wait(&barrier) > 0) in TEST_IMPL()
144 uv_barrier_destroy(&barrier); in TEST_IMPL()
154 uv_barrier_t barrier; in TEST_IMPL() local
156 ASSERT_OK(uv_barrier_init(&barrier, 1)); in TEST_IMPL()
157 ASSERT_LT(0, uv_barrier_wait(&barrier)); in TEST_IMPL()
158 uv_barrier_destroy(&barrier); in TEST_IMPL()
