Searched refs:done_cv (Results 1 – 4 of 4) sorted by relevance
38 gpr_cv done_cv; member48 gpr_cv_signal(&t->done_cv); in thd_body1()58 gpr_cv_init(&t.done_cv); in test1()67 gpr_cv_wait(&t.done_cv, &t.mu, gpr_inf_future(GPR_CLOCK_REALTIME)); in test1()
62 gpr_cv done_cv; member97 gpr_cv_signal(&ct->done_cv); in worker_thread()112 gpr_cv_init(&ct.done_cv); in cpu_test()125 gpr_cv_wait(&ct.done_cv, &ct.mu, gpr_inf_future(GPR_CLOCK_MONOTONIC)); in cpu_test()
151 gpr_cv done_cv; /* signalled when done == 0 */ member175 gpr_cv_init(&m->done_cv); in test_new()188 gpr_cv_destroy(&m->done_cv); in test_destroy()207 gpr_cv_wait(&m->done_cv, &m->mu, gpr_inf_future(GPR_CLOCK_MONOTONIC)); in test_wait()231 gpr_cv_signal(&m->done_cv); in mark_thread_done()
142 condition_variable done_cv; in Reduce() local145 SchedClosure([di, &done, &done_mu, &done_cv] { in Reduce()149 done_cv.notify_all(); in Reduce()154 while (done < instances_.size()) done_cv.wait(l); in Reduce()