Lines Matching defs:tqs
1131 spa_taskqs_t *tqs = &spa->spa_zio_taskq[t][q];
1200 tqs->stqs_count = 0;
1201 tqs->stqs_taskq = NULL;
1212 tqs->stqs_count = count;
1213 tqs->stqs_taskq = kmem_alloc(count * sizeof (taskq_t *), KM_SLEEP);
1262 tqs->stqs_taskq[i] = tq;
1269 spa_taskqs_t *tqs = &spa->spa_zio_taskq[t][q];
1271 if (tqs->stqs_taskq == NULL) {
1272 ASSERT3U(tqs->stqs_count, ==, 0);
1276 for (uint_t i = 0; i < tqs->stqs_count; i++) {
1277 ASSERT3P(tqs->stqs_taskq[i], !=, NULL);
1278 taskq_destroy(tqs->stqs_taskq[i]);
1281 kmem_free(tqs->stqs_taskq, tqs->stqs_count * sizeof (taskq_t *));
1282 tqs->stqs_taskq = NULL;
1563 spa_taskqs_t *tqs = &spa->spa_zio_taskq[t][q];
1566 ASSERT3P(tqs->stqs_taskq, !=, NULL);
1567 ASSERT3U(tqs->stqs_count, !=, 0);
1577 if (tqs->stqs_count == 1) {
1578 tq = tqs->stqs_taskq[0];
1581 tq = tqs->stqs_taskq[zio->io_allocator % tqs->stqs_count];
1583 tq = tqs->stqs_taskq[((uint64_t)gethrtime()) % tqs->stqs_count];