Searched refs:queue (Results 1 - 25 of 201) sorted by relevance

123456789

/haiku/src/libs/compat/freebsd_network/compat/netinet/
H A Din_var.h9 #include <sys/queue.h>
/haiku/src/add-ons/kernel/generic/dpc/
H A Ddpc.c21 // 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 Dqueue.h14 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 Dfbsd_subr_taskqueue.c105 _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 Ddpc.h23 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 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/libs/compat/freebsd_iflib/
H A Dsubr_gtaskqueue.c60 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 Dtaskqueue.h36 #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.h34 #include <sys/queue.h>
49 STAILQ_ENTRY(task) ta_link; /* (q) link for queue */
H A D_callout.h10 #include <sys/queue.h>
/haiku/src/system/kernel/vm/
H A DVMPageQueue.h73 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 Dstl_queue.h41 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 Dstack.h38 using __STD::queue;
/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/headers/os/media/
H A DPlaySound.h15 sound_handle play_sound(const entry_ref* soundRef, bool mix, bool queue,
/haiku/src/kits/media/
H A DPlaySound.cpp16 bool queue,
14 play_sound(const entry_ref *soundRef, bool mix, bool queue, bool background ) argument
H A DChunkCache.h12 #include <queue>
32 typedef std::queue<chunk_buffer*> ChunkQueue;
/haiku/src/libs/compat/freebsd_iflib/compat/sys/
H A D_task.h12 #include <sys/queue.h>
18 STAILQ_ENTRY(gtask) ta_link; /* (q) link for queue */
H A Dgtaskqueue.h64 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 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...]
/haiku/src/system/kernel/util/
H A Dqueue.cpp1 /* 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 DWorker.h19 Worker(JobQueue& queue);
41 MainWorker(JobQueue& queue);
H A DWorker.cpp18 Worker::Worker(JobQueue& queue) argument
21 fJobQueue(queue)
101 MainWorker::MainWorker(JobQueue& queue) argument
103 Worker(queue),
/haiku/src/servers/registrar/
H A DEvent.cpp37 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 DEvent.h47 virtual bool Do(EventQueue *queue);

Completed in 274 milliseconds

123456789