ipcmsg_man.hpp

/* ipcmsg_man.hpp */
/* $Id$ */
#ifndef __ipcmsg_man_hpp
#define __ipcmsg_man_hpp

#include <vector>
#include <unistd.h>

#ifdef GE_BUILD
#include <types.hpp>
#else
#include <dcf/types.hpp>
#endif

namespace dcf
{
  class IPCMsgMan
  {
  public:
    
    struct Message
    {
      dcf::mantype_t type;   
      pid_t pid;             
      int unit_id;           
      bool operator==(const Message &msg) const;
    };
        
    typedef std::vector<dcf::IPCMsgMan::Message> Messages;
    
    IPCMsgMan();
    
    virtual ~IPCMsgMan();
    
    dcf::error_t getMessagesNum(size_t &recs_num) const; 
    
    dcf::error_t getMessages(IPCMsgMan::Messages &recs) const; 
    
    dcf::error_t addMessage(const IPCMsgMan::Message &rec_data) const;
    
    dcf::error_t rmMessage(const IPCMsgMan::Message &rec_data, size_t &del_recs_num, bool rm_all=true) const;
    
    dcf::error_t rmQueue() const;
    
    dcf::error_t lock() const;
    
    dcf::error_t unlock() const;
        
  protected:
    
    struct IPCMessage
    {
      long mtype;              
      IPCMsgMan::Message data; 
    };
    
    int get_queue() const;
    
    int get_or_create_queue() const;
    
    int rm_queue() const;
    
    int get_sem() const;
    
    int get_or_create_sem() const;
    
    int rm_sem() const;
    
  private:
    
    static int m_mask;
    
    static key_t m_key;
    
    static key_t m_sem_key;
  };
}

#endif /* ipcmsg_man.hpp */