Home
last modified time | relevance | path

Searched refs:GPR_CLOCK_MONOTONIC (Results 1 – 25 of 70) sorted by relevance

123

/third_party/grpc/src/core/lib/iomgr/executor/
Dmpmcqueue.cc37 gpr_time_sub(gpr_now(GPR_CLOCK_MONOTONIC), queue_head_->insert_time); in PopFront()
46 gpr_time_sub(gpr_now(GPR_CLOCK_MONOTONIC), busy_time)); in PopFront()
130 auto current_time = gpr_now(GPR_CLOCK_MONOTONIC); in Put()
150 start_time = gpr_now(GPR_CLOCK_MONOTONIC); in Get()
161 *wait_time = gpr_time_sub(gpr_now(GPR_CLOCK_MONOTONIC), start_time); in Get()
/third_party/grpc/src/core/lib/gpr/
Dtime_precise.cc63 gpr_timespec start = gpr_now(GPR_CLOCK_MONOTONIC); in is_fake_clock()
66 gpr_timespec now = gpr_now(GPR_CLOCK_MONOTONIC); in is_fake_clock()
97 gpr_timespec start = gpr_now(GPR_CLOCK_MONOTONIC); in gpr_precise_clock_init()
100 gpr_timespec now = gpr_now(GPR_CLOCK_MONOTONIC); in gpr_precise_clock_init()
Dtime_posix.cc118 case GPR_CLOCK_MONOTONIC: in now_impl()
154 GPR_ASSERT(clock_type == GPR_CLOCK_MONOTONIC || in gpr_now()
/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()
94 f.client, GRPC_CHANNEL_IDLE, gpr_now(GPR_CLOCK_MONOTONIC), f.cq, tag(1)); 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/cpp/naming/
Dresolver_component_tests_runner_invoker.cc79 gpr_time_add(gpr_now(GPR_CLOCK_MONOTONIC), in RunSigHandlingThread()
82 gpr_timespec now = gpr_now(GPR_CLOCK_MONOTONIC); in RunSigHandlingThread()
90 gpr_now(GPR_CLOCK_MONOTONIC), gpr_time_from_seconds(1, GPR_TIMESPAN)); in RunSigHandlingThread()
/third_party/grpc/test/cpp/microbenchmarks/
Dbm_fullstack_trickle.cc133 auto now = gpr_time_sub(gpr_now(GPR_CLOCK_MONOTONIC), start_); in Log()
213 gpr_timespec start_ = gpr_now(GPR_CLOCK_MONOTONIC);
244 fixture->cq()->AsyncNext(t, ok, gpr_inf_past(GPR_CLOCK_MONOTONIC))) { in TrickleCQNext()
304 gpr_timespec warmup_start = gpr_now(GPR_CLOCK_MONOTONIC); in BM_PumpStreamServerToClient_Trickle()
310 if (gpr_time_cmp(gpr_time_sub(gpr_now(GPR_CLOCK_MONOTONIC), warmup_start), in BM_PumpStreamServerToClient_Trickle()
417 gpr_timespec warmup_start = gpr_now(GPR_CLOCK_MONOTONIC); in BM_PumpUnbalancedUnary_Trickle()
423 if (gpr_time_cmp(gpr_time_sub(gpr_now(GPR_CLOCK_MONOTONIC), warmup_start), in BM_PumpUnbalancedUnary_Trickle()
Dbm_call_create.cc107 gpr_timespec deadline = gpr_inf_future(GPR_CLOCK_MONOTONIC); in BM_CallCreateDestroy()
475 const gpr_timespec deadline_ = gpr_inf_future(GPR_CLOCK_MONOTONIC);
476 const gpr_timespec start_time_ = gpr_now(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()
783 gpr_timespec deadline = gpr_inf_future(GPR_CLOCK_MONOTONIC); in BM_IsolatedCall_StreamingSend()
802 grpc_completion_queue_next(fixture.cq(), gpr_inf_future(GPR_CLOCK_MONOTONIC), in BM_IsolatedCall_StreamingSend()
811 gpr_inf_future(GPR_CLOCK_MONOTONIC), nullptr); in BM_IsolatedCall_StreamingSend()
Dbm_cq_multiple_threads.cc129 gpr_timespec deadline = gpr_time_0(GPR_CLOCK_MONOTONIC); in teardown()
160 gpr_timespec deadline = gpr_inf_future(GPR_CLOCK_MONOTONIC); in BM_Cq_Throughput()
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()
146 gpr_timespec deadline = gpr_inf_past(GPR_CLOCK_MONOTONIC); in BM_EmptyCore()
/third_party/grpc/src/core/lib/transport/
Dbdp_estimator.cc36 ping_start_time_(gpr_time_0(GPR_CLOCK_MONOTONIC)), in BdpEstimator()
43 gpr_timespec now = gpr_now(GPR_CLOCK_MONOTONIC); in CompletePing()
/third_party/grpc/test/core/gpr/
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()
338 deadline = gpr_time_add(gpr_now(GPR_CLOCK_MONOTONIC), in inc_with_1ms_delay()
394 queue_remove(&m->q, &value, gpr_inf_future(GPR_CLOCK_MONOTONIC)); in consumer()
401 gpr_time_add(gpr_now(GPR_CLOCK_MONOTONIC), in consumer()
/third_party/grpc/test/core/surface/
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()
/third_party/grpc/test/core/end2end/
Dcq_verifier_uv.cc85 ev = grpc_completion_queue_next(v->cq, gpr_inf_past(GPR_CLOCK_MONOTONIC), in cq_verifier_next_event()
91 ev = grpc_completion_queue_next(v->cq, gpr_inf_past(GPR_CLOCK_MONOTONIC), in cq_verifier_next_event()
/third_party/grpc/test/cpp/end2end/
Dtime_change_test.cc104 gpr_timespec now = gpr_now(GPR_CLOCK_MONOTONIC); in TEST()
113 gpr_timespec now = gpr_now(GPR_CLOCK_MONOTONIC); in TEST()
121 gpr_timespec ts = grpc_millis_to_timespec(-1500, GPR_CLOCK_MONOTONIC); in TEST()
124 GPR_ASSERT(ts.clock_type == GPR_CLOCK_MONOTONIC); in TEST()
Dserver_early_return_test.cc69 gpr_now(GPR_CLOCK_MONOTONIC), in RequestStream()
94 gpr_now(GPR_CLOCK_MONOTONIC), in BidiStream()
/third_party/grpc/test/core/client_channel/resolvers/
Ddns_resolver_cooldown_test.cc75 grpc_timespec_to_millis_round_up(gpr_now(GPR_CLOCK_MONOTONIC)); in test_resolve_address_impl()
78 grpc_timespec_to_millis_round_up(gpr_now(GPR_CLOCK_MONOTONIC)); in test_resolve_address_impl()
108 grpc_timespec_to_millis_round_up(gpr_now(GPR_CLOCK_MONOTONIC)); in test_dns_lookup_ares_locked()
115 grpc_timespec_to_millis_round_up(gpr_now(GPR_CLOCK_MONOTONIC)); in test_dns_lookup_ares_locked()
/third_party/grpc/test/cpp/common/
Dtime_jump_test.cc118 gpr_timespec before = gpr_now(GPR_CLOCK_MONOTONIC); in TEST_P()
121 gpr_timespec after = gpr_now(GPR_CLOCK_MONOTONIC); in TEST_P()
/third_party/grpc/test/core/util/
Dtest_tcp_server.cc103 shutdown_deadline = gpr_time_add(gpr_now(GPR_CLOCK_MONOTONIC), in test_tcp_server_destroy()
107 gpr_time_cmp(gpr_now(GPR_CLOCK_MONOTONIC), shutdown_deadline) < 0) { in test_tcp_server_destroy()
Dtest_config.cc370 gpr_now(GPR_CLOCK_MONOTONIC), in grpc_timeout_seconds_to_deadline()
378 gpr_now(GPR_CLOCK_MONOTONIC), in grpc_timeout_milliseconds_to_deadline()
411 if (gpr_time_cmp(gpr_now(GPR_CLOCK_MONOTONIC), deadline) > 0) { in ~TestEnvironment()
/third_party/grpc/test/core/iomgr/
Dtimer_list_test.cc192 now + kMillisIn25Days, gpr_clock_type::GPR_CLOCK_MONOTONIC); in long_running_service_cleanup_test()
243 gpr_time_sub(gpr_now(gpr_clock_type::GPR_CLOCK_MONOTONIC), in main()
245 gpr_clock_type::GPR_CLOCK_MONOTONIC)); in main()
/third_party/grpc/test/core/tsi/alts/handshaker/
Dalts_concurrent_connectivity_test.cc323 if (gpr_time_cmp(gpr_now(GPR_CLOCK_MONOTONIC), test_deadline) > 0) { in TEST()
469 gpr_sleep_until(gpr_time_add(gpr_now(GPR_CLOCK_MONOTONIC), in RunServerLoop()
520 if (gpr_time_cmp(gpr_now(GPR_CLOCK_MONOTONIC), test_deadline) > 0) { in TEST()
551 if (gpr_time_cmp(gpr_now(GPR_CLOCK_MONOTONIC), test_deadline) > 0) { in TEST()
583 if (gpr_time_cmp(gpr_now(GPR_CLOCK_MONOTONIC), test_deadline) > 0) { in TEST()
/third_party/grpc/include/grpc/impl/codegen/
Dgpr_types.h33 GPR_CLOCK_MONOTONIC = 0, enumerator
/third_party/grpc/src/core/lib/iomgr/
Dtimer_manager.cc201 grpc_millis_to_timespec(next, GPR_CLOCK_MONOTONIC)); in wait_until()
326 gpr_cv_wait(&g_cv_shutdown, &g_mu, gpr_inf_future(GPR_CLOCK_MONOTONIC)); in stop_threads()
Dexec_ctx.cc136 g_start_time = gpr_now(GPR_CLOCK_MONOTONIC); in GlobalInit()
166 now_ = timespec_to_millis_round_down(gpr_now(GPR_CLOCK_MONOTONIC)); in Now()
/third_party/grpc/test/cpp/util/
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()

123