/haiku/src/libs/compat/freebsd_network/compat/netinet/ |
H A D | in_var.h | 9 #include <sys/queue.h>
|
/haiku/src/add-ons/kernel/generic/dpc/ |
H A D | dpc.c | 21 // Private DPC queue structures 45 dpc_queue *queue = arg; local 49 while (acquire_sem(queue->wakeup_sem) == B_OK) { 54 acquire_spinlock(&queue->lock); 56 dpc = queue->slots[queue->head]; 57 queue->head = (queue->head + 1) % queue->size; 58 queue 86 dpc_queue *queue; local 130 dpc_queue *queue = handle; local 161 dpc_queue *queue = handle; local [all...] |
/haiku/headers/private/kernel/util/ |
H A D | queue.h | 14 typedef struct queue { struct 18 } queue; typedef in typeref:struct:queue 20 int queue_init(queue *q); 21 int queue_remove_item(queue *q, void *e); 22 int queue_enqueue(queue *q, void *e); 23 void *queue_dequeue(queue *q); 24 void *queue_peek(queue *q);
|
/haiku/src/libs/compat/freebsd_network/ |
H A D | fbsd_subr_taskqueue.c | 105 _timeout_task_init(struct taskqueue *queue, struct timeout_task *timeout_task, argument 110 callout_init_mtx(&timeout_task->c, &queue->tq_mutex, 112 timeout_task->q = queue; 121 struct taskqueue *queue; local 128 queue = malloc(sizeof(struct taskqueue), M_TASKQUEUE, mflags | M_ZERO); 129 if (queue == NULL) { 136 STAILQ_INIT(&queue->tq_queue); 137 TAILQ_INIT(&queue->tq_active); 138 queue->tq_enqueue = enqueue; 139 queue 160 taskqueue_set_callback(struct taskqueue *queue, enum taskqueue_callback_type cb_type, taskqueue_callback_fn callback, void *context) argument 177 taskqueue_free(struct taskqueue *queue) argument 195 taskqueue_enqueue_locked(struct taskqueue *queue, struct task *task) argument 243 taskqueue_enqueue(struct taskqueue *queue, struct task *task) argument 257 struct taskqueue *queue; local 270 taskqueue_enqueue_timeout(struct taskqueue *queue, struct timeout_task *timeout_task, int _ticks) argument 312 taskqueue_block(struct taskqueue *queue) argument 321 taskqueue_unblock(struct taskqueue *queue) argument 332 taskqueue_run_locked(struct taskqueue *queue) argument 378 taskqueue_run(struct taskqueue *queue) argument 387 task_is_running(struct taskqueue *queue, struct task *task) argument 400 taskqueue_cancel_locked(struct taskqueue *queue, struct task *task, u_int *pendp) argument 413 taskqueue_cancel(struct taskqueue *queue, struct task *task, u_int *pendp) argument 425 taskqueue_cancel_timeout(struct taskqueue *queue, struct timeout_task *timeout_task, u_int *pendp) argument 446 taskqueue_drain_timeout(struct taskqueue *queue, struct timeout_task *timeout_task) argument 499 taskqueue_member(struct taskqueue *queue, struct thread *td) argument [all...] |
/haiku/headers/os/drivers/ |
H A D | dpc.h | 23 status_t (*new_dpc_queue)(void **queue, const char *name, int32 priority); 24 status_t (*delete_dpc_queue)(void *queue); 25 status_t (*queue_dpc)(void *queue, dpc_func func, void *arg);
|
/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/libs/compat/freebsd_iflib/ |
H A D | subr_gtaskqueue.c | 60 static int task_is_running(struct gtaskqueue *queue, struct gtask *gtask); 61 static void gtaskqueue_drain_locked(struct gtaskqueue *queue, struct gtask *gtask); 138 struct gtaskqueue *queue; local 147 queue = malloc(sizeof(struct gtaskqueue), M_GTASKQUEUE, mflags | M_ZERO); 148 if (!queue) { 153 STAILQ_INIT(&queue->tq_queue); 154 TAILQ_INIT(&queue->tq_active); 155 queue->tq_enqueue = enqueue; 156 queue->tq_context = context; 157 queue 182 gtaskqueue_free(struct gtaskqueue *queue) argument 202 struct gtaskqueue *queue = grouptask->gt_taskqueue; local 220 struct gtaskqueue *queue = grouptask->gt_taskqueue; local 235 grouptaskqueue_enqueue(struct gtaskqueue *queue, struct gtask *gtask) argument 271 gtaskqueue_drain_tq_queue(struct gtaskqueue *queue) argument 304 gtaskqueue_drain_tq_active(struct gtaskqueue *queue) argument 339 gtaskqueue_block(struct gtaskqueue *queue) argument 348 gtaskqueue_unblock(struct gtaskqueue *queue) argument 359 gtaskqueue_run_locked(struct gtaskqueue *queue) argument 399 task_is_running(struct gtaskqueue *queue, struct gtask *gtask) argument 412 gtaskqueue_cancel_locked(struct gtaskqueue *queue, struct gtask *gtask) argument 422 gtaskqueue_cancel(struct gtaskqueue *queue, struct gtask *gtask) argument 434 gtaskqueue_drain_locked(struct gtaskqueue *queue, struct gtask *gtask) argument 441 gtaskqueue_drain(struct gtaskqueue *queue, struct gtask *gtask) argument 454 gtaskqueue_drain_all(struct gtaskqueue *queue) argument [all...] |
/haiku/src/libs/compat/freebsd_network/compat/sys/ |
H A D | taskqueue.h | 36 #include <sys/queue.h> 66 * queue to arrange to run itself later (e.g., by scheduling a software 76 int taskqueue_enqueue(struct taskqueue *queue, struct task *task); 77 int taskqueue_enqueue_timeout(struct taskqueue *queue, 79 int taskqueue_cancel(struct taskqueue *queue, struct task *task, 81 int taskqueue_cancel_timeout(struct taskqueue *queue, 83 void taskqueue_drain(struct taskqueue *queue, struct task *task); 84 void taskqueue_drain_timeout(struct taskqueue *queue, 86 void taskqueue_drain_all(struct taskqueue *queue); 87 void taskqueue_free(struct taskqueue *queue); [all...] |
H A D | _task.h | 34 #include <sys/queue.h> 49 STAILQ_ENTRY(task) ta_link; /* (q) link for queue */
|
H A D | _callout.h | 10 #include <sys/queue.h>
|
/haiku/src/system/kernel/vm/ |
H A D | VMPageQueue.h | 73 if (page->queue != NULL) { 75 "already in queue %p", this, page, page->queue); 83 page->queue = this; 92 if (page->queue != NULL) { 94 "already in queue %p", this, page, page->queue); 102 page->queue = this; 111 if (page->queue != NULL) { 113 "already in queue [all...] |
/haiku/headers/cpp/ |
H A D | stl_queue.h | 41 class queue { class 42 friend bool operator== __STL_NULL_TMPL_ARGS (const queue&, const queue&); 43 friend bool operator< __STL_NULL_TMPL_ARGS (const queue&, const queue&); 54 queue() : c() {} function in class:queue 55 explicit queue(const _Sequence& __c) : c(__c) {} function in class:queue 69 operator==(const queue<_Tp, _Sequence>& __x, const queue<_Tp, _Sequence>& __y) argument 76 operator<(const queue<_T argument 85 operator !=(const queue<_Tp, _Sequence>& __x, const queue<_Tp, _Sequence>& __y) argument 92 operator >(const queue<_Tp, _Sequence>& __x, const queue<_Tp, _Sequence>& __y) argument 99 operator <=(const queue<_Tp, _Sequence>& __x, const queue<_Tp, _Sequence>& __y) argument 106 operator >=(const queue<_Tp, _Sequence>& __x, const queue<_Tp, _Sequence>& __y) argument [all...] |
H A D | stack.h | 38 using __STD::queue;
|
/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/headers/os/media/ |
H A D | PlaySound.h | 15 sound_handle play_sound(const entry_ref* soundRef, bool mix, bool queue,
|
/haiku/src/kits/media/ |
H A D | PlaySound.cpp | 16 bool queue, 14 play_sound(const entry_ref *soundRef, bool mix, bool queue, bool background ) argument
|
H A D | ChunkCache.h | 12 #include <queue> 32 typedef std::queue<chunk_buffer*> ChunkQueue;
|
/haiku/src/libs/compat/freebsd_iflib/compat/sys/ |
H A D | _task.h | 12 #include <sys/queue.h> 18 STAILQ_ENTRY(gtask) ta_link; /* (q) link for queue */
|
H A D | gtaskqueue.h | 64 void gtaskqueue_block(struct gtaskqueue *queue); 65 void gtaskqueue_unblock(struct gtaskqueue *queue); 67 int gtaskqueue_cancel(struct gtaskqueue *queue, struct gtask *gtask); 68 void gtaskqueue_drain(struct gtaskqueue *queue, struct gtask *task); 69 void gtaskqueue_drain_all(struct gtaskqueue *queue); 73 int grouptaskqueue_enqueue(struct gtaskqueue *queue, struct gtask *task);
|
/haiku/src/add-ons/kernel/bus_managers/virtio/ |
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...] |
/haiku/src/system/kernel/util/ |
H A D | queue.cpp | 1 /* Standard queue */ 9 #include <queue.h> 25 queue_init(queue *q) 34 queue_remove_item(queue *_q, void *e) 62 queue_enqueue(queue *_q, void *e) 81 queue_dequeue(queue *_q) 100 queue_peek(queue *q) 107 /* fixed queue stuff */
|
/haiku/src/servers/launch/ |
H A D | Worker.h | 19 Worker(JobQueue& queue); 41 MainWorker(JobQueue& queue);
|
H A D | Worker.cpp | 18 Worker::Worker(JobQueue& queue) argument 21 fJobQueue(queue) 101 MainWorker::MainWorker(JobQueue& queue) argument 103 Worker(queue),
|
/haiku/src/servers/registrar/ |
H A D | Event.cpp | 37 event queue after it has been executed. The same happens, if Do() returns 53 pushing the event into an event queue. 56 deleted by the event queue after being executed. 68 deleted by the event queue after being executed. 88 \note You must not call this method, when the event is in an event queue. 112 deleted by the event queue after being executed. 123 deleted by the event queue after being executed. 135 event queue's timer thread, the execution of the method should take 136 as little time as possible to keep the event queue precise. 138 The return value of this method indicates whether the event queue shal 168 Do(EventQueue *queue) argument [all...] |
H A D | Event.h | 47 virtual bool Do(EventQueue *queue);
|