#include <AVStreams_i.h>
Inheritance diagram for TAO_FlowConsumer:
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) |
|
default constructor.
Definition at line 4370 of file AVStreams_i.cpp.
04371 { 04372 } |
|
Definition at line 4374 of file AVStreams_i.cpp. References TAO_FlowEndPoint::open(), and AVStreams::protocolSpec.
04377 { 04378 this->open (flowname, protocols, format); 04379 } |
|
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 4416 of file AVStreams_i.cpp. References TAO_FlowEndPoint::connect_to_peer_i().
04419 { 04420 return this->connect_to_peer_i (TAO_FlowSpec_Entry::TAO_AV_CONSUMER, 04421 the_qos, 04422 address, 04423 use_flow_protocol); 04424 } |
|
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 4403 of file AVStreams_i.cpp. References TAO_FlowEndPoint::go_to_listen_i().
04407 { 04408 return this->go_to_listen_i (TAO_FlowSpec_Entry::TAO_AV_CONSUMER, 04409 the_qos, 04410 is_mcast, 04411 peer_fep, 04412 flowProtocol); 04413 } |
|
start this flow, to be overridden by the application.
Definition at line 4392 of file AVStreams_i.cpp. References ACE_Unbounded_Set< T >::begin(), ACE_Unbounded_Set< T >::end(), and TAO_AV_FlowSpecSetItor.
04393 { 04394 TAO_AV_FlowSpecSetItor end = this->flow_spec_set_.end (); 04395 for (TAO_AV_FlowSpecSetItor begin = this->flow_spec_set_.begin (); 04396 begin != end; ++begin) 04397 { 04398 (*begin)->handler ()->start (TAO_FlowSpec_Entry::TAO_AV_CONSUMER); 04399 } 04400 } |
|
stop this flow, to be overridden by the application.
Definition at line 4383 of file AVStreams_i.cpp. References ACE_Unbounded_Set< T >::begin(), ACE_Unbounded_Set< T >::end(), and TAO_AV_FlowSpecSetItor.
04384 { 04385 TAO_AV_FlowSpecSetItor end = this->flow_spec_set_.end (); 04386 for (TAO_AV_FlowSpecSetItor begin = this->flow_spec_set_.begin (); 04387 begin != end; ++begin) 04388 (*begin)->handler ()->stop (TAO_FlowSpec_Entry::TAO_AV_CONSUMER); 04389 } |