OutPortCorbaCdrProvider.h

Go to the documentation of this file.

// -*- C++ -*-
#ifndef RTC_OUTPORTCORBACDRPROVIDER_H
#define RTC_OUTPORTCORBACDRPROVIDER_H
 
#include <rtm/idl/DataPort_OpenRTMSkel.h>
#include <rtm/BufferBase.h>
#include <rtm/OutPortProvider.h>
#include <rtm/CORBA_SeqUtil.h>
#include <rtm/Manager.h>
#include <rtm/ConnectorListener.h>
#include <rtm/ConnectorBase.h>
 
namespace RTC
{
  class OutPortCorbaCdrProvider
    : public OutPortProvider,
      public virtual ::POA_OpenRTM::OutPortCdr,
      public virtual PortableServer::RefCountServantBase
  {
  public:
    OutPortCorbaCdrProvider();
 
    ~OutPortCorbaCdrProvider() override;
 
    void init(coil::Properties& prop) override;
 
    void setBuffer(CdrBufferBase* buffer) override;
 
    void setListener(ConnectorInfo& info,
                             ConnectorListenersBase* listeners) override;
 
    void setConnector(OutPortConnector* connector) override;
 
    ::OpenRTM::PortStatus get(::OpenRTM::CdrData_out data) override;
 
 
  private:
    ::OpenRTM::PortStatus convertReturn(BufferStatus status,
                                        ByteData& data);
 
 
    inline void onBufferRead(ByteData& data)
    {
      m_listeners->notifyOut(ConnectorDataListenerType::ON_BUFFER_READ, m_profile, data);
    }
 
    inline void onSend(ByteData& data)
    {
      m_listeners->notifyOut(ConnectorDataListenerType::ON_SEND, m_profile, data);
    }
 
    inline void onBufferEmpty()
    {
      m_listeners->notify(ConnectorListenerType::ON_BUFFER_EMPTY, m_profile);
    }
 
    inline void onBufferReadTimeout()
    {
      m_listeners->notify(ConnectorListenerType::ON_BUFFER_READ_TIMEOUT, m_profile);
    }
 
    inline void onSenderEmpty()
    {
      m_listeners->notify(ConnectorListenerType::ON_SENDER_EMPTY, m_profile);
    }
 
    inline void onSenderTimeout()
    {
      m_listeners->notify(ConnectorListenerType::ON_SENDER_TIMEOUT, m_profile);
    }
 
    inline void onSenderError()
    {
      m_listeners->notify(ConnectorListenerType::ON_SENDER_ERROR, m_profile);
    }
 
  private:
    CdrBufferBase* m_buffer{nullptr};
    ::OpenRTM::OutPortCdr_var m_objref;
    ConnectorListenersBase* m_listeners;
    ConnectorInfo m_profile;
    OutPortConnector* m_connector{nullptr};
    ByteData m_cdr;
  };  // class OutPortCorbaCdrProvider
} // namespace RTC
 
extern "C"
{
  void OutPortCorbaCdrProviderInit(void);
}
 
#endif  // RTC_OUTPORTCORBACDRPROVIDER_H