Lines Matching refs:tq_threads
75 struct thread **tq_threads; member
214 taskqueue_terminate(queue->tq_threads, queue); in taskqueue_free()
218 free(queue->tq_threads, M_TASKQUEUE); in taskqueue_free()
423 wakeup_one(queue->tq_threads); in taskqueue_drain_tq_active()
683 tq->tq_threads = malloc(sizeof(struct thread *) * count, M_TASKQUEUE, in _taskqueue_start_threads()
685 if (tq->tq_threads == NULL) { in _taskqueue_start_threads()
693 &tq->tq_threads[i], RFSTOPPED, 0, "%s", ktname); in _taskqueue_start_threads()
696 &tq->tq_threads[i], RFSTOPPED, 0, in _taskqueue_start_threads()
702 tq->tq_threads[i] = NULL; /* paranoid */ in _taskqueue_start_threads()
707 free(tq->tq_threads, M_TASKQUEUE); in _taskqueue_start_threads()
708 tq->tq_threads = NULL; in _taskqueue_start_threads()
712 if (tq->tq_threads[i] == NULL) in _taskqueue_start_threads()
714 td = tq->tq_threads[i]; in _taskqueue_start_threads()
833 wakeup_one(tq->tq_threads); in taskqueue_thread_loop()
890 if (queue->tq_threads[i] == NULL) in taskqueue_member()
892 if (queue->tq_threads[i] == td) { in taskqueue_member()