Lines Matching refs:data
13 q->data = (uint8_t *)calloc(element_count + 1, element_size); in queue_init_with_spinlock()
21 free(q->data); in queue_free()
26 return q->data + index * q->element_size; in element_ptr()
44 static bool queue_add_internal(queue_t *q, const void *data, bool block) { in queue_add_internal() argument
48 memcpy(element_ptr(q, q->wptr), data, q->element_size); in queue_add_internal()
62 static bool queue_remove_internal(queue_t *q, void *data, bool block) { in queue_remove_internal() argument
66 if (data) { in queue_remove_internal()
67 memcpy(data, element_ptr(q, q->rptr), q->element_size); in queue_remove_internal()
82 static bool queue_peek_internal(queue_t *q, void *data, bool block) { in queue_peek_internal() argument
86 if (data) { in queue_peek_internal()
87 memcpy(data, element_ptr(q, q->rptr), q->element_size); in queue_peek_internal()
101 bool queue_try_add(queue_t *q, const void *data) { in queue_try_add() argument
102 return queue_add_internal(q, data, false); in queue_try_add()
105 bool queue_try_remove(queue_t *q, void *data) { in queue_try_remove() argument
106 return queue_remove_internal(q, data, false); in queue_try_remove()
109 bool queue_try_peek(queue_t *q, void *data) { in queue_try_peek() argument
110 return queue_peek_internal(q, data, false); in queue_try_peek()
113 void queue_add_blocking(queue_t *q, const void *data) { in queue_add_blocking() argument
114 queue_add_internal(q, data, true); in queue_add_blocking()
117 void queue_remove_blocking(queue_t *q, void *data) { in queue_remove_blocking() argument
118 queue_remove_internal(q, data, true); in queue_remove_blocking()
121 void queue_peek_blocking(queue_t *q, void *data) { in queue_peek_blocking() argument
122 queue_peek_internal(q, data, true); in queue_peek_blocking()