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();
    
    inline void onBufferRead(cdrMemoryStream& data)
    {
      m_listeners.
        connectorData_[ON_BUFFER_READ].notify(m_profile, data);

    }
    void onBufferEmpty(cdrMemoryStream& data)
    {
      m_listeners.
        connector_[ON_BUFFER_EMPTY].notify(m_profile);

    }
    void onBufferReadTimeout(cdrMemoryStream& data)
    {
      m_listeners.
        connector_[ON_BUFFER_READ_TIMEOUT].notify(m_profile);
    }

  private:
    InPortProvider* m_provider;

    ConnectorListeners& m_listeners;

    bool m_deleteBuffer;
  };
}; // namespace RTC

#endif  // RTC_PUSH_CONNECTOR_H