ipcproccomm.hpp

#ifndef DDF_IPCPROCCOMM_HPP
#define DDF_IPCPROCCOMM_HPP

extern "C"
{
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
}

#include "infocontainer.hpp"
#include "commbase.hpp"
#include "ctime.hpp"
#include "mbx.hpp"
#include "debugging.hpp"

namespace jafar
{
  namespace ddf
  {

    template<typename PARENT>
    class CommThreadFunc
    {
      PARENT *m_par;
   
    public:
      CommThreadFunc(PARENT *parent): m_par(parent) {}
      ~CommThreadFunc() {}
      void operator()()
      {
        time t_time = time::from_us(5);
        m_par->SetInitialized();
        JFR_VDEBUG("Listen to message queue: " << m_par->GetCommId() << "\n");
      
        while(m_par->KeepRunning())
        {
            m_par->Read();
            t_time.sleep_period();
        }
      }
    };


    class IPCProcComm : public CommBase
    {
      bool                          m_run;
      unsigned long                 m_snd_cntr;
      unsigned long                 m_rec_cntr;
      boost::thread                 *pCommThread;
      CommThreadFunc<IPCProcComm>   m_commFunc;
      int                           m_msgqid_send;
      mutable  boost::mutex         m_mutex;
      ChanFltrMsg                   *m_buf_send;
      ChanFltrMsg                   *m_buf_rec;

    private:
      void AllocTempBuffers();

    public:
      IPCProcComm(unsigned short sv_size);
      IPCProcComm(unsigned short sv_size, key_t key);
      virtual ~IPCProcComm();
    
      void GetMsgQueue();
      void DeleteMsgQueue();
      CommBase::EC_STATUS Send(InfoContainer const& info);
      CommBase::EC_STATUS Read();
      bool KeepRunning() { return m_run; }

    private:
      void Constructor();
    };

  } // namespace ddf
} // namespace jafar
#endif