/haiku/headers/private/virtio/ |
H A D | virtio.h | 64 // queue cookie, issued by virtio bus manager 76 status_t (*queue_interrupt_handler)(virtio_sim sim, uint16 queue); 96 uint16 (*get_queue_ring_size)(void* cookie, uint16 queue); 97 status_t (*setup_queue)(void* cookie, uint16 queue, phys_addr_t phy, phys_addr_t phyAvail, 101 void (*notify_queue)(void* cookie, uint16 queue); 129 status_t (*queue_setup_interrupt)(virtio_queue queue, 132 status_t (*queue_request)(virtio_queue queue, 136 status_t (*queue_request_v)(virtio_queue queue, 141 bool (*queue_is_full)(virtio_queue queue); 143 bool (*queue_is_empty)(virtio_queue queue); [all...] |
/haiku/src/add-ons/kernel/busses/virtio/virtio_pci/ |
H A D | virtio_pci.cpp | 44 uint16 queue; member in struct:__anon21 148 gVirtio->queue_interrupt_handler(cookie->sim, cookie->queue); 185 for (uint16 queue = 0; queue < bus->queue_count; queue++) { 189 *queueSelect = queue; 195 + VIRTIO_PCI_QUEUE_SEL, queue); 201 ERROR("msix queue vector incorrect\n"); 394 get_queue_ring_size(void* cookie, uint16 queue) argument 401 *queueSelect = queue; 415 setup_queue(void* cookie, uint16 queue, phys_addr_t phy, phys_addr_t phyAvail, phys_addr_t phyUsed) argument 577 notify_queue(void* cookie, uint16 queue) argument [all...] |
/haiku/src/add-ons/kernel/busses/usb/ |
H A D | uhci.h | 67 Queue * queue; member in struct:transfer_data 84 // linked to each other in a queue like in every other 132 Queue *queue, 163 // Transfer queue functions
|
H A D | uhci.cpp | 300 mutex_init(&fLock, "uhci queue lock"); 418 // append the transfer queue to the list 443 // this was the only element, terminate this queue 485 TRACE("queue:\n"); 600 // 4: debug queue 601 // TODO: 4: bandwidth reclamation queue 621 // Make sure the last queue terminates 855 Queue *queue = NULL; 857 queue = fQueues[UHCI_INTERRUPT_QUEUE]; 859 queue 1132 Queue *queue = NULL; local 1154 AddPendingTransfer(Transfer *transfer, Queue *queue, uhci_qh *transferQueue, uhci_td *firstDescriptor, uhci_td *dataDescriptor, bool directionIn) argument [all...] |
/haiku/src/system/kernel/ |
H A D | DPC.cpp | 43 FunctionDPCCallback::DoDPC(DPCQueue* queue) argument 78 fPendingCallbacksCondition.Init(this, "dpc queue"); 148 // mark the queue closed 163 // queue the callback, if the queue isn't closed already 276 // nothing is pending -- wait unless the queue is already closed
|
H A D | sem.cpp | 118 ThreadQueue queue; // should be in u.used, but has a constructor member in struct:sem_entry 184 kprintf("queue: "); 185 if (!sem->queue.IsEmpty()) { 186 ThreadQueue::Iterator it = sem->queue.GetIterator(); 332 while (queued_thread* entry = sem.queue.RemoveHead()) { 512 new(&sem->queue) ThreadQueue; 598 /*! Forcibly removes a thread from a semaphores wait queue. May have to wake up 608 sem->queue.Remove(entry); 619 while ((entry = sem->queue.Head()) != NULL) { 635 sem->queue [all...] |
/haiku/src/apps/haikudepot/ui/ |
H A D | MainWindow.h | 13 #include <queue> 177 std::queue<ProcessCoordinator*>
|
/haiku/src/system/kernel/events/ |
H A D | event_queue.cpp | 135 * Protects the queue. We cannot call select or deselect while holding 141 * Notified when events are available on the queue. 146 * Used to wait on a changing select_event while the queue lock is dropped 370 // If it's not already queued, it's our responsibility to queue it. 521 * queue lock held. This method will sleep if the event is undergoing selection 552 EventQueue* queue = (EventQueue*)descriptor->u.queue; local 553 queue->Closed(); 561 EventQueue* queue = (EventQueue*)descriptor->u.queue; local 616 EventQueue* queue = new(std::nothrow) EventQueue(false); local 648 _user_event_queue_select(int queue, event_wait_info* userInfos, int numInfos) argument 698 _user_event_queue_wait(int queue, event_wait_info* userInfos, int numInfos, uint32 flags, bigtime_t timeout) argument [all...] |
/haiku/src/servers/registrar/ |
H A D | MessageRunnerManager.cpp | 37 among these a RunnerEvent added to the event queue. When the event is 57 \brief Event queue used by the manager. 105 \param queue The event queue executing the event. 108 virtual bool Do(EventQueue *queue) argument 225 The manager's event queue must already have been stopped 230 // The event queue should already be stopped, but must still exist. 581 // If the event is not in the event queue and has not been removed 691 // queue for execution, it needs to be ignored. This may happen, when 713 // event was removed from the event queue, bu [all...] |
/haiku/src/kits/tracker/ |
H A D | Thumbnails.cpp | 251 JobQueue* queue = (JobQueue*)castToJobQueue; local 254 status_t status = queue->Pop(B_INFINITE_TIMEOUT, false, &job);
|
/haiku/src/system/kernel/vm/ |
H A D | vm_page.cpp | 93 // queue. 131 // lock, otherwise, a read lock suffices (each queue still has a spinlock to 830 VMPageQueue* queue; member in struct:__anon3 853 VMPageQueue::Iterator it = pageQueueInfos[i].queue->GetIterator(); 856 kprintf("found page %p in queue %p (%s)\n", page, 857 pageQueueInfos[i].queue, pageQueueInfos[i].name); 863 kprintf("page %p isn't in any queue\n", page); 974 kprintf("queue: %p\n", page->queue); 1028 struct VMPageQueue *queue; local 1758 VMPageQueue& queue = page->State() == PAGE_STATE_FREE local 2658 VMPageQueue& queue = sActivePageQueue; local 2753 VMPageQueue& queue = sInactivePageQueue; local 2870 VMPageQueue& queue = sActivePageQueue; local 3581 VMPageQueue* queue; local 4065 VMPageQueue *queue = NULL; local [all...] |
/haiku/src/add-ons/kernel/busses/virtio/virtio_mmio/ |
H A D | virtio_mmio.cpp | 536 VirtioQueue* queue = dev->fQueues[i].Get(); local 537 queue->fQueueHandler = NULL; 538 queue->fQueueHandlerCookie = NULL; 539 queue->fQueueHandlerRef.Unset(); 556 VirtioQueue* queue = (VirtioQueue*)aQueue; local 557 VirtioDevice* dev = queue->fDev; 559 queue->fQueueHandler = handler; 560 queue->fQueueHandlerCookie = cookie; 561 queue->fQueueHandlerRef.SetTo((handler == NULL) ? NULL : &dev->fIrqHandler); 575 VirtioQueue* queue local 586 VirtioQueue* queue = (VirtioQueue*)aQueue; local 603 virtio_device_queue_is_full(virtio_queue queue) argument 613 VirtioQueue *queue = (VirtioQueue *)aQueue; local 621 VirtioQueue *queue = (VirtioQueue *)aQueue; local 631 VirtioQueue* queue = (VirtioQueue*)aQueue; local [all...] |
H A D | VirtioDevice.cpp | 154 ERROR("no free virtio descs, queue: %p\n", this); 257 VirtioQueue* queue = dev->fQueues[i].Get(); local 258 if (queue->fUsed->idx != queue->fLastUsed 259 && queue->fQueueHandler != NULL) { 260 queue->fQueueHandler(dev->fConfigHandlerCookie, 261 queue->fQueueHandlerCookie);
|
/haiku/src/add-ons/kernel/bus_managers/virtio/ |
H A D | VirtioQueue.cpp | 53 TransferDescriptor(VirtioQueue* queue, 78 TransferDescriptor::TransferDescriptor(VirtioQueue* queue, uint16 indirectMaxSize) argument 79 : fQueue(queue),
|
H A D | VirtioModule.cpp | 141 VirtioQueue *queue = (VirtioQueue *)_queue; local 142 return queue->SetupInterrupt(handler, cookie); 151 VirtioQueue *queue = (VirtioQueue *)_queue; local 152 return queue->QueueRequest(vector, readVectorCount, writtenVectorCount, 177 VirtioQueue *queue = (VirtioQueue *)_queue; local 178 return queue->IsFull(); 185 VirtioQueue *queue = (VirtioQueue *)_queue; local 186 return queue->IsEmpty(); 193 VirtioQueue *queue = (VirtioQueue *)_queue; local 194 return queue 201 VirtioQueue *queue = (VirtioQueue *)_queue; local 235 virtio_queue_interrupt_handler(virtio_sim sim, uint16 queue) argument [all...] |
H A D | VirtioBalloonDevice.cpp | 63 ERROR("queue allocation failed (%s)\n", strerror(fStatus)); 76 ERROR("queue interrupt setup failed (%s)\n", strerror(fStatus)); 83 ERROR("queue interrupt setup failed (%s)\n", strerror(fStatus)); 141 ::virtio_queue queue; local 145 queue = fVirtioQueues[0]; 169 queue = fVirtioQueues[1]; 191 TRACE("queue request\n"); 192 status_t result = fVirtio->queue_request(queue, &fEntry, NULL, NULL); 198 while (!fVirtio->queue_dequeue(queue, NULL, NULL)) {
|
/haiku/src/system/kernel/arch/riscv64/ |
H A D | RISCV64VMTranslationMap.cpp | 453 VMAreaMappings queue; local 500 queue.Add(mapping); 536 while (vm_page_mapping* mapping = queue.RemoveHead())
|
/haiku/src/libs/icon/flat_icon/ |
H A D | FlatIconImporter.cpp | 385 PathCommandQueue queue; local 386 return queue.Read(buffer, path, pointCount);
|
/haiku/src/system/libnetwork/netresolv/net/ |
H A D | nsdispatch.c | 72 #include <sys/queue.h>
|
/haiku/src/apps/icon-o-matic/import_export/flat_icon/ |
H A D | FlatIconExporter.cpp | 391 PathCommandQueue queue; local 392 return queue.Write(buffer, path, pointCount);
|
/haiku/headers/private/system/ |
H A D | syscalls.h | 79 extern status_t _kern_event_queue_select(int queue, 81 extern ssize_t _kern_event_queue_wait(int queue, struct event_wait_info* infos, 133 /* POSIX XSI message queue syscalls */
|
/haiku/headers/private/kernel/util/ |
H A D | DoublyLinkedQueue.h | 15 A doubly linked queue is like a doubly linked list, but only has a pointer 36 Iterator(Queue *queue) argument 38 fQueue(queue) 93 ConstIterator(const Queue *queue) argument 95 fQueue(queue) 234 "queue: %p, element: %p\n", this, element);
|
/haiku/headers/private/kernel/fs/ |
H A D | fd.h | 58 struct event_queue *queue; member in union:file_descriptor::__anon24
|
/haiku/headers/private/kernel/ |
H A D | event_queue.h | 19 extern status_t _user_event_queue_select(int queue, event_wait_info* userInfos, 21 extern ssize_t _user_event_queue_wait(int queue, event_wait_info* infos,
|
/haiku/src/tests/kits/storage/ |
H A D | MimeTypeTest.cpp | 6 #include <queue> 536 QueueAdapter(std::queue<std::string> &queue) argument 537 : fQueue(queue) { } 542 std::queue<std::string> &fQueue; 2710 std::queue<std::string> appList; 3193 // * change something, check message queue (not empty) 3199 // * change something, check message queue (not empty) 3201 // * change something, check message queue (empty) 3435 BMessageQueue &queue local [all...] |