Function receiver_timeout

components/lwp/lwp_ipc.c:778–803

}

static void receiver_timeout(void *parameter)
{
    struct rt_thread *thread = (struct rt_thread *)parameter;
    rt_channel_t ch;
    rt_sched_lock_level_t slvl;

    rt_sched_lock(&slvl);

    ch = (rt_channel_t)(thread->wakeup_handle.user_data);

    thread->error = -RT_ETIMEOUT;
    thread->wakeup_handle.func = RT_NULL;

    rt_spin_lock(&ch->slock);
    ch->stat = RT_IPC_STAT_IDLE;

    rt_list_remove(&RT_THREAD_LIST_NODE(thread));
    /* insert to schedule ready list */
    rt_sched_insert_thread(thread);

    _rt_channel_check_wq_wakup_locked(ch);
    rt_spin_unlock(&ch->slock);

    /* do schedule */
    rt_sched_unlock_n_resched(slvl);
}

/**
 * Fetch a message from the specified IPC channel.