Lines Matching refs:fixed_queue_t
31 typedef struct fixed_queue_t {
41 } fixed_queue_t;
45 fixed_queue_t* fixed_queue_new(size_t capacity) {
46 fixed_queue_t* ret =
47 static_cast<fixed_queue_t*>(osi_calloc(sizeof(fixed_queue_t)));
68 void fixed_queue_free(fixed_queue_t* queue, fixed_queue_free_cb free_cb) {
85 void fixed_queue_flush(fixed_queue_t* queue, fixed_queue_free_cb free_cb) {
96 bool fixed_queue_is_empty(fixed_queue_t* queue) {
103 size_t fixed_queue_length(fixed_queue_t* queue) {
110 size_t fixed_queue_capacity(fixed_queue_t* queue) {
116 void fixed_queue_enqueue(fixed_queue_t* queue, void* data) {
130 void* fixed_queue_dequeue(fixed_queue_t* queue) {
147 bool fixed_queue_try_enqueue(fixed_queue_t* queue, void* data) {
162 void* fixed_queue_try_dequeue(fixed_queue_t* queue) {
179 void* fixed_queue_try_peek_first(fixed_queue_t* queue) {
186 void* fixed_queue_try_peek_last(fixed_queue_t* queue) {
193 void* fixed_queue_try_remove_from_queue(fixed_queue_t* queue, void* data) {
213 list_t* fixed_queue_get_list(fixed_queue_t* queue) {
222 int fixed_queue_get_dequeue_fd(const fixed_queue_t* queue) {
227 int fixed_queue_get_enqueue_fd(const fixed_queue_t* queue) {
232 void fixed_queue_register_dequeue(fixed_queue_t* queue, reactor_t* reactor,
248 void fixed_queue_unregister_dequeue(fixed_queue_t* queue) {
260 fixed_queue_t* queue = static_cast<fixed_queue_t*>(context);
