Lines Matching refs:tq
68 taskq_t *tq; in taskq_create_impl() local
73 tq = kmem_alloc(sizeof(*tq), KM_SLEEP); in taskq_create_impl()
74 tq->tq_queue = taskqueue_create(name, M_WAITOK, taskqueue_thread_enqueue, in taskq_create_impl()
75 &tq->tq_queue); in taskq_create_impl()
76 (void) taskqueue_start_threads_in_proc(&tq->tq_queue, nthreads, pri, in taskq_create_impl()
79 return ((taskq_t *)tq); in taskq_create_impl()
97 taskq_destroy(taskq_t *tq) in taskq_destroy() argument
100 taskqueue_free(tq->tq_queue); in taskq_destroy()
101 kmem_free(tq, sizeof(*tq)); in taskq_destroy()
105 taskq_member(taskq_t *tq, kthread_t *thread) in taskq_member() argument
108 return (taskqueue_member(tq->tq_queue, thread)); in taskq_member()
122 taskq_dispatch(taskq_t *tq, task_func_t func, void *arg, uint_t flags) in taskq_dispatch() argument
145 taskqueue_enqueue(tq->tq_queue, &task->tqent_task); in taskq_dispatch()
159 taskq_dispatch_ent(taskq_t *tq, task_func_t func, void *arg, u_int flags, in taskq_dispatch_ent() argument
174 taskqueue_enqueue(tq->tq_queue, &task->tqent_task); in taskq_dispatch_ent()
178 taskq_wait(taskq_t *tq) in taskq_wait() argument
180 taskqueue_quiesce(tq->tq_queue); in taskq_wait()
184 taskq_wait_id(taskq_t *tq, taskqid_t id) in taskq_wait_id() argument
186 taskqueue_drain_all(tq->tq_queue); in taskq_wait_id()