Lines Matching refs:taskqueue

65 struct taskqueue {  struct
109 _timeout_task_init(struct taskqueue *queue, struct timeout_task *timeout_task, in _timeout_task_init()
121 TQ_SLEEP(struct taskqueue *tq, void *p, const char *wm) in TQ_SLEEP()
128 static struct taskqueue *
133 struct taskqueue *queue; in _taskqueue_create()
140 queue = malloc(sizeof(struct taskqueue), M_TASKQUEUE, mflags | M_ZERO); in _taskqueue_create()
165 struct taskqueue *
175 taskqueue_set_callback(struct taskqueue *queue, in taskqueue_set_callback()
195 taskqueue_terminate(struct thread **pp, struct taskqueue *tq) in taskqueue_terminate()
205 taskqueue_free(struct taskqueue *queue) in taskqueue_free()
220 taskqueue_enqueue_locked(struct taskqueue *queue, struct task *task) in taskqueue_enqueue_locked()
277 taskqueue_enqueue(struct taskqueue *queue, struct task *task) in taskqueue_enqueue()
291 struct taskqueue *queue; in taskqueue_timeout_func()
304 taskqueue_enqueue_timeout_sbt(struct taskqueue *queue, in taskqueue_enqueue_timeout_sbt()
342 taskqueue_enqueue_timeout(struct taskqueue *queue, in taskqueue_enqueue_timeout()
361 taskqueue_drain_tq_queue(struct taskqueue *queue) in taskqueue_drain_tq_queue()
396 taskqueue_drain_tq_active(struct taskqueue *queue) in taskqueue_drain_tq_active()
425 taskqueue_block(struct taskqueue *queue) in taskqueue_block()
434 taskqueue_unblock(struct taskqueue *queue) in taskqueue_unblock()
445 taskqueue_run_locked(struct taskqueue *queue) in taskqueue_run_locked()
488 taskqueue_run(struct taskqueue *queue) in taskqueue_run()
497 task_is_running(struct taskqueue *queue, struct task *task) in task_is_running()
515 taskqueue_poll_is_busy(struct taskqueue *queue, struct task *task) in taskqueue_poll_is_busy()
527 taskqueue_cancel_locked(struct taskqueue *queue, struct task *task, in taskqueue_cancel_locked()
543 taskqueue_cancel(struct taskqueue *queue, struct task *task, u_int *pendp) in taskqueue_cancel()
555 taskqueue_cancel_timeout(struct taskqueue *queue, in taskqueue_cancel_timeout()
576 taskqueue_drain(struct taskqueue *queue, struct task *task) in taskqueue_drain()
589 taskqueue_drain_all(struct taskqueue *queue) in taskqueue_drain_all()
602 taskqueue_drain_timeout(struct taskqueue *queue, in taskqueue_drain_timeout()
627 taskqueue_quiesce(struct taskqueue *queue) in taskqueue_quiesce()
665 _taskqueue_start_threads(struct taskqueue **tqp, int count, int pri, in _taskqueue_start_threads()
670 struct taskqueue *tq; in _taskqueue_start_threads()
733 taskqueue_start_threads(struct taskqueue **tqp, int count, int pri, in taskqueue_start_threads()
746 taskqueue_start_threads_in_proc(struct taskqueue **tqp, int count, int pri, in taskqueue_start_threads_in_proc()
759 taskqueue_start_threads_cpuset(struct taskqueue **tqp, int count, int pri, in taskqueue_start_threads_cpuset()
772 taskqueue_run_callback(struct taskqueue *tq, in taskqueue_run_callback()
786 struct taskqueue **tqp, *tq; in taskqueue_thread_loop()
824 struct taskqueue **tqp, *tq; in taskqueue_thread_enqueue()
841 struct taskqueue *
868 taskqueue_member(struct taskqueue *queue, struct thread *td) in taskqueue_member()