Lines Matching refs:headOffset

173 	UInt32            headOffset;  in peek()  local
182 headOffset = __c11_atomic_load((_Atomic UInt32 *)&dataQueue->head, __ATOMIC_RELAXED); in peek()
185 if (headOffset != tailOffset) { in peek()
188 UInt32 headOffset = dataQueue->head; in peek() local
191 if (headOffset > queueSize) { in peek()
195 head = (IODataQueueEntry *)((char *)dataQueue->queue + headOffset); in peek()
202 if ((headOffset > UINT32_MAX - DATA_QUEUE_ENTRY_HEADER_SIZE) || in peek()
203 (headOffset + DATA_QUEUE_ENTRY_HEADER_SIZE > queueSize) || in peek()
204 (headOffset + DATA_QUEUE_ENTRY_HEADER_SIZE > UINT32_MAX - headSize) || in peek()
205 (headOffset + headSize + DATA_QUEUE_ENTRY_HEADER_SIZE > queueSize)) { in peek()
319 UInt32 headOffset = 0; in dequeue() local
329 headOffset = __c11_atomic_load((_Atomic UInt32 *)&dataQueue->head, __ATOMIC_RELAXED); in dequeue()
332 if (headOffset != tailOffset) { in dequeue()
337 if (headOffset > queueSize) { in dequeue()
341 head = (IODataQueueEntry *)((char *)dataQueue->queue + headOffset); in dequeue()
346 if ((headOffset > UINT32_MAX - DATA_QUEUE_ENTRY_HEADER_SIZE) || in dequeue()
347 (headOffset + DATA_QUEUE_ENTRY_HEADER_SIZE > queueSize) || in dequeue()
349 (headOffset + DATA_QUEUE_ENTRY_HEADER_SIZE > UINT32_MAX - headSize) || in dequeue()
350 (headOffset + headSize + DATA_QUEUE_ENTRY_HEADER_SIZE > queueSize)) { in dequeue()
365 (entrySize + DATA_QUEUE_ENTRY_HEADER_SIZE > UINT32_MAX - headOffset) || in dequeue()
366 (entrySize + DATA_QUEUE_ENTRY_HEADER_SIZE + headOffset > queueSize)) { in dequeue()
369 newHeadOffset = headOffset + entrySize + DATA_QUEUE_ENTRY_HEADER_SIZE; in dequeue()