OutPortPushConnector.h

Go to the documentation of this file.

// -*- C++ -*-
 
#ifndef RTC_OUTPORTPUSHCONNECTOR_H
#define RTC_OUTPORTPUSHCONNECTOR_H
 
#include <rtm/OutPortConnector.h>
#include <rtm/InPortConsumer.h>
#include <rtm/PublisherBase.h>
 
namespace RTC
{
  class ConnectorListeners;

  class OutPortPushConnector
    : public OutPortConnector
  {
  public:

    OutPortPushConnector(ConnectorInfo info,
                         InPortConsumer* consumer,
                         ConnectorListenersBase* listeners,
                         CdrBufferBase* buffer = nullptr);

    ~OutPortPushConnector() override;

    DataPortStatus write(RTC::ByteDataStreamBase* data) override;

    DataPortStatus disconnect() override;

    void activate() override;

    void deactivate() override;

    CdrBufferBase* getBuffer() override;

    void unsubscribeInterface(const coil::Properties& prop) override;
 
  protected:
    virtual PublisherBase* createPublisher(ConnectorInfo& info);

    virtual CdrBufferBase* createBuffer(ConnectorInfo& info);

    void onConnect();

    void onDisconnect();
 
  private:
    InPortConsumer* m_consumer;

    PublisherBase* m_publisher;

    ConnectorListenersBase* m_listeners;

    CdrBufferBase* m_buffer;
 
  };
} // namespace RTC
 
#endif  // RTC_PUSH_CONNECTOR_H