Home
last modified time | relevance | path

Searched refs:GPR_CLOCK_REALTIME (Results 1 – 25 of 134) sorted by relevance

123456

/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()
44 to->clock_type = 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()
60 to->clock_type = GPR_CLOCK_REALTIME; in TimepointHR2Timespec()
67 t = gpr_convert_clock_type(t, GPR_CLOCK_REALTIME); in Timespec2Timepoint()
/third_party/grpc/src/core/lib/gprpp/
Dtime_util.cc40 return gpr_inf_future(GPR_CLOCK_REALTIME); in ToGprTimeSpec()
42 return gpr_inf_past(GPR_CLOCK_REALTIME); in ToGprTimeSpec()
48 out.clock_type = GPR_CLOCK_REALTIME; in ToGprTimeSpec()
66 gpr_timespec rts = gpr_convert_clock_type(ts, GPR_CLOCK_REALTIME); in ToAbslTime()
67 if (gpr_time_cmp(rts, gpr_inf_future(GPR_CLOCK_REALTIME)) == 0) { in ToAbslTime()
69 } else if (gpr_time_cmp(rts, gpr_inf_past(GPR_CLOCK_REALTIME)) == 0) { in ToAbslTime()
/third_party/grpc/test/cpp/util/
Dtime_test.cc35 ts.clock_type = GPR_CLOCK_REALTIME; in TEST_F()
50 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()
Dmetrics_server.cc32 : start_time_(gpr_now(GPR_CLOCK_REALTIME)), num_queries_(0) {} in QpsGauge()
37 start_time_ = gpr_now(GPR_CLOCK_REALTIME); in Reset()
48 gpr_time_sub(gpr_now(GPR_CLOCK_REALTIME), start_time_); in Get()
/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/surface/
Dcompletion_queue_test.cc44 ev = grpc_completion_queue_next(cc, gpr_inf_past(GPR_CLOCK_REALTIME), in shutdown_and_destroy()
51 cc, create_test_tag(), gpr_inf_past(GPR_CLOCK_REALTIME), nullptr); in shutdown_and_destroy()
126 grpc_completion_queue_next(cc, gpr_now(GPR_CLOCK_REALTIME), nullptr); in test_wait_empty()
158 ev = grpc_completion_queue_next(cc, gpr_inf_past(GPR_CLOCK_REALTIME), in test_cq_end_op()
194 ev = grpc_completion_queue_next(cc, gpr_inf_past(GPR_CLOCK_REALTIME), in test_cq_tls_cache_full()
203 ev = grpc_completion_queue_next(cc, gpr_inf_past(GPR_CLOCK_REALTIME), in test_cq_tls_cache_full()
253 event = grpc_completion_queue_next(cc, gpr_inf_past(GPR_CLOCK_REALTIME), in test_shutdown_then_next_polling()
276 event = grpc_completion_queue_next(cc, gpr_inf_future(GPR_CLOCK_REALTIME), in test_shutdown_then_next_with_timeout()
318 cc, tags[i], gpr_inf_past(GPR_CLOCK_REALTIME), nullptr); in test_pluck()
330 gpr_inf_past(GPR_CLOCK_REALTIME), in test_pluck()
[all …]
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()
/third_party/grpc/src/core/lib/iomgr/
Diomgr.cc91 gpr_now(GPR_CLOCK_REALTIME), gpr_time_from_seconds(10, GPR_TIMESPAN)); in grpc_iomgr_shutdown()
92 gpr_timespec last_warning_time = gpr_now(GPR_CLOCK_REALTIME); in grpc_iomgr_shutdown()
103 gpr_time_sub(gpr_now(GPR_CLOCK_REALTIME), last_warning_time), in grpc_iomgr_shutdown()
110 last_warning_time = gpr_now(GPR_CLOCK_REALTIME); in grpc_iomgr_shutdown()
134 if (gpr_time_cmp(gpr_now(GPR_CLOCK_REALTIME), shutdown_deadline) > in grpc_iomgr_shutdown()
Dbuffer_list.cc39 gts->clock_type = GPR_CLOCK_REALTIME; in fill_gpr_from_timestamp()
203 new_elem->ts_.sendmsg_time.time = gpr_now(GPR_CLOCK_REALTIME); in AddNewEntry()
204 new_elem->ts_.scheduled_time.time = gpr_inf_past(GPR_CLOCK_REALTIME); in AddNewEntry()
205 new_elem->ts_.sent_time.time = gpr_inf_past(GPR_CLOCK_REALTIME); in AddNewEntry()
206 new_elem->ts_.acked_time.time = gpr_inf_past(GPR_CLOCK_REALTIME); in AddNewEntry()
/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()
129 gpr_timespec tv = gpr_now(GPR_CLOCK_REALTIME); in now()
229 event = grpc_completion_queue_next(cq, gpr_inf_future(GPR_CLOCK_REALTIME), in main()
/third_party/grpc/test/cpp/end2end/
Dserver_crash_test.cc62 gpr_sleep_until(gpr_time_add(gpr_now(GPR_CLOCK_REALTIME), in BidiStream()
78 gpr_sleep_until(gpr_time_add(gpr_now(GPR_CLOCK_REALTIME), in ResponseStream()
126 gpr_sleep_until(gpr_time_add(gpr_now(GPR_CLOCK_REALTIME), in TEST_F()
136 gpr_sleep_until(gpr_time_add(gpr_now(GPR_CLOCK_REALTIME), in TEST_F()
/third_party/grpc/test/cpp/interop/
Dstress_interop_client.cc90 test_end_time = gpr_inf_future(GPR_CLOCK_REALTIME); in MainLoop()
93 gpr_time_add(gpr_now(GPR_CLOCK_REALTIME), in MainLoop()
99 while (gpr_time_cmp(gpr_now(GPR_CLOCK_REALTIME), test_end_time) < 0) { in MainLoop()
110 gpr_time_add(gpr_now(GPR_CLOCK_REALTIME), in MainLoop()
/third_party/grpc/src/python/grpcio/grpc/_cython/_cygrpc/
Dtime.pyx.pxi18 return gpr_inf_future(GPR_CLOCK_REALTIME)
22 GPR_CLOCK_REALTIME,
28 timespec, GPR_CLOCK_REALTIME)
/third_party/grpc/test/core/gprpp/
Dfork_test.cc55 gpr_sleep_until(gpr_time_add(gpr_now(GPR_CLOCK_REALTIME), in sleeping_thd()
70 gpr_time_add(gpr_now(GPR_CLOCK_REALTIME), in test_thd_count()
82 gpr_timespec end_time = gpr_now(GPR_CLOCK_REALTIME); in test_thd_count()
124 gpr_sleep_until(gpr_time_add(gpr_now(GPR_CLOCK_REALTIME), in test_exec_count()
/third_party/grpc/src/ruby/ext/grpc/
Drb_grpc.c101 t.clock_type = GPR_CLOCK_REALTIME; in grpc_rb_time_timeval()
173 real_time = gpr_convert_clock_type(*time_const, GPR_CLOCK_REALTIME); in grpc_rb_time_val_to_time()
198 zero_realtime = gpr_time_0(GPR_CLOCK_REALTIME); in Init_grpc_time_consts()
199 inf_future_realtime = gpr_inf_future(GPR_CLOCK_REALTIME); in Init_grpc_time_consts()
200 inf_past_realtime = gpr_inf_past(GPR_CLOCK_REALTIME); in Init_grpc_time_consts()
Drb_server.c65 server->queue, tag, gpr_inf_future(GPR_CLOCK_REALTIME), NULL); in grpc_rb_server_maybe_shutdown_and_notify()
97 deadline = gpr_time_add(gpr_now(GPR_CLOCK_REALTIME), in grpc_rb_server_free_internal()
227 gpr_inf_future(GPR_CLOCK_REALTIME), NULL); in grpc_rb_server_request_call()
235 deadline = gpr_convert_clock_type(st.details.deadline, GPR_CLOCK_REALTIME); in grpc_rb_server_request_call()
266 deadline = gpr_inf_future(GPR_CLOCK_REALTIME); in grpc_rb_server_shutdown_and_notify()
/third_party/grpc/test/core/end2end/fuzzers/
Dclient_fuzzer.cc70 gpr_inf_future(GPR_CLOCK_REALTIME), nullptr); in LLVMFuzzerTestOneInput()
121 ev = grpc_completion_queue_next(cq, gpr_inf_past(GPR_CLOCK_REALTIME), in LLVMFuzzerTestOneInput()
139 ev = grpc_completion_queue_next(cq, gpr_inf_past(GPR_CLOCK_REALTIME), in LLVMFuzzerTestOneInput()
145 ev = grpc_completion_queue_next(cq, gpr_inf_past(GPR_CLOCK_REALTIME), in LLVMFuzzerTestOneInput()
Dserver_fuzzer.cc79 ev = grpc_completion_queue_next(cq, gpr_inf_past(GPR_CLOCK_REALTIME), in LLVMFuzzerTestOneInput()
114 ev = grpc_completion_queue_next(cq, gpr_inf_past(GPR_CLOCK_REALTIME), in LLVMFuzzerTestOneInput()
124 ev = grpc_completion_queue_next(cq, gpr_inf_past(GPR_CLOCK_REALTIME), in LLVMFuzzerTestOneInput()
/third_party/grpc/test/core/gpr/
Dtime_test.cc65 gpr_timespec x = gpr_time_0(GPR_CLOCK_REALTIME); in test_values()
68 x = gpr_inf_future(GPR_CLOCK_REALTIME); in test_values()
80 x = gpr_inf_past(GPR_CLOCK_REALTIME); in test_values()
241 gpr_timespec realtime = {INT64_MAX, 1, GPR_CLOCK_REALTIME}; in test_convert_extreme()
248 gpr_timespec t1 = {INT64_MAX, 1, GPR_CLOCK_REALTIME}; in test_cmp_extreme()
249 gpr_timespec t2 = {INT64_MAX, 2, GPR_CLOCK_REALTIME}; in test_cmp_extreme()
Dspinlock_test.cc94 gpr_timespec start = gpr_now(GPR_CLOCK_REALTIME); in test()
101 while (gpr_time_cmp(gpr_now(GPR_CLOCK_REALTIME), deadline) < 0) { in test()
117 time_taken = gpr_time_sub(gpr_now(GPR_CLOCK_REALTIME), start); in test()
/third_party/grpc/src/core/lib/channel/
Dchannel_trace.cc49 GPR_CLOCK_REALTIME)), in TraceEvent()
58 GPR_CLOCK_REALTIME)), in TraceEvent()
75 GPR_CLOCK_REALTIME); in ChannelTrace()
/third_party/grpc/src/core/lib/security/credentials/jwt/
Djwt_credentials.cc49 cached_.jwt_expiration = gpr_inf_past(GPR_CLOCK_REALTIME); in reset_cache()
74 gpr_time_sub(cached_.jwt_expiration, gpr_now(GPR_CLOCK_REALTIME)), in get_request_metadata()
92 gpr_time_add(gpr_now(GPR_CLOCK_REALTIME), jwt_lifetime_); in get_request_metadata()
Djwt_verifier.cc110 gpr_timespec result = gpr_time_0(GPR_CLOCK_REALTIME); in validate_time_field()
225 if (claims == nullptr) return gpr_inf_past(GPR_CLOCK_REALTIME); in grpc_jwt_claims_issued_at()
230 if (claims == nullptr) return gpr_inf_future(GPR_CLOCK_REALTIME); in grpc_jwt_claims_expires_at()
235 if (claims == nullptr) return gpr_inf_past(GPR_CLOCK_REALTIME); in grpc_jwt_claims_not_before()
243 claims->iat = gpr_inf_past(GPR_CLOCK_REALTIME); in grpc_jwt_claims_from_json()
244 claims->nbf = gpr_inf_past(GPR_CLOCK_REALTIME); in grpc_jwt_claims_from_json()
245 claims->exp = gpr_inf_future(GPR_CLOCK_REALTIME); in grpc_jwt_claims_from_json()
263 if (gpr_time_cmp(claims->iat, gpr_time_0(GPR_CLOCK_REALTIME)) == 0) { in grpc_jwt_claims_from_json()
268 if (gpr_time_cmp(claims->exp, gpr_time_0(GPR_CLOCK_REALTIME)) == 0) { in grpc_jwt_claims_from_json()
273 if (gpr_time_cmp(claims->nbf, gpr_time_0(GPR_CLOCK_REALTIME)) == 0) { in grpc_jwt_claims_from_json()
[all …]
/third_party/grpc/src/php/ext/grpc/
Dtimeval.c198 zval *now = grpc_php_wrap_timeval(gpr_now(GPR_CLOCK_REALTIME) TSRMLS_CC); in PHP_METHOD()
208 grpc_php_wrap_timeval(gpr_time_0(GPR_CLOCK_REALTIME) TSRMLS_CC); in PHP_METHOD()
218 grpc_php_wrap_timeval(gpr_inf_future(GPR_CLOCK_REALTIME) TSRMLS_CC); in PHP_METHOD()
228 grpc_php_wrap_timeval(gpr_inf_past(GPR_CLOCK_REALTIME) TSRMLS_CC); in PHP_METHOD()

123456