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:
    DATAPORTSTATUS_ENUM

    OutPortPushConnector(ConnectorInfo info,
                         InPortConsumer* consumer,
                         ConnectorListeners& listeners,
                         CdrBufferBase* buffer = 0);

    virtual ~OutPortPushConnector();

    virtual ReturnCode write(const cdrMemoryStream& data);

    virtual ReturnCode disconnect();

    virtual void activate();

    virtual void deactivate();

    virtual CdrBufferBase* getBuffer();

  protected:
    virtual PublisherBase* createPublisher(ConnectorInfo& info);

    virtual CdrBufferBase* createBuffer(ConnectorInfo& info);

    void onConnect();

    void onDisconnect();

  private:
    InPortConsumer* m_consumer;

    PublisherBase* m_publisher;

    ConnectorListeners& m_listeners;

    CdrBufferBase* m_buffer;

  };
}; // namespace RTC

#endif  // RTC_PUSH_CONNECTOR_H