| /third_party/grpc/src/core/lib/iomgr/ |
| D | timer.h | 30 typedef struct grpc_timer { struct
35 struct grpc_timer* next; argument
36 struct grpc_timer* prev; argument
39 struct grpc_timer* hash_table_next; argument
44 } grpc_timer; typedef
53 void (*init)(grpc_timer* timer, grpc_millis, grpc_closure* closure);
54 void (*cancel)(grpc_timer* timer);
70 void grpc_timer_init(grpc_timer* timer, grpc_millis deadline,
75 void grpc_timer_init_unset(grpc_timer* timer);
103 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 bool 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.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_generic.cc | 75 grpc_timer list;
95 static grpc_timer* g_timer_ht[NUM_HASH_BUCKETS] = {nullptr};
109 static bool is_in_ht(grpc_timer* t) { in is_in_ht()
113 grpc_timer* p = g_timer_ht[i]; in is_in_ht()
122 static void add_to_ht(grpc_timer* t) { in add_to_ht()
127 grpc_timer* p = g_timer_ht[i]; in add_to_ht()
148 static void remove_from_ht(grpc_timer* t) { in remove_from_ht()
157 grpc_timer* p = g_timer_ht[i]; in remove_from_ht()
186 static void validate_non_pending_timer(grpc_timer* t) { in validate_non_pending_timer()
317 static void list_join(grpc_timer* head, grpc_timer* timer) { in list_join()
[all …]
|
| D | timer_heap.h | 27 grpc_timer** timers;
32 bool grpc_timer_heap_add(grpc_timer_heap* heap, grpc_timer* timer);
37 void grpc_timer_heap_remove(grpc_timer_heap* heap, grpc_timer* timer);
38 grpc_timer* grpc_timer_heap_top(grpc_timer_heap* heap);
|
| D | timer_custom.cc | 37 grpc_timer* timer = t->original; in grpc_custom_timer_callback()
45 static void timer_init(grpc_timer* timer, grpc_millis deadline, in timer_init()
67 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;
|
| /third_party/grpc/test/cpp/common/ |
| D | timer_test.cc | 83 grpc_timer timer; in TEST_F()
107 grpc_timer timers[kNumTimers]; in TEST_F()
134 grpc_timer timers[kNumTimers]; in TEST_F()
167 grpc_timer timer; in TEST_F()
179 grpc_timer timers[kNumTimers]; in TEST_F()
181 grpc_timer* arg = (i != 0) ? &timers[i - 1] : nullptr; in TEST_F()
185 grpc_timer* timer = static_cast<grpc_timer*>(arg); in TEST_F()
201 grpc_timer timers[kNumTimers]; in TEST_F()
208 grpc_timer* arg = nullptr; in TEST_F()
215 grpc_timer* timer = static_cast<grpc_timer*>(arg); in TEST_F()
|
| D | time_jump_test.cc | 88 grpc_timer timer; in TEST_P()
|
| /third_party/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()
|
| /third_party/grpc/src/python/grpcio/grpc/_cython/_cygrpc/aio/iomgr/ |
| D | iomgr.pyx.pxi | 185 cdef void asyncio_timer_start(grpc_custom_timer* grpc_timer) with gil: argument
186 timer = _AsyncioTimer.create(grpc_timer, grpc_timer.timeout_ms / 1000.0)
187 grpc_timer.timer = <void*>timer
190 cdef void asyncio_timer_stop(grpc_custom_timer* grpc_timer) with gil: argument
192 if grpc_timer.timer == NULL:
195 timer = <_AsyncioTimer>grpc_timer.timer
|
| D | timer.pyx.pxi | 25 cdef _AsyncioTimer create(grpc_custom_timer * grpc_timer, float timeout): argument
27 timer._grpc_timer = grpc_timer
|
| D | timer.pxd.pxi | 23 cdef _AsyncioTimer create(grpc_custom_timer * grpc_timer, float timeout) argument
|
| /third_party/grpc/ |
| D | libgrpc.map | 162 "grpc_timer_init_unset(grpc_timer*)";
166 "grpc_timer_init(grpc_timer*, long long, grpc_closure*)";
167 "grpc_timer_init(grpc_timer*, long, grpc_closure*)";
168 "grpc_timer_cancel(grpc_timer*)";
|
| /third_party/grpc/src/core/ext/filters/max_age/ |
| D | max_age_filter.cc | 63 grpc_timer max_age_timer ABSL_GUARDED_BY(max_age_timer_mu);
66 grpc_timer max_age_grace_timer ABSL_GUARDED_BY(max_age_timer_mu);
69 grpc_timer max_idle_timer;
|
| /third_party/grpc/src/core/ext/transport/chttp2/transport/ |
| D | internal.h | 126 grpc_timer delayed_ping_timer;
464 grpc_timer next_bdp_ping_timer;
476 grpc_timer keepalive_ping_timer;
478 grpc_timer keepalive_watchdog_timer;
|
| /third_party/grpc/src/core/ext/transport/chttp2/client/ |
| D | chttp2_connector.h | 67 grpc_timer timer_;
|
| /third_party/grpc/src/core/lib/channel/ |
| D | handshaker.h | 158 grpc_timer deadline_timer_;
|
| /third_party/grpc/test/cpp/microbenchmarks/ |
| D | bm_timer.cc | 37 grpc_timer timer;
|
| /third_party/grpc/src/core/ext/filters/client_channel/health/ |
| D | health_check_client.h | 168 grpc_timer retry_timer_;
|
| /third_party/grpc/src/core/ext/filters/client_channel/ |
| D | backup_poller.cc | 42 grpc_timer polling_timer;
|
| /third_party/grpc/src/cpp/common/ |
| D | alarm.cc | 118 grpc_timer timer_;
|