Lines Matching defs:tq
196 taskq_t *tq = context;
202 tsd_set(taskq_tsd, tq);
209 taskq_t *tq;
214 tq = kmem_alloc(sizeof (*tq), KM_SLEEP);
215 tq->tq_nthreads = nthreads;
216 tq->tq_queue = taskqueue_create(name, M_WAITOK,
217 taskqueue_thread_enqueue, &tq->tq_queue);
218 taskqueue_set_callback(tq->tq_queue, TASKQUEUE_CALLBACK_TYPE_INIT,
219 taskq_tsd_set, tq);
220 taskqueue_set_callback(tq->tq_queue, TASKQUEUE_CALLBACK_TYPE_SHUTDOWN,
222 (void) taskqueue_start_threads_in_proc(&tq->tq_queue, nthreads, pri,
225 return ((taskq_t *)tq);
243 taskq_destroy(taskq_t *tq)
246 taskqueue_free(tq->tq_queue);
247 kmem_free(tq, sizeof (*tq));
283 taskq_t *tq;
290 tq = taskq_create(name, nthreads, minclsyspri, nthreads, INT_MAX,
292 VERIFY(tq != NULL);
293 VERIFY(tq->tq_nthreads == nthreads);
299 (void) taskq_dispatch(tq, taskq_sync_assign,
318 taskq_wait(tq);
328 return (tq);
332 taskq_member(taskq_t *tq, kthread_t *thread)
335 return (taskqueue_member(tq->tq_queue, thread));
353 taskq_cancel_id(taskq_t *tq, taskqid_t tid)
363 rc = taskqueue_cancel(tq->tq_queue, &ent->tqent_task, &pend);
365 taskqueue_drain(tq->tq_queue, &ent->tqent_task);
367 rc = taskqueue_cancel_timeout(tq->tq_queue,
370 taskqueue_drain_timeout(tq->tq_queue,
398 taskq_dispatch_delay(taskq_t *tq, task_func_t func, void *arg,
408 return (taskq_dispatch(tq, func, arg, flags));
423 TIMEOUT_TASK_INIT(tq->tq_queue, &task->tqent_timeout_task, 0,
426 taskqueue_enqueue_timeout(tq->tq_queue, &task->tqent_timeout_task,
432 taskq_dispatch(taskq_t *tq, task_func_t func, void *arg, uint_t flags)
457 taskqueue_enqueue(tq->tq_queue, &task->tqent_task);
472 taskq_dispatch_ent(taskq_t *tq, task_func_t func, void *arg, uint32_t flags,
482 taskqueue_enqueue(tq->tq_queue, &task->tqent_task);
503 taskq_wait(taskq_t *tq)
505 taskqueue_quiesce(tq->tq_queue);
509 taskq_wait_id(taskq_t *tq, taskqid_t tid)
517 taskqueue_drain(tq->tq_queue, &ent->tqent_task);
519 taskqueue_drain_timeout(tq->tq_queue, &ent->tqent_timeout_task);
524 taskq_wait_outstanding(taskq_t *tq, taskqid_t id __unused)
526 taskqueue_drain_all(tq->tq_queue);