52   ret->list = list_new(NULL);  in fixed_queue_new()
64   fixed_queue_free(ret, NULL);  in fixed_queue_new()
65   return NULL;  in fixed_queue_new()
90     if (free_cb != NULL) {  in fixed_queue_flush()
97   if (queue == NULL) return true;  in fixed_queue_is_empty()
104   if (queue == NULL) return 0;  in fixed_queue_length()
111   CHECK(queue != NULL);  in fixed_queue_capacity()
117   CHECK(queue != NULL);  in fixed_queue_enqueue()
118   CHECK(data != NULL);  in fixed_queue_enqueue()
131   CHECK(queue != NULL);  in fixed_queue_dequeue()
135   void* ret = NULL;  in fixed_queue_dequeue()
148   CHECK(queue != NULL);  in fixed_queue_try_enqueue()
149   CHECK(data != NULL);  in fixed_queue_try_enqueue()
163   if (queue == NULL) return NULL;  in fixed_queue_try_dequeue()
165   if (!semaphore_try_wait(queue->dequeue_sem)) return NULL;  in fixed_queue_try_dequeue()
167   void* ret = NULL;  in fixed_queue_try_dequeue()
180   if (queue == NULL) return NULL;  in fixed_queue_try_peek_first()
183   return list_is_empty(queue->list) ? NULL : list_front(queue->list);  in fixed_queue_try_peek_first()
187   if (queue == NULL) return NULL;  in fixed_queue_try_peek_last()
190   return list_is_empty(queue->list) ? NULL : list_back(queue->list);  in fixed_queue_try_peek_last()
194   if (queue == NULL) return NULL;  in fixed_queue_try_remove_from_queue()
210   return NULL;  in fixed_queue_try_remove_from_queue()
214   CHECK(queue != NULL);  in fixed_queue_get_list()
223   CHECK(queue != NULL);  in fixed_queue_get_dequeue_fd()
228   CHECK(queue != NULL);  in fixed_queue_get_enqueue_fd()
234   CHECK(queue != NULL);  in fixed_queue_register_dequeue()
235   CHECK(reactor != NULL);  in fixed_queue_register_dequeue()
236   CHECK(ready_cb != NULL);  in fixed_queue_register_dequeue()
245                        internal_dequeue_ready, NULL);  in fixed_queue_register_dequeue()
249   CHECK(queue != NULL);  in fixed_queue_unregister_dequeue()
253     queue->dequeue_object = NULL;  in fixed_queue_unregister_dequeue()
258   CHECK(context != NULL);  in internal_dequeue_ready()