| /third_party/grpc/src/core/lib/iomgr/ |
| D | pollset_windows.cc | 145 gpr_cv_signal(&next_worker->cv); in pollset_work()
199 gpr_cv_signal(&specific_worker->cv); in pollset_kick()
211 gpr_cv_signal(&specific_worker->cv); in pollset_kick()
231 gpr_cv_signal(&next_global_worker->cv); in pollset_kick()
|
| D | timer_manager.cc | 126 gpr_cv_signal(&g_cv_wait); in run_some_timers()
270 gpr_cv_signal(&g_cv_shutdown); in timer_thread_cleanup()
359 gpr_cv_signal(&g_cv_wait); in grpc_kick_poller()
|
| D | ev_epoll1_linux.cc | 607 gpr_cv_signal(&worker->cv); in pollset_kick_all()
900 gpr_cv_signal(&inspect_worker->cv); in check_neighborhood_for_available_poller()
959 gpr_cv_signal(&worker->next->cv); in end_worker()
1140 gpr_cv_signal(&next_worker->cv); in pollset_kick()
1153 gpr_cv_signal(&root_worker->cv); in pollset_kick()
1212 gpr_cv_signal(&specific_worker->cv); in pollset_kick()
|
| D | executor.cc | 176 gpr_cv_signal(&thd_state_[i].cv); in SetThreading()
346 gpr_cv_signal(&ts->cv); in Enqueue()
|
| D | iomgr.cc | 189 gpr_cv_signal(&g_rcv); in grpc_iomgr_unregister_object()
|
| /third_party/grpc/test/core/iomgr/ |
| D | pollset_windows_starvation_test.cc | 89 gpr_cv_signal(&tparams->cv); in main()
102 gpr_cv_signal(&tparams->cv); in main()
|
| /third_party/grpc/src/ruby/ext/grpc/ |
| D | rb_event_thread.c | 67 gpr_cv_signal(&event_queue.cv); in grpc_rb_event_queue_enqueue()
111 gpr_cv_signal(&event_queue.cv); in grpc_rb_event_unblocking_func()
|
| /third_party/grpc/test/cpp/util/ |
| D | cli_call.cc | 158 gpr_cv_signal(&write_cv_); in ReadAndMaybeNotifyWrite()
176 gpr_cv_signal(&write_cv_); in ReadAndMaybeNotifyWrite()
|
| /third_party/grpc/src/cpp/common/ |
| D | core_codegen.cc | 94 void CoreCodegen::gpr_cv_signal(gpr_cv* cv) { ::gpr_cv_signal(cv); } in gpr_cv_signal() function in grpc::CoreCodegen
|
| /third_party/grpc/test/core/gprpp/ |
| D | thd_test.cc | 48 gpr_cv_signal(&t->done_cv); in thd_body1()
|
| /third_party/grpc/test/cpp/microbenchmarks/ |
| D | bm_cq.cc | 176 gpr_cv_signal(&cv); in Run()
195 gpr_cv_signal(&shutdown_cv); in Run()
|
| /third_party/grpc/src/core/lib/gpr/ |
| D | sync_abseil.cc | 98 void gpr_cv_signal(gpr_cv* cv) { in gpr_cv_signal() function
|
| D | sync_windows.cc | 97 void gpr_cv_signal(gpr_cv* cv) { WakeConditionVariable(cv); } in gpr_cv_signal() function
|
| D | sync_posix.cc | 147 void gpr_cv_signal(gpr_cv* cv) { in gpr_cv_signal() function
|
| /third_party/grpc/test/core/end2end/tests/ |
| D | filter_status_code.cc | 295 gpr_cv_signal(&g_client_code_cv); in client_destroy_call_elem()
310 gpr_cv_signal(&g_server_code_cv); in server_destroy_call_elem()
|
| /third_party/grpc/include/grpcpp/impl/codegen/ |
| D | sync.h | 126 void Signal() { g_core_codegen_interface->gpr_cv_signal(&cv_); } in Signal()
|
| D | core_codegen_interface.h | 81 virtual void gpr_cv_signal(gpr_cv* cv) = 0;
|
| D | core_codegen.h | 63 void gpr_cv_signal(gpr_cv* cv) override;
|
| /third_party/grpc/test/core/gpr/ |
| D | cpu_test.cc | 97 gpr_cv_signal(&ct->done_cv); in worker_thread()
|
| /third_party/grpc/src/core/lib/gprpp/ |
| D | thd_windows.cc | 104 gpr_cv_signal(&ready_); in Start()
|
| D | fork.cc | 139 gpr_cv_signal(&cv_); in DecThreadCount()
|
| D | thd_posix.cc | 167 gpr_cv_signal(&ready_); in Start()
|
| /third_party/grpc/test/cpp/naming/ |
| D | resolver_component_tests_runner_invoker.cc | 151 gpr_cv_signal(&test_driver_cv); in InvokeResolverComponentTestsRunner()
|
| /third_party/grpc/include/grpc/support/ |
| D | sync.h | 86 GPRAPI void gpr_cv_signal(gpr_cv* cv);
|
| /third_party/grpc/ |
| D | grpc.def | 236 gpr_cv_signal
|