109 _timeout_task_init(struct taskqueue *queue, struct timeout_task *timeout_task,  in _timeout_task_init()  argument
113 	TASK_INIT(&timeout_task->t, priority, func, context);  in _timeout_task_init()
114 	callout_init_mtx(&timeout_task->c, &queue->tq_mutex,  in _timeout_task_init()
116 	timeout_task->q = queue;  in _timeout_task_init()
117 	timeout_task->f = 0;  in _timeout_task_init()
296 	struct timeout_task *timeout_task;  in taskqueue_timeout_func()  local
298 	timeout_task = arg;  in taskqueue_timeout_func()
299 	queue = timeout_task->q;  in taskqueue_timeout_func()
300 	KASSERT((timeout_task->f & DT_CALLOUT_ARMED) != 0, ("Stray timeout"));  in taskqueue_timeout_func()
301 	timeout_task->f &= ~DT_CALLOUT_ARMED;  in taskqueue_timeout_func()
303 	taskqueue_enqueue_locked(timeout_task->q, &timeout_task->t);  in taskqueue_timeout_func()
309     struct timeout_task *timeout_task, sbintime_t sbt, sbintime_t pr, int flags)  in taskqueue_enqueue_timeout_sbt()  argument
314 	KASSERT(timeout_task->q == NULL || timeout_task->q == queue,  in taskqueue_enqueue_timeout_sbt()
317 	timeout_task->q = queue;  in taskqueue_enqueue_timeout_sbt()
318 	res = timeout_task->t.ta_pending;  in taskqueue_enqueue_timeout_sbt()
319 	if (timeout_task->f & DT_DRAIN_IN_PROGRESS) {  in taskqueue_enqueue_timeout_sbt()
324 		taskqueue_enqueue_locked(queue, &timeout_task->t);  in taskqueue_enqueue_timeout_sbt()
327 		if ((timeout_task->f & DT_CALLOUT_ARMED) != 0) {  in taskqueue_enqueue_timeout_sbt()
331 			timeout_task->f |= DT_CALLOUT_ARMED;  in taskqueue_enqueue_timeout_sbt()
336 			callout_reset_sbt(&timeout_task->c, sbt, pr,  in taskqueue_enqueue_timeout_sbt()
337 			    taskqueue_timeout_func, timeout_task, flags);  in taskqueue_enqueue_timeout_sbt()
346     struct timeout_task *ttask, int ticks)  in taskqueue_enqueue_timeout()
559     struct timeout_task *timeout_task, u_int *pendp)  in taskqueue_cancel_timeout()  argument
565 	pending = !!(callout_stop(&timeout_task->c) > 0);  in taskqueue_cancel_timeout()
566 	error = taskqueue_cancel_locked(queue, &timeout_task->t, &pending1);  in taskqueue_cancel_timeout()
567 	if ((timeout_task->f & DT_CALLOUT_ARMED) != 0) {  in taskqueue_cancel_timeout()
568 		timeout_task->f &= ~DT_CALLOUT_ARMED;  in taskqueue_cancel_timeout()
606     struct timeout_task *timeout_task)  in taskqueue_drain_timeout()  argument
613 	KASSERT((timeout_task->f & DT_DRAIN_IN_PROGRESS) == 0,  in taskqueue_drain_timeout()
615 	timeout_task->f |= DT_DRAIN_IN_PROGRESS;  in taskqueue_drain_timeout()
618 	callout_drain(&timeout_task->c);  in taskqueue_drain_timeout()
619 	taskqueue_drain(queue, &timeout_task->t);  in taskqueue_drain_timeout()
625 	timeout_task->f &= ~DT_DRAIN_IN_PROGRESS;  in taskqueue_drain_timeout()