Lines Matching refs:taskqueue
45 static STAILQ_HEAD(taskqueue_list, taskqueue) taskqueue_queues;
49 struct taskqueue { struct
50 STAILQ_ENTRY(taskqueue) tq_link;
72 _timeout_task_init(struct taskqueue *queue, struct timeout_task *timeout_task, in _timeout_task_init() argument
82 static void taskqueue_run(struct taskqueue *queue, int lock_held);
85 TQ_LOCK_INIT(struct taskqueue *tq) in TQ_LOCK_INIT()
91 TQ_LOCK_UNINIT(struct taskqueue *tq) in TQ_LOCK_UNINIT()
97 TQ_LOCK(struct taskqueue *tq) in TQ_LOCK()
103 TQ_UNLOCK(struct taskqueue *tq) in TQ_UNLOCK()
109 TQ_SLEEP(struct taskqueue *tq, void *ident, const char *wmesg) in TQ_SLEEP()
114 struct taskqueue *
118 struct taskqueue *queue; in taskqueue_create()
139 taskqueue_terminate(struct thread **pp, struct taskqueue *tq) in taskqueue_terminate()
151 taskqueue_free(struct taskqueue *queue) in taskqueue_free()
160 STAILQ_REMOVE(&taskqueue_queues, queue, taskqueue, tq_link); in taskqueue_free()
168 struct taskqueue *
171 struct taskqueue *queue; in taskqueue_find()
191 taskqueue_enqueue_locked(struct taskqueue *queue, struct task *task) in taskqueue_enqueue_locked()
247 taskqueue_enqueue(struct taskqueue *queue, struct task *task) in taskqueue_enqueue()
264 taskqueue_enqueue_optq(struct taskqueue *queue, struct taskqueue **qpp, in taskqueue_enqueue_optq()
267 struct taskqueue *qtmp; in taskqueue_enqueue_optq()
326 struct taskqueue *queue; in taskqueue_timeout_func()
341 taskqueue_enqueue_timeout(struct taskqueue *queue, in taskqueue_enqueue_timeout()
370 taskqueue_block(struct taskqueue *queue) in taskqueue_block()
378 taskqueue_unblock(struct taskqueue *queue) in taskqueue_unblock()
391 taskqueue_run(struct taskqueue *queue, int lock_held) in taskqueue_run()
420 taskqueue_cancel_locked(struct taskqueue *queue, struct task *task, in taskqueue_cancel_locked()
433 taskqueue_cancel(struct taskqueue *queue, struct task *task, u_int *pendp) in taskqueue_cancel()
447 struct taskqueue *queue; in taskqueue_cancel_simple()
469 taskqueue_cancel_timeout(struct taskqueue *queue, in taskqueue_cancel_timeout()
490 taskqueue_drain(struct taskqueue *queue, struct task *task) in taskqueue_drain()
504 struct taskqueue *queue; in taskqueue_drain_simple()
522 taskqueue_drain_timeout(struct taskqueue *queue, in taskqueue_drain_timeout()
548 taskqueue_start_threads(struct taskqueue **tqp, int count, int pri, int ncpu, in taskqueue_start_threads()
553 struct taskqueue *tq; in taskqueue_start_threads()
612 struct taskqueue **tqp, *tq; in taskqueue_thread_loop()
633 struct taskqueue **tqp, *tq; in taskqueue_thread_enqueue()
655 struct taskqueue *taskqueue_thread[MAXCPU];