#include <AVStreams_i.h>
Public Member Functions | |
TAO_FlowConsumer (void) | |
default constructor. | |
TAO_FlowConsumer (const char *flowname, AVStreams::protocolSpec protocols, const char *format) | |
virtual void | stop (void) |
stop this flow, to be overridden by the application. | |
virtual void | start (void) |
start this flow, to be overridden by the application. | |
virtual char * | go_to_listen (AVStreams::QoS &the_qos, CORBA::Boolean is_mcast, AVStreams::FlowEndPoint_ptr peer, char *&flowProtocol) |
virtual CORBA::Boolean | connect_to_peer (AVStreams::QoS &the_qos, const char *address, const char *use_flow_protocol) |
Definition at line 1085 of file AVStreams_i.h.
TAO_FlowConsumer::TAO_FlowConsumer | ( | void | ) |
TAO_FlowConsumer::TAO_FlowConsumer | ( | const char * | flowname, | |
AVStreams::protocolSpec | protocols, | |||
const char * | format | |||
) |
Definition at line 4423 of file AVStreams_i.cpp.
{ this->open (flowname, protocols, format); }
CORBA::Boolean TAO_FlowConsumer::connect_to_peer | ( | AVStreams::QoS & | the_qos, | |
const char * | address, | |||
const char * | use_flow_protocol | |||
) | [virtual] |
This should be implemented in both the FlowProducer and consumer and hence is pure virtual since we need to know the role of the flowendpoint to create appropriate protocol objects. eg. in SFP to create Producer Object/ Consumer Object.
Implements TAO_FlowEndPoint.
Definition at line 4465 of file AVStreams_i.cpp.
{ return this->connect_to_peer_i (TAO_FlowSpec_Entry::TAO_AV_CONSUMER, the_qos, address, use_flow_protocol); }
char * TAO_FlowConsumer::go_to_listen | ( | AVStreams::QoS & | the_qos, | |
CORBA::Boolean | is_mcast, | |||
AVStreams::FlowEndPoint_ptr | peer, | |||
char *& | flowProtocol | |||
) | [virtual] |
This should be implemented in both the FlowProducer and consumer and hence is pure virtual since we need to know the role of the flowendpoint to create appropriate protocol objects. eg. in SFP to create Producer Object/ Consumer Object.
Implements TAO_FlowEndPoint.
Definition at line 4452 of file AVStreams_i.cpp.
{ return this->go_to_listen_i (TAO_FlowSpec_Entry::TAO_AV_CONSUMER, the_qos, is_mcast, peer_fep, flowProtocol); }
void TAO_FlowConsumer::start | ( | void | ) | [virtual] |
start this flow, to be overridden by the application.
Definition at line 4441 of file AVStreams_i.cpp.
{ TAO_AV_FlowSpecSetItor end = this->flow_spec_set_.end (); for (TAO_AV_FlowSpecSetItor begin = this->flow_spec_set_.begin (); begin != end; ++begin) { (*begin)->handler ()->start (TAO_FlowSpec_Entry::TAO_AV_CONSUMER); } }
void TAO_FlowConsumer::stop | ( | void | ) | [virtual] |
stop this flow, to be overridden by the application.
Definition at line 4432 of file AVStreams_i.cpp.
{ TAO_AV_FlowSpecSetItor end = this->flow_spec_set_.end (); for (TAO_AV_FlowSpecSetItor begin = this->flow_spec_set_.begin (); begin != end; ++begin) (*begin)->handler ()->stop (TAO_FlowSpec_Entry::TAO_AV_CONSUMER); }