Lines Matching refs:tb
130 struct taskqueue_busy *tb; in task_get_busy() local
133 LIST_FOREACH(tb, &queue->tq_active, tb_link) { in task_get_busy()
134 if (tb->tb_running == task) in task_get_busy()
135 return (tb); in task_get_busy()
236 struct taskqueue_busy *tb; in taskqueue_enqueue_locked() local
243 tb = task_get_busy(queue, task); in taskqueue_enqueue_locked()
244 if (tb != NULL && tb->tb_canceling) { in taskqueue_enqueue_locked()
438 struct taskqueue_busy *tb; in taskqueue_drain_tq_active() local
450 LIST_FOREACH(tb, &queue->tq_active, tb_link) { in taskqueue_drain_tq_active()
451 if ((int)(tb->tb_seq - seq) <= 0) { in taskqueue_drain_tq_active()
452 TQ_SLEEP(queue, tb->tb_running, "tq_adrain"); in taskqueue_drain_tq_active()
488 struct taskqueue_busy tb; in taskqueue_run_locked() local
495 tb.tb_running = NULL; in taskqueue_run_locked()
496 LIST_INSERT_HEAD(&queue->tq_active, &tb, tb_link); in taskqueue_run_locked()
505 tb.tb_running = task; in taskqueue_run_locked()
506 tb.tb_seq = ++queue->tq_seq; in taskqueue_run_locked()
507 tb.tb_canceling = false; in taskqueue_run_locked()
525 LIST_REMOVE(&tb, tb_link); in taskqueue_run_locked()
558 struct taskqueue_busy *tb; in taskqueue_cancel_locked() local
569 tb = task_get_busy(queue, task); in taskqueue_cancel_locked()
570 if (tb != NULL) { in taskqueue_cancel_locked()
571 tb->tb_canceling = true; in taskqueue_cancel_locked()