Function sender_timeout

components/lwp/lwp_ipc.c:361–401

}

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

    rt_sched_lock(&slvl);

    ch = (rt_channel_t)(thread->wakeup_handle.user_data);
    if (ch->stat == RT_IPC_STAT_ACTIVE && ch->reply == thread)
    {
        ch->stat = RT_IPC_STAT_IDLE;
        ch->reply = RT_NULL;
    }
    else
    {
        rt_ipc_msg_t msg;
        rt_list_t *l;

        l = ch->wait_msg.next;
        while (l != &ch->wait_msg)
        {
            msg = rt_list_entry(l, struct rt_ipc_msg, mlist);
            if (msg->need_reply && msg->msg.sender == thread)
            {
                rt_list_remove(&msg->mlist); /* remove the msg from the channel */
                _ipc_msg_free(msg);
                break;
            }
            l = l->next;
        }
    }

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

    /* insert to schedule ready list */
    rt_sched_insert_thread(thread);
    /* do schedule */
    rt_sched_unlock_n_resched(slvl);
}

/**
 * Get file vnode from fd.