Lines Matching refs:gtaskqueue

54 static int	task_is_running(struct gtaskqueue *queue, struct gtask *gtask);
55 static void gtaskqueue_drain_locked(struct gtaskqueue *queue, struct gtask *gtask);
69 struct gtaskqueue { struct
119 TQ_SLEEP(struct gtaskqueue *tq, void *p, struct mtx *m, int pri, const char *wm, in TQ_SLEEP()
127 static struct gtaskqueue *
132 struct gtaskqueue *queue; in _gtaskqueue_create()
141 queue = malloc(sizeof(struct gtaskqueue), M_GTASKQUEUE, mflags | M_ZERO); in _gtaskqueue_create()
166 gtaskqueue_terminate(struct thread **pp, struct gtaskqueue *tq) in gtaskqueue_terminate()
176 gtaskqueue_free(struct gtaskqueue *queue) in gtaskqueue_free()
196 struct gtaskqueue *queue = grouptask->gt_taskqueue; in grouptask_block()
214 struct gtaskqueue *queue = grouptask->gt_taskqueue; in grouptask_unblock()
229 grouptaskqueue_enqueue(struct gtaskqueue *queue, struct gtask *gtask) in grouptaskqueue_enqueue()
265 gtaskqueue_drain_tq_queue(struct gtaskqueue *queue) in gtaskqueue_drain_tq_queue()
298 gtaskqueue_drain_tq_active(struct gtaskqueue *queue) in gtaskqueue_drain_tq_active()
333 gtaskqueue_block(struct gtaskqueue *queue) in gtaskqueue_block()
342 gtaskqueue_unblock(struct gtaskqueue *queue) in gtaskqueue_unblock()
353 gtaskqueue_run_locked(struct gtaskqueue *queue) in gtaskqueue_run_locked()
393 task_is_running(struct gtaskqueue *queue, struct gtask *gtask) in task_is_running()
406 gtaskqueue_cancel_locked(struct gtaskqueue *queue, struct gtask *gtask) in gtaskqueue_cancel_locked()
416 gtaskqueue_cancel(struct gtaskqueue *queue, struct gtask *gtask) in gtaskqueue_cancel()
428 gtaskqueue_drain_locked(struct gtaskqueue *queue, struct gtask *gtask) in gtaskqueue_drain_locked()
435 gtaskqueue_drain(struct gtaskqueue *queue, struct gtask *gtask) in gtaskqueue_drain()
447 gtaskqueue_drain_all(struct gtaskqueue *queue) in gtaskqueue_drain_all()
460 _gtaskqueue_start_threads(struct gtaskqueue **tqp, int count, int pri, in _gtaskqueue_start_threads()
465 struct gtaskqueue *tq; in _gtaskqueue_start_threads()
524 gtaskqueue_start_threads(struct gtaskqueue **tqp, int count, int pri, in gtaskqueue_start_threads()
537 gtaskqueue_run_callback(struct gtaskqueue *tq, in gtaskqueue_run_callback()
551 struct gtaskqueue **tqp, *tq; in gtaskqueue_thread_loop()
589 struct gtaskqueue **tqp, *tq; in gtaskqueue_thread_enqueue()
597 static struct gtaskqueue *
608 struct gtaskqueue *tgc_taskq;