Main Page | Namespace List | Class Hierarchy | Alphabetical List | Class List | File List | Namespace Members | Class Members | File Members | Search for 

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 (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.

Definition at line 1040 of file AVStreams_i.h.

Member Typedef Documentation

typedef ACE_Unbounded_Set<AVStreams::FlowConsumer_ptr> TAO_FlowConnection::FlowConsumer_Set [protected]
 

Definition at line 1131 of file AVStreams_i.h.

typedef ACE_Unbounded_Set_Iterator<AVStreams::FlowConsumer_ptr> TAO_FlowConnection::FlowConsumer_SetItor [protected]
 

Definition at line 1132 of file AVStreams_i.h.

typedef ACE_Unbounded_Set<AVStreams::FlowProducer_ptr> TAO_FlowConnection::FlowProducer_Set [protected]
 

Definition at line 1129 of file AVStreams_i.h.

typedef ACE_Unbounded_Set_Iterator<AVStreams::FlowProducer_ptr> TAO_FlowConnection::FlowProducer_SetItor [protected]
 

Definition at line 1130 of file AVStreams_i.h.

Constructor & Destructor Documentation

TAO_FlowConnection::TAO_FlowConnection (  void   ) 
 

default constructor.

Definition at line 3881 of file AVStreams_i.cpp. 

03882   :fp_name_ (CORBA::string_dup ("")),
03883    ip_multicast_ (0)
03884 {
03885 }

Member Function Documentation

virtual 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.

virtual 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.

virtual 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.

virtual 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.

Definition at line 4410 of file AVStreams_i.cpp. 

04414 {
04415   ACE_UNUSED_ARG (target);
04416   return 0;
04417 }

virtual 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.

virtual 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
) 
 

Definition at line 3896 of file AVStreams_i.cpp. 

03897 {
03898   this->mcast_addr_ = mcast_addr;
03899   this->mcast_port_ = mcast_port;
03900   return 0;
03901 }

void TAO_FlowConnection::set_protocol (  const char *  protocol  ) 
 

Definition at line 3904 of file AVStreams_i.cpp. 

03905 {
03906   this->protocol_ = protocol;
03907 }

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

start this flow.

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

stop this flow.

virtual 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.

Member Data Documentation

FlowConsumer_Set TAO_FlowConnection::flow_consumer_set_ [protected]
 

Definition at line 1136 of file AVStreams_i.h.

FlowProducer_Set TAO_FlowConnection::flow_producer_set_ [protected]
 

The multicast address returned by the producer.

Definition at line 1135 of file AVStreams_i.h.

CORBA::String_var TAO_FlowConnection::fp_name_ [protected]
 

Definition at line 1137 of file AVStreams_i.h.

CORBA::Any TAO_FlowConnection::fp_settings_ [protected]
 

Definition at line 1138 of file AVStreams_i.h.

int TAO_FlowConnection::ip_multicast_ [protected]
 

IP Multicasting is used.

Definition at line 1142 of file AVStreams_i.h.

ACE_CString TAO_FlowConnection::mcast_addr_ [protected]
 

Definition at line 1146 of file AVStreams_i.h.

u_short TAO_FlowConnection::mcast_port_ [protected]
 

Definition at line 1145 of file AVStreams_i.h.

AVStreams::MCastConfigIf_var TAO_FlowConnection::mcastconfigif_ [protected]
 

Definition at line 1144 of file AVStreams_i.h.

TAO_MCastConfigIf* TAO_FlowConnection::mcastconfigif_i_ [protected]
 

Definition at line 1143 of file AVStreams_i.h.

CORBA::String_var TAO_FlowConnection::producer_address_ [protected]
 

Definition at line 1139 of file AVStreams_i.h.

CORBA::String_var TAO_FlowConnection::protocol_ [protected]
 

Definition at line 1147 of file AVStreams_i.h.

The documentation for this class was generated from the following files:
Generated on Thu Nov 9 13:48:29 2006 for TAO_AV by doxygen 1.3.6