107 _timeout_task_init(struct taskqueue *queue, struct timeout_task *timeout_task,  in _timeout_task_init()  argument
111 	TASK_INIT(&timeout_task->t, priority, func, context);  in _timeout_task_init()
112 	callout_init_mtx(&timeout_task->c, &queue->tq_mutex,  in _timeout_task_init()
114 	timeout_task->q = queue;  in _timeout_task_init()
115 	timeout_task->f = 0;  in _timeout_task_init()
282 	struct timeout_task *timeout_task;  in taskqueue_timeout_func()  local
284 	timeout_task = arg;  in taskqueue_timeout_func()
285 	queue = timeout_task->q;  in taskqueue_timeout_func()
286 	KASSERT((timeout_task->f & DT_CALLOUT_ARMED) != 0, ("Stray timeout"));  in taskqueue_timeout_func()
287 	timeout_task->f &= ~DT_CALLOUT_ARMED;  in taskqueue_timeout_func()
289 	taskqueue_enqueue_locked(timeout_task->q, &timeout_task->t);  in taskqueue_timeout_func()
295     struct timeout_task *timeout_task, sbintime_t sbt, sbintime_t pr, int flags)  in taskqueue_enqueue_timeout_sbt()  argument
300 	KASSERT(timeout_task->q == NULL || timeout_task->q == queue,  in taskqueue_enqueue_timeout_sbt()
303 	timeout_task->q = queue;  in taskqueue_enqueue_timeout_sbt()
304 	res = timeout_task->t.ta_pending;  in taskqueue_enqueue_timeout_sbt()
305 	if (timeout_task->f & DT_DRAIN_IN_PROGRESS) {  in taskqueue_enqueue_timeout_sbt()
310 		taskqueue_enqueue_locked(queue, &timeout_task->t);  in taskqueue_enqueue_timeout_sbt()
313 		if ((timeout_task->f & DT_CALLOUT_ARMED) != 0) {  in taskqueue_enqueue_timeout_sbt()
317 			timeout_task->f |= DT_CALLOUT_ARMED;  in taskqueue_enqueue_timeout_sbt()
322 			callout_reset_sbt(&timeout_task->c, sbt, pr,  in taskqueue_enqueue_timeout_sbt()
323 			    taskqueue_timeout_func, timeout_task, flags);  in taskqueue_enqueue_timeout_sbt()
332     struct timeout_task *ttask, int ticks)  in taskqueue_enqueue_timeout()
547     struct timeout_task *timeout_task, u_int *pendp)  in taskqueue_cancel_timeout()  argument
553 	pending = !!(callout_stop(&timeout_task->c) > 0);  in taskqueue_cancel_timeout()
554 	error = taskqueue_cancel_locked(queue, &timeout_task->t, &pending1);  in taskqueue_cancel_timeout()
555 	if ((timeout_task->f & DT_CALLOUT_ARMED) != 0) {  in taskqueue_cancel_timeout()
556 		timeout_task->f &= ~DT_CALLOUT_ARMED;  in taskqueue_cancel_timeout()
594     struct timeout_task *timeout_task)  in taskqueue_drain_timeout()  argument
601 	KASSERT((timeout_task->f & DT_DRAIN_IN_PROGRESS) == 0,  in taskqueue_drain_timeout()
603 	timeout_task->f |= DT_DRAIN_IN_PROGRESS;  in taskqueue_drain_timeout()
606 	callout_drain(&timeout_task->c);  in taskqueue_drain_timeout()
607 	taskqueue_drain(queue, &timeout_task->t);  in taskqueue_drain_timeout()
613 	timeout_task->f &= ~DT_DRAIN_IN_PROGRESS;  in taskqueue_drain_timeout()