Lines Matching refs:taskq_t
510 taskq_t *system_taskq;
571 static taskq_t *taskq_create_common(const char *, int, int, pri_t, int,
580 static taskq_ent_t *taskq_ent_alloc(taskq_t *, int);
581 static void taskq_ent_free(taskq_t *, taskq_ent_t *);
582 static int taskq_ent_exists(taskq_t *, task_func_t, void *);
751 DTRACE_PROBE2(taskq__enqueue, taskq_t *, tq, taskq_ent_t *, tqe); \
773 taskq_t *tq = buf; in taskq_constructor()
775 bzero(tq, sizeof (taskq_t)); in taskq_constructor()
794 taskq_t *tq = buf; in taskq_destructor()
837 taskq_cache = kmem_cache_create("taskq_cache", sizeof (taskq_t), in taskq_init()
843 list_create(&taskq_cpupct_list, sizeof (taskq_t), in taskq_init()
844 offsetof(taskq_t, tq_cpupct_link)); in taskq_init()
848 taskq_update_nthreads(taskq_t *tq, uint_t ncpus) in taskq_update_nthreads()
870 taskq_cpupct_install(taskq_t *tq, cpupart_t *cpup) in taskq_cpupct_install()
885 taskq_cpupct_remove(taskq_t *tq) in taskq_cpupct_remove()
898 taskq_t *tq; in taskq_cpu_setup()
970 taskq_ent_alloc(taskq_t *tq, int flags) in taskq_ent_alloc()
1037 taskq_ent_free(taskq_t *tq, taskq_ent_t *tqe) in taskq_ent_free()
1063 taskq_ent_exists(taskq_t *tq, task_func_t func, void *arg) in taskq_ent_exists()
1137 taskq_dispatch(taskq_t *tq, task_func_t func, void *arg, uint_t flags) in taskq_dispatch()
1294 taskq_dispatch_ent(taskq_t *tq, task_func_t func, void *arg, uint_t flags, in taskq_dispatch_ent()
1323 taskq_wait(taskq_t *tq) in taskq_wait()
1352 taskq_suspend(taskq_t *tq) in taskq_suspend()
1378 taskq_suspended(taskq_t *tq) in taskq_suspended()
1387 taskq_resume(taskq_t *tq) in taskq_resume()
1409 taskq_member(taskq_t *tq, kthread_t *thread) in taskq_member()
1423 taskq_thread_create(taskq_t *tq) in taskq_thread_create()
1480 taskq_thread_wait(taskq_t *tq, kmutex_t *mx, kcondvar_t *cv, in taskq_thread_wait()
1508 taskq_t *tq = arg; in taskq_thread()
1618 DTRACE_PROBE2(taskq__exec__start, taskq_t *, tq, in taskq_thread()
1621 DTRACE_PROBE2(taskq__exec__end, taskq_t *, tq, in taskq_thread()
1672 taskq_t *tq = bucket->tqbucket_taskq; in taskq_d_thread()
1706 DTRACE_PROBE3(taskq__d__exec__start, taskq_t *, tq, in taskq_d_thread()
1709 DTRACE_PROBE3(taskq__d__exec__end, taskq_t *, tq, in taskq_d_thread()
1804 taskq_t *
1823 taskq_t *
1838 taskq_t *
1849 taskq_t *
1860 static taskq_t *
1864 taskq_t *tq = kmem_cache_alloc(taskq_cache, KM_SLEEP); in taskq_create_common()
2041 taskq_destroy(taskq_t *tq) in taskq_destroy()
2171 taskq_t *tq = b->tqbucket_taskq; in taskq_bucket_extend()
2243 taskq_t *tq = ksp->ks_private; in taskq_kstat_update()
2264 taskq_t *tq = ksp->ks_private; in taskq_d_kstat_update()