OutPortPullConnector.h

Go to the documentation of this file.

// -*- C++ -*-
#ifndef RTC_OUTPORTPULLCONNECTOR_H
#define RTC_OUTPORTPULLCONNECTOR_H

#include <rtm/OutPortConnector.h>
#include <rtm/ConnectorListener.h>

namespace RTC
{
  class OutPortProvider;

  class OutPortPullConnector
    : public OutPortConnector
  {
  public:
    DATAPORTSTATUS_ENUM

    OutPortPullConnector(ConnectorInfo info,
                         OutPortProvider* provider,
                         ConnectorListeners& listeners,
                         CdrBufferBase* buffer = 0);

    virtual ~OutPortPullConnector();

    virtual ReturnCode write(const cdrMemoryStream& data);

    virtual ReturnCode disconnect();

    virtual CdrBufferBase* getBuffer();

    virtual void activate(){}; // do nothing

    virtual void deactivate(){}; // do nothing

    CdrBufferBase* createBuffer(ConnectorInfo& info);

    void onConnect();

    void onDisconnect();

  protected:

    OutPortProvider* m_provider;

    ConnectorListeners& m_listeners;

    CdrBufferBase* m_buffer;
  };
}; // namespace RTC

#endif  // RTC_PULL_CONNECTOR_H