Lines Matching refs:tq
49 struct taskqueue *tq; member
53 struct taskqueue *tq; member
104 __w->tq = taskqueue_create("lkpi kthread taskq", M_WAITOK, \
105 taskqueue_thread_enqueue, &__w->tq); \
106 taskqueue_start_threads(&__w->tq, 1, PWAIT, fmt, ##__VA_ARGS__);\
108 taskqueue_enqueue(__w->tq, &__task); \
109 taskqueue_drain(__w->tq, &__task); \
116 taskqueue_drain_all(worker->tq); in kthread_destroy_worker()
117 taskqueue_free(worker->tq); in kthread_destroy_worker()
124 work->tq = NULL; in kthread_init_work()
134 error = taskqueue_enqueue_flags(worker->tq, &work->task, in kthread_queue_work()
137 work->tq = worker->tq; in kthread_queue_work()
146 if (work->tq != NULL && in kthread_cancel_work_sync()
147 taskqueue_cancel(work->tq, &work->task, &pending) != 0) in kthread_cancel_work_sync()
148 taskqueue_drain(work->tq, &work->task); in kthread_cancel_work_sync()
156 if (work->tq != NULL) in kthread_flush_work()
157 taskqueue_drain(work->tq, &work->task); in kthread_flush_work()
163 taskqueue_drain_all(worker->tq); in kthread_flush_worker()