Lines Matching defs:tqt
364 taskq_thread_t *tqt;
382 tqt = list_entry(tq->tq_active_list.next, taskq_thread_t,
384 ASSERT(tqt->tqt_id != TASKQID_INVALID);
385 lowest_id = MIN(lowest_id, tqt->tqt_id);
395 taskq_insert_in_order(taskq_t *tq, taskq_thread_t *tqt)
401 ASSERT(tqt);
405 if (w->tqt_id < tqt->tqt_id) {
406 list_add(&tqt->tqt_active_list, l);
411 list_add(&tqt->tqt_active_list, &tq->tq_active_list);
446 taskq_thread_t *tqt;
463 tqt = list_entry(l, taskq_thread_t, tqt_active_list);
464 if (tqt->tqt_id == id) {
949 taskq_thread_should_stop(taskq_t *tq, taskq_thread_t *tqt)
957 tqt_thread_list) == tqt)
974 taskq_thread_t *tqt = args;
981 ASSERT(tqt);
982 ASSERT(tqt->tqt_tq);
983 tq = tqt->tqt_tq;
1008 list_add_tail(&tqt->tqt_thread_list, &tq->tq_thread_list);
1019 if (taskq_thread_should_stop(tq, tqt))
1056 tqt->tqt_id = t->tqent_id;
1057 tqt->tqt_flags = t->tqent_flags;
1063 tqt->tqt_task = t;
1065 taskq_insert_in_order(tq, tqt);
1089 list_del_init(&tqt->tqt_active_list);
1090 tqt->tqt_task = NULL;
1093 if (!(tqt->tqt_flags & TQENT_FLAG_PREALLOC))
1100 if (tq->tq_lowest_id == tqt->tqt_id) {
1102 ASSERT3S(tq->tq_lowest_id, >, tqt->tqt_id);
1110 tqt->tqt_id = TASKQID_INVALID;
1111 tqt->tqt_flags = 0;
1122 list_del_init(&tqt->tqt_thread_list);
1128 kmem_free(tqt, sizeof (taskq_thread_t));
1141 taskq_thread_t *tqt;
1143 tqt = kmem_alloc(sizeof (*tqt), KM_PUSHPAGE);
1144 INIT_LIST_HEAD(&tqt->tqt_thread_list);
1145 INIT_LIST_HEAD(&tqt->tqt_active_list);
1146 tqt->tqt_tq = tq;
1147 tqt->tqt_id = TASKQID_INVALID;
1149 tqt->tqt_thread = spl_kthread_create(taskq_thread, tqt,
1151 if (tqt->tqt_thread == NULL) {
1152 kmem_free(tqt, sizeof (taskq_thread_t));
1158 kthread_bind(tqt->tqt_thread, last_used_cpu);
1162 set_user_nice(tqt->tqt_thread, PRIO_TO_NICE(tq->tq_pri));
1164 wake_up_process(tqt->tqt_thread);
1168 return (tqt);
1321 taskq_thread_t *tqt;
1396 tqt = taskq_thread_create(tq);
1397 if (tqt == NULL)
1432 taskq_thread_t *tqt;
1478 tqt = list_entry(tq->tq_thread_list.next,
1480 thread = tqt->tqt_thread;
1527 taskq_thread_t *tqt;
1540 list_for_each_entry(tqt, &tq->tq_thread_list, tqt_thread_list) {
1541 kthreads[i] = tqt->tqt_thread;
1731 taskq_thread_t *tqt = taskq_thread_create(tq);
1732 if (tqt == NULL)
1765 taskq_thread_t *tqt = list_entry(tq->tq_thread_list.next,
1767 struct task_struct *thread = tqt->tqt_thread;