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()
325 	struct timeout_task *timeout_task;  in taskqueue_timeout_func()  local
327 	timeout_task = arg;  in taskqueue_timeout_func()
328 	queue = timeout_task->q;  in taskqueue_timeout_func()
329 	KASSERT((timeout_task->f & DT_CALLOUT_ARMED) != 0, ("Stray timeout"));  in taskqueue_timeout_func()
330 	timeout_task->f &= ~DT_CALLOUT_ARMED;  in taskqueue_timeout_func()
332 	taskqueue_enqueue_locked(timeout_task->q, &timeout_task->t, 0);  in taskqueue_timeout_func()
338     struct timeout_task *timeout_task, sbintime_t sbt, sbintime_t pr, int flags)  in taskqueue_enqueue_timeout_sbt()  argument
343 	KASSERT(timeout_task->q == NULL || timeout_task->q == queue,  in taskqueue_enqueue_timeout_sbt()
345 	timeout_task->q = queue;  in taskqueue_enqueue_timeout_sbt()
346 	res = timeout_task->t.ta_pending;  in taskqueue_enqueue_timeout_sbt()
347 	if (timeout_task->f & DT_DRAIN_IN_PROGRESS) {  in taskqueue_enqueue_timeout_sbt()
352 		taskqueue_enqueue_locked(queue, &timeout_task->t, 0);  in taskqueue_enqueue_timeout_sbt()
355 		if ((timeout_task->f & DT_CALLOUT_ARMED) != 0) {  in taskqueue_enqueue_timeout_sbt()
359 			timeout_task->f |= DT_CALLOUT_ARMED;  in taskqueue_enqueue_timeout_sbt()
368 				callout_reset_sbt_curcpu(&timeout_task->c, sbt, pr,  in taskqueue_enqueue_timeout_sbt()
369 				    taskqueue_timeout_func, timeout_task, flags);  in taskqueue_enqueue_timeout_sbt()
371 				callout_reset_sbt(&timeout_task->c, sbt, pr,  in taskqueue_enqueue_timeout_sbt()
372 				    taskqueue_timeout_func, timeout_task, flags);  in taskqueue_enqueue_timeout_sbt()
382     struct timeout_task *ttask, int ticks)  in taskqueue_enqueue_timeout()
591     struct timeout_task *timeout_task, u_int *pendp)  in taskqueue_cancel_timeout()  argument
597 	pending = !!(callout_stop(&timeout_task->c) > 0);  in taskqueue_cancel_timeout()
598 	error = taskqueue_cancel_locked(queue, &timeout_task->t, &pending1);  in taskqueue_cancel_timeout()
599 	if ((timeout_task->f & DT_CALLOUT_ARMED) != 0) {  in taskqueue_cancel_timeout()
600 		timeout_task->f &= ~DT_CALLOUT_ARMED;  in taskqueue_cancel_timeout()
638     struct timeout_task *timeout_task)  in taskqueue_drain_timeout()  argument
645 	KASSERT((timeout_task->f & DT_DRAIN_IN_PROGRESS) == 0,  in taskqueue_drain_timeout()
647 	timeout_task->f |= DT_DRAIN_IN_PROGRESS;  in taskqueue_drain_timeout()
650 	callout_drain(&timeout_task->c);  in taskqueue_drain_timeout()
651 	taskqueue_drain(queue, &timeout_task->t);  in taskqueue_drain_timeout()
657 	timeout_task->f &= ~DT_DRAIN_IN_PROGRESS;  in taskqueue_drain_timeout()