Lines Matching refs:taskqueue

56 struct taskqueue {  struct
105 _timeout_task_init(struct taskqueue *queue, struct timeout_task *timeout_task, in _timeout_task_init()
116 static struct taskqueue *
121 struct taskqueue *queue; in _taskqueue_create()
128 queue = malloc(sizeof(struct taskqueue), M_TASKQUEUE, mflags | M_ZERO); in _taskqueue_create()
150 struct taskqueue *
160 taskqueue_set_callback(struct taskqueue *queue, in taskqueue_set_callback()
177 taskqueue_free(struct taskqueue *queue) in taskqueue_free()
195 taskqueue_enqueue_locked(struct taskqueue *queue, struct task *task) in taskqueue_enqueue_locked()
243 taskqueue_enqueue(struct taskqueue *queue, struct task *task) in taskqueue_enqueue()
257 struct taskqueue *queue; in taskqueue_timeout_func()
270 taskqueue_enqueue_timeout(struct taskqueue *queue, in taskqueue_enqueue_timeout()
312 taskqueue_block(struct taskqueue *queue) in taskqueue_block()
321 taskqueue_unblock(struct taskqueue *queue) in taskqueue_unblock()
332 taskqueue_run_locked(struct taskqueue *queue) in taskqueue_run_locked()
378 taskqueue_run(struct taskqueue *queue) in taskqueue_run()
387 task_is_running(struct taskqueue *queue, struct task *task) in task_is_running()
400 taskqueue_cancel_locked(struct taskqueue *queue, struct task *task, in taskqueue_cancel_locked()
413 taskqueue_cancel(struct taskqueue *queue, struct task *task, u_int *pendp) in taskqueue_cancel()
425 taskqueue_cancel_timeout(struct taskqueue *queue, in taskqueue_cancel_timeout()
446 taskqueue_drain_timeout(struct taskqueue *queue, in taskqueue_drain_timeout()
471 taskqueue_start_threads(struct taskqueue **tqp, int count, int pri, in taskqueue_start_threads()
487 taskqueue_run_callback(struct taskqueue *tq, in taskqueue_run_callback()
499 taskqueue_member(struct taskqueue *queue, struct thread *td) in taskqueue_member()
516 struct taskqueue *