InPortPushConnector.h

Go to the documentation of this file.

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

#include <rtm/InPortConnector.h>
#include <rtm/InPortConsumer.h>
#include <rtm/PublisherBase.h>

namespace RTC
{
  class InPortProvider;

  class InPortPushConnector
    : public InPortConnector
  {
  public:
    DATAPORTSTATUS_ENUM

    InPortPushConnector(ConnectorInfo info,
                        InPortProvider* provider,
                        ConnectorListeners& listeners,
                        CdrBufferBase* buffer = 0);

    virtual ~InPortPushConnector();

    virtual ReturnCode read(cdrMemoryStream& data);

    virtual ReturnCode disconnect();

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

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

  protected:
    virtual CdrBufferBase* createBuffer(ConnectorInfo& info);

    void onConnect();

    void onDisconnect();

  private:
    InPortProvider* m_provider;

    ConnectorListeners& m_listeners;

    bool m_deleteBuffer;
  };
}; // namespace RTC

#endif  // RTC_PUSH_CONNECTOR_H