kern/msg.h

Go to the documentation of this file.

#ifndef KERN_MSG_H
#define KERN_MSG_H

#include <mware/event.h>
#include <struct/list.h>
#include <kern/proc.h>

typedef struct MsgPort
{
    List  queue;   
    Event event;   
} MsgPort;


typedef struct Msg
{
    Node     link;      
    MsgPort *replyPort; 
    /* User data may follow */
} Msg;


INLINE void msg_lockPort(UNUSED_ARG(MsgPort *, port))
{
    proc_forbid();
}

INLINE void msg_unlockPort(UNUSED_ARG(MsgPort *, port))
{
    proc_permit();
}


INLINE void msg_initPort(MsgPort *port, Event event)
{
    LIST_INIT(&port->queue);
    port->event = event;
}

INLINE void msg_put(MsgPort *port, Msg *msg)
{
    msg_lockPort(port);
    ADDTAIL(&port->queue, &msg->link);
    msg_unlockPort(port);

    event_do(&port->event);
}

INLINE Msg *msg_get(MsgPort *port)
{
    Msg *msg;

    msg_lockPort(port);
    msg = (Msg *)list_remHead(&port->queue);
    msg_unlockPort(port);

    return msg;
}

INLINE Msg *msg_peek(MsgPort *port)
{
    Msg *msg;

    msg_lockPort(port);
    msg = (Msg *)port->queue.head.succ;
    if (LIST_EMPTY(&port->queue))
        msg = NULL;
    msg_unlockPort(port);

    return msg;
}

INLINE void msg_reply(Msg *msg)
{
    msg_put(msg->replyPort, msg);
}

#endif /* KERN_MSG_H */