Searched refs:abs_deadline (Results 1 – 10 of 10) sorted by relevance
| /third_party/grpc/src/core/lib/gpr/ |
| D | sync_windows.cc | 68 int gpr_cv_wait(gpr_cv* cv, gpr_mu* mu, gpr_timespec abs_deadline) { in gpr_cv_wait() argument
72 if (gpr_time_cmp(abs_deadline, gpr_inf_future(abs_deadline.clock_type)) == in gpr_cv_wait()
76 abs_deadline = gpr_convert_clock_type(abs_deadline, GPR_CLOCK_REALTIME); in gpr_cv_wait()
77 gpr_timespec now = gpr_now(abs_deadline.clock_type); in gpr_cv_wait()
80 (int64_t)abs_deadline.tv_sec * 1000 + abs_deadline.tv_nsec / 1000000; in gpr_cv_wait()
|
| D | sync_posix.cc | 119 int gpr_cv_wait(gpr_cv* cv, gpr_mu* mu, gpr_timespec abs_deadline) { in gpr_cv_wait() argument
121 if (gpr_time_cmp(abs_deadline, gpr_inf_future(abs_deadline.clock_type)) == in gpr_cv_wait()
131 abs_deadline = gpr_convert_clock_type(abs_deadline, GPR_CLOCK_MONOTONIC); in gpr_cv_wait()
133 abs_deadline = gpr_convert_clock_type(abs_deadline, GPR_CLOCK_REALTIME); in gpr_cv_wait()
135 abs_deadline_ts.tv_sec = static_cast<time_t>(abs_deadline.tv_sec); in gpr_cv_wait()
136 abs_deadline_ts.tv_nsec = abs_deadline.tv_nsec; in gpr_cv_wait()
|
| D | sync_abseil.cc | 81 int gpr_cv_wait(gpr_cv* cv, gpr_mu* mu, gpr_timespec abs_deadline) { in gpr_cv_wait() argument
83 if (gpr_time_cmp(abs_deadline, gpr_inf_future(abs_deadline.clock_type)) == in gpr_cv_wait()
89 abs_deadline = gpr_convert_clock_type(abs_deadline, GPR_CLOCK_REALTIME); in gpr_cv_wait()
90 timespec ts = {static_cast<decltype(ts.tv_sec)>(abs_deadline.tv_sec), in gpr_cv_wait()
91 static_cast<decltype(ts.tv_nsec)>(abs_deadline.tv_nsec)}; in gpr_cv_wait()
|
| D | sync.cc | 73 void* gpr_event_wait(gpr_event* ev, gpr_timespec abs_deadline) { in gpr_event_wait() argument
80 } while (result == nullptr && !gpr_cv_wait(&s->cv, &s->mu, abs_deadline)); in gpr_event_wait()
|
| /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);
131 GPRAPI void* gpr_event_wait(gpr_event* ev, gpr_timespec abs_deadline);
253 int queue_remove(queue *q, int *head, gpr_timespec abs_deadline) {
262 !gpr_cv_wait(&q->non_empty, &q->mu, abs_deadline)) {
|
| /third_party/grpc/src/cpp/common/ |
| D | core_codegen.cc | 91 gpr_timespec abs_deadline) { in gpr_cv_wait() argument
92 return ::gpr_cv_wait(cv, mu, abs_deadline); in gpr_cv_wait()
|
| /third_party/grpc/test/core/gpr/ |
| D | sync_test.cc | 112 int queue_remove(queue* q, int* head, gpr_timespec abs_deadline) { in queue_remove() argument
120 while (q->length == 0 && !gpr_cv_wait(&q->non_empty, &q->mu, abs_deadline)) { in queue_remove()
|
| /third_party/grpc/include/grpcpp/impl/codegen/ |
| D | core_codegen_interface.h | 80 gpr_timespec abs_deadline) = 0;
|
| D | core_codegen.h | 62 int gpr_cv_wait(gpr_cv* cv, gpr_mu* mu, gpr_timespec abs_deadline) override;
|
| /third_party/grpc/src/ruby/ext/grpc/ |
| D | rb_grpc_imports.generated.h | 773 typedef int(*gpr_cv_wait_type)(gpr_cv* cv, gpr_mu* mu, gpr_timespec abs_deadline);
794 typedef void*(*gpr_event_wait_type)(gpr_event* ev, gpr_timespec abs_deadline);
|