51 static int	task_is_running(struct gtaskqueue *queue, struct gtask *gtask);
52 static void	gtaskqueue_drain_locked(struct gtaskqueue *queue, struct gtask *gtask);
64 struct gtaskqueue {  struct
115 TQ_SLEEP(struct gtaskqueue *tq, void *p, const char *wm)  in TQ_SLEEP()
122 static struct gtaskqueue *
127 	struct gtaskqueue *queue;  in _gtaskqueue_create()
136 	queue = malloc(sizeof(struct gtaskqueue), M_GTASKQUEUE, mflags | M_ZERO);  in _gtaskqueue_create()
160 gtaskqueue_terminate(struct thread **pp, struct gtaskqueue *tq)  in gtaskqueue_terminate()
170 gtaskqueue_free(struct gtaskqueue *queue)  in gtaskqueue_free()
190 	struct gtaskqueue *queue = grouptask->gt_taskqueue;  in grouptask_block()
208 	struct gtaskqueue *queue = grouptask->gt_taskqueue;  in grouptask_unblock()
223 grouptaskqueue_enqueue(struct gtaskqueue *queue, struct gtask *gtask)  in grouptaskqueue_enqueue()
259 gtaskqueue_drain_tq_queue(struct gtaskqueue *queue)  in gtaskqueue_drain_tq_queue()
292 gtaskqueue_drain_tq_active(struct gtaskqueue *queue)  in gtaskqueue_drain_tq_active()
320 gtaskqueue_block(struct gtaskqueue *queue)  in gtaskqueue_block()
329 gtaskqueue_unblock(struct gtaskqueue *queue)  in gtaskqueue_unblock()
340 gtaskqueue_run_locked(struct gtaskqueue *queue)  in gtaskqueue_run_locked()
379 task_is_running(struct gtaskqueue *queue, struct gtask *gtask)  in task_is_running()
392 gtaskqueue_cancel_locked(struct gtaskqueue *queue, struct gtask *gtask)  in gtaskqueue_cancel_locked()
402 gtaskqueue_cancel(struct gtaskqueue *queue, struct gtask *gtask)  in gtaskqueue_cancel()
414 gtaskqueue_drain_locked(struct gtaskqueue *queue, struct gtask *gtask)  in gtaskqueue_drain_locked()
421 gtaskqueue_drain(struct gtaskqueue *queue, struct gtask *gtask)  in gtaskqueue_drain()
433 gtaskqueue_drain_all(struct gtaskqueue *queue)  in gtaskqueue_drain_all()
446 _gtaskqueue_start_threads(struct gtaskqueue **tqp, int count, int pri,  in _gtaskqueue_start_threads()
451 	struct gtaskqueue *tq;  in _gtaskqueue_start_threads()
509 gtaskqueue_start_threads(struct gtaskqueue **tqp, int count, int pri,  in gtaskqueue_start_threads()
522 gtaskqueue_run_callback(struct gtaskqueue *tq,  in gtaskqueue_run_callback()
536 	struct gtaskqueue **tqp, *tq;  in gtaskqueue_thread_loop()
574 	struct gtaskqueue **tqp, *tq;  in gtaskqueue_thread_enqueue()
581 static struct gtaskqueue *
591 	struct gtaskqueue *tgc_taskq;
821 	struct gtaskqueue *q;  in taskqgroup_drain_all()