Lines Matching refs:timeout_task
72 _timeout_task_init(struct taskqueue *queue, struct timeout_task *timeout_task, in _timeout_task_init() argument
76 TASK_INIT(&timeout_task->t, priority, func, context); in _timeout_task_init()
77 callout_init_mp(&timeout_task->c); in _timeout_task_init()
78 timeout_task->t.ta_queue = queue; in _timeout_task_init()
79 timeout_task->f = 0; in _timeout_task_init()
327 struct timeout_task *timeout_task; in taskqueue_timeout_func() local
329 timeout_task = arg; in taskqueue_timeout_func()
330 queue = timeout_task->t.ta_queue; in taskqueue_timeout_func()
333 KASSERT((timeout_task->f & DT_CALLOUT_ARMED) != 0, ("Stray timeout")); in taskqueue_timeout_func()
334 timeout_task->f &= ~DT_CALLOUT_ARMED; in taskqueue_timeout_func()
336 taskqueue_enqueue_locked(queue, &timeout_task->t); in taskqueue_timeout_func()
342 struct timeout_task *timeout_task, int ticks) in taskqueue_enqueue_timeout() argument
347 KASSERT(timeout_task->t.ta_queue == NULL || in taskqueue_enqueue_timeout()
348 timeout_task->t.ta_queue == queue, in taskqueue_enqueue_timeout()
350 timeout_task->t.ta_queue = queue; in taskqueue_enqueue_timeout()
351 res = timeout_task->t.ta_pending; in taskqueue_enqueue_timeout()
353 taskqueue_enqueue_locked(queue, &timeout_task->t); in taskqueue_enqueue_timeout()
356 if ((timeout_task->f & DT_CALLOUT_ARMED) != 0) { in taskqueue_enqueue_timeout()
360 timeout_task->f |= DT_CALLOUT_ARMED; in taskqueue_enqueue_timeout()
363 callout_reset(&timeout_task->c, ticks, taskqueue_timeout_func, in taskqueue_enqueue_timeout()
364 timeout_task); in taskqueue_enqueue_timeout()
470 struct timeout_task *timeout_task, u_int *pendp) in taskqueue_cancel_timeout() argument
475 pending = !!callout_stop(&timeout_task->c); in taskqueue_cancel_timeout()
477 error = taskqueue_cancel_locked(queue, &timeout_task->t, &pending1); in taskqueue_cancel_timeout()
478 if ((timeout_task->f & DT_CALLOUT_ARMED) != 0) { in taskqueue_cancel_timeout()
479 timeout_task->f &= ~DT_CALLOUT_ARMED; in taskqueue_cancel_timeout()
523 struct timeout_task *timeout_task) in taskqueue_drain_timeout() argument
525 callout_cancel(&timeout_task->c); in taskqueue_drain_timeout()
526 taskqueue_drain(queue, &timeout_task->t); in taskqueue_drain_timeout()