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