TAO_AV  2.0.8
Public Member Functions | Protected Types | Protected Attributes
TAO_FlowConnection Class Reference

This class currently supports only one producer and one consumer per flow. More...

#include <AVStreams_i.h>

Collaboration diagram for TAO_FlowConnection:
Collaboration graph
[legend]

List of all members.

Public Member Functions

 TAO_FlowConnection (void)
 default constructor.
virtual void stop (void)
 stop this flow.
virtual void start (void)
 start this flow.
virtual void destroy (void)
 destroy this flow.
virtual CORBA::Boolean modify_QoS (AVStreams::QoS &new_qos)
 modify the QoS for this flow.
virtual CORBA::Boolean use_flow_protocol (const char *fp_name, const CORBA::Any &fp_settings)
 use the specified flow protocol for this flow.
virtual void push_event (const AVStreams::streamEvent &the_event)
 pushes an event , to be handled by the application.
virtual CORBA::Boolean connect_devs (AVStreams::FDev_ptr a_party, AVStreams::FDev_ptr b_party, AVStreams::QoS &the_qos)
 connect 2 Flow Devices.
virtual CORBA::Boolean connect (AVStreams::FlowProducer_ptr flow_producer, AVStreams::FlowConsumer_ptr flow_consumer, AVStreams::QoS &the_qos)
 Connect a flow producer and consumer under this flow connection.
virtual CORBA::Boolean disconnect (void)
 disconnect this flow connection.
virtual CORBA::Boolean add_producer (AVStreams::FlowProducer_ptr flow_producer, AVStreams::QoS &the_qos)
 adds the producer to this flow connection.
virtual CORBA::Boolean add_consumer (AVStreams::FlowConsumer_ptr flow_consumer, AVStreams::QoS &the_qos)
 adds a consumer to this flow connection.
virtual CORBA::Boolean drop (AVStreams::FlowEndPoint_ptr target)
 drops a flow endpoint from the flow.
int set_mcast_addr (ACE_CString addr, u_short port)
void set_protocol (const char *protocol)

Protected Types

typedef ACE_Unbounded_Set
< AVStreams::FlowProducer_ptr > 
FlowProducer_Set
typedef
ACE_Unbounded_Set_Iterator
< AVStreams::FlowProducer_ptr > 
FlowProducer_SetItor
typedef ACE_Unbounded_Set
< AVStreams::FlowConsumer_ptr > 
FlowConsumer_Set
typedef
ACE_Unbounded_Set_Iterator
< AVStreams::FlowConsumer_ptr > 
FlowConsumer_SetItor

Protected Attributes

FlowProducer_Set flow_producer_set_
 The multicast address returned by the producer.
FlowConsumer_Set flow_consumer_set_
CORBA::String_var fp_name_
CORBA::Any fp_settings_
CORBA::String_var producer_address_
int ip_multicast_
 IP Multicasting is used.
TAO_MCastConfigIfmcastconfigif_i_
AVStreams::MCastConfigIf_var mcastconfigif_
u_short mcast_port_
ACE_CString mcast_addr_
CORBA::String_var protocol_

Detailed Description

This class currently supports only one producer and one consumer per flow.


Member Typedef Documentation

typedef ACE_Unbounded_Set<AVStreams::FlowConsumer_ptr> TAO_FlowConnection::FlowConsumer_Set [protected]
typedef ACE_Unbounded_Set_Iterator<AVStreams::FlowConsumer_ptr> TAO_FlowConnection::FlowConsumer_SetItor [protected]
typedef ACE_Unbounded_Set<AVStreams::FlowProducer_ptr> TAO_FlowConnection::FlowProducer_Set [protected]
typedef ACE_Unbounded_Set_Iterator<AVStreams::FlowProducer_ptr> TAO_FlowConnection::FlowProducer_SetItor [protected]

Constructor & Destructor Documentation

TAO_FlowConnection::TAO_FlowConnection ( void  )

default constructor.


Member Function Documentation

CORBA::Boolean TAO_FlowConnection::add_consumer ( AVStreams::FlowConsumer_ptr  flow_consumer,
AVStreams::QoS the_qos 
) [virtual]

adds a consumer to this flow connection.

CORBA::Boolean TAO_FlowConnection::add_producer ( AVStreams::FlowProducer_ptr  flow_producer,
AVStreams::QoS the_qos 
) [virtual]

adds the producer to this flow connection.

CORBA::Boolean TAO_FlowConnection::connect ( AVStreams::FlowProducer_ptr  flow_producer,
AVStreams::FlowConsumer_ptr  flow_consumer,
AVStreams::QoS the_qos 
) [virtual]

Connect a flow producer and consumer under this flow connection.

CORBA::Boolean TAO_FlowConnection::connect_devs ( AVStreams::FDev_ptr  a_party,
AVStreams::FDev_ptr  b_party,
AVStreams::QoS the_qos 
) [virtual]

connect 2 Flow Devices.

void TAO_FlowConnection::destroy ( void  ) [virtual]

destroy this flow.

CORBA::Boolean TAO_FlowConnection::disconnect ( void  ) [virtual]

disconnect this flow connection.

CORBA::Boolean TAO_FlowConnection::drop ( AVStreams::FlowEndPoint_ptr  target) [virtual]

drops a flow endpoint from the flow.

CORBA::Boolean TAO_FlowConnection::modify_QoS ( AVStreams::QoS new_qos) [virtual]

modify the QoS for this flow.

void TAO_FlowConnection::push_event ( const AVStreams::streamEvent the_event) [virtual]

pushes an event , to be handled by the application.

int TAO_FlowConnection::set_mcast_addr ( ACE_CString  addr,
u_short  port 
)
void TAO_FlowConnection::set_protocol ( const char *  protocol)
void TAO_FlowConnection::start ( void  ) [virtual]

start this flow.

void TAO_FlowConnection::stop ( void  ) [virtual]

stop this flow.

CORBA::Boolean TAO_FlowConnection::use_flow_protocol ( const char *  fp_name,
const CORBA::Any &  fp_settings 
) [virtual]

use the specified flow protocol for this flow.


Member Data Documentation

The multicast address returned by the producer.

CORBA::Any TAO_FlowConnection::fp_settings_ [protected]

IP Multicasting is used.

u_short TAO_FlowConnection::mcast_port_ [protected]
AVStreams::MCastConfigIf_var TAO_FlowConnection::mcastconfigif_ [protected]

The documentation for this class was generated from the following files:
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Defines