Lines Matching defs:tqs
284 taskq_sync_arg_t *tqs = kmem_zalloc(sizeof (*tqs) * nthreads, KM_SLEEP);
297 cv_init(&tqs[i].tqa_cv, NULL, CV_DEFAULT, NULL);
298 mutex_init(&tqs[i].tqa_lock, NULL, MUTEX_DEFAULT, NULL);
300 &tqs[i], TQ_FRONT);
305 mutex_enter(&tqs[i].tqa_lock);
306 while (tqs[i].tqa_ready == 0)
307 cv_wait(&tqs[i].tqa_cv, &tqs[i].tqa_lock);
308 mutex_exit(&tqs[i].tqa_lock);
313 mutex_enter(&tqs[i].tqa_lock);
314 tqs[i].tqa_ready = 2;
315 cv_broadcast(&tqs[i].tqa_cv);
316 mutex_exit(&tqs[i].tqa_lock);
321 kthreads[i] = tqs[i].tqa_thread;
322 mutex_destroy(&tqs[i].tqa_lock);
323 cv_destroy(&tqs[i].tqa_cv);
325 kmem_free(tqs, sizeof (*tqs) * nthreads);