Lines Matching refs:tqs
863 spa_taskqs_t *tqs = &spa->spa_zio_taskq[t][q]; in spa_taskqs_init() local
869 tqs->stqs_count = 0; in spa_taskqs_init()
870 tqs->stqs_taskq = NULL; in spa_taskqs_init()
876 tqs->stqs_count = count; in spa_taskqs_init()
877 tqs->stqs_taskq = kmem_alloc(count * sizeof (taskq_t *), KM_SLEEP); in spa_taskqs_init()
941 tqs->stqs_taskq[i] = tq; in spa_taskqs_init()
948 spa_taskqs_t *tqs = &spa->spa_zio_taskq[t][q]; in spa_taskqs_fini() local
950 if (tqs->stqs_taskq == NULL) { in spa_taskqs_fini()
951 ASSERT0(tqs->stqs_count); in spa_taskqs_fini()
955 for (uint_t i = 0; i < tqs->stqs_count; i++) { in spa_taskqs_fini()
956 ASSERT3P(tqs->stqs_taskq[i], !=, NULL); in spa_taskqs_fini()
957 taskq_destroy(tqs->stqs_taskq[i]); in spa_taskqs_fini()
960 kmem_free(tqs->stqs_taskq, tqs->stqs_count * sizeof (taskq_t *)); in spa_taskqs_fini()
961 tqs->stqs_taskq = NULL; in spa_taskqs_fini()
974 spa_taskqs_t *tqs = &spa->spa_zio_taskq[t][q]; in spa_taskq_dispatch_ent() local
977 ASSERT3P(tqs->stqs_taskq, !=, NULL); in spa_taskq_dispatch_ent()
978 ASSERT3U(tqs->stqs_count, !=, 0); in spa_taskq_dispatch_ent()
980 if (tqs->stqs_count == 1) { in spa_taskq_dispatch_ent()
981 tq = tqs->stqs_taskq[0]; in spa_taskq_dispatch_ent()
984 tq = tqs->stqs_taskq[cpu_ticks() % tqs->stqs_count]; in spa_taskq_dispatch_ent()
986 tq = tqs->stqs_taskq[gethrtime() % tqs->stqs_count]; in spa_taskq_dispatch_ent()