Home
last modified time | relevance | path

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

1234

/external/grpc-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()
/external/grpc-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()
Dmpscq_test.cc70 gpr_event_wait(a->start, gpr_inf_future(GPR_CLOCK_REALTIME)); in test_thread()
124 gpr_event_wait(pa->start, gpr_inf_future(GPR_CLOCK_REALTIME)); in pull_thread()
/external/grpc-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()
/external/grpc-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()
/external/grpc-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()
/external/grpc-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()
148 sum = gpr_inf_future(sum.clock_type); in gpr_time_add()
155 sum = gpr_inf_future(sum.clock_type); in gpr_time_add()
181 diff = gpr_inf_future(GPR_CLOCK_REALTIME); in gpr_time_sub()
/external/grpc-grpc/test/core/memory_usage/
Dclient.cc79 gpr_inf_future(GPR_CLOCK_REALTIME), nullptr); in init_ping_pong_request()
85 grpc_completion_queue_next(cq, gpr_inf_future(GPR_CLOCK_REALTIME), nullptr); in init_ping_pong_request()
105 grpc_completion_queue_next(cq, gpr_inf_future(GPR_CLOCK_REALTIME), nullptr); in finish_ping_pong_request()
145 gpr_inf_future(GPR_CLOCK_REALTIME), nullptr); in send_snapshot_request()
150 grpc_completion_queue_next(cq, gpr_inf_future(GPR_CLOCK_REALTIME), nullptr); in send_snapshot_request()
282 event = grpc_completion_queue_next(cq, gpr_inf_future(GPR_CLOCK_REALTIME), in main()
/external/grpc-grpc/test/core/surface/
Dsequential_connectivity_test.cc48 a->cq, gpr_inf_future(GPR_CLOCK_REALTIME), nullptr); in server_thread_func()
85 cq, gpr_inf_future(GPR_CLOCK_REALTIME), nullptr); in run_test()
102 gpr_inf_future(GPR_CLOCK_REALTIME), nullptr) in run_test()
105 while (grpc_completion_queue_next(cq, gpr_inf_future(GPR_CLOCK_REALTIME), in run_test()
Dnum_external_connectivity_watchers_test.cc54 cq, gpr_inf_future(GPR_CLOCK_REALTIME), nullptr); in channel_idle_poll_for_timeout()
108 GPR_ASSERT(grpc_completion_queue_next(cq, gpr_inf_future(GPR_CLOCK_REALTIME), in run_timeouts_test()
145 cq, gpr_inf_future(GPR_CLOCK_REALTIME), nullptr); in run_channel_shutdown_before_timeout_test()
151 GPR_ASSERT(grpc_completion_queue_next(cq, gpr_inf_future(GPR_CLOCK_REALTIME), in run_channel_shutdown_before_timeout_test()
Dserver_test.cc98 grpc_completion_queue_next(cq, gpr_inf_future(GPR_CLOCK_MONOTONIC), nullptr); in test_bind_server_twice()
99 grpc_completion_queue_next(cq, gpr_inf_future(GPR_CLOCK_MONOTONIC), nullptr); in test_bind_server_twice()
126 grpc_completion_queue_next(cq, gpr_inf_future(GPR_CLOCK_MONOTONIC), nullptr); in test_bind_server_to_addr()
Dcompletion_queue_threading_test.cc73 gpr_inf_future(GPR_CLOCK_REALTIME), nullptr); in pluck_one()
106 gpr_inf_future(GPR_CLOCK_REALTIME), nullptr); in test_too_many_plucks()
191 opt->cc, gpr_inf_future(GPR_CLOCK_MONOTONIC), nullptr); in consumer_thread()
/external/grpc-grpc/test/cpp/microbenchmarks/
Dbm_call_create.cc110 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()
491 const gpr_timespec deadline_ = gpr_inf_future(GPR_CLOCK_MONOTONIC);
729 gpr_timespec deadline = gpr_inf_future(GPR_CLOCK_MONOTONIC); in BM_IsolatedCall_NoOp()
744 gpr_timespec deadline = gpr_inf_future(GPR_CLOCK_MONOTONIC); in BM_IsolatedCall_Unary()
778 gpr_inf_future(GPR_CLOCK_MONOTONIC), nullptr); in BM_IsolatedCall_Unary()
[all …]
Dbm_cq.cc102 gpr_timespec deadline = gpr_inf_future(GPR_CLOCK_MONOTONIC); in BM_Pass1Core()
121 gpr_timespec deadline = gpr_inf_future(GPR_CLOCK_MONOTONIC); in BM_Pluck1Core()
/external/grpc-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()
223 gpr_inf_future(GPR_CLOCK_REALTIME), NULL); in grpc_rb_server_request_call()
262 deadline = gpr_inf_future(GPR_CLOCK_REALTIME); in grpc_rb_server_shutdown_and_notify()
Drb_channel.c344 gpr_inf_future(GPR_CLOCK_REALTIME)); in wait_for_watch_state_op_complete_without_gvl()
592 gpr_inf_future(GPR_CLOCK_REALTIME), in grpc_rb_channel_try_register_connection_polling()
617 channel_polling_cq, gpr_inf_future(GPR_CLOCK_REALTIME), NULL); in run_poll_channels_loop_no_gil()
698 gpr_inf_future(GPR_CLOCK_REALTIME)); in wait_until_channel_polling_thread_started_no_gil()
/external/grpc-grpc/src/core/lib/gprpp/
Dfork.cc67 gpr_cv_wait(&cv_, &mu_, gpr_inf_future(GPR_CLOCK_REALTIME)); in IncExecCtxCount()
138 gpr_cv_wait(&cv_, &mu_, gpr_inf_future(GPR_CLOCK_REALTIME)); in AwaitThreads()
/external/grpc-grpc/test/core/end2end/tests/
Dconnectivity.cc41 ev = grpc_completion_queue_next(ce->cq, gpr_inf_future(GPR_CLOCK_MONOTONIC), in child_thread()
71 gpr_event_wait(&ce.started, gpr_inf_future(GPR_CLOCK_MONOTONIC)); in test_connectivity()
/external/grpc-grpc/src/php/ext/grpc/
Dserver.c43 gpr_inf_future(GPR_CLOCK_REALTIME), NULL);
117 gpr_inf_future(GPR_CLOCK_REALTIME), in PHP_METHOD()
/external/grpc-grpc/test/core/transport/chttp2/
Dsettings_timeout_test.cc83 cq_, gpr_inf_future(GPR_CLOCK_MONOTONIC), nullptr); in Serve()
117 grpc_timespec_to_millis_round_up(gpr_inf_future(GPR_CLOCK_MONOTONIC)))); in Connect()
/external/grpc-grpc/src/cpp/common/
Dcore_codegen.cc206 gpr_timespec CoreCodegen::gpr_inf_future(gpr_clock_type type) { in gpr_inf_future() function in grpc::CoreCodegen
207 return ::gpr_inf_future(type); in gpr_inf_future()
/external/grpc-grpc/src/python/grpcio/grpc/_cython/_cygrpc/
Dcompletion_queue.pyx.pxi29 c_deadline = gpr_inf_future(GPR_CLOCK_REALTIME)
110 c_deadline = gpr_inf_future(GPR_CLOCK_REALTIME)
/external/grpc-grpc/src/core/tsi/
Dalts_transport_security.cc35 gpr_inf_future(GPR_CLOCK_REALTIME)); in grpc_tsi_alts_wait_for_cq_drain()

1234