Lines Matching refs:dataQueue
64 OSSharedPtr<IODataQueue> dataQueue = OSMakeShared<IODataQueue>(); in OSDefineMetaClassAndStructors() local
66 if (dataQueue) { in OSDefineMetaClassAndStructors()
67 if (!dataQueue->initWithCapacity(size)) { in OSDefineMetaClassAndStructors()
72 return dataQueue; in OSDefineMetaClassAndStructors()
78 OSSharedPtr<IODataQueue> dataQueue = OSMakeShared<IODataQueue>(); in withEntries() local
80 if (dataQueue) { in withEntries()
81 if (!dataQueue->initWithEntries(numEntries, entrySize)) { in withEntries()
86 return dataQueue; in withEntries()
113 kr = kmem_alloc(kernel_map, (vm_offset_t *)&dataQueue, allocSize, in initWithCapacity()
119 dataQueue->queueSize = size; in initWithCapacity()
146 if (dataQueue) { in free()
147 kmem_free(kernel_map, (vm_offset_t)dataQueue, in free()
150 dataQueue = NULL; in free()
179 tail = __c11_atomic_load((_Atomic UInt32 *)&dataQueue->tail, __ATOMIC_RELAXED); in enqueue()
180 head = __c11_atomic_load((_Atomic UInt32 *)&dataQueue->head, __ATOMIC_ACQUIRE); in enqueue()
192 entry = (IODataQueueEntry *)((UInt8 *)dataQueue->queue + tail); in enqueue()
206 dataQueue->queue->size = dataSize; in enqueue()
213 ((IODataQueueEntry *)((UInt8 *)dataQueue->queue + tail))->size = dataSize; in enqueue()
216 __nochk_memcpy(&dataQueue->queue->data, data, dataSize); in enqueue()
226 entry = (IODataQueueEntry *)((UInt8 *)dataQueue->queue + tail); in enqueue()
237 __c11_atomic_store((_Atomic UInt32 *)&dataQueue->tail, newTail, __ATOMIC_RELEASE); in enqueue()
250 head = __c11_atomic_load((_Atomic UInt32 *)&dataQueue->head, __ATOMIC_RELAXED); in enqueue()
301 if (dataQueue != NULL) { in getMemoryDescriptor()
302 …descriptor = IOMemoryDescriptor::withAddress(dataQueue, queueSize + DATA_QUEUE_MEMORY_HEADER_SIZE,… in getMemoryDescriptor()