InPortPullConnector.h

Go to the documentation of this file.

// -*- C++ -*-
#ifndef RTC_OUTPORTPULLCONNECTOR_H
#define RTC_OUTPORTPULLCONNECTOR_H
 
#include <rtm/InPortConnector.h>
#include <rtm/InPortProvider.h>
#include <rtm/PublisherBase.h>
#include <rtm/DataPortStatus.h>
 
namespace RTC
{
  class OutPortConsumer;
  class ConnectorListeners;
 
  class InPortPullConnector
    : public InPortConnector
  {
  public:
 
    InPortPullConnector(ConnectorInfo info,
                        OutPortConsumer* consumer,
                        ConnectorListenersBase* listeners,
                        CdrBufferBase* buffer = nullptr);
 
    ~InPortPullConnector() override;
 
    DataPortStatus read(ByteDataStreamBase* data) override;
 
    DataPortStatus disconnect() override;
 
    void activate() override {}  // do nothing
 
    void deactivate() override {}  // do nothing
    void unsubscribeInterface(const coil::Properties& prop) override;
 
  protected:
    static CdrBufferBase* createBuffer(ConnectorInfo& info);
 
    void onConnect();
 
    void onDisconnect();
 
  private:
    OutPortConsumer* m_consumer;
 
    ConnectorListenersBase* m_listeners;
    ByteData m_data;
  };
} // namespace RTC
 
#endif  // RTC_PULL_CONNECTOR_H