InPortCorbaCdrConsumer.h

Go to the documentation of this file.

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


//#include <rtm/BufferBase.h>

#include <rtm/idl/DataPortSkel.h>
#include <rtm/CorbaConsumer.h>
#include <rtm/InPortConsumer.h>
#include <rtm/Manager.h>

namespace RTC
{
  class InPortCorbaCdrConsumer
    : public InPortConsumer,
      public CorbaConsumer< ::OpenRTM::InPortCdr >
  {
  public:
    DATAPORTSTATUS_ENUM
    InPortCorbaCdrConsumer(void);
    
    virtual ~InPortCorbaCdrConsumer(void);

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

    virtual ReturnCode put(const cdrMemoryStream& data);

    virtual void publishInterfaceProfile(SDOPackage::NVList& properties);

    virtual bool subscribeInterface(const SDOPackage::NVList& properties);
    
    virtual void unsubscribeInterface(const SDOPackage::NVList& properties);

  private:
    bool subscribeFromIor(const SDOPackage::NVList& properties);

    bool subscribeFromRef(const SDOPackage::NVList& properties);

    bool unsubscribeFromIor(const SDOPackage::NVList& properties);

    bool unsubscribeFromRef(const SDOPackage::NVList& properties);
    
  private:
    InPortConsumer::ReturnCode convertReturnCode(OpenRTM::PortStatus ret);

    mutable Logger rtclog;
    coil::Properties m_properties;
  };
};     // namespace RTC

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

#endif // RTC_INPORTCORBACDRCONSUMER_H