Lines Matching refs:head
182 headOffset = __c11_atomic_load((_Atomic UInt32 *)&dataQueue->head, __ATOMIC_RELAXED); in peek()
186 volatile IODataQueueEntry * head = NULL; in peek() local
188 UInt32 headOffset = dataQueue->head; in peek()
195 head = (IODataQueueEntry *)((char *)dataQueue->queue + headOffset); in peek()
196 headSize = head->size; in peek()
211 entry = (IODataQueueEntry *)head; in peek()
221 UInt32 head; in enqueue() local
230 head = __c11_atomic_load((_Atomic UInt32 *)&dataQueue->head, __ATOMIC_ACQUIRE); in enqueue()
237 if (getQueueSize() < tail || getQueueSize() < head) { in enqueue()
241 if (tail >= head) { in enqueue()
255 } else if (head > entrySize) { // Is there enough room at the beginning? in enqueue()
278 if ((head - tail) > entrySize) { in enqueue()
292 if (tail != head) { in enqueue()
303 head = __c11_atomic_load((_Atomic UInt32 *)&dataQueue->head, __ATOMIC_RELAXED); in enqueue()
306 if (tail == head) { in enqueue()
329 headOffset = __c11_atomic_load((_Atomic UInt32 *)&dataQueue->head, __ATOMIC_RELAXED); in dequeue()
333 volatile IODataQueueEntry * head = NULL; in dequeue() local
341 head = (IODataQueueEntry *)((char *)dataQueue->queue + headOffset); in dequeue()
342 headSize = head->size; in dequeue()
362 entry = head; in dequeue()
385 __c11_atomic_store((_Atomic UInt32 *)&dataQueue->head, newHeadOffset, __ATOMIC_RELEASE); in dequeue()