Lines Matching defs:queue
102 fixed_queue_t* queue; // The processing queue to add this alarm to
138 // Default alarm callback thread and queue
147 fixed_queue_t* queue, bool for_msg_loop);
152 static void alarm_queue_ready(fixed_queue_t* queue, void* context);
158 // Registers |queue| for processing alarm callbacks on |thread|.
159 // |queue| may not be NULL. |thread| may not be NULL.
160 static void alarm_register_processing_queue(fixed_queue_t* queue,
232 fixed_queue_t* queue, bool for_msg_loop) {
241 alarm->queue = queue;
276 alarm->queue = NULL;
349 LOG_ERROR(LOG_TAG, "%s unable to create default alarm callbacks queue.",
403 // Remove alarm from internal alarm list and the processing queue
411 while (fixed_queue_try_remove_from_queue(alarm->queue, alarm) != NULL) {
412 // Remove all repeated alarm instances from the queue.
549 static void alarm_register_processing_queue(fixed_queue_t* queue,
551 CHECK(queue != NULL);
554 fixed_queue_register_dequeue(queue, thread_get_reactor(thread),
579 alarm->queue = NULL;
598 static void alarm_queue_ready(fixed_queue_t* queue, UNUSED_ATTR void* context) {
599 CHECK(queue != NULL);
602 alarm_t* alarm = (alarm_t*)fixed_queue_try_dequeue(queue);
653 fixed_queue_enqueue(alarm->queue, alarm);
