Function _workqueue_thread_entry

components/drivers/ipc/workqueue.c:50–113

}

static void _workqueue_thread_entry(void *parameter)
{
    rt_base_t            level;
    struct rt_work      *work;
    struct rt_workqueue *queue;
    rt_tick_t            current_tick;
    rt_int32_t           delay_tick;
    void (*work_func)(struct rt_work *work, void *work_data);
    void *work_data;

    queue = (struct rt_workqueue *)parameter;
    RT_ASSERT(queue != RT_NULL);

    while (1)
    {
        level = rt_spin_lock_irqsave(&(queue->spinlock));

        /* timer check */
        current_tick = rt_tick_get();
        delay_tick   = RT_WAITING_FOREVER;
        while (!rt_list_isempty(&(queue->delayed_list)))
        {
            work = rt_list_entry(queue->delayed_list.next, struct rt_work, list);
            if ((current_tick - work->timeout_tick) < RT_TICK_MAX / 2)
            {
                rt_list_remove(&(work->list));
                rt_list_insert_after(queue->work_list.prev, &(work->list));
                work->flags &= ~RT_WORK_STATE_SUBMITTING;
                work->flags |= RT_WORK_STATE_PENDING;
            }
            else
            {
                delay_tick = work->timeout_tick - current_tick;
                break;
            }
        }

        if (rt_list_isempty(&(queue->work_list)))
        {
            rt_spin_unlock_irqrestore(&(queue->spinlock), level);
            /* wait for work completion */
            rt_completion_wait(&(queue->wakeup_completion), delay_tick);
            continue;
        }

        /* we have work to do with. */
        work = rt_list_entry(queue->work_list.next, struct rt_work, list);
        rt_list_remove(&(work->list));
        queue->work_current  = work;
        work->flags         &= ~RT_WORK_STATE_PENDING;
        work->workqueue      = RT_NULL;
        work_func            = work->work_func;
        work_data            = work->work_data;
        rt_spin_unlock_irqrestore(&(queue->spinlock), level);

        /* do work */
        work_func(work, work_data);
        /* clean current work */