Home
last modified time | relevance | path

Searched refs:gpr_inf_future (Results 1 – 25 of 97) sorted by relevance

1234

/third_party/grpc/src/cpp/util/
Dtime_cc.cc36 secs.count() >= gpr_inf_future(GPR_CLOCK_REALTIME).tv_sec || in Timepoint2Timespec()
38 *to = gpr_inf_future(GPR_CLOCK_REALTIME); in Timepoint2Timespec()
52 secs.count() >= gpr_inf_future(GPR_CLOCK_REALTIME).tv_sec || in TimepointHR2Timespec()
54 *to = gpr_inf_future(GPR_CLOCK_REALTIME); in TimepointHR2Timespec()
64 if (gpr_time_cmp(t, gpr_inf_future(t.clock_type)) == 0) { in Timespec2Timepoint()
/third_party/grpc/test/core/end2end/
Dmultiple_server_queues_test.cc55 grpc_completion_queue_next(cq2, gpr_inf_future(GPR_CLOCK_REALTIME), in main()
61 grpc_completion_queue_next(cq1, gpr_inf_future(GPR_CLOCK_REALTIME), nullptr); in main()
62 grpc_completion_queue_next(cq2, gpr_inf_future(GPR_CLOCK_REALTIME), nullptr); in main()
63 grpc_completion_queue_next(cq3, gpr_inf_future(GPR_CLOCK_REALTIME), nullptr); in main()
/third_party/grpc/test/core/gpr/
Dtime_test.cc68 x = gpr_inf_future(GPR_CLOCK_REALTIME); in test_values()
171 } while (gpr_time_cmp(x, gpr_inf_future(GPR_TIMESPAN)) < 0); in test_overflow()
172 GPR_ASSERT(gpr_time_cmp(x, gpr_inf_future(GPR_TIMESPAN)) == 0); in test_overflow()
186 infinity[0] = gpr_inf_future(GPR_TIMESPAN); in test_sticky_infinities()
188 addend[0] = gpr_inf_future(GPR_TIMESPAN); in test_sticky_infinities()
211 GPR_ASSERT(1 == gpr_time_similar(gpr_inf_future(GPR_TIMESPAN), in test_similar()
212 gpr_inf_future(GPR_TIMESPAN), in test_similar()
218 gpr_inf_future(GPR_TIMESPAN), in test_similar()
220 GPR_ASSERT(0 == gpr_time_similar(gpr_inf_future(GPR_TIMESPAN), in test_similar()
Dsync_test.cc79 gpr_cv_wait(&q->non_full, &q->mu, gpr_inf_future(GPR_CLOCK_MONOTONIC)); in queue_append()
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()
394 queue_remove(&m->q, &value, gpr_inf_future(GPR_CLOCK_MONOTONIC)); in consumer()
446 GPR_ASSERT(gpr_event_wait(&m->event, gpr_inf_future(GPR_CLOCK_REALTIME)) == in refcheck()
/third_party/grpc/src/core/lib/gprpp/
Dtime_util.cc27 return gpr_inf_future(GPR_TIMESPAN); in ToGprTimeSpec()
40 return gpr_inf_future(GPR_CLOCK_REALTIME); in ToGprTimeSpec()
55 if (gpr_time_cmp(ts, gpr_inf_future(GPR_TIMESPAN)) == 0) { in ToAbslDuration()
67 if (gpr_time_cmp(rts, gpr_inf_future(GPR_CLOCK_REALTIME)) == 0) { in ToAbslTime()
Dfork.cc77 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()
/third_party/grpc/test/core/fling/
Dclient.cc83 gpr_inf_future(GPR_CLOCK_REALTIME), nullptr); in step_ping_pong_request()
87 grpc_completion_queue_next(cq, gpr_inf_future(GPR_CLOCK_REALTIME), nullptr); in step_ping_pong_request()
101 gpr_inf_future(GPR_CLOCK_REALTIME), nullptr); in init_ping_pong_stream()
109 grpc_completion_queue_next(cq, gpr_inf_future(GPR_CLOCK_REALTIME), nullptr); in init_ping_pong_stream()
124 grpc_completion_queue_next(cq, gpr_inf_future(GPR_CLOCK_REALTIME), nullptr); in step_ping_pong_stream()
229 event = grpc_completion_queue_next(cq, gpr_inf_future(GPR_CLOCK_REALTIME), in main()
/third_party/grpc/test/cpp/util/
Dtime_test.cc50 Timespec2Timepoint(gpr_inf_future(GPR_CLOCK_REALTIME))); in TEST_F()
54 0, gpr_time_cmp(gpr_inf_future(GPR_CLOCK_REALTIME), from_time_point_max)); in TEST_F()
60 0, gpr_time_cmp(gpr_inf_future(GPR_CLOCK_REALTIME), from_time_point_max)); in TEST_F()
Dcli_call.cc131 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/test/cpp/microbenchmarks/
Dbm_cq.cc108 gpr_timespec deadline = gpr_inf_future(GPR_CLOCK_MONOTONIC); in BM_Pass1Core()
127 gpr_timespec deadline = gpr_inf_future(GPR_CLOCK_MONOTONIC); in BM_Pluck1Core()
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()
Dbm_call_create.cc107 gpr_timespec deadline = gpr_inf_future(GPR_CLOCK_MONOTONIC); in BM_CallCreateDestroy()
181 gpr_inf_future(GPR_CLOCK_REALTIME), nullptr); in BM_LameChannelCallCreateCore()
216 cq, gpr_inf_future(GPR_CLOCK_REALTIME), nullptr); in BM_LameChannelCallCreateCore()
255 gpr_inf_future(GPR_CLOCK_REALTIME), nullptr); in BM_LameChannelCallCreateCoreSeparateBatch()
295 cq, gpr_inf_future(GPR_CLOCK_REALTIME), nullptr); in BM_LameChannelCallCreateCoreSeparateBatch()
298 ev = grpc_completion_queue_next(cq, gpr_inf_future(GPR_CLOCK_REALTIME), in BM_LameChannelCallCreateCoreSeparateBatch()
475 const gpr_timespec deadline_ = gpr_inf_future(GPR_CLOCK_MONOTONIC);
722 gpr_timespec deadline = gpr_inf_future(GPR_CLOCK_MONOTONIC); in BM_IsolatedCall_NoOp()
737 gpr_timespec deadline = gpr_inf_future(GPR_CLOCK_MONOTONIC); in BM_IsolatedCall_Unary()
771 gpr_inf_future(GPR_CLOCK_MONOTONIC), nullptr); in BM_IsolatedCall_Unary()
[all …]
Dbm_chttp2_transport.cc200 gpr_event_wait(&done_, gpr_inf_future(GPR_CLOCK_REALTIME)); in ~Stream()
360 gpr_event_wait(&bm_done, gpr_inf_future(GPR_CLOCK_REALTIME)); in BM_StreamCreateSendInitialMetadataDestroy()
400 gpr_event_wait(stream_cancel_done, gpr_inf_future(GPR_CLOCK_REALTIME)); in BM_TransportEmptyOp()
468 gpr_event_wait(bm_done, gpr_inf_future(GPR_CLOCK_REALTIME)); in BM_TransportStreamSend()
484 gpr_event_wait(stream_cancel_done, gpr_inf_future(GPR_CLOCK_REALTIME)); in BM_TransportStreamSend()
670 gpr_event_wait(stream_cancel_done, gpr_inf_future(GPR_CLOCK_REALTIME)); in BM_TransportStreamRecv()
/third_party/grpc/src/core/lib/gpr/
Dtime.cc54 gpr_timespec gpr_inf_future(gpr_clock_type type) { in gpr_inf_future() function
75 out = gpr_inf_future(type); in to_seconds_from_sub_second_time()
99 out = gpr_inf_future(type); in to_seconds_from_above_second_time()
152 sum = gpr_inf_future(sum.clock_type); in gpr_time_add()
159 sum = gpr_inf_future(sum.clock_type); in gpr_time_add()
189 diff = gpr_inf_future(GPR_CLOCK_REALTIME); in gpr_time_sub()
/third_party/grpc/test/core/surface/
Dnum_external_connectivity_watchers_test.cc57 cq, gpr_inf_future(GPR_CLOCK_REALTIME), nullptr); in channel_idle_poll_for_timeout()
109 GPR_ASSERT(grpc_completion_queue_next(cq, gpr_inf_future(GPR_CLOCK_REALTIME), in run_timeouts_test()
143 cq, gpr_inf_future(GPR_CLOCK_REALTIME), nullptr); in run_channel_shutdown_before_timeout_test()
149 GPR_ASSERT(grpc_completion_queue_next(cq, gpr_inf_future(GPR_CLOCK_REALTIME), in run_channel_shutdown_before_timeout_test()
Dsequential_connectivity_test.cc57 a->cq, gpr_inf_future(GPR_CLOCK_REALTIME), nullptr); in server_thread_func()
116 cq, gpr_inf_future(GPR_CLOCK_REALTIME), nullptr); in run_test()
133 gpr_inf_future(GPR_CLOCK_REALTIME), nullptr) in run_test()
136 while (grpc_completion_queue_next(cq, gpr_inf_future(GPR_CLOCK_REALTIME), in run_test()
Dserver_test.cc101 grpc_completion_queue_next(cq, gpr_inf_future(GPR_CLOCK_MONOTONIC), nullptr); in test_bind_server_twice()
102 grpc_completion_queue_next(cq, gpr_inf_future(GPR_CLOCK_MONOTONIC), nullptr); in test_bind_server_twice()
128 grpc_completion_queue_next(cq, gpr_inf_future(GPR_CLOCK_MONOTONIC), nullptr); in test_bind_server_to_addr()
Dcompletion_queue_threading_test.cc74 gpr_inf_future(GPR_CLOCK_REALTIME), nullptr); in pluck_one()
107 gpr_inf_future(GPR_CLOCK_REALTIME), nullptr); in test_too_many_plucks()
192 opt->cc, gpr_inf_future(GPR_CLOCK_MONOTONIC), nullptr); in consumer_thread()
Dcompletion_queue_test.cc276 event = grpc_completion_queue_next(cc, gpr_inf_future(GPR_CLOCK_REALTIME), in test_shutdown_then_next_with_timeout()
356 cc, nullptr, gpr_inf_future(GPR_CLOCK_REALTIME), nullptr); in test_pluck_after_shutdown()
457 gpr_cv_wait(&cv, &mu, gpr_inf_future(GPR_CLOCK_REALTIME)); in test_callback()
467 gpr_inf_future(GPR_CLOCK_REALTIME)); in test_callback()
/third_party/grpc/test/core/end2end/tests/
Dconnectivity.cc52 ev = grpc_completion_queue_next(ce->cq, gpr_inf_future(GPR_CLOCK_MONOTONIC), in child_thread()
82 gpr_event_wait(&ce.started, gpr_inf_future(GPR_CLOCK_MONOTONIC)); in test_connectivity()
222 gpr_inf_future(GPR_CLOCK_MONOTONIC)) != nullptr); in test_watch_connectivity_cq_callback()
228 gpr_inf_future(GPR_CLOCK_MONOTONIC)); in test_watch_connectivity_cq_callback()
/third_party/grpc/test/core/iomgr/
Dstranded_event_test.cc78 while (grpc_completion_queue_next(cq, gpr_inf_future(GPR_CLOCK_REALTIME), in ~TestCall()
204 test_call->cq, gpr_inf_future(GPR_CLOCK_REALTIME), nullptr); in FinishCall()
231 while (grpc_completion_queue_next(cq_, gpr_inf_future(GPR_CLOCK_REALTIME), in ~TestServer()
252 cq_, gpr_inf_future(GPR_CLOCK_REALTIME), nullptr); in AcceptThread()
267 event = grpc_completion_queue_next(cq_, gpr_inf_future(GPR_CLOCK_REALTIME), in AcceptThread()
358 gpr_inf_future(GPR_CLOCK_REALTIME), nullptr); in TEST()
Dpollset_windows_starvation_test.cc114 !gpr_cv_wait(&params.cv, &params.mu, gpr_inf_future(GPR_CLOCK_REALTIME))) in main()
135 !gpr_cv_wait(&params.cv, &params.mu, gpr_inf_future(GPR_CLOCK_REALTIME))) in main()
/third_party/grpc/include/grpcpp/impl/codegen/
Dsync.h131 g_core_codegen_interface->gpr_inf_future(GPR_CLOCK_REALTIME)); in Wait()
140 Wait(mu, g_core_codegen_interface->gpr_inf_future(GPR_CLOCK_REALTIME)); in WaitUntil()
/third_party/grpc/src/ruby/ext/grpc/
Drb_server.c65 server->queue, tag, gpr_inf_future(GPR_CLOCK_REALTIME), NULL); in grpc_rb_server_maybe_shutdown_and_notify()
227 gpr_inf_future(GPR_CLOCK_REALTIME), NULL); in grpc_rb_server_request_call()
266 deadline = gpr_inf_future(GPR_CLOCK_REALTIME); in grpc_rb_server_shutdown_and_notify()
/third_party/grpc/src/php/ext/grpc/
Dserver.c48 gpr_inf_future(GPR_CLOCK_REALTIME), NULL);
122 gpr_inf_future(GPR_CLOCK_REALTIME), in PHP_METHOD()
/third_party/grpc/test/core/gprpp/
Dmpscq_test.cc71 gpr_event_wait(a->start, gpr_inf_future(GPR_CLOCK_REALTIME)); in test_thread()
123 gpr_event_wait(pa->start, gpr_inf_future(GPR_CLOCK_REALTIME)); in pull_thread()

1234