Searched refs:done_cv (Results 1 – 5 of 5) sorted by relevance
| /external/grpc-grpc/test/core/gprpp/ |
| D | thd_test.cc | 38 gpr_cv done_cv; member
48 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()
|
| /external/grpc-grpc/test/core/gpr/ |
| D | cpu_test.cc | 62 gpr_cv done_cv; member
97 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()
|
| D | sync_test.cc | 151 gpr_cv done_cv; /* signalled when done == 0 */ member
175 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()
|
| /external/tensorflow/tensorflow/core/kernels/ |
| D | collective_nccl_test.cc | 169 condition_variable done_cv; in RunCollective() local
173 SchedClosure([this, di, &done, &done_mu, &done_cv] { in RunCollective()
177 done_cv.notify_all(); in RunCollective()
182 while (done < instances_.size()) done_cv.wait(l); in RunCollective()
|
| /external/tensorflow/tensorflow/core/nccl/ |
| D | nccl_manager_test.cc | 65 condition_variable done_cv; member
251 test_case->done_cv.wait(l); in WaitForTestCompletion()
292 test_case->done_cv.notify_one(); in CreateDoneCallback()
927 test_case->done_cv.wait(l); in TYPED_TEST()
|