Home
last modified time | relevance | path

Searched refs:grpc_millis (Results 1 – 25 of 112) sorted by relevance

12345

/external/grpc-grpc/test/core/backoff/
Dbackoff_test.cc35 const grpc_millis initial_backoff = 200; in TEST()
38 const grpc_millis max_backoff = 1000; in TEST()
47 grpc_millis next_attempt_start_time = backoff.NextAttemptTime(); in TEST()
58 const grpc_millis initial_backoff = 100; in TEST()
61 const grpc_millis max_backoff = 1000; in TEST()
69 grpc_millis next = backoff.NextAttemptTime(); in TEST()
74 const grpc_millis initial_backoff = 2; in TEST()
77 const grpc_millis max_backoff = 513; in TEST()
88 grpc_millis next = backoff.NextAttemptTime(); in TEST()
128 const grpc_millis initial_backoff = 500; in TEST()
[all …]
/external/grpc-grpc/test/core/transport/
Dtimeout_encoding_test.cc35 static void assert_encodes_as(grpc_millis ts, const char* s) { in assert_encodes_as()
67 static void assert_decodes_as(const char* buffer, grpc_millis expected) { in assert_decodes_as()
68 grpc_millis got; in assert_decodes_as()
80 void decode_suite(char ext, grpc_millis (*answer)(int64_t x)) { in decode_suite()
105 static grpc_millis millis_from_nanos(int64_t x) { in millis_from_nanos()
106 return static_cast<grpc_millis>(x / GPR_NS_PER_MS + (x % GPR_NS_PER_MS != 0)); in millis_from_nanos()
108 static grpc_millis millis_from_micros(int64_t x) { in millis_from_micros()
109 return static_cast<grpc_millis>(x / GPR_US_PER_MS + (x % GPR_US_PER_MS != 0)); in millis_from_micros()
111 static grpc_millis millis_from_millis(int64_t x) { in millis_from_millis()
112 return static_cast<grpc_millis>(x); in millis_from_millis()
[all …]
/external/grpc-grpc/src/core/lib/backoff/
Dbackoff.h38 grpc_millis NextAttemptTime();
48 Options& set_initial_backoff(grpc_millis initial_backoff) { in set_initial_backoff()
60 Options& set_max_backoff(grpc_millis max_backoff) { in set_max_backoff()
65 grpc_millis initial_backoff() const { return initial_backoff_; } in initial_backoff()
71 grpc_millis max_backoff() const { return max_backoff_; } in max_backoff()
74 grpc_millis initial_backoff_;
77 grpc_millis max_backoff_;
85 grpc_millis current_backoff_;
Dbackoff.cc55 grpc_millis BackOff::NextAttemptTime() { in NextAttemptTime()
60 current_backoff_ = static_cast<grpc_millis>( in NextAttemptTime()
66 const grpc_millis next_timeout = in NextAttemptTime()
67 static_cast<grpc_millis>(current_backoff_ + jitter); in NextAttemptTime()
/external/grpc-grpc/src/core/lib/iomgr/
Dtimer_generic.cc63 grpc_millis queue_deadline_cap;
65 grpc_millis min_deadline;
229 grpc_millis min_timer;
239 static grpc_millis saturating_add(grpc_millis a, grpc_millis b) { in saturating_add()
246 static grpc_timer_check_result run_some_expired_timers(grpc_millis now,
247 grpc_millis* next,
250 static grpc_millis compute_min_deadline(timer_shard* shard) { in compute_min_deadline()
353 static void timer_init(grpc_timer* timer, grpc_millis deadline, in timer_init()
380 grpc_millis now = grpc_core::ExecCtx::Get()->Now(); in timer_init()
427 grpc_millis old_min_deadline = g_shard_queue[0]->min_deadline; in timer_init()
[all …]
Dexec_ctx.cc56 static grpc_millis timespec_to_millis_round_down(gpr_timespec ts) { in timespec_to_millis_round_down()
62 return static_cast<grpc_millis>(x); in timespec_to_millis_round_down()
65 static grpc_millis timespec_to_millis_round_up(gpr_timespec ts) { in timespec_to_millis_round_up()
73 return static_cast<grpc_millis>(x); in timespec_to_millis_round_up()
76 gpr_timespec grpc_millis_to_timespec(grpc_millis millis, in grpc_millis_to_timespec()
94 grpc_millis grpc_timespec_to_millis_round_down(gpr_timespec ts) { in grpc_timespec_to_millis_round_down()
99 grpc_millis grpc_timespec_to_millis_round_up(gpr_timespec ts) { in grpc_timespec_to_millis_round_up()
145 grpc_millis ExecCtx::Now() { in Now()
Dexec_ctx.h32 typedef int64_t grpc_millis; typedef
54 gpr_timespec grpc_millis_to_timespec(grpc_millis millis, gpr_clock_type clock);
55 grpc_millis grpc_timespec_to_millis_round_down(gpr_timespec timespec);
56 grpc_millis grpc_timespec_to_millis_round_up(gpr_timespec timespec);
174 grpc_millis Now();
190 void TestOnlySetNow(grpc_millis new_val) { in TestOnlySetNow()
231 grpc_millis now_ = 0;
Dtimer.h31 grpc_millis deadline;
52 void (*init)(grpc_timer* timer, grpc_millis, grpc_closure* closure);
56 grpc_timer_check_result (*check)(grpc_millis* next);
69 void grpc_timer_init(grpc_timer* timer, grpc_millis deadline,
113 grpc_timer_check_result grpc_timer_check(grpc_millis* next);
Dtimer_manager.cc58 static grpc_millis g_timed_waiter_deadline;
95 grpc_millis next = GRPC_MILLIS_INF_FUTURE; in grpc_timer_manager_tick()
133 static bool wait_until(grpc_millis next) { in wait_until()
174 grpc_millis wait_time = next - grpc_core::ExecCtx::Get()->Now(); in wait_until()
216 grpc_millis next = GRPC_MILLIS_INF_FUTURE; in timer_main_loop()
Diocp_windows.cc46 static DWORD deadline_to_millis_timeout(grpc_millis deadline) { in deadline_to_millis_timeout()
50 grpc_millis now = grpc_core::ExecCtx::Get()->Now(); in deadline_to_millis_timeout()
52 grpc_millis timeout = deadline - now; in deadline_to_millis_timeout()
57 grpc_iocp_work_status grpc_iocp_work(grpc_millis deadline) { in grpc_iocp_work()
Dtimer_custom.cc44 static void timer_init(grpc_timer* timer, grpc_millis deadline, in timer_init()
48 grpc_millis now = grpc_core::ExecCtx::Get()->Now(); in timer_init()
77 static grpc_timer_check_result timer_check(grpc_millis* next) { in timer_check()
Dpollset_custom.cc68 grpc_millis deadline) { in pollset_work()
71 grpc_millis now = grpc_core::ExecCtx::Get()->Now(); in pollset_work()
72 grpc_millis timeout = 0; in pollset_work()
Dtcp_client.h34 const grpc_resolved_address* addr, grpc_millis deadline);
46 grpc_millis deadline);
Dtimer.cc30 void grpc_timer_init(grpc_timer* timer, grpc_millis deadline, in grpc_timer_init()
37 grpc_timer_check_result grpc_timer_check(grpc_millis* next) { in grpc_timer_check()
/external/grpc-grpc/test/cpp/microbenchmarks/
Dbm_error.cc161 grpc_millis deadline() const { return deadline_; } in deadline()
165 const grpc_millis deadline_ = GRPC_MILLIS_INF_FUTURE;
170 grpc_millis deadline() const { return deadline_; } in deadline()
174 const grpc_millis deadline_ = GRPC_MILLIS_INF_FUTURE;
179 grpc_millis deadline() const { return deadline_; } in deadline()
183 const grpc_millis deadline_ = GRPC_MILLIS_INF_FUTURE;
189 grpc_millis deadline() const { return deadline_; } in deadline()
193 const grpc_millis deadline_ = GRPC_MILLIS_INF_FUTURE;
201 grpc_millis deadline() const { return deadline_; } in deadline()
205 const grpc_millis deadline_ = GRPC_MILLIS_INF_FUTURE;
[all …]
Dbm_chttp2_hpack.cc72 grpc_millis saved_now = grpc_core::ExecCtx::Get()->Now(); in BM_HpackEncoderEncodeDeadline()
791 grpc_millis* cached_timeout = in OnInitialHeader()
792 static_cast<grpc_millis*>(grpc_mdelem_get_user_data(md, free_timeout)); in OnInitialHeader()
793 grpc_millis timeout; in OnInitialHeader()
808 static_cast<grpc_millis*>(gpr_malloc(sizeof(grpc_millis))); in OnInitialHeader()
831 grpc_millis* cached_timeout = in OnHeaderTimeout()
832 static_cast<grpc_millis*>(grpc_mdelem_get_user_data(md, free_timeout)); in OnHeaderTimeout()
833 grpc_millis timeout; in OnHeaderTimeout()
847 static_cast<grpc_millis*>(gpr_malloc(sizeof(grpc_millis))); in OnHeaderTimeout()
/external/grpc-grpc/src/core/lib/http/
Dhttpcli.h47 grpc_millis deadline,
86 const grpc_httpcli_request* request, grpc_millis deadline,
109 grpc_millis deadline, grpc_closure* on_complete,
114 grpc_millis deadline,
120 grpc_millis deadline,
/external/grpc-grpc/src/core/ext/filters/client_channel/
Dmethod_params.h43 grpc_millis initial_backoff = 0;
44 grpc_millis max_backoff = 0;
54 grpc_millis timeout() const { return timeout_; } in timeout()
70 grpc_millis timeout_ = 0;
/external/grpc-grpc/test/core/client_channel/resolvers/
Ddns_resolver_cooldown_test.cc68 static grpc_millis last_resolution_time = 0; in test_resolve_address_impl()
73 grpc_millis now = in test_resolve_address_impl()
99 static grpc_millis last_resolution_time = 0; in test_dns_lookup_ares_locked()
104 grpc_millis now = in test_dns_lookup_ares_locked()
143 static grpc_millis n_sec_deadline(int seconds) { in n_sec_deadline()
150 grpc_millis deadline = n_sec_deadline(10); in poll_pollset_until_request_done()
156 grpc_millis time_left = deadline - grpc_core::ExecCtx::Get()->Now(); in poll_pollset_until_request_done()
/external/grpc-grpc/src/core/ext/filters/client_channel/resolver/dns/native/
Ddns_resolver.cc99 grpc_millis min_time_between_resolutions_;
101 grpc_millis last_resolution_timestamp_ = -1;
217 grpc_millis next_try = r->backoff_.NextAttemptTime(); in OnResolvedLocked()
218 grpc_millis timeout = next_try - ExecCtx::Get()->Now(); in OnResolvedLocked()
252 const grpc_millis earliest_next_resolution = in MaybeStartResolvingLocked()
254 const grpc_millis ms_until_next_resolution = in MaybeStartResolvingLocked()
257 const grpc_millis last_resolution_ago = in MaybeStartResolvingLocked()
/external/grpc-grpc/test/core/channel/
Dchannelz_test.cc51 grpc_millis last_call_started_millis() const { in last_call_started_millis()
52 return (grpc_millis)gpr_atm_no_barrier_load( in last_call_started_millis()
215 grpc_millis GetLastCallStartedMillis(CallCountingHelper* channel) { in GetLastCallStartedMillis()
270 grpc_millis millis1 = GetLastCallStartedMillis(&counter); in TEST_P()
273 grpc_millis millis2 = GetLastCallStartedMillis(&counter); in TEST_P()
279 grpc_millis millis3 = GetLastCallStartedMillis(&counter); in TEST_P()
285 grpc_millis millis4 = GetLastCallStartedMillis(&counter); in TEST_P()
/external/grpc-grpc/src/core/ext/filters/client_channel/resolver/dns/c_ares/
Ddns_resolver_ares.cc114 grpc_millis min_time_between_resolutions_;
116 grpc_millis last_resolution_timestamp_ = -1;
345 grpc_millis next_try = r->backoff_.NextAttemptTime(); in OnResolvedLocked()
346 grpc_millis timeout = next_try - ExecCtx::Get()->Now(); in OnResolvedLocked()
378 const grpc_millis earliest_next_resolution = in MaybeStartResolvingLocked()
380 const grpc_millis ms_until_next_resolution = in MaybeStartResolvingLocked()
383 const grpc_millis last_resolution_ago = in MaybeStartResolvingLocked()
/external/grpc-grpc/src/core/lib/transport/
Dtimeout_encoding.h34 void grpc_http2_encode_timeout(grpc_millis timeout, char* buffer);
35 int grpc_http2_decode_timeout(grpc_slice text, grpc_millis* timeout);
Dtimeout_encoding.cc76 void grpc_http2_encode_timeout(grpc_millis timeout, char* buffer) { in grpc_http2_encode_timeout()
92 int grpc_http2_decode_timeout(grpc_slice text, grpc_millis* timeout) { in grpc_http2_decode_timeout()
93 grpc_millis x = 0; in grpc_http2_decode_timeout()
/external/grpc-grpc/src/core/ext/transport/chttp2/transport/
Dinternal.h112 grpc_millis min_sent_ping_interval_without_data;
113 grpc_millis min_recv_ping_interval_without_data;
117 grpc_millis last_ping_sent_time;
124 grpc_millis last_ping_recv_time;
467 grpc_millis keepalive_time;
469 grpc_millis keepalive_timeout;
564 grpc_millis deadline;

12345