receive.c

Go to the documentation of this file.

#include <xinu.h>

umsg32 receive(void)
{
    intmask mask;          /* Saved interrupt mask      */
    struct procent *prptr; /* Ptr to process's table entry  */
    umsg32 msg;            /* Message to return     */

    mask = disable();
    prptr = &proctab[currpid];
    if (prptr->prhasmsg == FALSE)
    {
        prptr->prstate = PR_RECV;
        resched(); /* Block until message arrives   */
    }
    msg = prptr->prmsg;      /* Retrieve message        */
    prptr->prhasmsg = FALSE; /* Reset message flag      */
    restore(mask);
    return msg;
}