|
Public Types |
typedef ACE_Hash_Map_Manager_Ex<
PortableServer::ServantBase *,
unsigned int, ServantBaseHash,
ACE_Equal_To< PortableServer::ServantBase * >,
TAO_SYNCH_MUTEX > | ServantRetryMap |
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 Member Functions |
| 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 () |
virtual void | shutdown () |
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) |
| Function allows consumer admin to register the uses interface.
|
int | supplier_register_supported_interface (const char *supported_interface) |
| 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) |
| Function populates the NVList from the provide param information.
|
virtual void | create_list (CORBA::Long count, CORBA::NVList_out new_list) |
| Function creates an empty NVList.
|
virtual ::CosTypedEventChannelAdmin::TypedConsumerAdmin_ptr | for_consumers () throw (CORBA::SystemException) |
virtual ::CosTypedEventChannelAdmin::TypedSupplierAdmin_ptr | for_suppliers () throw (CORBA::SystemException) |
virtual void | destroy () throw (CORBA::SystemException) |
ServantRetryMap & | get_servant_retry_map (void) |
Protected Member Functions |
int | cache_interface_description (const char *interface) |
| 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_ |
ServantRetryMap | retry_map_ |
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.
|