InPortConsumer.h

説明を見る。

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

#include <coil/Factory.h>
#include <rtm/DataPortStatus.h>

namespace coil
{
  class Properties;
};

// Why RtORB does not allow forward declaration?
#ifndef ORB_IS_RTORB
namespace SDOPackage
{
  class NVList;
};
#endif // ORB_IS_RTORB

class cdrMemoryStream;

namespace RTC
{
  class InPortConsumer
    : public DataPortStatus
  {
  public:
    DATAPORTSTATUS_ENUM
    
    virtual ~InPortConsumer(void){};

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

    virtual ReturnCode put(const cdrMemoryStream& data) = 0;

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

    virtual bool subscribeInterface(const SDOPackage::NVList& properties) = 0;
    
    virtual void unsubscribeInterface(const SDOPackage::NVList& properties) = 0;
    
    struct publishInterfaceProfileFunc
    {
      publishInterfaceProfileFunc(SDOPackage::NVList& prop) : m_prop(prop) {}
      void operator()(InPortConsumer* consumer)
      {
        consumer->publishInterfaceProfile(m_prop);
      }
      SDOPackage::NVList& m_prop;
    };

    struct subscribeInterfaceFunc
    {
      subscribeInterfaceFunc(SDOPackage::NVList& prop) : m_prop(prop) {}
      bool operator()(InPortConsumer* consumer)
      {
        return consumer->subscribeInterface(m_prop);
      }
      SDOPackage::NVList& m_prop;
    };

  
  };

  typedef ::coil::GlobalFactory<InPortConsumer> InPortConsumerFactory;
};     // namespace RTC

#endif // RTC_INPORTCONSUMER_H

---