TAO_AV 4.0.1
Loading...
Searching...
No Matches
Public Types | Public Member Functions | Static Public Member Functions | Protected Attributes | List of all members
TAO_AV_Core Class Reference

This class encapsulates access to the TAO AV Core's resources and its state. More...

#include <AV_Core.h>

Collaboration diagram for TAO_AV_Core:
Collaboration graph
[legend]

Public Types

enum  EndPoint { TAO_AV_ENDPOINT_A , TAO_AV_ENDPOINT_B }
 
enum  Protocol {
  TAO_AV_NOPROTOCOL = -1 , TAO_AV_TCP = 0 , TAO_AV_UDP = 1 , TAO_AV_AAL5 = 2 ,
  TAO_AV_AAL3_4 = 3 , TAO_AV_AAL1 = 4 , TAO_AV_RTP_UDP = 5 , TAO_AV_RTP_AAL5 = 6 ,
  TAO_AV_IPX = 7 , TAO_AV_SFP_UDP = 8 , TAO_AV_UDP_MCAST = 9 , TAO_AV_RTP_UDP_MCAST = 10 ,
  TAO_AV_SFP_UDP_MCAST = 11 , TAO_AV_QOS_UDP = 12 , TAO_AV_USERDEFINED_UDP = 13 , TAO_AV_USERDEFINED_UDP_MCAST = 14 ,
  TAO_AV_SCTP_SEQ = 15
}
 
enum  Flow_Component { TAO_AV_DATA = 1 , TAO_AV_CONTROL = 2 , TAO_AV_BOTH = 3 }
 

Public Member Functions

 TAO_AV_Core ()
 Default constructor.
 
 ~TAO_AV_Core ()
 Destructor.
 
int init (CORBA::ORB_ptr orb, PortableServer::POA_ptr poa)
 
int run ()
 
int stop_run ()
 
int init_forward_flows (TAO_Base_StreamEndPoint *endpoint, TAO_AV_FlowSpecSet &flow_spec_set, EndPoint direction, AVStreams::flowSpec &flow_spec)
 
int init_reverse_flows (TAO_Base_StreamEndPoint *endpoint, TAO_AV_FlowSpecSet &forward_flow_spec_set, TAO_AV_FlowSpecSet &reverse_flow_spec_set, EndPoint direction)
 
int init_transport_factories ()
 
int init_flow_protocol_factories ()
 
int load_default_transport_factories ()
 
int load_default_flow_protocol_factories ()
 
TAO_AV_Acceptorget_acceptor (const char *flowname)
 = Get the acceptor registry
 
TAO_AV_Connectorget_connector (const char *flowname)
 
int remove_acceptor (const char *flowname)
 
int remove_connector (const char *flowname)
 
TAO_AV_Connector_Registryconnector_registry ()
 
TAO_FlowSpec_Entryget_flow_spec_entry (TAO_AV_FlowSpecSet &flow_spec_set, const char *flowname)
 
TAO_AV_Acceptor_Registryacceptor_registry ()
 
TAO_AV_Flow_Protocol_Factoryget_flow_protocol_factory (const char *flow_protocol)
 = Set/get the <ACE_Reactor>.
 
TAO_AV_Transport_Factoryget_transport_factory (const char *transport_protocol)
 
TAO_AV_Flow_ProtocolFactorySetflow_protocol_factories ()
 
TAO_AV_TransportFactorySettransport_factories ()
 
void reactor (ACE_Reactor *r)
 
ACE_Reactorreactor ()
 
CORBA::ORB_ptr orb ()
 
void orb (CORBA::ORB_ptr orb_)
 
PortableServer::POA_ptr poa ()
 
void poa (PortableServer::POA_ptr poa_)
 

Static Public Member Functions

static int deactivate_servant (PortableServer::Servant servant)
 
static char * get_flowname (const char *flow_spec_entry_str)
 
static ACE_CString get_control_flowname (const char *flowname)
 

Protected Attributes

TAO_AV_Connector_Registryconnector_registry_
 
TAO_AV_Acceptor_Registryacceptor_registry_
 
TAO_AV_TransportFactorySet transport_factories_
 Pointer to the list of transports loaded into this AV_Core instance.
 
TAO_AV_Flow_ProtocolFactorySet flow_protocol_factories_
 Pointer to the list of flow protocol loaded into this AV_Core instance.
 
ACE_Reactorreactor_
 
CORBA::ORB_var orb_
 
PortableServer::POA_var poa_
 
CORBA::Boolean stop_run_
 

Detailed Description

This class encapsulates access to the TAO AV Core's resources and its state.

Member Enumeration Documentation

◆ EndPoint

Enumerator
TAO_AV_ENDPOINT_A 
TAO_AV_ENDPOINT_B 

◆ Flow_Component

Enumerator
TAO_AV_DATA 
TAO_AV_CONTROL 
TAO_AV_BOTH 

◆ Protocol

Enumerator
TAO_AV_NOPROTOCOL 
TAO_AV_TCP 
TAO_AV_UDP 
TAO_AV_AAL5 
TAO_AV_AAL3_4 
TAO_AV_AAL1 
TAO_AV_RTP_UDP 
TAO_AV_RTP_AAL5 
TAO_AV_IPX 
TAO_AV_SFP_UDP 
TAO_AV_UDP_MCAST 
TAO_AV_RTP_UDP_MCAST 
TAO_AV_SFP_UDP_MCAST 
TAO_AV_QOS_UDP 
TAO_AV_USERDEFINED_UDP 
TAO_AV_USERDEFINED_UDP_MCAST 
TAO_AV_SCTP_SEQ 

Constructor & Destructor Documentation

◆ TAO_AV_Core()

TAO_AV_Core::TAO_AV_Core ( )

Default constructor.

◆ ~TAO_AV_Core()

TAO_AV_Core::~TAO_AV_Core ( )

Destructor.

Member Function Documentation

◆ acceptor_registry()

TAO_AV_Acceptor_Registry * TAO_AV_Core::acceptor_registry ( )

◆ connector_registry()

TAO_AV_Connector_Registry * TAO_AV_Core::connector_registry ( )

◆ deactivate_servant()

int TAO_AV_Core::deactivate_servant ( PortableServer::Servant servant)
static

◆ flow_protocol_factories()

TAO_AV_Flow_ProtocolFactorySet * TAO_AV_Core::flow_protocol_factories ( )

◆ get_acceptor()

TAO_AV_Acceptor * TAO_AV_Core::get_acceptor ( const char * flowname)

= Get the acceptor registry

◆ get_connector()

TAO_AV_Connector * TAO_AV_Core::get_connector ( const char * flowname)

◆ get_control_flowname()

ACE_CString TAO_AV_Core::get_control_flowname ( const char * flowname)
static

◆ get_flow_protocol_factory()

TAO_AV_Flow_Protocol_Factory * TAO_AV_Core::get_flow_protocol_factory ( const char * flow_protocol)

= Set/get the <ACE_Reactor>.

◆ get_flow_spec_entry()

TAO_FlowSpec_Entry * TAO_AV_Core::get_flow_spec_entry ( TAO_AV_FlowSpecSet & flow_spec_set,
const char * flowname )

◆ get_flowname()

char * TAO_AV_Core::get_flowname ( const char * flow_spec_entry_str)
static

◆ get_transport_factory()

TAO_AV_Transport_Factory * TAO_AV_Core::get_transport_factory ( const char * transport_protocol)

◆ init()

int TAO_AV_Core::init ( CORBA::ORB_ptr orb,
PortableServer::POA_ptr poa )

◆ init_flow_protocol_factories()

int TAO_AV_Core::init_flow_protocol_factories ( )

◆ init_forward_flows()

int TAO_AV_Core::init_forward_flows ( TAO_Base_StreamEndPoint * endpoint,
TAO_AV_FlowSpecSet & flow_spec_set,
TAO_AV_Core::EndPoint direction,
AVStreams::flowSpec & flow_spec )

◆ init_reverse_flows()

int TAO_AV_Core::init_reverse_flows ( TAO_Base_StreamEndPoint * endpoint,
TAO_AV_FlowSpecSet & forward_flow_spec_set,
TAO_AV_FlowSpecSet & reverse_flow_spec_set,
TAO_AV_Core::EndPoint direction )

◆ init_transport_factories()

int TAO_AV_Core::init_transport_factories ( )

◆ load_default_flow_protocol_factories()

int TAO_AV_Core::load_default_flow_protocol_factories ( )

◆ load_default_transport_factories()

int TAO_AV_Core::load_default_transport_factories ( )

◆ orb() [1/2]

CORBA::ORB_ptr TAO_AV_Core::orb ( )

◆ orb() [2/2]

void TAO_AV_Core::orb ( CORBA::ORB_ptr orb_)

◆ poa() [1/2]

PortableServer::POA_ptr TAO_AV_Core::poa ( )

◆ poa() [2/2]

void TAO_AV_Core::poa ( PortableServer::POA_ptr poa_)

◆ reactor() [1/2]

ACE_Reactor * TAO_AV_Core::reactor ( )

◆ reactor() [2/2]

void TAO_AV_Core::reactor ( ACE_Reactor * r)

◆ remove_acceptor()

int TAO_AV_Core::remove_acceptor ( const char * flowname)

◆ remove_connector()

int TAO_AV_Core::remove_connector ( const char * flowname)

◆ run()

int TAO_AV_Core::run ( )

◆ stop_run()

int TAO_AV_Core::stop_run ( )

◆ transport_factories()

TAO_AV_TransportFactorySet * TAO_AV_Core::transport_factories ( )

Member Data Documentation

◆ acceptor_registry_

TAO_AV_Acceptor_Registry* TAO_AV_Core::acceptor_registry_
protected

The registry which maintains a list of acceptor factories for each loaded protocol.

◆ connector_registry_

TAO_AV_Connector_Registry* TAO_AV_Core::connector_registry_
protected

The connector registry which all active connecters must register themselves with.

◆ flow_protocol_factories_

TAO_AV_Flow_ProtocolFactorySet TAO_AV_Core::flow_protocol_factories_
protected

Pointer to the list of flow protocol loaded into this AV_Core instance.

◆ orb_

CORBA::ORB_var TAO_AV_Core::orb_
protected

◆ poa_

PortableServer::POA_var TAO_AV_Core::poa_
protected

◆ reactor_

ACE_Reactor* TAO_AV_Core::reactor_
protected

◆ stop_run_

CORBA::Boolean TAO_AV_Core::stop_run_
protected

◆ transport_factories_

TAO_AV_TransportFactorySet TAO_AV_Core::transport_factories_
protected

Pointer to the list of transports loaded into this AV_Core instance.


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