39 #ifndef ORO_CONN_OUTPUT_ENDPOINT_HPP 40 #define ORO_CONN_OUTPUT_ENDPOINT_HPP 65 typedef boost::intrusive_ptr<ConnOutputEndpoint<T> >
shared_ptr;
97 if ( channel->inputReady(
this) ) {
138 if (port && channel && forward)
140 port->
getManager()->removeConnection(channel.get(),
false);
160 #ifdef ORO_SIGNALLING_PORTS 161 if (port && port->new_data_on_port_event)
162 (*port->new_data_on_port_event)(port);
195 return std::string(
"ConnOutputEndpoint");
boost::intrusive_ptr< ChannelElement< T > > shared_ptr
virtual base::ChannelElement< T >::shared_ptr getSharedBuffer()
std::string getElementName() const
base::MultipleInputsChannelElement< T > Base
base::ChannelElement< T >::shared_ptr getReadEndpoint()
virtual base::PortInterface * getPort() const
virtual internal::ConnectionManager * getManager()
virtual base::ChannelElementBase::shared_ptr getOutputEndPoint()
ConnOutputEndpoint(InputPort< T > *port)
boost::intrusive_ptr< ChannelElementBase > shared_ptr
bool channelReady(base::ChannelElementBase::shared_ptr const &channel, ConnPolicy const &policy, ConnID *conn_id)
virtual bool disconnect(const base::ChannelElementBase::shared_ptr &channel, bool forward)
boost::intrusive_ptr< ConnOutputEndpoint< T > > shared_ptr
virtual WriteStatus write(param_t sample)
Contains TaskContext, Activity, OperationCaller, Operation, Property, InputPort, OutputPort, Attribute.
virtual WriteStatus write(typename Base::param_t sample)