| /external/grpc-grpc/src/core/lib/iomgr/ |
| D | timer.h | 30 typedef struct grpc_timer { struct
34 struct grpc_timer* next; argument
35 struct grpc_timer* prev; argument
38 struct grpc_timer* hash_table_next; argument
43 } grpc_timer; argument
52 void (*init)(grpc_timer* timer, grpc_millis, grpc_closure* closure);
53 void (*cancel)(grpc_timer* timer);
69 void grpc_timer_init(grpc_timer* timer, grpc_millis deadline,
74 void grpc_timer_init_unset(grpc_timer* timer);
102 void grpc_timer_cancel(grpc_timer* timer);
|
| D | timer_heap.cc | 36 static void adjust_upwards(grpc_timer** first, uint32_t i, grpc_timer* t) { in adjust_upwards()
51 static void adjust_downwards(grpc_timer** first, uint32_t i, uint32_t length, in adjust_downwards()
52 grpc_timer* t) { in adjust_downwards()
77 heap->timers = static_cast<grpc_timer**>( in maybe_shrink()
78 gpr_realloc(heap->timers, heap->timer_capacity * sizeof(grpc_timer*))); in maybe_shrink()
82 static void note_changed_priority(grpc_timer_heap* heap, grpc_timer* timer) { in note_changed_priority()
98 int grpc_timer_heap_add(grpc_timer_heap* heap, grpc_timer* timer) { in grpc_timer_heap_add()
102 heap->timers = static_cast<grpc_timer**>( in grpc_timer_heap_add()
103 gpr_realloc(heap->timers, heap->timer_capacity * sizeof(grpc_timer*))); in grpc_timer_heap_add()
111 void grpc_timer_heap_remove(grpc_timer_heap* heap, grpc_timer* timer) { in grpc_timer_heap_remove()
[all …]
|
| D | timer_generic.cc | 72 grpc_timer list;
93 static grpc_timer* g_timer_ht[NUM_HASH_BUCKETS] = {nullptr};
107 static bool is_in_ht(grpc_timer* t) { in is_in_ht()
111 grpc_timer* p = g_timer_ht[i]; in is_in_ht()
120 static void add_to_ht(grpc_timer* t) { in add_to_ht()
125 grpc_timer* p = g_timer_ht[i]; in add_to_ht()
146 static void remove_from_ht(grpc_timer* t) { in remove_from_ht()
155 grpc_timer* p = g_timer_ht[i]; in remove_from_ht()
184 static void validate_non_pending_timer(grpc_timer* t) { in validate_non_pending_timer()
315 static void list_join(grpc_timer* head, grpc_timer* timer) { in list_join()
[all …]
|
| D | timer_generic.h | 27 struct grpc_timer { struct
31 struct grpc_timer* next; argument
32 struct grpc_timer* prev; argument
35 struct grpc_timer* hash_table_next; argument
|
| D | timer_heap.h | 27 grpc_timer** timers;
33 int grpc_timer_heap_add(grpc_timer_heap* heap, grpc_timer* timer);
38 void grpc_timer_heap_remove(grpc_timer_heap* heap, grpc_timer* timer);
39 grpc_timer* grpc_timer_heap_top(grpc_timer_heap* heap);
|
| D | timer_custom.cc | 36 grpc_timer* timer = t->original; in grpc_custom_timer_callback()
44 static void timer_init(grpc_timer* timer, grpc_millis deadline, in timer_init()
66 static void timer_cancel(grpc_timer* timer) { in timer_cancel()
|
| D | timer.cc | 30 void grpc_timer_init(grpc_timer* timer, grpc_millis deadline, in grpc_timer_init()
35 void grpc_timer_cancel(grpc_timer* timer) { grpc_timer_impl->cancel(timer); } in grpc_timer_cancel()
|
| D | timer_custom.h | 31 grpc_timer* original;
|
| D | tcp_client_custom.cc | 40 grpc_timer alarm;
|
| D | tcp_client_windows.cc | 47 grpc_timer alarm;
|
| D | tcp_client_cfstream.cc | 57 grpc_timer alarm;
|
| D | tcp_client_posix.cc | 55 grpc_timer alarm;
|
| /external/grpc-grpc/test/core/iomgr/ |
| D | timer_heap_test.cc | 34 static grpc_timer* create_test_elements(size_t num_elements) { in create_test_elements()
35 grpc_timer* elems = in create_test_elements()
36 static_cast<grpc_timer*>(gpr_malloc(num_elements * sizeof(grpc_timer))); in create_test_elements()
44 static int contains(grpc_timer_heap* pq, grpc_timer* el) { in contains()
75 grpc_timer* test_elements = create_test_elements(num_test_elements); in test1()
103 grpc_timer* el = &test_elements[elem_num]; in test1()
130 grpc_timer elem;
193 grpc_timer* top = grpc_timer_heap_top(&pq); in test2()
249 grpc_timer* const te = pq.timers[pq.timer_count - 1]; in shrink_test()
266 grpc_timer* te = pq.timers[which]; in shrink_test()
|
| D | timer_list_test.cc | 50 grpc_timer timers[20]; in add_test()
114 grpc_timer timers[5]; in destruction_test()
169 grpc_timer timers[4]; in long_running_service_cleanup_test()
|
| /external/grpc-grpc/src/core/ext/transport/chttp2/transport/ |
| D | internal.h | 119 grpc_timer delayed_ping_timer;
451 grpc_timer next_bdp_ping_timer;
463 grpc_timer keepalive_ping_timer;
465 grpc_timer keepalive_watchdog_timer;
|
| /external/grpc-grpc/src/core/ext/filters/deadline/ |
| D | deadline_filter.h | 38 grpc_timer timer;
|
| /external/grpc-grpc/src/core/ext/filters/max_age/ |
| D | max_age_filter.cc | 60 grpc_timer max_age_timer;
63 grpc_timer max_age_grace_timer;
66 grpc_timer max_idle_timer;
|
| /external/grpc-grpc/src/cpp/common/ |
| D | alarm.cc | 106 grpc_timer timer_;
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/ |
| D | backup_poller.cc | 40 grpc_timer polling_timer;
|
| D | channel_connectivity.cc | 70 grpc_timer alarm;
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/resolver/dns/native/ |
| D | dns_resolver.cc | 96 grpc_timer next_resolution_timer_;
|
| /external/grpc-grpc/src/core/lib/channel/ |
| D | handshaker.cc | 81 grpc_timer deadline_timer;
|
| /external/grpc-grpc/src/core/ext/transport/chttp2/server/ |
| D | chttp2_server.cc | 67 grpc_timer timer;
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/resolver/dns/c_ares/ |
| D | dns_resolver_ares.cc | 112 grpc_timer next_resolution_timer_;
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/ |
| D | grpclb.cc | 238 grpc_timer client_load_report_timer_;
316 grpc_timer lb_call_retry_timer_;
334 grpc_timer lb_fallback_timer_;
|