Lines Matching refs:tail
183 tailOffset = __c11_atomic_load((_Atomic UInt32 *)&dataQueue->tail, __ATOMIC_ACQUIRE); in peek()
222 UInt32 tail; in enqueue() local
229 tail = __c11_atomic_load((_Atomic UInt32 *)&dataQueue->tail, __ATOMIC_RELAXED); in enqueue()
237 if (getQueueSize() < tail || getQueueSize() < head) { in enqueue()
241 if (tail >= head) { in enqueue()
243 if ((entrySize <= UINT32_MAX - tail) && in enqueue()
244 ((tail + entrySize) <= getQueueSize())) { in enqueue()
245 entry = (IODataQueueEntry *)((UInt8 *)dataQueue->queue + tail); in enqueue()
254 newTail = tail + entrySize; in enqueue()
265 if ((getQueueSize() - tail) >= DATA_QUEUE_ENTRY_HEADER_SIZE) { in enqueue()
266 ((IODataQueueEntry *)((UInt8 *)dataQueue->queue + tail))->size = dataSize; in enqueue()
278 if ((head - tail) > entrySize) { in enqueue()
279 entry = (IODataQueueEntry *)((UInt8 *)dataQueue->queue + tail); in enqueue()
283 newTail = tail + entrySize; in enqueue()
290 __c11_atomic_store((_Atomic UInt32 *)&dataQueue->tail, newTail, __ATOMIC_RELEASE); in enqueue()
292 if (tail != head) { in enqueue()
306 if (tail == head) { in enqueue()
330 tailOffset = __c11_atomic_load((_Atomic UInt32 *)&dataQueue->tail, __ATOMIC_ACQUIRE); in dequeue()