54 	OSSharedPtr<IOSharedDataQueue> dataQueue = OSMakeShared<IOSharedDataQueue>();  in OSDefineMetaClassAndStructors()  local
56 	if (dataQueue) {  in OSDefineMetaClassAndStructors()
57 		if (!dataQueue->initWithCapacity(size)) {  in OSDefineMetaClassAndStructors()
62 	return dataQueue;  in OSDefineMetaClassAndStructors()
68 	OSSharedPtr<IOSharedDataQueue> dataQueue = OSMakeShared<IOSharedDataQueue>();  in withEntries()  local
70 	if (dataQueue) {  in withEntries()
71 		if (!dataQueue->initWithEntries(numEntries, entrySize)) {  in withEntries()
76 	return dataQueue;  in withEntries()
105 	kr = kmem_alloc(kernel_map, (vm_offset_t *)&dataQueue, allocSize,  in initWithCapacity()
111 	dataQueue->queueSize    = size;  in initWithCapacity()
119 …appendix            = (IODataQueueAppendix *)((UInt8 *)dataQueue + size + DATA_QUEUE_MEMORY_HEADER…  in initWithCapacity()
138 	if (dataQueue) {  in free()
139 		kmem_free(kernel_map, (vm_offset_t)dataQueue, round_page(getQueueSize() +  in free()
141 		dataQueue = NULL;  in free()
161 	if (dataQueue != NULL) {  in getMemoryDescriptor()
162 …descriptor = IOMemoryDescriptor::withAddress(dataQueue, getQueueSize() + DATA_QUEUE_MEMORY_HEADER_…  in getMemoryDescriptor()
176 	if (!dataQueue) {  in peek()
182 	headOffset = __c11_atomic_load((_Atomic UInt32 *)&dataQueue->head, __ATOMIC_RELAXED);  in peek()
183 	tailOffset = __c11_atomic_load((_Atomic UInt32 *)&dataQueue->tail, __ATOMIC_ACQUIRE);  in peek()
188 		UInt32              headOffset   = dataQueue->head;  in peek()
195 		head         = (IODataQueueEntry *)((char *)dataQueue->queue + headOffset);  in peek()
209 			entry = dataQueue->queue;  in peek()
229 	tail = __c11_atomic_load((_Atomic UInt32 *)&dataQueue->tail, __ATOMIC_RELAXED);  in enqueue()
230 	head = __c11_atomic_load((_Atomic UInt32 *)&dataQueue->head, __ATOMIC_ACQUIRE);  in enqueue()
245 			entry = (IODataQueueEntry *)((UInt8 *)dataQueue->queue + tail);  in enqueue()
259 			dataQueue->queue->size = dataSize;  in enqueue()
266 				((IODataQueueEntry *)((UInt8 *)dataQueue->queue + tail))->size = dataSize;  in enqueue()
269 			__nochk_memcpy(&dataQueue->queue->data, data, dataSize);  in enqueue()
279 			entry = (IODataQueueEntry *)((UInt8 *)dataQueue->queue + tail);  in enqueue()
290 	__c11_atomic_store((_Atomic UInt32 *)&dataQueue->tail, newTail, __ATOMIC_RELEASE);  in enqueue()
303 		head = __c11_atomic_load((_Atomic UInt32 *)&dataQueue->head, __ATOMIC_RELAXED);  in enqueue()
323 	if (!dataQueue || (data && !dataSize)) {  in dequeue()
329 	headOffset = __c11_atomic_load((_Atomic UInt32 *)&dataQueue->head, __ATOMIC_RELAXED);  in dequeue()
330 	tailOffset = __c11_atomic_load((_Atomic UInt32 *)&dataQueue->tail, __ATOMIC_ACQUIRE);  in dequeue()
341 		head         = (IODataQueueEntry *)((char *)dataQueue->queue + headOffset);  in dequeue()
353 			entry           = dataQueue->queue;  in dequeue()
385 	__c11_atomic_store((_Atomic UInt32 *)&dataQueue->head, newHeadOffset, __ATOMIC_RELEASE);  in dequeue()