Lines Matching refs:queue
101 fixed_queue_t* queue; // The processing queue to add this alarm to member
140 fixed_queue_t* queue, bool for_msg_loop);
145 static void alarm_queue_ready(fixed_queue_t* queue, void* context);
153 static void alarm_register_processing_queue(fixed_queue_t* queue,
227 fixed_queue_t* queue, bool for_msg_loop) { in alarm_set_internal() argument
236 alarm->queue = queue; in alarm_set_internal()
273 alarm->queue = NULL; in alarm_cancel_internal()
412 while (fixed_queue_try_remove_from_queue(alarm->queue, alarm) != NULL) { in remove_pending_alarm()
551 static void alarm_register_processing_queue(fixed_queue_t* queue, in alarm_register_processing_queue() argument
553 CHECK(queue != NULL); in alarm_register_processing_queue()
556 fixed_queue_register_dequeue(queue, thread_get_reactor(thread), in alarm_register_processing_queue()
586 alarm->queue = NULL; in alarm_ready_generic()
608 static void alarm_queue_ready(fixed_queue_t* queue, UNUSED_ATTR void* context) { in alarm_queue_ready() argument
609 CHECK(queue != NULL); in alarm_queue_ready()
612 alarm_t* alarm = (alarm_t*)fixed_queue_try_dequeue(queue); in alarm_queue_ready()
664 fixed_queue_enqueue(alarm->queue, alarm); in callback_dispatch()