Lines Matching refs:alarm_t
83 struct alarm_t { struct
130 static alarm_t* alarm_new_internal(const char* name, bool is_periodic);
133 static void alarm_set_internal(alarm_t* alarm, uint64_t period_ms, alarm_callback_t cb, void* data,
135 static void alarm_cancel_internal(alarm_t* alarm);
136 static void remove_pending_alarm(alarm_t* alarm);
137 static void schedule_next_instance(alarm_t* alarm);
155 alarm_t* alarm_new(const char* name) { return alarm_new_internal(name, false); } in alarm_new()
157 alarm_t* alarm_new_periodic(const char* name) { return alarm_new_internal(name, true); } in alarm_new_periodic()
159 static alarm_t* alarm_new_internal(const char* name, bool is_periodic) { in alarm_new_internal()
167 alarm_t* ret = static_cast<alarm_t*>(osi_calloc(sizeof(alarm_t))); in alarm_new_internal()
183 void alarm_free(alarm_t* alarm) { in alarm_free()
196 uint64_t alarm_get_remaining_ms(const alarm_t* alarm) { in alarm_get_remaining_ms()
209 void alarm_set(alarm_t* alarm, uint64_t interval_ms, alarm_callback_t cb, void* data) { in alarm_set()
213 void alarm_set_on_mloop(alarm_t* alarm, uint64_t interval_ms, alarm_callback_t cb, void* data) { in alarm_set_on_mloop()
218 static void alarm_set_internal(alarm_t* alarm, uint64_t period_ms, alarm_callback_t cb, void* data, in alarm_set_internal()
237 void alarm_cancel(alarm_t* alarm) { in alarm_cancel()
256 static void alarm_cancel_internal(alarm_t* alarm) { in alarm_cancel_internal()
273 bool alarm_is_scheduled(const alarm_t* alarm) { in alarm_is_scheduled()
413 static void remove_pending_alarm(alarm_t* alarm) { in remove_pending_alarm()
428 static void schedule_next_instance(alarm_t* alarm) { in schedule_next_instance()
445 if (list_is_empty(alarms) || ((alarm_t*)list_front(alarms))->deadline_ms > alarm->deadline_ms) { in schedule_next_instance()
451 ((alarm_t*)list_node(next))->deadline_ms > alarm->deadline_ms) { in schedule_next_instance()
470 alarm_t* next; in reschedule_root_alarm()
481 next = static_cast<alarm_t*>(list_front(alarms)); in reschedule_root_alarm()
560 static void alarm_ready_generic(alarm_t* alarm, std::unique_lock<std::mutex>& lock) { in alarm_ready_generic()
601 static void alarm_ready_mloop(alarm_t* alarm) { in alarm_ready_mloop()
610 alarm_t* alarm = (alarm_t*)fixed_queue_try_dequeue(queue); in alarm_queue_ready()
629 alarm_t* alarm; in callback_dispatch()
635 (alarm = static_cast<alarm_t*>(list_front(alarms)))->deadline_ms > now_ms()) { in callback_dispatch()
741 alarm_t* alarm = (alarm_t*)list_node(node); in alarm_debug_dump()