Searched refs:abs_deadline (Results 1 – 9 of 9) sorted by relevance
| /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() argument
77 if (gpr_time_cmp(abs_deadline, gpr_inf_future(abs_deadline.clock_type)) == in gpr_cv_wait()
83 abs_deadline = gpr_convert_clock_type(abs_deadline, GPR_CLOCK_MONOTONIC); in gpr_cv_wait()
85 abs_deadline = gpr_convert_clock_type(abs_deadline, GPR_CLOCK_REALTIME); in gpr_cv_wait()
87 abs_deadline_ts.tv_sec = static_cast<time_t>(abs_deadline.tv_sec); in gpr_cv_wait()
88 abs_deadline_ts.tv_nsec = abs_deadline.tv_nsec; in gpr_cv_wait()
|
| D | sync_windows.cc | 67 int gpr_cv_wait(gpr_cv* cv, gpr_mu* mu, gpr_timespec abs_deadline) { in gpr_cv_wait() argument
71 if (gpr_time_cmp(abs_deadline, gpr_inf_future(abs_deadline.clock_type)) == in gpr_cv_wait()
75 abs_deadline = gpr_convert_clock_type(abs_deadline, GPR_CLOCK_REALTIME); in gpr_cv_wait()
76 gpr_timespec now = gpr_now(abs_deadline.clock_type); in gpr_cv_wait()
79 (int64_t)abs_deadline.tv_sec * 1000 + abs_deadline.tv_nsec / 1000000; 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()
|
| /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);
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)) {
|
| /external/grpc-grpc/src/cpp/common/ |
| D | core_codegen.cc | 87 gpr_timespec abs_deadline) { in gpr_cv_wait() argument
88 return ::gpr_cv_wait(cv, mu, abs_deadline); in gpr_cv_wait()
|
| /external/grpc-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()
|
| /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 | 78 gpr_timespec abs_deadline) = 0;
|
| /external/grpc-grpc/src/ruby/ext/grpc/ |
| D | rb_grpc_imports.generated.h | 689 typedef int(*gpr_cv_wait_type)(gpr_cv* cv, gpr_mu* mu, gpr_timespec abs_deadline);
710 typedef void*(*gpr_event_wait_type)(gpr_event* ev, gpr_timespec abs_deadline);
|