Home
last modified time | relevance | path

Searched refs:gpr_cv (Results 1 – 25 of 39) sorted by relevance

12

/external/grpc-grpc/include/grpc/support/
Dsync.h67 GPRAPI void gpr_cv_init(gpr_cv* cv);
71 GPRAPI void gpr_cv_destroy(gpr_cv* cv);
80 GPRAPI int gpr_cv_wait(gpr_cv* cv, gpr_mu* mu, gpr_timespec abs_deadline);
86 GPRAPI void gpr_cv_signal(gpr_cv* cv);
89 GPRAPI void gpr_cv_broadcast(gpr_cv* cv);
183 gpr_cv non_empty; /* Signalled when length becomes non-zero. */
184 gpr_cv non_full; /* Signalled when length becomes non-N. */
/external/grpc-grpc/src/core/lib/gpr/
Dsync_posix.cc64 void gpr_cv_init(gpr_cv* cv) { in gpr_cv_init()
73 void gpr_cv_destroy(gpr_cv* cv) { GPR_ASSERT(pthread_cond_destroy(cv) == 0); } in gpr_cv_destroy()
75 int gpr_cv_wait(gpr_cv* cv, gpr_mu* mu, gpr_timespec abs_deadline) { in gpr_cv_wait()
95 void gpr_cv_signal(gpr_cv* cv) { GPR_ASSERT(pthread_cond_signal(cv) == 0); } in gpr_cv_signal()
97 void gpr_cv_broadcast(gpr_cv* cv) { in gpr_cv_broadcast()
Dsync_windows.cc61 void gpr_cv_init(gpr_cv* cv) { InitializeConditionVariable(cv); } in gpr_cv_init()
63 void gpr_cv_destroy(gpr_cv* cv) { in gpr_cv_destroy()
67 int gpr_cv_wait(gpr_cv* cv, gpr_mu* mu, gpr_timespec abs_deadline) { in gpr_cv_wait()
96 void gpr_cv_signal(gpr_cv* cv) { WakeConditionVariable(cv); } in gpr_cv_signal()
98 void gpr_cv_broadcast(gpr_cv* cv) { WakeAllConditionVariable(cv); } in gpr_cv_broadcast()
Dsync.cc36 gpr_cv cv;
/external/grpc-grpc/include/grpcpp/impl/codegen/
Dcore_codegen_interface.h75 virtual void gpr_cv_init(gpr_cv* cv) = 0;
76 virtual void gpr_cv_destroy(gpr_cv* cv) = 0;
77 virtual int gpr_cv_wait(gpr_cv* cv, gpr_mu* mu,
79 virtual void gpr_cv_signal(gpr_cv* cv) = 0;
80 virtual void gpr_cv_broadcast(gpr_cv* cv) = 0;
Dcore_codegen.h60 void gpr_cv_init(gpr_cv* cv) override;
61 void gpr_cv_destroy(gpr_cv* cv) override;
62 int gpr_cv_wait(gpr_cv* cv, gpr_mu* mu, gpr_timespec abs_deadline) override;
63 void gpr_cv_signal(gpr_cv* cv) override;
64 void gpr_cv_broadcast(gpr_cv* cv) override;
/external/grpc-grpc/src/cpp/common/
Dcore_codegen.cc84 void CoreCodegen::gpr_cv_init(gpr_cv* cv) { ::gpr_cv_init(cv); } in gpr_cv_init()
85 void CoreCodegen::gpr_cv_destroy(gpr_cv* cv) { ::gpr_cv_destroy(cv); } in gpr_cv_destroy()
86 int CoreCodegen::gpr_cv_wait(gpr_cv* cv, gpr_mu* mu, in gpr_cv_wait()
90 void CoreCodegen::gpr_cv_signal(gpr_cv* cv) { ::gpr_cv_signal(cv); } in gpr_cv_signal()
91 void CoreCodegen::gpr_cv_broadcast(gpr_cv* cv) { ::gpr_cv_broadcast(cv); } in gpr_cv_broadcast()
/external/grpc-grpc/src/core/lib/iomgr/
Dwakeup_fd_cv.h46 gpr_cv* cv;
60 gpr_cv shutdown_cv;
Dtimer_manager.cc43 static gpr_cv g_cv_wait;
45 static gpr_cv g_cv_shutdown;
Dpollset_windows.h51 gpr_cv cv;
Dexecutor.h32 gpr_cv cv;
/external/grpc-grpc/test/cpp/naming/
Dresolver_component_tests_runner_invoker.cc73 gpr_cv* test_driver_cv, int* test_driver_done) { in RunSigHandlingThread()
119 gpr_cv test_driver_cv; in InvokeResolverComponentTestsRunner()
/external/grpc-grpc/test/core/gpr/
Dsync_test.cc41 gpr_cv non_empty; /* Signalled when length becomes non-zero. */
42 gpr_cv non_full; /* Signalled when length becomes non-N. */
149 gpr_cv cv; /* signalling depends on test */
151 gpr_cv done_cv; /* signalled when done == 0 */
/external/grpc-grpc/src/core/lib/gprpp/
Dfork.cc107 gpr_cv cv_;
153 gpr_cv cv_;
Dthd_windows.cc125 gpr_cv ready_;
Dthd_posix.cc131 gpr_cv ready_;
/external/grpc-grpc/include/grpc/impl/codegen/
Dsync_posix.h29 typedef pthread_cond_t gpr_cv; typedef
Dsync_custom.h31 typedef GPR_CUSTOM_CV_TYPE gpr_cv; typedef
Dsync_windows.h31 typedef CONDITION_VARIABLE gpr_cv; typedef
/external/grpc-grpc/src/core/tsi/
Dalts_transport_security.h34 gpr_cv cv;
/external/grpc-grpc/test/cpp/util/
Dcli_call.h92 gpr_cv write_cv_; // Protected by write_mu_;
/external/grpc-grpc/test/core/gprpp/
Dthd_test.cc38 gpr_cv done_cv;
/external/grpc-grpc/test/core/end2end/tests/
Dfilter_status_code.cc50 static gpr_cv g_client_code_cv;
51 static gpr_cv g_server_code_cv;
/external/grpc-grpc/test/core/tsi/
Dtransport_security_test_lib.h105 gpr_cv cv;
/external/grpc-grpc/src/ruby/ext/grpc/
Drb_event_thread.c45 gpr_cv cv;

12