TAO_FlowConsumer Class Reference

#include <AVStreams_i.h>

Inheritance diagram for TAO_FlowConsumer:

Inheritance graph
[legend]
Collaboration diagram for TAO_FlowConsumer:

Collaboration graph
[legend]
List of all members.

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)

Constructor & Destructor Documentation

TAO_FlowConsumer::TAO_FlowConsumer void   ) 
 

default constructor.

Definition at line 4370 of file AVStreams_i.cpp.

04371 {
04372 }

TAO_FlowConsumer::TAO_FlowConsumer const char *  flowname,
AVStreams::protocolSpec  protocols,
const char *  format
 

Definition at line 4374 of file AVStreams_i.cpp.

References TAO_FlowEndPoint::open(), and AVStreams::protocolSpec.

04377 {
04378   this->open (flowname, protocols, format);
04379 }


Member Function Documentation

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 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 }

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 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 }

void TAO_FlowConsumer::start void   )  [virtual]
 

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 }

void TAO_FlowConsumer::stop void   )  [virtual]
 

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 }


The documentation for this class was generated from the following files:
Generated on Sun Jan 27 16:07:48 2008 for TAO_AV by doxygen 1.3.6