#include <CEC_TypedEventChannel.h>
Collaboration diagram for TAO_CEC_TypedEventChannel:
Public Types | |
typedef ACE_Hash_Map_Manager_Ex< const char *, TAO_CEC_Operation_Params *, ACE_Hash< const char * >, ACE_Equal_To< const char * >, ACE_Null_Mutex > | InterfaceDescription |
typedef InterfaceDescription::iterator | Iterator |
Public Methods | |
TAO_CEC_TypedEventChannel (const TAO_CEC_TypedEventChannel_Attributes &attributes, TAO_CEC_Factory *factory=0, int own_factory=0) | |
virtual | ~TAO_CEC_TypedEventChannel (void) |
Destructor. | |
virtual void | activate (ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS) |
virtual void | shutdown (ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS) |
TAO_CEC_Dispatching * | dispatching (void) const |
Access the dispatching module.... | |
TAO_CEC_TypedConsumerAdmin * | typed_consumer_admin (void) const |
Access the consumer admin implementation. | |
TAO_CEC_TypedSupplierAdmin * | typed_supplier_admin (void) const |
Access the supplier admin implementation. | |
TAO_CEC_ConsumerControl * | consumer_control (void) const |
Access the consumer control strategy. | |
TAO_CEC_SupplierControl * | supplier_control (void) const |
Access the supplier control strategy. | |
void | create_proxy (TAO_CEC_ProxyPushSupplier *&) |
Create and destroy a ProxyPushSupplier. | |
void | destroy_proxy (TAO_CEC_ProxyPushSupplier *) |
void | create_proxy (TAO_CEC_TypedProxyPushConsumer *&) |
Create and destroy a TypedProxyPushConsumer. | |
void | destroy_proxy (TAO_CEC_TypedProxyPushConsumer *) |
void | create_proxy_collection (TAO_CEC_ProxyPushSupplier_Collection *&) |
void | destroy_proxy_collection (TAO_CEC_ProxyPushSupplier_Collection *) |
void | create_proxy_collection (TAO_CEC_TypedProxyPushConsumer_Collection *&) |
void | destroy_proxy_collection (TAO_CEC_TypedProxyPushConsumer_Collection *) |
PortableServer::POA_ptr | typed_supplier_poa (void) |
Access the supplier and consumer POAs from the factory. | |
PortableServer::POA_ptr | typed_consumer_poa (void) |
ACE_Lock * | create_consumer_lock (void) |
void | destroy_consumer_lock (ACE_Lock *) |
ACE_Lock * | create_supplier_lock (void) |
void | destroy_supplier_lock (ACE_Lock *) |
virtual void | connected (TAO_CEC_TypedProxyPushConsumer *ACE_ENV_ARG_DECL_NOT_USED) |
virtual void | reconnected (TAO_CEC_TypedProxyPushConsumer *ACE_ENV_ARG_DECL_NOT_USED) |
virtual void | disconnected (TAO_CEC_TypedProxyPushConsumer *ACE_ENV_ARG_DECL_NOT_USED) |
virtual void | connected (TAO_CEC_ProxyPushSupplier *ACE_ENV_ARG_DECL_NOT_USED) |
virtual void | reconnected (TAO_CEC_ProxyPushSupplier *ACE_ENV_ARG_DECL_NOT_USED) |
virtual void | disconnected (TAO_CEC_ProxyPushSupplier *ACE_ENV_ARG_DECL_NOT_USED) |
int | consumer_reconnect (void) const |
Can the consumers reconnect to the EC? | |
int | supplier_reconnect (void) const |
Can the suppliers reconnect to the EC? | |
int | disconnect_callbacks (void) const |
TAO_CEC_Operation_Params * | find_from_ifr_cache (const char *operation) |
Finds a operation/parameter from the IFR cache. | |
int | consumer_register_uses_interace (const char *uses_interface ACE_ENV_ARG_DECL) |
Function allows consumer admin to register the uses interface. | |
int | supplier_register_supported_interface (const char *supported_interface ACE_ENV_ARG_DECL) |
Function allows supplier admin to register the supported interface. | |
const char * | supported_interface (void) const |
Function to return the supported_interface_. | |
CORBA::RepositoryId | base_interfaces (CORBA::ULong index) const |
Function to return the base_interfaces_. | |
CORBA::ULong | number_of_base_interfaces (void) const |
Function to return the number of base_interfaces_. | |
virtual void | create_operation_list (TAO_CEC_Operation_Params *oper_params, CORBA::NVList_out new_list ACE_ENV_ARG_DECL) |
Function populates the NVList from the provide param information. | |
virtual void | create_list (CORBA::Long count, CORBA::NVList_out new_list ACE_ENV_ARG_DECL) |
Function creates an empty NVList. | |
virtual::CosTypedEventChannelAdmin::TypedConsumerAdmin_ptr | for_consumers (ACE_ENV_SINGLE_ARG_DECL) throw (CORBA::SystemException) |
virtual::CosTypedEventChannelAdmin::TypedSupplierAdmin_ptr | for_suppliers (ACE_ENV_SINGLE_ARG_DECL) throw (CORBA::SystemException) |
virtual void | destroy (ACE_ENV_SINGLE_ARG_DECL) throw (CORBA::SystemException) |
Protected Methods | |
int | cache_interface_description (const char *interface ACE_ENV_ARG_DECL) |
Function caches the full interface description from the IFR. | |
int | insert_into_ifr_cache (const char *operation, TAO_CEC_Operation_Params *parameters) |
Insert a operation/parameter into the IFR cache. | |
int | clear_ifr_cache (void) |
Function clears the IFR cache. | |
Private Attributes | |
PortableServer::POA_var | typed_supplier_poa_ |
PortableServer::POA_var | typed_consumer_poa_ |
CORBA::ORB_var | orb_ |
The ORB. | |
CORBA::Repository_var | interface_repository_ |
Storage of the IFR reference. | |
TAO_CEC_Factory * | factory_ |
int | own_factory_ |
Flag that indicates if we own the factory. | |
TAO_CEC_Dispatching * | dispatching_ |
The dispatching "module". | |
TAO_CEC_TypedConsumerAdmin * | typed_consumer_admin_ |
The ConsumerAdmin implementation. | |
TAO_CEC_TypedSupplierAdmin * | typed_supplier_admin_ |
The SupplierAdmin implementation. | |
int | consumer_reconnect_ |
Consumer reconnection flags. | |
int | supplier_reconnect_ |
Supplier reconnection flags. | |
int | disconnect_callbacks_ |
If not zero we send callbacks when a proxy is disconnected. | |
int | destroy_on_shutdown_ |
If not zero the event channel is destroyed on shutdown. | |
int | destroyed_ |
Set if the event channel has been destroyed. | |
TAO_CEC_ConsumerControl * | consumer_control_ |
TAO_CEC_SupplierControl * | supplier_control_ |
ACE_CString | uses_interface_ |
The uses_interface_ for the TypedConsumerAdmin. | |
ACE_CString | supported_interface_ |
The supported_interface_ for the TypedSupplierAdmin. | |
InterfaceDescription | interface_description_ |
The IFR cache for the interface description. | |
CORBA::RepositoryIdSeq | base_interfaces_ |
The supported_interface_ base interfaces. |
|
|
|
|
|
Constructor If <own_factory> is not 0 it assumes ownership of the factory. If the factory is <nil> it uses the Service_Configurator to load the Factory, if not found it uses TAO_CEC_Default_Resource_Factory |
|
Destructor.
|
|
Start the internal threads (if any), etc. After this call the EC can be used. |
|
Function to return the base_interfaces_.
|
|
Function caches the full interface description from the IFR.
|
|
Function clears the IFR cache.
|
|
Used to inform the EC that a Supplier has connected or disconnected from it. |
|
Used to inform the EC that a Consumer has connected or disconnected from it. |
|
Access the consumer control strategy.
|
|
Can the consumers reconnect to the EC?
|
|
Function allows consumer admin to register the uses interface.
|
|
Locking strategies for the ProxyPushConsumer and ProxyPushSupplier objects |
|
Function creates an empty NVList.
|
|
Function populates the NVList from the provide param information.
|
|
Create and destroy a TypedProxyPushConsumer.
|
|
Create and destroy a ProxyPushSupplier.
|
|
Create and destroy a the collections used to store Proxy*Consumers |
|
Create and destroy a the collections used to store Proxy*Suppliers |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
Should we send callback disconnect messages when a proxy is disconnected by the client |
|
|
|
|
|
Access the dispatching module....
|
|
Finds a operation/parameter from the IFR cache.
|
|
|
|
|
|
Insert a operation/parameter into the IFR cache.
|
|
Function to return the number of base_interfaces_.
|
|
|
|
|
|
Shutdown any internal threads, cleanup all the internal structures, flush all the messages, etc. |
|
Access the supplier control strategy.
|
|
Can the suppliers reconnect to the EC?
|
|
Function allows supplier admin to register the supported interface.
|
|
Function to return the supported_interface_.
|
|
Access the consumer admin implementation.
|
|
|
|
Access the supplier admin implementation.
|
|
Access the supplier and consumer POAs from the factory.
|
|
The supported_interface_ base interfaces.
|
|
Strategies to disconnect misbehaving or destroyed consumers and suppliers |
|
Consumer reconnection flags.
|
|
If not zero the event channel is destroyed on shutdown.
|
|
Set if the event channel has been destroyed.
|
|
If not zero we send callbacks when a proxy is disconnected.
|
|
The dispatching "module".
|
|
This is the abstract factory that creates all the objects that compose an event channel, the event channel simply acts as a Mediator among them. |
|
The IFR cache for the interface description.
|
|
Storage of the IFR reference.
|
|
The ORB.
|
|
Flag that indicates if we own the factory.
|
|
|
|
Supplier reconnection flags.
|
|
The supported_interface_ for the TypedSupplierAdmin.
|
|
The ConsumerAdmin implementation.
|
|
|
|
The SupplierAdmin implementation.
|
|
The POAs used to activate "supplier-side" and "consumer-side" objects. |
|
The uses_interface_ for the TypedConsumerAdmin.
|