Lines Matching refs:tq_flags
701 (!(tq->tq_flags & TASKQ_PREPOPULATE) || \
861 tq->tq_flags |= TASKQ_CHANGING; in taskq_update_nthreads()
872 ASSERT(tq->tq_flags & TASKQ_THREADS_CPU_PCT); in taskq_cpupct_install()
887 ASSERT(tq->tq_flags & TASKQ_THREADS_CPU_PCT); in taskq_cpupct_remove()
1147 if (!(tq->tq_flags & TASKQ_DYNAMIC)) { in taskq_dispatch()
1298 ASSERT(!(tq->tq_flags & TASKQ_DYNAMIC)); in taskq_dispatch_ent()
1332 if (tq->tq_flags & TASKQ_DYNAMIC) { in taskq_wait()
1356 if (tq->tq_flags & TASKQ_DYNAMIC) { in taskq_suspend()
1369 ASSERT(!(tq->tq_flags & TASKQ_SUSPENDED)); in taskq_suspend()
1370 tq->tq_flags |= TASKQ_SUSPENDED; in taskq_suspend()
1380 return ((tq->tq_flags & TASKQ_SUSPENDED) != 0); in taskq_suspended()
1391 if (tq->tq_flags & TASKQ_DYNAMIC) { in taskq_resume()
1401 ASSERT(tq->tq_flags & TASKQ_SUSPENDED); in taskq_resume()
1402 tq->tq_flags &= ~TASKQ_SUSPENDED; in taskq_resume()
1429 ASSERT(tq->tq_flags & TASKQ_CHANGING); in taskq_thread_create()
1431 ASSERT(!(tq->tq_flags & TASKQ_THREAD_CREATED)); in taskq_thread_create()
1434 tq->tq_flags |= TASKQ_THREAD_CREATED; in taskq_thread_create()
1443 if ((tq->tq_flags & TASKQ_DUTY_CYCLE) != 0) { in taskq_thread_create()
1463 if (tq->tq_flags & TASKQ_THREADS_CPU_PCT) { in taskq_thread_create()
1485 if (!(tq->tq_flags & TASKQ_CPR_SAFE)) { in taskq_thread_wait()
1493 if (!(tq->tq_flags & TASKQ_CPR_SAFE)) { in taskq_thread_wait()
1516 if (curproc != &p0 && (tq->tq_flags & TASKQ_DUTY_CYCLE)) { in taskq_thread()
1518 (tq->tq_flags & TASKQ_DC_BATCH) ? SYSDC_THREAD_BATCH : 0); in taskq_thread()
1521 if (tq->tq_flags & TASKQ_CPR_SAFE) { in taskq_thread()
1529 ASSERT(tq->tq_flags & TASKQ_THREAD_CREATED); in taskq_thread()
1530 ASSERT(tq->tq_flags & TASKQ_CHANGING); in taskq_thread()
1531 tq->tq_flags &= ~TASKQ_THREAD_CREATED; in taskq_thread()
1545 if (tq->tq_flags & TASKQ_CHANGING) { in taskq_thread()
1573 if (!(tq->tq_flags & TASKQ_THREAD_CREATED)) { in taskq_thread()
1576 tq->tq_flags &= ~TASKQ_CHANGING; in taskq_thread()
1607 if ((!(tq->tq_flags & TASKQ_DYNAMIC)) && in taskq_thread()
1649 if (!(tq->tq_flags & TASKQ_THREAD_CREATED)) in taskq_thread()
1650 tq->tq_flags &= ~TASKQ_CHANGING; in taskq_thread()
1655 ASSERT(!(tq->tq_flags & TASKQ_CPR_SAFE)); in taskq_thread()
1934 tq->tq_flags = flags | TASKQ_CHANGING; in taskq_create_common()
2046 ASSERT(! (tq->tq_flags & TASKQ_CPR_SAFE)); in taskq_destroy()
2059 if (tq->tq_flags & TASKQ_NOINSTANCE) { in taskq_destroy()
2068 if (tq->tq_flags & TASKQ_THREADS_CPU_PCT) { in taskq_destroy()
2084 tq->tq_flags |= TASKQ_CHANGING; in taskq_destroy()
2131 ASSERT(tq->tq_flags & TASKQ_DYNAMIC); in taskq_destroy()
2140 ASSERT(!(tq->tq_flags & TASKQ_DYNAMIC)); in taskq_destroy()
2271 ASSERT(tq->tq_flags & TASKQ_DYNAMIC); in taskq_d_kstat_update()