Lines Matching refs:fixed_queue_t
30 typedef struct fixed_queue_t { struct
40 } fixed_queue_t; argument
44 fixed_queue_t *fixed_queue_new(size_t capacity) { in fixed_queue_new()
45 fixed_queue_t *ret = osi_calloc(sizeof(fixed_queue_t)); in fixed_queue_new()
69 void fixed_queue_free(fixed_queue_t *queue, fixed_queue_free_cb free_cb) { in fixed_queue_free()
86 bool fixed_queue_is_empty(fixed_queue_t *queue) { in fixed_queue_is_empty()
97 size_t fixed_queue_length(fixed_queue_t *queue) { in fixed_queue_length()
108 size_t fixed_queue_capacity(fixed_queue_t *queue) { in fixed_queue_capacity()
114 void fixed_queue_enqueue(fixed_queue_t *queue, void *data) { in fixed_queue_enqueue()
127 void *fixed_queue_dequeue(fixed_queue_t *queue) { in fixed_queue_dequeue()
142 bool fixed_queue_try_enqueue(fixed_queue_t *queue, void *data) { in fixed_queue_try_enqueue()
157 void *fixed_queue_try_dequeue(fixed_queue_t *queue) { in fixed_queue_try_dequeue()
174 void *fixed_queue_try_peek_first(fixed_queue_t *queue) { in fixed_queue_try_peek_first()
185 void *fixed_queue_try_peek_last(fixed_queue_t *queue) { in fixed_queue_try_peek_last()
196 void *fixed_queue_try_remove_from_queue(fixed_queue_t *queue, void *data) { in fixed_queue_try_remove_from_queue()
216 list_t *fixed_queue_get_list(fixed_queue_t *queue) { in fixed_queue_get_list()
225 int fixed_queue_get_dequeue_fd(const fixed_queue_t *queue) { in fixed_queue_get_dequeue_fd()
230 int fixed_queue_get_enqueue_fd(const fixed_queue_t *queue) { in fixed_queue_get_enqueue_fd()
235 void fixed_queue_register_dequeue(fixed_queue_t *queue, reactor_t *reactor, fixed_queue_cb ready_cb… in fixed_queue_register_dequeue()
254 void fixed_queue_unregister_dequeue(fixed_queue_t *queue) { in fixed_queue_unregister_dequeue()
266 fixed_queue_t *queue = context; in internal_dequeue_ready()