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.c1197 taskq_sums_t *tqs = &tq->tq_sums; in taskq_stats_init() local
1198 wmsum_init(&tqs->tqs_threads_active, 0); in taskq_stats_init()
1199 wmsum_init(&tqs->tqs_threads_idle, 0); in taskq_stats_init()
1200 wmsum_init(&tqs->tqs_threads_total, 0); in taskq_stats_init()
1201 wmsum_init(&tqs->tqs_tasks_pending, 0); in taskq_stats_init()
1202 wmsum_init(&tqs->tqs_tasks_priority, 0); in taskq_stats_init()
1203 wmsum_init(&tqs->tqs_tasks_total, 0); in taskq_stats_init()
1204 wmsum_init(&tqs->tqs_tasks_delayed, 0); in taskq_stats_init()
1205 wmsum_init(&tqs->tqs_entries_free, 0); in taskq_stats_init()
1206 wmsum_init(&tqs->tqs_threads_created, 0); in taskq_stats_init()
[all …]
/freebsd/sys/contrib/openzfs/module/os/freebsd/spl/
H A Dspl_taskq.c285 taskq_sync_arg_t *tqs = kmem_zalloc(sizeof (*tqs) * nthreads, KM_SLEEP); in taskq_create_synced() local
298 cv_init(&tqs[i].tqa_cv, NULL, CV_DEFAULT, NULL); in taskq_create_synced()
299 mutex_init(&tqs[i].tqa_lock, NULL, MUTEX_DEFAULT, NULL); in taskq_create_synced()
301 &tqs[i], TQ_FRONT); in taskq_create_synced()
306 mutex_enter(&tqs[i].tqa_lock); in taskq_create_synced()
307 while (tqs[i].tqa_ready == 0) in taskq_create_synced()
308 cv_wait(&tqs[i].tqa_cv, &tqs[i].tqa_lock); in taskq_create_synced()
309 mutex_exit(&tqs[i].tqa_lock); in taskq_create_synced()
314 mutex_enter(&tqs[i].tqa_lock); in taskq_create_synced()
315 tqs[i].tqa_ready = 2; in taskq_create_synced()
[all …]
/freebsd/sys/contrib/openzfs/module/zfs/
H A Dspa.c1172 spa_taskqs_t *tqs = &spa->spa_zio_taskq[t][q]; in spa_taskqs_init() local
1251 tqs->stqs_count = 0; in spa_taskqs_init()
1252 tqs->stqs_taskq = NULL; in spa_taskqs_init()
1263 tqs->stqs_count = count; in spa_taskqs_init()
1264 tqs->stqs_taskq = kmem_alloc(count * sizeof (taskq_t *), KM_SLEEP); in spa_taskqs_init()
1298 tqs->stqs_taskq[i] = tq; in spa_taskqs_init()
1305 spa_taskqs_t *tqs = &spa->spa_zio_taskq[t][q]; in spa_taskqs_fini() local
1307 if (tqs->stqs_taskq == NULL) { in spa_taskqs_fini()
1308 ASSERT0(tqs->stqs_count); in spa_taskqs_fini()
1312 for (uint_t i = 0; i < tqs->stqs_count; i++) { in spa_taskqs_fini()
[all …]
H A Dzio.c2196 spa_taskqs_t *tqs = &spa->spa_zio_taskq[t][q]; in zio_taskq_member() local
2198 for (i = 0; i < tqs->stqs_count; i++) { in zio_taskq_member()
2199 if (tqs->stqs_taskq[i] == tq) in zio_taskq_member()