InPortProvider.h

Go to the documentation of this file.

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

#include <string>

#include <coil/Factory.h>

#include <rtm/BufferBase.h>
#include <rtm/NVUtil.h>
#include <rtm/SystemLogger.h>
#include <rtm/DataPortStatus.h>
#include <rtm/InPortConnector.h>

namespace RTC
{
  class ConnectorListeners;
  class ConnectorInfo;

  class InPortProvider
    : public DataPortStatus
  {
  public:
    DATAPORTSTATUS_ENUM
    InPortProvider();
    
    virtual ~InPortProvider(void);

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

    virtual void setBuffer(BufferBase<cdrMemoryStream>* buffer) = 0;

    virtual void setListener(ConnectorInfo& info,
                             ConnectorListeners* listeners) = 0;

    virtual void setConnector(InPortConnector* connector) = 0;

    virtual void publishInterfaceProfile(SDOPackage::NVList& properties);
    
    virtual bool publishInterface(SDOPackage::NVList& properties);
    
  protected:
    void setInterfaceType(const char* interface_type);
    
    void setDataFlowType(const char* dataflow_type);
    
    void setSubscriptionType(const char* subs_type);


  protected:
    SDOPackage::NVList m_properties;

    mutable Logger rtclog;

  private:
    std::string m_interfaceType;
    std::string m_dataflowType;
    std::string m_subscriptionType;

  public:
    // functors
    struct publishInterfaceProfileFunc
    {
      publishInterfaceProfileFunc(SDOPackage::NVList& prop) : m_prop(prop) {}
      void operator()(InPortProvider* provider)
      {
        provider->publishInterfaceProfile(m_prop);
      }
      SDOPackage::NVList& m_prop;
    };

    struct publishInterfaceFunc
    {
      publishInterfaceFunc(SDOPackage::NVList& prop)
        : m_prop(prop), provider_(0) {}
      void operator()(InPortProvider* provider)
      {
        if (provider->publishInterface(m_prop))
          {
            provider_ = provider;
          }
      }
      SDOPackage::NVList& m_prop;
      InPortProvider* provider_;
    };


  };

  typedef ::coil::GlobalFactory<InPortProvider> InPortProviderFactory;

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