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:

[legend]Collaboration diagram for TAO_FlowConnection:

[legend]List of all members.


Public Member Functions
	TAO_FlowConnection (void)
	default constructor.
virtual void	stop (ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS) throw (CORBA::SystemException)
	stop this flow.
virtual void	start (ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS) throw (CORBA::SystemException)
	start this flow.
virtual void	destroy (ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS) throw (CORBA::SystemException)
	destroy this flow.
virtual CORBA::Boolean	modify_QoS (AVStreams::QoS &new_qos ACE_ENV_ARG_DECL_WITH_DEFAULTS) throw (CORBA::SystemException, AVStreams::QoSRequestFailed)
	modify the QoS for this flow.
virtual CORBA::Boolean	use_flow_protocol (const char *fp_name, const CORBA::Any &fp_settings ACE_ENV_ARG_DECL_WITH_DEFAULTS) throw (CORBA::SystemException, AVStreams::FPError, AVStreams::notSupported)
	use the specified flow protocol for this flow.
virtual void	push_event (const AVStreams::streamEvent &the_event ACE_ENV_ARG_DECL_WITH_DEFAULTS) throw (CORBA::SystemException)
	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 ACE_ENV_ARG_DECL_WITH_DEFAULTS) throw (CORBA::SystemException, AVStreams::streamOpFailed, AVStreams::streamOpDenied, AVStreams::QoSRequestFailed)
	connect 2 Flow Devices.
virtual CORBA::Boolean	connect (AVStreams::FlowProducer_ptr flow_producer, AVStreams::FlowConsumer_ptr flow_consumer, AVStreams::QoS &the_qos ACE_ENV_ARG_DECL_WITH_DEFAULTS) throw (CORBA::SystemException, AVStreams::formatMismatch, AVStreams::FEPMismatch, AVStreams::alreadyConnected)
	Connect a flow producer and consumer under this flow connection.
virtual CORBA::Boolean	disconnect (ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS) throw (CORBA::SystemException)
	disconnect this flow connection.
virtual CORBA::Boolean	add_producer (AVStreams::FlowProducer_ptr flow_producer, AVStreams::QoS &the_qos ACE_ENV_ARG_DECL_WITH_DEFAULTS) throw (CORBA::SystemException, AVStreams::alreadyConnected, AVStreams::notSupported)
	adds the producer to this flow connection.
virtual CORBA::Boolean	add_consumer (AVStreams::FlowConsumer_ptr flow_consumer, AVStreams::QoS &the_qos ACE_ENV_ARG_DECL_WITH_DEFAULTS) throw (CORBA::SystemException, AVStreams::alreadyConnected)
	adds a consumer to this flow connection.
virtual CORBA::Boolean	drop (AVStreams::FlowEndPoint_ptr target ACE_ENV_ARG_DECL_WITH_DEFAULTS) throw (CORBA::SystemException, AVStreams::notConnected)
	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

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 ACE_ENV_ARG_DECL_WITH_DEFAULTS

) throw (CORBA::SystemException, AVStreams::alreadyConnected) [virtual]

adds a consumer to this flow connection.

CORBA::Boolean TAO_FlowConnection::add_producer ( AVStreams::FlowProducer_ptr flow_producer,

AVStreams::QoS &the_qos ACE_ENV_ARG_DECL_WITH_DEFAULTS

) throw (CORBA::SystemException, AVStreams::alreadyConnected, AVStreams::notSupported) [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 ACE_ENV_ARG_DECL_WITH_DEFAULTS

) throw (CORBA::SystemException, AVStreams::formatMismatch, AVStreams::FEPMismatch, AVStreams::alreadyConnected) [virtual]

Connect a flow producer and consumer under this flow connection.

virtual CORBA::Boolean TAO_FlowConnection::connect_devs ( AVStreams::FDev_ptr a_party,

AVStreams::FDev_ptr b_party,

AVStreams::QoS &the_qos ACE_ENV_ARG_DECL_WITH_DEFAULTS

) throw (CORBA::SystemException, AVStreams::streamOpFailed, AVStreams::streamOpDenied, AVStreams::QoSRequestFailed) [virtual]

connect 2 Flow Devices.

void TAO_FlowConnection::destroy ( ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS ) throw (CORBA::SystemException) [virtual]

destroy this flow.

virtual CORBA::Boolean TAO_FlowConnection::disconnect ( ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS ) throw (CORBA::SystemException) [virtual]

disconnect this flow connection.

CORBA::Boolean TAO_FlowConnection::drop ( AVStreams::FlowEndPoint_ptr target ACE_ENV_ARG_DECL_WITH_DEFAULTS ) throw (CORBA::SystemException, AVStreams::notConnected) [virtual]

drops a flow endpoint from the flow.

CORBA::Boolean TAO_FlowConnection::modify_QoS ( AVStreams::QoS &new_qos ACE_ENV_ARG_DECL_WITH_DEFAULTS ) throw (CORBA::SystemException, AVStreams::QoSRequestFailed) [virtual]

modify the QoS for this flow.

void TAO_FlowConnection::push_event ( const AVStreams::streamEvent &the_event ACE_ENV_ARG_DECL_WITH_DEFAULTS ) throw (CORBA::SystemException) [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 ( ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS ) throw (CORBA::SystemException) [virtual]

start this flow.

void TAO_FlowConnection::stop ( ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS ) throw (CORBA::SystemException) [virtual]

stop this flow.

CORBA::Boolean TAO_FlowConnection::use_flow_protocol ( const char * fp_name,

const CORBA::Any &fp_settings ACE_ENV_ARG_DECL_WITH_DEFAULTS

) throw (CORBA::SystemException, AVStreams::FPError, AVStreams::notSupported) [virtual]

use the specified flow protocol for this flow.