Lines Matching defs:tqs
843 spa_taskqs_t *tqs = &spa->spa_zio_taskq[t][q];
849 tqs->stqs_count = 0;
850 tqs->stqs_taskq = NULL;
856 tqs->stqs_count = count;
857 tqs->stqs_taskq = kmem_alloc(count * sizeof (taskq_t *), KM_SLEEP);
909 tqs->stqs_taskq[i] = tq;
916 spa_taskqs_t *tqs = &spa->spa_zio_taskq[t][q];
918 if (tqs->stqs_taskq == NULL) {
919 ASSERT0(tqs->stqs_count);
923 for (uint_t i = 0; i < tqs->stqs_count; i++) {
924 ASSERT3P(tqs->stqs_taskq[i], !=, NULL);
925 taskq_destroy(tqs->stqs_taskq[i]);
928 kmem_free(tqs->stqs_taskq, tqs->stqs_count * sizeof (taskq_t *));
929 tqs->stqs_taskq = NULL;
942 spa_taskqs_t *tqs = &spa->spa_zio_taskq[t][q];
945 ASSERT3P(tqs->stqs_taskq, !=, NULL);
946 ASSERT3U(tqs->stqs_count, !=, 0);
948 if (tqs->stqs_count == 1) {
949 tq = tqs->stqs_taskq[0];
951 tq = tqs->stqs_taskq[gethrtime() % tqs->stqs_count];