TAO_FlowConnection Class Reference

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

#include <AVStreams_i.h>

Inheritance diagram for TAO_FlowConnection:

Collaboration diagram for TAO_FlowConnection:

Public Member Functions
	TAO_FlowConnection ()
	default constructor.
virtual void	stop ()
	stop this flow.
virtual void	start ()
	start this flow.
virtual void	destroy ()
	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 ()
	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_MCastConfigIf *	mcastconfigif_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

FlowConsumer_Set

typedef ACE_Unbounded_Set<AVStreams::FlowConsumer_ptr> TAO_FlowConnection::FlowConsumer_Set

protected

FlowConsumer_SetItor

typedef ACE_Unbounded_Set_Iterator<AVStreams::FlowConsumer_ptr> TAO_FlowConnection::FlowConsumer_SetItor

protected

FlowProducer_Set

typedef ACE_Unbounded_Set<AVStreams::FlowProducer_ptr> TAO_FlowConnection::FlowProducer_Set

protected

FlowProducer_SetItor

typedef ACE_Unbounded_Set_Iterator<AVStreams::FlowProducer_ptr> TAO_FlowConnection::FlowProducer_SetItor

protected

Constructor & Destructor Documentation

TAO_FlowConnection()

TAO_FlowConnection::TAO_FlowConnection

(

)

default constructor.

Member Function Documentation

add_consumer()

CORBA::Boolean TAO_FlowConnection::add_consumer ( AVStreams::FlowConsumer_ptr flow_consumer, AVStreams::QoS & the_qos )

virtual

adds a consumer to this flow connection.

add_producer()

CORBA::Boolean TAO_FlowConnection::add_producer ( AVStreams::FlowProducer_ptr flow_producer, AVStreams::QoS & the_qos )

virtual

adds the producer to this flow connection.

connect()

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.

connect_devs()

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.

destroy()

void TAO_FlowConnection::destroy ( )

virtual

destroy this flow.

disconnect()

CORBA::Boolean TAO_FlowConnection::disconnect ( )

virtual

disconnect this flow connection.

drop()

CORBA::Boolean TAO_FlowConnection::drop ( AVStreams::FlowEndPoint_ptr target )

virtual

drops a flow endpoint from the flow.

modify_QoS()

CORBA::Boolean TAO_FlowConnection::modify_QoS ( AVStreams::QoS & new_qos )

virtual

modify the QoS for this flow.

push_event()

void TAO_FlowConnection::push_event ( const AVStreams::streamEvent & the_event )

virtual

pushes an event , to be handled by the application.

set_mcast_addr()

int TAO_FlowConnection::set_mcast_addr	(	ACE_CString	addr,
		u_short	port )

set_protocol()

void TAO_FlowConnection::set_protocol

(

const char *

protocol

)

start()

void TAO_FlowConnection::start ( )

virtual

start this flow.

stop()

void TAO_FlowConnection::stop ( )

virtual

stop this flow.

use_flow_protocol()

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

flow_consumer_set_

FlowConsumer_Set TAO_FlowConnection::flow_consumer_set_

protected

flow_producer_set_

FlowProducer_Set TAO_FlowConnection::flow_producer_set_

protected

The multicast address returned by the producer.

fp_name_

CORBA::String_var TAO_FlowConnection::fp_name_

protected

fp_settings_

CORBA::Any TAO_FlowConnection::fp_settings_

protected

ip_multicast_

int TAO_FlowConnection::ip_multicast_

protected

IP Multicasting is used.

mcast_addr_

ACE_CString TAO_FlowConnection::mcast_addr_

protected

mcast_port_

u_short TAO_FlowConnection::mcast_port_

protected

mcastconfigif_

AVStreams::MCastConfigIf_var TAO_FlowConnection::mcastconfigif_

protected

mcastconfigif_i_

TAO_MCastConfigIf* TAO_FlowConnection::mcastconfigif_i_

protected

producer_address_

CORBA::String_var TAO_FlowConnection::producer_address_

protected

protocol_

CORBA::String_var TAO_FlowConnection::protocol_

protected

---

The documentation for this class was generated from the following files:

• AVStreams_i.h
• AVStreams_i.cpp