Searched refs:queue (Results 1 - 25 of 201) sorted by last modified time

123456789

/haiku/headers/private/virtio/
H A Dvirtio.h64 // 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 Dvirtio_pci.cpp44 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 Duhci.h67 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 Duhci.cpp300 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 DDPC.cpp43 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 Dsem.cpp118 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 DMainWindow.h13 #include <queue>
177 std::queue<ProcessCoordinator*>
/haiku/src/system/kernel/events/
H A Devent_queue.cpp135 * 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 DMessageRunnerManager.cpp37 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 DThumbnails.cpp251 JobQueue* queue = (JobQueue*)castToJobQueue; local
254 status_t status = queue->Pop(B_INFINITE_TIMEOUT, false, &job);
/haiku/src/system/kernel/vm/
H A Dvm_page.cpp93 // 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 Dvirtio_mmio.cpp536 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 DVirtioDevice.cpp154 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 DVirtioQueue.cpp53 TransferDescriptor(VirtioQueue* queue,
78 TransferDescriptor::TransferDescriptor(VirtioQueue* queue, uint16 indirectMaxSize) argument
79 : fQueue(queue),
H A DVirtioModule.cpp141 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 DVirtioBalloonDevice.cpp63 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 DRISCV64VMTranslationMap.cpp453 VMAreaMappings queue; local
500 queue.Add(mapping);
536 while (vm_page_mapping* mapping = queue.RemoveHead())
/haiku/src/libs/icon/flat_icon/
H A DFlatIconImporter.cpp385 PathCommandQueue queue; local
386 return queue.Read(buffer, path, pointCount);
/haiku/src/system/libnetwork/netresolv/net/
H A Dnsdispatch.c72 #include <sys/queue.h>
/haiku/src/apps/icon-o-matic/import_export/flat_icon/
H A DFlatIconExporter.cpp391 PathCommandQueue queue; local
392 return queue.Write(buffer, path, pointCount);
/haiku/headers/private/system/
H A Dsyscalls.h79 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 DDoublyLinkedQueue.h15 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 Dfd.h58 struct event_queue *queue; member in union:file_descriptor::__anon24
/haiku/headers/private/kernel/
H A Devent_queue.h19 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 DMimeTypeTest.cpp6 #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...]

Completed in 131 milliseconds

123456789