Lines Matching refs:fixed_queue_t

26 struct fixed_queue_t;
27 typedef struct fixed_queue_t fixed_queue_t;  typedef
31 typedef void (*fixed_queue_cb)(fixed_queue_t* queue, void* context);
37 fixed_queue_t* fixed_queue_new(size_t capacity);
44 void fixed_queue_free(fixed_queue_t* queue, fixed_queue_free_cb free_cb);
49 void fixed_queue_flush(fixed_queue_t* queue, fixed_queue_free_cb free_cb);
53 bool fixed_queue_is_empty(fixed_queue_t* queue);
57 size_t fixed_queue_length(fixed_queue_t* queue);
61 size_t fixed_queue_capacity(fixed_queue_t* queue);
66 void fixed_queue_enqueue(fixed_queue_t* queue, void* data);
71 void* fixed_queue_dequeue(fixed_queue_t* queue);
77 bool fixed_queue_try_enqueue(fixed_queue_t* queue, void* data);
82 void* fixed_queue_try_dequeue(fixed_queue_t* queue);
87 void* fixed_queue_try_peek_first(fixed_queue_t* queue);
92 void* fixed_queue_try_peek_last(fixed_queue_t* queue);
99 void* fixed_queue_try_remove_from_queue(fixed_queue_t* queue, void* data);
108 list_t* fixed_queue_get_list(fixed_queue_t* queue);
115 int fixed_queue_get_enqueue_fd(const fixed_queue_t* queue);
122 int fixed_queue_get_dequeue_fd(const fixed_queue_t* queue);
128 void fixed_queue_register_dequeue(fixed_queue_t* queue, reactor_t* reactor,
133 void fixed_queue_unregister_dequeue(fixed_queue_t* queue);