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