Lines Matching refs:stqs_taskq
1202 tqs->stqs_taskq = NULL; in spa_taskqs_init()
1214 tqs->stqs_taskq = kmem_alloc(count * sizeof (taskq_t *), KM_SLEEP); in spa_taskqs_init()
1248 tqs->stqs_taskq[i] = tq; in spa_taskqs_init()
1257 if (tqs->stqs_taskq == NULL) { in spa_taskqs_fini()
1263 ASSERT3P(tqs->stqs_taskq[i], !=, NULL); in spa_taskqs_fini()
1264 taskq_destroy(tqs->stqs_taskq[i]); in spa_taskqs_fini()
1267 kmem_free(tqs->stqs_taskq, tqs->stqs_count * sizeof (taskq_t *)); in spa_taskqs_fini()
1268 tqs->stqs_taskq = NULL; in spa_taskqs_fini()
1552 ASSERT3P(tqs->stqs_taskq, !=, NULL); in spa_taskq_dispatch()
1564 tq = tqs->stqs_taskq[0]; in spa_taskq_dispatch()
1567 tq = tqs->stqs_taskq[zio->io_allocator % tqs->stqs_count]; in spa_taskq_dispatch()
1569 tq = tqs->stqs_taskq[((uint64_t)gethrtime()) % tqs->stqs_count]; in spa_taskq_dispatch()