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()
292 	struct timeout_task *timeout_task;  in taskqueue_timeout_func()  local
294 	timeout_task = arg;  in taskqueue_timeout_func()
295 	queue = timeout_task->q;  in taskqueue_timeout_func()
296 	KASSERT((timeout_task->f & DT_CALLOUT_ARMED) != 0, ("Stray timeout"));  in taskqueue_timeout_func()
297 	timeout_task->f &= ~DT_CALLOUT_ARMED;  in taskqueue_timeout_func()
299 	taskqueue_enqueue_locked(timeout_task->q, &timeout_task->t);  in taskqueue_timeout_func()
305     struct timeout_task *timeout_task, sbintime_t sbt, sbintime_t pr, int flags)  in taskqueue_enqueue_timeout_sbt()  argument
310 	KASSERT(timeout_task->q == NULL || timeout_task->q == queue,  in taskqueue_enqueue_timeout_sbt()
312 	timeout_task->q = queue;  in taskqueue_enqueue_timeout_sbt()
313 	res = timeout_task->t.ta_pending;  in taskqueue_enqueue_timeout_sbt()
314 	if (timeout_task->f & DT_DRAIN_IN_PROGRESS) {  in taskqueue_enqueue_timeout_sbt()
319 		taskqueue_enqueue_locked(queue, &timeout_task->t);  in taskqueue_enqueue_timeout_sbt()
322 		if ((timeout_task->f & DT_CALLOUT_ARMED) != 0) {  in taskqueue_enqueue_timeout_sbt()
326 			timeout_task->f |= DT_CALLOUT_ARMED;  in taskqueue_enqueue_timeout_sbt()
333 			callout_reset_sbt(&timeout_task->c, sbt, pr,  in taskqueue_enqueue_timeout_sbt()
334 			    taskqueue_timeout_func, timeout_task, flags);  in taskqueue_enqueue_timeout_sbt()
343     struct timeout_task *ttask, int ticks)  in taskqueue_enqueue_timeout()
556     struct timeout_task *timeout_task, u_int *pendp)  in taskqueue_cancel_timeout()  argument
562 	pending = !!(callout_stop(&timeout_task->c) > 0);  in taskqueue_cancel_timeout()
563 	error = taskqueue_cancel_locked(queue, &timeout_task->t, &pending1);  in taskqueue_cancel_timeout()
564 	if ((timeout_task->f & DT_CALLOUT_ARMED) != 0) {  in taskqueue_cancel_timeout()
565 		timeout_task->f &= ~DT_CALLOUT_ARMED;  in taskqueue_cancel_timeout()
603     struct timeout_task *timeout_task)  in taskqueue_drain_timeout()  argument
610 	KASSERT((timeout_task->f & DT_DRAIN_IN_PROGRESS) == 0,  in taskqueue_drain_timeout()
612 	timeout_task->f |= DT_DRAIN_IN_PROGRESS;  in taskqueue_drain_timeout()
615 	callout_drain(&timeout_task->c);  in taskqueue_drain_timeout()
616 	taskqueue_drain(queue, &timeout_task->t);  in taskqueue_drain_timeout()
622 	timeout_task->f &= ~DT_DRAIN_IN_PROGRESS;  in taskqueue_drain_timeout()