Lines Matching refs:ASSERT
747 ASSERT(MUTEX_HELD(&tq->tq_lock)); \
805 ASSERT(tq->tq_nthreads == 0); in taskq_destructor()
806 ASSERT(tq->tq_buckets == NULL); in taskq_destructor()
807 ASSERT(tq->tq_tcreates == 0); in taskq_destructor()
808 ASSERT(tq->tq_tdeaths == 0); in taskq_destructor()
836 ASSERT(tqe->tqent_thread == NULL); in taskq_ent_destructor()
861 ASSERT(MUTEX_HELD(&cpu_lock)); in taskq_update_nthreads()
862 ASSERT(MUTEX_HELD(&tq->tq_lock)); in taskq_update_nthreads()
881 ASSERT(tq->tq_flags & TASKQ_THREADS_CPU_PCT); in taskq_cpupct_install()
896 ASSERT(tq->tq_flags & TASKQ_THREADS_CPU_PCT); in taskq_cpupct_remove()
911 ASSERT(MUTEX_HELD(&cpu_lock)); in taskq_cpu_setup()
912 ASSERT(ncpus > 0); in taskq_cpu_setup()
986 ASSERT(MUTEX_HELD(&tq->tq_lock)); in taskq_ent_alloc()
1048 ASSERT(MUTEX_HELD(&tq->tq_lock)); in taskq_ent_free()
1076 ASSERT(MUTEX_HELD(&tq->tq_lock)); in taskq_ent_exists()
1098 ASSERT(MUTEX_NOT_HELD(&b->tqbucket_lock)); in taskq_bucket_dispatch()
1099 ASSERT(func != NULL); in taskq_bucket_dispatch()
1103 ASSERT(b->tqbucket_nfree != 0 || IS_EMPTY(b->tqbucket_freelist)); in taskq_bucket_dispatch()
1104 ASSERT(b->tqbucket_nfree == 0 || !IS_EMPTY(b->tqbucket_freelist)); in taskq_bucket_dispatch()
1114 ASSERT(tqe != &b->tqbucket_freelist); in taskq_bucket_dispatch()
1115 ASSERT(tqe->tqent_thread != NULL); in taskq_bucket_dispatch()
1153 ASSERT(tq != NULL); in taskq_dispatch()
1154 ASSERT(func != NULL); in taskq_dispatch()
1160 ASSERT(!(flags & TQ_NOQUEUE)); in taskq_dispatch()
1188 ASSERT(!(flags & (TQ_NOALLOC | TQ_FRONT))); in taskq_dispatch()
1215 ASSERT(b->tqbucket_taskq == tq); /* Sanity check */ in taskq_dispatch()
1237 ASSERT(b->tqbucket_taskq == tq); /* Sanity check */ in taskq_dispatch()
1271 ASSERT(bucket != NULL); in taskq_dispatch()
1307 ASSERT(func != NULL); in taskq_dispatch_ent()
1308 ASSERT(!(tq->tq_flags & TASKQ_DYNAMIC)); in taskq_dispatch_ent()
1351 ASSERT(tq != curthread->t_taskq); in taskq_wait()
1401 ASSERT(!(tq->tq_flags & TASKQ_SUSPENDED)); in taskq_suspend()
1421 ASSERT(RW_WRITE_HELD(&tq->tq_threadlock)); in taskq_resume()
1433 ASSERT(tq->tq_flags & TASKQ_SUSPENDED); in taskq_resume()
1460 ASSERT(MUTEX_HELD(&tq->tq_lock)); in taskq_thread_create()
1461 ASSERT(tq->tq_flags & TASKQ_CHANGING); in taskq_thread_create()
1462 ASSERT(tq->tq_nthreads < tq->tq_nthreads_target); in taskq_thread_create()
1463 ASSERT(!(tq->tq_flags & TASKQ_THREAD_CREATED)); in taskq_thread_create()
1562 ASSERT(tq->tq_flags & TASKQ_THREAD_CREATED); in taskq_thread()
1563 ASSERT(tq->tq_flags & TASKQ_CHANGING); in taskq_thread()
1673 ASSERT(tq->tq_active > 0); in taskq_thread()
1676 ASSERT(tq->tq_nthreads > 0); in taskq_thread()
1688 ASSERT(!(tq->tq_flags & TASKQ_CPR_SAFE)); in taskq_thread()
1724 ASSERT(bucket->tqbucket_nalloc > 0); in taskq_d_thread()
1755 ASSERT(!IS_EMPTY(bucket->tqbucket_freelist)); in taskq_d_thread()
1768 ASSERT(bucket->tqbucket_nfree > 0); in taskq_d_thread()
1789 ASSERT((tqe->tqent_func != NULL) || in taskq_d_thread()
1792 ASSERT((tqe->tqent_func == NULL) || in taskq_d_thread()
1796 ASSERT((bucket->tqbucket_nfree > 0) || in taskq_d_thread()
1798 ASSERT((bucket->tqbucket_nfree == 0) || in taskq_d_thread()
1820 ASSERT(bucket->tqbucket_nfree > 0); in taskq_d_thread()
1852 ASSERT((flags & ~TASKQ_INTERFACE_FLAGS) == 0); in taskq_create()
1871 ASSERT((flags & ~TASKQ_INTERFACE_FLAGS) == 0); in taskq_create_instance()
1872 ASSERT((instance >= 0) || (instance == -1)); in taskq_create_instance()
1886 ASSERT((flags & ~TASKQ_INTERFACE_FLAGS) == 0); in taskq_create_proc()
1887 ASSERT(proc->p_flag & SSYS); in taskq_create_proc()
1897 ASSERT((flags & ~TASKQ_INTERFACE_FLAGS) == 0); in taskq_create_sysdc()
1898 ASSERT(proc->p_flag & SSYS); in taskq_create_sysdc()
1931 ASSERT((flags & (TASKQ_DUTY_CYCLE|TASKQ_DC_BATCH)) != TASKQ_DC_BATCH); in taskq_create_common()
1933 ASSERT(proc != NULL); in taskq_create_common()
1936 ASSERT(bsize >= 1); in taskq_create_common()
1961 ASSERT(curproc == proc || proc == &p0); in taskq_create_common()
2093 ASSERT(! (tq->tq_flags & TASKQ_CPR_SAFE)); in taskq_destroy()
2125 ASSERT((tq->tq_task.tqent_next == &tq->tq_task) && in taskq_destroy()
2163 ASSERT(b->tqbucket_nalloc == 0); in taskq_destroy()
2178 ASSERT(tq->tq_flags & TASKQ_DYNAMIC); in taskq_destroy()
2187 ASSERT(!(tq->tq_flags & TASKQ_DYNAMIC)); in taskq_destroy()
2250 ASSERT(tqe->tqent_thread == NULL); in taskq_bucket_extend()
2338 ASSERT(tq->tq_flags & TASKQ_DYNAMIC); in taskq_d_kstat_update()