Lines Matching refs:tqs
963 spa_taskqs_t *tqs = &spa->spa_zio_taskq[t][q];
1016 tqs->stqs_count = 0;
1017 tqs->stqs_taskq = NULL;
1028 tqs->stqs_count = count;
1029 tqs->stqs_taskq = kmem_alloc(count * sizeof (taskq_t *), KM_SLEEP);
1076 tqs->stqs_taskq[i] = tq;
1083 spa_taskqs_t *tqs = &spa->spa_zio_taskq[t][q];
1085 if (tqs->stqs_taskq == NULL) {
1086 ASSERT3U(tqs->stqs_count, ==, 0);
1090 for (uint_t i = 0; i < tqs->stqs_count; i++) {
1091 ASSERT3P(tqs->stqs_taskq[i], !=, NULL);
1092 taskq_destroy(tqs->stqs_taskq[i]);
1095 kmem_free(tqs->stqs_taskq, tqs->stqs_count * sizeof (taskq_t *));
1096 tqs->stqs_taskq = NULL;
1109 spa_taskqs_t *tqs = &spa->spa_zio_taskq[t][q];
1112 ASSERT3P(tqs->stqs_taskq, !=, NULL);
1113 ASSERT3U(tqs->stqs_count, !=, 0);
1115 if (tqs->stqs_count == 1) {
1116 tq = tqs->stqs_taskq[0];
1118 tq = tqs->stqs_taskq[((uint64_t)gethrtime()) % tqs->stqs_count];
1131 spa_taskqs_t *tqs = &spa->spa_zio_taskq[t][q];
1135 ASSERT3P(tqs->stqs_taskq, !=, NULL);
1136 ASSERT3U(tqs->stqs_count, !=, 0);
1138 if (tqs->stqs_count == 1) {
1139 tq = tqs->stqs_taskq[0];
1141 tq = tqs->stqs_taskq[((uint64_t)gethrtime()) % tqs->stqs_count];