Public Methods |
| | TAO_FlowConnection (void) |
| | default constructor. More...
|
| virtual void | stop (ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS) throw (CORBA::SystemException) |
| | stop this flow. More...
|
| virtual void | start (ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS) throw (CORBA::SystemException) |
| | start this flow. More...
|
| virtual void | destroy (ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS) throw (CORBA::SystemException) |
| | destroy this flow. More...
|
| 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. More...
|
| 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. More...
|
| 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. More...
|
| 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. More...
|
| 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. More...
|
| virtual CORBA::Boolean | disconnect (ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS) throw (CORBA::SystemException) |
| | disconnect this flow connection. More...
|
| 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. More...
|
| 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. More...
|
| 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. More...
|
| 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. More...
|
| 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. More...
|
| TAO_MCastConfigIf * | mcastconfigif_i_ |
| AVStreams::MCastConfigIf_var | mcastconfigif_ |
| u_short | mcast_port_ |
| ACE_CString | mcast_addr_ |
| CORBA::String_var | protocol_ |