util/workqueue.c

Go to the documentation of this file.

#include <interrupt.h>
#include <types.h>
#include <workqueue.h>

struct workqueue main_workqueue;

bool workqueue_add_task(struct workqueue *queue, struct workqueue_task *task)
{
        irqflags_t      iflags;
        bool            was_queued = false;

        /* Sanity check on parameters. */
        assert(queue);

        /*
         * Allowing callers to pass a NULL task will eliminate a few
         * tests elsewhere and thus reduce the code size.
         */
        if (!task)
                return false;

        /* We will run this later, so check that it is valid */
        assert(task->worker);

        iflags = cpu_irq_save();
        if (!workqueue_task_is_queued(task)) {
                slist_insert_tail(&queue->task_list, &task->node);
                was_queued = true;
        }
        cpu_irq_restore(iflags);

        return was_queued;
}

bool nested_workqueue_add_task(struct nested_workqueue *nwq,
                struct workqueue_task *task)
{
        irqflags_t      iflags;
        bool            was_queued;

        iflags = cpu_irq_save();
        if (nwq->current) {
                was_queued = workqueue_add_task(&nwq->wq, task);
        } else {
                nwq->current = task;
                was_queued = workqueue_add_task(&main_workqueue, task);
        }
        cpu_irq_restore(iflags);

        return was_queued;
}

void nested_workqueue_next_task(struct nested_workqueue *nwq)
{
        struct workqueue_task   *task;
        irqflags_t              iflags;

        iflags = cpu_irq_save();
        task = workqueue_pop_task(&nwq->wq);
        if (task)
                workqueue_add_task(&main_workqueue, task);
        nwq->current = task;
        cpu_irq_restore(iflags);
}

---