Searched refs:tq_nthreads (Results 1 – 6 of 6) sorted by relevance
247 tq->tq_nthreads--; in taskq_thread() 282 tq->tq_nthreads = nthreads; in taskq_create() 307 int nthreads = tq->tq_nthreads; in taskq_destroy() 316 while (tq->tq_nthreads != 0) in taskq_destroy() 361 VERIFY(tq->tq_nthreads == nthreads); in taskq_create_synced() 378 for (i = 0; i < tq->tq_nthreads; i++) in taskq_member()
675 ASSERT(tq->tq_nactive <= tq->tq_nthreads); in taskq_dispatch()676 if ((flags & TQ_NOQUEUE) && (tq->tq_nactive == tq->tq_nthreads)) { in taskq_dispatch()722 if (!(flags & TQ_NOQUEUE) && tq->tq_nactive == tq->tq_nthreads) in taskq_dispatch()774 if (tq->tq_nactive == tq->tq_nthreads) in taskq_dispatch_delay()799 if ((flags & TQ_NOQUEUE) && (tq->tq_nactive == tq->tq_nthreads)) { in taskq_dispatch_ent()847 if (tq->tq_nactive == tq->tq_nthreads) in taskq_dispatch_ent()929 if ((tq->tq_nthreads + tq->tq_nspawn < tq->tq_maxthreads) && in taskq_thread_spawn()959 ASSERT3U(tq->tq_nthreads, >, 1); in taskq_thread_should_stop()1004 if (tq->tq_nthreads >= tq->tq_maxthreads) in taskq_thread()1007 tq->tq_nthreads++; in taskq_thread()[all …]
45 int tq_nthreads; member
116 int tq_nthreads; /* # of existing threads */ member
215 tq->tq_nthreads = nthreads; in taskq_create_impl()293 VERIFY(tq->tq_nthreads == nthreads); in taskq_create_synced()
470 int tq_nthreads;