InPortConsumer.h

Go to the documentation of this file.

// -*- C++ -*-
#ifndef RTC_INPORTCONSUMER_H
#define RTC_INPORTCONSUMER_H
 
#include <coil/Factory.h>
#include <rtm/DataPortStatus.h>
#include <rtm/ByteData.h>
 
namespace coil
{
  class Properties;
} // namespace coil
 
// Why RtORB does not allow forward declaration?
#if !defined ORB_IS_RTORB && !defined ORB_IS_ORBEXPRESS
namespace SDOPackage
{
  class NVList;
} // namespace SDOPackage
#endif  // ORB_IS_RTORB
 
 
 
namespace RTC
{
  class InPortConsumer
  {
  public:
 
    virtual ~InPortConsumer() = default;
 
    virtual void init(coil::Properties& prop) = 0;
 
    virtual DataPortStatus put(ByteData& 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
    {
      explicit publishInterfaceProfileFunc(SDOPackage::NVList& prop)
             : m_prop(prop) {}
      void operator()(InPortConsumer* consumer)
      {
        consumer->publishInterfaceProfile(m_prop);
      }
      SDOPackage::NVList& m_prop;
    };
 
    struct subscribeInterfaceFunc
    {
      explicit subscribeInterfaceFunc(SDOPackage::NVList& prop)
             : m_prop(prop) {}
      bool operator()(InPortConsumer* consumer)
      {
        return consumer->subscribeInterface(m_prop);
      }
      SDOPackage::NVList& m_prop;
    };
 
 
  };
 
  using InPortConsumerFactory = ::coil::GlobalFactory<InPortConsumer>;
} // namespace RTC
 
#if defined(WIN32) || defined(_WIN32) || defined(__WIN32__) || defined(__NT__)
EXTERN template class DLL_PLUGIN coil::GlobalFactory<RTC::InPortConsumer>;
#elif defined(__GNUC__)
EXTERN template class coil::GlobalFactory<RTC::InPortConsumer>;
#endif
 
#endif  // RTC_INPORTCONSUMER_H