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

    InPortPullConnector(ConnectorInfo info,
                        OutPortConsumer* consumer,
                        ConnectorListeners& listeners,
                        CdrBufferBase* buffer = 0);

    virtual ~InPortPullConnector();

    virtual ReturnCode read(cdrMemoryStream& data);

    virtual ReturnCode disconnect();

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

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

  protected:
    CdrBufferBase* createBuffer(ConnectorInfo& info);

    void onConnect();

    void onDisconnect();
    
  private:
    OutPortConsumer* m_consumer;
    
    ConnectorListeners& m_listeners;
  };
}; // namespace RTC

#endif  // RTC_PULL_CONNECTOR_H