Function taskqueue_run_locked

freebsd/kern/subr_taskqueue.c:450–491

}

static void
taskqueue_run_locked(struct taskqueue *queue)
{
	struct epoch_tracker et;
	struct taskqueue_busy tb;
	struct task *task;
	bool in_net_epoch;
	int pending;

	KASSERT(queue != NULL, ("tq is NULL"));
	TQ_ASSERT_LOCKED(queue);
	tb.tb_running = NULL;
	LIST_INSERT_HEAD(&queue->tq_active, &tb, tb_link);
	in_net_epoch = false;

	while ((task = STAILQ_FIRST(&queue->tq_queue)) != NULL) {
		STAILQ_REMOVE_HEAD(&queue->tq_queue, ta_link);
		if (queue->tq_hint == task)
			queue->tq_hint = NULL;
		pending = task->ta_pending;
		task->ta_pending = 0;
		tb.tb_running = task;
		tb.tb_seq = ++queue->tq_seq;
		TQ_UNLOCK(queue);

		KASSERT(task->ta_func != NULL, ("task->ta_func is NULL"));
		if (!in_net_epoch && TASK_IS_NET(task)) {
			in_net_epoch = true;
			NET_EPOCH_ENTER(et);
		} else if (in_net_epoch && !TASK_IS_NET(task)) {
			NET_EPOCH_EXIT(et);
			in_net_epoch = false;
		}
		task->ta_func(task->ta_context, pending);

		TQ_LOCK(queue);
		wakeup(task);
	}
	if (in_net_epoch)
		NET_EPOCH_EXIT(et);
	LIST_REMOVE(&tb, tb_link);
}

void
taskqueue_run(struct taskqueue *queue)