OutPortProvider.h

説明を見る。

// -*- C++ -*-
#ifndef RTC_OUTPORTPROVIDER_H
#define RTC_OUTPORTPROVIDER_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/OutPortConnector.h>

namespace RTC
{
  class ConnectorListeners;
  class OutPortProvider
    : public DataPortStatus
  {
  public:
    DATAPORTSTATUS_ENUM
    virtual ~OutPortProvider(void);

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

    virtual void setBuffer(CdrBufferBase* buffer) = 0;

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

    virtual void setConnector(OutPortConnector* connector) = 0;

    virtual void publishInterfaceProfile(SDOPackage::NVList& properties);
    
    virtual bool publishInterface(SDOPackage::NVList& properties);
    
  protected:
    void setPortType(const char* port_type);
    
    void setDataType(const char* data_type);
    
    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_portType;
    std::string m_dataType;
    std::string m_interfaceType;
    std::string m_dataflowType;
    std::string m_subscriptionType;


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

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

  typedef ::coil::GlobalFactory<OutPortProvider> OutPortProviderFactory;

}; // namespace RTC
#endif // RTC_OUTPORTPROVIDER_H

---