Function _workqueue_submit_work

components/drivers/ipc/workqueue.c:115–166

}

static rt_err_t _workqueue_submit_work(struct rt_workqueue *queue,
                                       struct rt_work *work, rt_tick_t ticks)
{
    rt_base_t       level;
    rt_err_t        err = RT_EOK;
    struct rt_work *work_tmp;
    rt_list_t      *list_tmp;

    level = rt_spin_lock_irqsave(&(queue->spinlock));
    /* remove list */
    rt_list_remove(&(work->list));
    work->flags = 0;

    if (ticks == 0)
    {
        rt_list_insert_after(queue->work_list.prev, &(work->list));
        work->flags     |= RT_WORK_STATE_PENDING;
        work->workqueue  = queue;

        rt_completion_done(&(queue->wakeup_completion));
        err = RT_EOK;
    }
    else if (ticks < RT_TICK_MAX / 2)
    {
        /* insert delay work list */
        work->flags        |= RT_WORK_STATE_SUBMITTING;
        work->workqueue     = queue;
        work->timeout_tick  = rt_tick_get() + ticks;

        list_tmp = &(queue->delayed_list);
        for (work_tmp = rt_list_entry(list_tmp->next, struct rt_work, list);
                &work_tmp->list != list_tmp;
                work_tmp = rt_list_entry(work_tmp->list.next, struct rt_work, list))
        {
            if ((work_tmp->timeout_tick - work->timeout_tick) < RT_TICK_MAX / 2)
            {
                list_tmp = &(work_tmp->list);
                break;
            }
        }
        rt_list_insert_before(list_tmp, &(work->list));

        rt_completion_done(&(queue->wakeup_completion));
        err = RT_EOK;
    }
    else
    {
        err = -RT_ERROR;
    }
    rt_spin_unlock_irqrestore(&(queue->spinlock), level);
    return err;
}

static rt_err_t _workqueue_cancel_work(struct rt_workqueue *queue, struct rt_work *work)
{