| /external/grpc-grpc/include/grpc/support/ |
| D | sync.h | 80 GPRAPI int gpr_cv_wait(gpr_cv* cv, gpr_mu* mu, gpr_timespec abs_deadline);
220 gpr_cv_wait(&q->non_full, &q->mu, gpr_inf_future);
262 !gpr_cv_wait(&q->non_empty, &q->mu, abs_deadline)) {
|
| /external/grpc-grpc/test/core/gpr/ |
| D | sync_test.cc | 79 gpr_cv_wait(&q->non_full, &q->mu, gpr_inf_future(GPR_CLOCK_MONOTONIC)); in queue_append()
120 while (q->length == 0 && !gpr_cv_wait(&q->non_empty, &q->mu, abs_deadline)) { in queue_remove()
207 gpr_cv_wait(&m->done_cv, &m->mu, gpr_inf_future(GPR_CLOCK_MONOTONIC)); in test_wait()
321 gpr_cv_wait(&m->cv, &m->mu, gpr_inf_future(GPR_CLOCK_MONOTONIC)); in inc_by_turns()
340 while (!gpr_cv_wait(&m->cv, &m->mu, deadline)) { in inc_with_1ms_delay()
|
| D | cpu_test.cc | 125 gpr_cv_wait(&ct.done_cv, &ct.mu, gpr_inf_future(GPR_CLOCK_MONOTONIC)); in cpu_test()
|
| /external/grpc-grpc/test/cpp/microbenchmarks/ |
| D | bm_cq_multiple_threads.cc | 164 gpr_cv_wait(&g_cv, &g_mu, deadline); in BM_Cq_Throughput()
187 gpr_cv_wait(&g_cv, &g_mu, deadline); in BM_Cq_Throughput()
|
| /external/grpc-grpc/src/core/lib/gprpp/ |
| D | fork.cc | 67 gpr_cv_wait(&cv_, &mu_, gpr_inf_future(GPR_CLOCK_REALTIME)); in IncExecCtxCount()
138 gpr_cv_wait(&cv_, &mu_, gpr_inf_future(GPR_CLOCK_REALTIME)); in AwaitThreads()
|
| D | thd_posix.cc | 95 gpr_cv_wait(&arg.thread->ready_, &arg.thread->mu_, in ThreadInternalsPosix()
|
| D | thd_windows.cc | 80 gpr_cv_wait(&g_thd_info->thread->ready_, &g_thd_info->thread->mu_, in ThreadInternalsWindows()
|
| /external/grpc-grpc/src/core/lib/iomgr/ |
| D | timer_manager.cc | 186 gpr_cv_wait(&g_cv_wait, &g_mu, in wait_until()
311 gpr_cv_wait(&g_cv_shutdown, &g_mu, gpr_inf_future(GPR_CLOCK_MONOTONIC)); in stop_threads()
|
| D | iomgr.cc | 126 if (gpr_cv_wait(&g_rcv, &g_mu, short_deadline)) { in grpc_iomgr_shutdown()
|
| D | ev_poll_posix.cc | 1534 gpr_cv_wait(&args->join, &g_cvfds.mu,
1590 gpr_cv_wait(&pargs->trigger, &g_cvfds.mu, deadline);
1604 gpr_cv_wait(&pargs->harvest, &g_cvfds.mu,
1690 gpr_cv_wait(&pollcv_cv, &g_cvfds.mu, deadline);
1697 gpr_cv_wait(&pollcv_cv, &g_cvfds.mu, deadline);
1765 int res = gpr_cv_wait(&g_cvfds.shutdown_cv, &g_cvfds.mu,
|
| D | pollset_windows.cc | 160 if (gpr_cv_wait(&worker.cv, &grpc_polling_mu, in pollset_work()
|
| /external/grpc-grpc/test/cpp/util/ |
| D | cli_call.cc | 131 gpr_cv_wait(&write_cv_, &write_mu_, gpr_inf_future(GPR_CLOCK_MONOTONIC)); in WriteAndWait()
141 gpr_cv_wait(&write_cv_, &write_mu_, gpr_inf_future(GPR_CLOCK_MONOTONIC)); in WritesDoneAndWait()
|
| /external/grpc-grpc/src/cpp/common/ |
| D | core_codegen.cc | 86 int CoreCodegen::gpr_cv_wait(gpr_cv* cv, gpr_mu* mu, in gpr_cv_wait() function in grpc::CoreCodegen
88 return ::gpr_cv_wait(cv, mu, abs_deadline); in gpr_cv_wait()
|
| /external/grpc-grpc/src/core/tsi/ |
| D | alts_transport_security.cc | 34 gpr_cv_wait(&g_alts_resource.cv, &g_alts_resource.mu, in grpc_tsi_alts_wait_for_cq_drain()
|
| /external/grpc-grpc/test/core/gprpp/ |
| D | thd_test.cc | 67 gpr_cv_wait(&t.done_cv, &t.mu, gpr_inf_future(GPR_CLOCK_REALTIME)); in test1()
|
| /external/grpc-grpc/src/core/lib/gpr/ |
| D | sync_posix.cc | 75 int gpr_cv_wait(gpr_cv* cv, gpr_mu* mu, gpr_timespec abs_deadline) { in gpr_cv_wait() function
|
| D | sync_windows.cc | 67 int gpr_cv_wait(gpr_cv* cv, gpr_mu* mu, gpr_timespec abs_deadline) { in gpr_cv_wait() function
|
| D | sync.cc | 80 } while (result == nullptr && !gpr_cv_wait(&s->cv, &s->mu, abs_deadline)); in gpr_event_wait()
|
| /external/grpc-grpc/test/core/end2end/tests/ |
| D | filter_status_code.cc | 240 GPR_ASSERT(gpr_cv_wait(&g_client_code_cv, &g_mu, in test_request()
244 GPR_ASSERT(gpr_cv_wait(&g_server_code_cv, &g_mu, in test_request()
|
| /external/grpc-grpc/src/ruby/ext/grpc/ |
| D | rb_event_thread.c | 98 gpr_cv_wait(&event_queue.cv, &event_queue.mu, in grpc_rb_wait_for_event_no_gil()
|
| /external/grpc-grpc/test/cpp/naming/ |
| D | resolver_component_tests_runner_invoker.cc | 87 gpr_cv_wait(test_driver_cv, test_driver_mu, wait_deadline); in RunSigHandlingThread()
|
| /external/grpc-grpc/ |
| D | grpc.def | 217 gpr_cv_wait
|
| /external/grpc-grpc/include/grpcpp/impl/codegen/ |
| D | core_codegen.h | 62 int gpr_cv_wait(gpr_cv* cv, gpr_mu* mu, gpr_timespec abs_deadline) override;
|
| D | core_codegen_interface.h | 77 virtual int gpr_cv_wait(gpr_cv* cv, gpr_mu* mu,
|
| /external/grpc-grpc/test/core/end2end/ |
| D | inproc_callback_test.cc | 86 while (!done_ && !gpr_cv_wait(&cv_, &mu_, deadline)) { in Wait()
174 gpr_cv_wait(&tags_cv, &tags_mu, deadline); in verify_tags()
|