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>

namespace coil
{
  class Properties;
};

// Why RtORB does not allow forward declaration?
#if !defined ORB_IS_RTORB && !defined ORB_IS_ORBEXPRESS
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(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;

#if defined(WIN32) || defined(_WIN32) || defined(__WIN32__) || defined(__NT__)
  EXTERN template class DLL_PLUGIN ::coil::GlobalFactory<InPortConsumer>;
#endif
};     // namespace RTC

#ifdef __GNUC__
extern template class coil::Singleton<coil::GlobalFactory<RTC::InPortConsumer> >;
#endif

#endif // RTC_INPORTCONSUMER_H