conn_input_endpoint.hpp

Go to the documentation of this file.

#ifndef ROSRTT_CONN_INPUT_ENDPOINT_HPP
#define ROSRTT_CONN_INPUT_ENDPOINT_HPP

#include "channel_data_element.hpp"
#include "../connection_base.h"

namespace hpcl_rtt
{
template<typename T>
class ConnInputEndpoint : public ChannelElement<T>
{
  ConnectionBasePtr port;

public:
  ConnInputEndpoint(ConnectionBasePtr port) : port(port) { }

  ~ConnInputEndpoint()
  {
    //this->disconnect(false); // inform port (if any) we're gone.
  }

  using ChannelElement<T>::read;

  virtual FlowStatus read(typename ChannelElement<T>::reference_t sample)
  { return NoData; }

  virtual bool inputReady() 
  {
    return true;
  }

  virtual void disconnect(bool forward)
  {
      // Call the base class first
//      base::ChannelElement<T>::disconnect(forward);
//
//      Publication<T>* port = this->port;
//      if (port && !forward)
//      {
//        this->port   = 0;
//        port->removeConnection();
//      }
  }
};

}

#endif