| /third_party/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)) {
|
| /third_party/grpc/test/cpp/microbenchmarks/ |
| D | bm_cq.cc | 236 gpr_cv_wait(&cv, &mu, gpr_inf_future(GPR_CLOCK_REALTIME)); in BM_Callback_CQ_Pass1Core()
243 gpr_cv_wait(&shutdown_cv, &shutdown_mu, gpr_inf_future(GPR_CLOCK_REALTIME)); in BM_Callback_CQ_Pass1Core()
281 gpr_cv_wait(&cv, &mu, gpr_inf_future(GPR_CLOCK_REALTIME)); in BM_Callback_CQ_Pass1CoreHeapCompletion()
288 gpr_cv_wait(&shutdown_cv, &shutdown_mu, gpr_inf_future(GPR_CLOCK_REALTIME)); in BM_Callback_CQ_Pass1CoreHeapCompletion()
|
| D | bm_cq_multiple_threads.cc | 171 gpr_cv_wait(&g_cv, &g_mu, deadline); in BM_Cq_Throughput()
194 gpr_cv_wait(&g_cv, &g_mu, deadline); in BM_Cq_Throughput()
|
| /third_party/grpc/test/core/iomgr/ |
| D | pollset_windows_starvation_test.cc | 114 !gpr_cv_wait(¶ms.cv, ¶ms.mu, gpr_inf_future(GPR_CLOCK_REALTIME))) in main()
135 !gpr_cv_wait(¶ms.cv, ¶ms.mu, gpr_inf_future(GPR_CLOCK_REALTIME))) in main()
|
| /third_party/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()
|
| /third_party/grpc/src/core/lib/gprpp/ |
| D | fork.cc | 77 gpr_cv_wait(&cv_, &mu_, gpr_inf_future(GPR_CLOCK_REALTIME)); in IncExecCtxCount()
148 gpr_cv_wait(&cv_, &mu_, gpr_inf_future(GPR_CLOCK_REALTIME)); in AwaitThreads()
|
| D | sync.h | 136 return gpr_cv_wait(&cv_, &mu->mu_, ToGprTimeSpec(timeout)) != 0;
139 return gpr_cv_wait(&cv_, &mu->mu_, ToGprTimeSpec(deadline)) != 0;
|
| D | thd_windows.cc | 119 gpr_cv_wait(&g_thd_info->thread->ready_, &g_thd_info->thread->mu_, in thread_body()
|
| D | thd_posix.cc | 131 gpr_cv_wait(&arg.thread->ready_, &arg.thread->mu_, in ThreadInternalsPosix()
|
| /third_party/grpc/src/core/lib/iomgr/ |
| D | timer_manager.cc | 200 gpr_cv_wait(&g_cv_wait, &g_mu, in wait_until()
326 gpr_cv_wait(&g_cv_shutdown, &g_mu, gpr_inf_future(GPR_CLOCK_MONOTONIC)); in stop_threads()
|
| D | iomgr.cc | 133 if (gpr_cv_wait(&g_rcv, &g_mu, short_deadline)) { in grpc_iomgr_shutdown()
|
| /third_party/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()
|
| /third_party/grpc/src/cpp/common/ |
| D | core_codegen.cc | 90 int CoreCodegen::gpr_cv_wait(gpr_cv* cv, gpr_mu* mu, in gpr_cv_wait() function in grpc::CoreCodegen
92 return ::gpr_cv_wait(cv, mu, abs_deadline); in gpr_cv_wait()
|
| /third_party/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()
|
| /third_party/grpc/src/core/lib/gpr/ |
| D | sync_abseil.cc | 81 int gpr_cv_wait(gpr_cv* cv, gpr_mu* mu, gpr_timespec abs_deadline) { in gpr_cv_wait() function
|
| D | sync_windows.cc | 68 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()
|
| D | sync_posix.cc | 119 int gpr_cv_wait(gpr_cv* cv, gpr_mu* mu, gpr_timespec abs_deadline) { in gpr_cv_wait() function
|
| /third_party/grpc/src/ruby/ext/grpc/ |
| D | rb_event_thread.c | 100 gpr_cv_wait(&event_queue.cv, &event_queue.mu, in grpc_rb_wait_for_event_no_gil()
|
| /third_party/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()
|
| /third_party/grpc/include/grpcpp/impl/codegen/ |
| D | sync.h | 134 return g_core_codegen_interface->gpr_cv_wait(&cv_, mu->get(), deadline); in Wait()
|
| D | core_codegen_interface.h | 79 virtual int gpr_cv_wait(gpr_cv* cv, gpr_mu* mu,
|
| /third_party/grpc/test/cpp/naming/ |
| D | resolver_component_tests_runner_invoker.cc | 91 gpr_cv_wait(test_driver_cv, test_driver_mu, wait_deadline); in RunSigHandlingThread()
|
| /third_party/grpc/ |
| D | grpc.def | 235 gpr_cv_wait
|