Home
last modified time | relevance | path

Searched refs:tqs (Results 1 – 4 of 4) sorted by relevance

/freebsd/sys/contrib/openzfs/module/os/linux/spl/
H A Dspl-taskq.c1174 taskq_sums_t *tqs = &tq->tq_sums; in taskq_stats_init() local
1175 wmsum_init(&tqs->tqs_threads_active, 0); in taskq_stats_init()
1176 wmsum_init(&tqs->tqs_threads_idle, 0); in taskq_stats_init()
1177 wmsum_init(&tqs->tqs_threads_total, 0); in taskq_stats_init()
1178 wmsum_init(&tqs->tqs_tasks_pending, 0); in taskq_stats_init()
1179 wmsum_init(&tqs->tqs_tasks_priority, 0); in taskq_stats_init()
1180 wmsum_init(&tqs->tqs_tasks_total, 0); in taskq_stats_init()
1181 wmsum_init(&tqs->tqs_tasks_delayed, 0); in taskq_stats_init()
1182 wmsum_init(&tqs->tqs_entries_free, 0); in taskq_stats_init()
1183 wmsum_init(&tqs->tqs_threads_created, 0); in taskq_stats_init()
[all …]
/freebsd/sys/contrib/openzfs/module/os/freebsd/spl/
H A Dspl_taskq.c284 taskq_sync_arg_t *tqs = kmem_zalloc(sizeof (*tqs) * nthreads, KM_SLEEP); in taskq_create_synced() local
297 cv_init(&tqs[i].tqa_cv, NULL, CV_DEFAULT, NULL); in taskq_create_synced()
298 mutex_init(&tqs[i].tqa_lock, NULL, MUTEX_DEFAULT, NULL); in taskq_create_synced()
300 &tqs[i], TQ_FRONT); in taskq_create_synced()
305 mutex_enter(&tqs[i].tqa_lock); in taskq_create_synced()
306 while (tqs[i].tqa_ready == 0) in taskq_create_synced()
307 cv_wait(&tqs[i].tqa_cv, &tqs[i].tqa_lock); in taskq_create_synced()
308 mutex_exit(&tqs[i].tqa_lock); in taskq_create_synced()
313 mutex_enter(&tqs[i].tqa_lock); in taskq_create_synced()
314 tqs[i].tqa_ready = 2; in taskq_create_synced()
[all …]
/freebsd/sys/contrib/openzfs/module/zfs/
H A Dspa.c1131 spa_taskqs_t *tqs = &spa->spa_zio_taskq[t][q]; in spa_taskqs_init() local
1200 tqs->stqs_count = 0; in spa_taskqs_init()
1201 tqs->stqs_taskq = NULL; in spa_taskqs_init()
1212 tqs->stqs_count = count; in spa_taskqs_init()
1213 tqs->stqs_taskq = kmem_alloc(count * sizeof (taskq_t *), KM_SLEEP); in spa_taskqs_init()
1262 tqs->stqs_taskq[i] = tq; in spa_taskqs_init()
1269 spa_taskqs_t *tqs = &spa->spa_zio_taskq[t][q]; in spa_taskqs_fini() local
1271 if (tqs->stqs_taskq == NULL) { in spa_taskqs_fini()
1272 ASSERT3U(tqs->stqs_count, ==, 0); in spa_taskqs_fini()
1276 for (uint_t i = 0; i < tqs->stqs_count; i++) { in spa_taskqs_fini()
[all …]
H A Dzio.c2204 spa_taskqs_t *tqs = &spa->spa_zio_taskq[t][q]; in zio_taskq_member() local
2206 for (i = 0; i < tqs->stqs_count; i++) { in zio_taskq_member()
2207 if (tqs->stqs_taskq[i] == tq) in zio_taskq_member()