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