conn_output_endpoint.hpp

Go to the documentation of this file.

#ifndef ROSRTT_CONN_OUTPUT_ENDPOINT_HPP
#define ROSRTT_CONN_OUTPUT_ENDPOINT_HPP

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

namespace hpcl_rtt
{
template<typename T>
class ConnOutputEndpoint : public ChannelElement<T>
{
  ConnectionBasePtr port;
public:
  ConnOutputEndpoint(ConnectionBasePtr port)
        : port(port)
  {
    // cid is deleted/owned by the port's ConnectionManager.
  }

  ~ConnOutputEndpoint()
  {
  }

  bool inputReady()
  {
    // cid is deleted/owned by the ConnectionManager.
    port->addConnection(this);
    return ChannelElement<T>::inputReady();
  }

  using ChannelElement<T>::write;

  virtual bool write(typename ChannelElement<T>::param_t sample)
  { return false; }

  virtual void disconnect(bool forward)
  {
//    // Call the base class: it does the common cleanup
//    base::ChannelElement<T>::disconnect(forward);
//
//    InputPort<T>* port = this->port;
//    if (port && forward)
//    {
//      this->port = 0;
//      port->removeConnection(cid);
//    }
  }

  virtual bool signal()
  {
//    InputPort<T>* port = this->port;
//#ifdef ORO_SIGNALLING_PORTS
//    if (port && port->new_data_on_port_event)
//      (*port->new_data_on_port_event)(port);
//#else
//    if (port )
//      port->signal();
//#endif
    return true;
  }

  virtual bool data_sample(typename ChannelElement<T>::param_t sample)
  {
    return true;
  }

};

}

#endif