src/ipc/msg.hpp

Idź do dokumentacji tego pliku.

/* header file for src/ipc/msg.cpp */

#ifndef _CORE_IPC_MSG_HPP
#define _CORE_IPC_MSG_HPP

//necessary includes
#include "src/ipc/lock.hpp"
#include "src/ipc/sem.hpp"
#include "src/common/blist.hpp"
#include "src/memory/heap.hpp"

namespace Thread {
        class thread_t;
 };     /*namespace Thread*/

namespace IPC {
namespace Message {

//a single message
struct message
 {
        class mailbox *sender;  //who sent the message?
        uint32 size;            //how much data is stored here
        uint64 time_stamp;      //when has it been sent
        uint32 flags;           //flags
 };

//a message box
class mailbox
 {
        friend int allocate_mailbox (mailbox *mbx, struct ::Thread::thread_t *owner, Memory::Heap::heapbox *hp);
public:
// protected:
        IPC::Lock::lock_t lock_mail;    // lock a mailbox
        struct sem_t sem_mail;
        blist_t volatile inbox;         // inbox
        Memory::Heap::heapbox *heap;    // the heap
        struct ::Thread::thread_t *thread;      // who owns the mailbox if anyone?
        uint32 mail;    //count

        int new_mail(mailbox *sender, void *data, size_t size, uint32 flags);   //add a message to the inbox
public:
        void done();    //free memory

        int ksend(mailbox *dest, void *data, size_t size, uint32 flags);
        int kreceive(message **msg);
        int kreceive(message **msg, mailbox *sender);

        int count();    //how many messages are waiting in the inbox
//      int alloc_msg(message **msg, void **dt, size_t size);
        int free_msg(message *msg);
 };

int allocate_mailbox (mailbox *mbx, struct ::Thread::thread_t *owner, Memory::Heap::heapbox *hp);//create a mailbox

  };    /*namespace Message*/
 };     /*namespace IPC*/

#include "src/thread/thread.hpp"

#endif

---