Lines Matching refs:tq
68 taskq_t *tq;
73 tq = kmem_alloc(sizeof(*tq), KM_SLEEP);
74 tq->tq_queue = taskqueue_create(name, M_WAITOK, taskqueue_thread_enqueue,
75 &tq->tq_queue);
76 (void) taskqueue_start_threads(&tq->tq_queue, nthreads, pri, "%s", name);
78 return ((taskq_t *)tq);
90 taskq_destroy(taskq_t *tq)
93 taskqueue_free(tq->tq_queue);
94 kmem_free(tq, sizeof(*tq));
98 taskq_member(taskq_t *tq, kthread_t *thread)
101 return (taskqueue_member(tq->tq_queue, thread));
115 taskq_dispatch(taskq_t *tq, task_func_t func, void *arg, uint_t flags)
138 taskqueue_enqueue(tq->tq_queue, &task->tqent_task);
152 taskq_dispatch_ent(taskq_t *tq, task_func_t func, void *arg, u_int flags,
167 taskqueue_enqueue(tq->tq_queue, &task->tqent_task);
171 taskq_wait(taskq_t *tq)
173 taskqueue_drain_all(tq->tq_queue);