InPortSHMProvider.h

Go to the documentation of this file.

// -*- C++ -*-
#ifndef RTC_INPORTSHMPROVIDER_H
#define RTC_INPORTSHMPROVIDER_H

#include <rtm/SharedMemoryPort.h>
#include <rtm/BufferBase.h>
#include <rtm/InPortProvider.h>
#include <rtm/CORBA_SeqUtil.h>
#include <rtm/Manager.h>
#include <rtm/ConnectorListener.h>
#include <rtm/ConnectorBase.h>

#ifdef WIN32
#pragma warning( disable : 4290 )
#endif

namespace RTC
{
  class InPortSHMProvider
    : public InPortProvider,
      public virtual SharedMemoryPort
  {
  public:
    InPortSHMProvider();
    
    virtual ~InPortSHMProvider();

    virtual void init(coil::Properties& prop);

    virtual void setBuffer(BufferBase<cdrMemoryStream>* buffer);

    virtual void setListener(ConnectorInfo& info,
                             ConnectorListeners* listeners);
    virtual void setConnector(InPortConnector* connector);

    virtual ::OpenRTM::PortStatus put()
      throw (CORBA::SystemException);
    
  private:

    ::OpenRTM::PortStatus
    convertReturn(BufferStatus::Enum status,
                  cdrMemoryStream& data);

    
    inline void onBufferWrite(cdrMemoryStream& data)
    {
      m_listeners->
        connectorData_[ON_BUFFER_WRITE].notify(m_profile, data);
    }

    inline void onBufferFull(cdrMemoryStream& data)
    {
      m_listeners->
        connectorData_[ON_BUFFER_FULL].notify(m_profile, data);
    }

    inline void onBufferWriteTimeout(cdrMemoryStream& data)
    {
      m_listeners->
        connectorData_[ON_BUFFER_WRITE_TIMEOUT].notify(m_profile, data);
    }

    inline void onBufferWriteOverwrite(cdrMemoryStream& data)
    {
      m_listeners->
        connectorData_[ON_BUFFER_OVERWRITE].notify(m_profile, data);
    }

    inline void onReceived(cdrMemoryStream& data)
    {
      m_listeners->
        connectorData_[ON_RECEIVED].notify(m_profile, data);
    }

    inline void onReceiverFull(cdrMemoryStream& data)
    {
      m_listeners->
        connectorData_[ON_RECEIVER_FULL].notify(m_profile, data);
    }

    inline void onReceiverTimeout(cdrMemoryStream& data)
    {
      m_listeners->
        connectorData_[ON_RECEIVER_TIMEOUT].notify(m_profile, data);
    }

    inline void onReceiverError(cdrMemoryStream& data)
    {
      m_listeners->
        connectorData_[ON_RECEIVER_ERROR].notify(m_profile, data);
    }

  private:
    mutable Logger rtclog;

    InPortConnector* m_connector;
    CdrBufferBase* m_buffer;
    ConnectorListeners* m_listeners;
    ConnectorInfo m_profile;

    ::OpenRTM::PortSharedMemory_var  m_objref;

  };  // class InPortCorCdrbaProvider
};    // namespace RTC

extern "C"
{
  void InPortSHMProviderInit();
};

#ifdef WIN32
#pragma warning( default : 4290 )
#endif

#endif // RTC_INPORTCORBACDRPROVIDER_H