Lines Matching refs:stqs_taskq
960 tqs->stqs_taskq = NULL; in spa_taskqs_init()
967 tqs->stqs_taskq = kmem_alloc(count * sizeof (taskq_t *), KM_SLEEP); in spa_taskqs_init()
1019 tqs->stqs_taskq[i] = tq; in spa_taskqs_init()
1028 if (tqs->stqs_taskq == NULL) { in spa_taskqs_fini()
1034 ASSERT3P(tqs->stqs_taskq[i], !=, NULL); in spa_taskqs_fini()
1035 taskq_destroy(tqs->stqs_taskq[i]); in spa_taskqs_fini()
1038 kmem_free(tqs->stqs_taskq, tqs->stqs_count * sizeof (taskq_t *)); in spa_taskqs_fini()
1039 tqs->stqs_taskq = NULL; in spa_taskqs_fini()
1055 ASSERT3P(tqs->stqs_taskq, !=, NULL); in spa_taskq_dispatch_ent()
1059 tq = tqs->stqs_taskq[0]; in spa_taskq_dispatch_ent()
1061 tq = tqs->stqs_taskq[gethrtime() % tqs->stqs_count]; in spa_taskq_dispatch_ent()