TAO_CosEvent  2.0.8
Classes | Public Types | Public Member Functions | Private Attributes
TAO_CEC_EventChannel Class Reference

The CosEventChannelAdmin::EventChannel implementation. More...

#include <CEC_EventChannel.h>

Collaboration diagram for TAO_CEC_EventChannel:
Collaboration graph
[legend]

List of all members.

Classes

class  ServantBaseHash

Public Types

typedef
ACE_Hash_Map_Manager_Ex
< PortableServer::ServantBase
*, unsigned int,
ServantBaseHash, ACE_Equal_To
< PortableServer::ServantBase * >
, TAO_SYNCH_MUTEX
ServantRetryMap

Public Member Functions

 TAO_CEC_EventChannel (const TAO_CEC_EventChannel_Attributes &attributes, TAO_CEC_Factory *factory=0, int own_factory=0)
virtual ~TAO_CEC_EventChannel (void)
 destructor
virtual void activate (void)
virtual void shutdown (void)
TAO_CEC_Dispatchingdispatching (void) const
 Access the dispatching module....
TAO_CEC_ConsumerAdminconsumer_admin (void) const
 Access the consumer admin implementation.
TAO_CEC_SupplierAdminsupplier_admin (void) const
 Access the supplier admin implementation.
TAO_CEC_ConsumerControlconsumer_control (void) const
 Access the consumer control strategy.
TAO_CEC_SupplierControlsupplier_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_ProxyPullSupplier *&)
 Create and destroy a ProxyPullSupplier.
void destroy_proxy (TAO_CEC_ProxyPullSupplier *)
void create_proxy (TAO_CEC_ProxyPushConsumer *&)
 Create and destroy a ProxyPushConsumer.
void destroy_proxy (TAO_CEC_ProxyPushConsumer *)
void create_proxy (TAO_CEC_ProxyPullConsumer *&)
 Create and destroy a ProxyPushConsumer.
void destroy_proxy (TAO_CEC_ProxyPullConsumer *)
void create_proxy_collection (TAO_CEC_ProxyPushSupplier_Collection *&)
void destroy_proxy_collection (TAO_CEC_ProxyPushSupplier_Collection *)
void create_proxy_collection (TAO_CEC_ProxyPullSupplier_Collection *&)
void destroy_proxy_collection (TAO_CEC_ProxyPullSupplier_Collection *)
void create_proxy_collection (TAO_CEC_ProxyPushConsumer_Collection *&)
void destroy_proxy_collection (TAO_CEC_ProxyPushConsumer_Collection *)
void create_proxy_collection (TAO_CEC_ProxyPullConsumer_Collection *&)
void destroy_proxy_collection (TAO_CEC_ProxyPullConsumer_Collection *)
PortableServer::POA_ptr supplier_poa (void)
 Access the supplier and consumer POAs from the factory.
PortableServer::POA_ptr consumer_poa (void)
ACE_Lockcreate_consumer_lock (void)
void destroy_consumer_lock (ACE_Lock *)
ACE_Lockcreate_supplier_lock (void)
void destroy_supplier_lock (ACE_Lock *)
virtual void connected (TAO_CEC_ProxyPushConsumer *)
virtual void reconnected (TAO_CEC_ProxyPushConsumer *)
virtual void disconnected (TAO_CEC_ProxyPushConsumer *)
virtual void connected (TAO_CEC_ProxyPullConsumer *)
virtual void reconnected (TAO_CEC_ProxyPullConsumer *)
virtual void disconnected (TAO_CEC_ProxyPullConsumer *)
virtual void connected (TAO_CEC_ProxyPushSupplier *)
virtual void reconnected (TAO_CEC_ProxyPushSupplier *)
virtual void disconnected (TAO_CEC_ProxyPushSupplier *)
virtual void connected (TAO_CEC_ProxyPullSupplier *)
virtual void reconnected (TAO_CEC_ProxyPullSupplier *)
virtual void disconnected (TAO_CEC_ProxyPullSupplier *)
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
virtual
CosEventChannelAdmin::ConsumerAdmin_ptr 
for_consumers (void)
virtual
CosEventChannelAdmin::SupplierAdmin_ptr 
for_suppliers (void)
virtual void destroy (void)
 Commit suicide.
ServantRetryMapget_servant_retry_map (void)
CORBA::Policy_ptr create_roundtrip_timeout_policy (const ACE_Time_Value &timeout)
 Forwarded to the factory.

Private Attributes

PortableServer::POA_var supplier_poa_
PortableServer::POA_var consumer_poa_
TAO_CEC_Factoryfactory_
int own_factory_
 Flag that indicates if we own the factory.
TAO_CEC_Dispatchingdispatching_
 The dispatching "module".
TAO_CEC_Pulling_Strategypulling_strategy_
 The pulling strategy.
TAO_CEC_ConsumerAdminconsumer_admin_
 The ConsumerAdmin implementation.
TAO_CEC_SupplierAdminsupplier_admin_
 The SupplierAdmin implementation.
int consumer_reconnect_
 Consumer/Supplier reconnection flags.
int supplier_reconnect_
int disconnect_callbacks_
 If not zero we send callbacks when a proxy is disconnected.
TAO_CEC_ConsumerControlconsumer_control_
TAO_CEC_SupplierControlsupplier_control_
ServantRetryMap retry_map_

Detailed Description

The CosEventChannelAdmin::EventChannel implementation.

This class is the Mediator between all the classes in the EC implementation, its main task is to redirect the messages to the right components, to hold and manage the lifetime of the long lived objects (Timer_Module, SupplierAdmin, ConsumerAdmin and Dispatching) and to provide a simpler interface to the CEC_Factory.


Member Typedef Documentation


Constructor & Destructor Documentation

TAO_CEC_EventChannel::TAO_CEC_EventChannel ( const TAO_CEC_EventChannel_Attributes attributes,
TAO_CEC_Factory factory = 0,
int  own_factory = 0 
)

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

TAO_CEC_EventChannel::~TAO_CEC_EventChannel ( void  ) [virtual]

destructor


Member Function Documentation

void TAO_CEC_EventChannel::activate ( void  ) [virtual]

Start the internal threads (if any), etc. After this call the EC can be used.

void TAO_CEC_EventChannel::connected ( TAO_CEC_ProxyPushConsumer consumer) [virtual]

Used to inform the EC that a Consumer has connected or disconnected from it.

void TAO_CEC_EventChannel::connected ( TAO_CEC_ProxyPullConsumer consumer) [virtual]
void TAO_CEC_EventChannel::connected ( TAO_CEC_ProxyPushSupplier supplier) [virtual]

Used to inform the EC that a Supplier has connected or disconnected from it.

void TAO_CEC_EventChannel::connected ( TAO_CEC_ProxyPullSupplier supplier) [virtual]
TAO_CEC_ConsumerAdmin * TAO_CEC_EventChannel::consumer_admin ( void  ) const

Access the consumer admin implementation.

TAO_CEC_ConsumerControl * TAO_CEC_EventChannel::consumer_control ( void  ) const

Access the consumer control strategy.

PortableServer::POA_ptr TAO_CEC_EventChannel::consumer_poa ( void  )
int TAO_CEC_EventChannel::consumer_reconnect ( void  ) const

Can the consumers reconnect to the EC?

ACE_Lock * TAO_CEC_EventChannel::create_consumer_lock ( void  )

Locking strategies for the ProxyPushConsumer and ProxyPushSupplier objects

void TAO_CEC_EventChannel::create_proxy ( TAO_CEC_ProxyPushSupplier *&  x)

Create and destroy a ProxyPushSupplier.

void TAO_CEC_EventChannel::create_proxy ( TAO_CEC_ProxyPullSupplier *&  x)

Create and destroy a ProxyPullSupplier.

void TAO_CEC_EventChannel::create_proxy ( TAO_CEC_ProxyPushConsumer *&  x)

Create and destroy a ProxyPushConsumer.

void TAO_CEC_EventChannel::create_proxy ( TAO_CEC_ProxyPullConsumer *&  x)

Create and destroy a ProxyPushConsumer.

void TAO_CEC_EventChannel::create_proxy_collection ( TAO_CEC_ProxyPushSupplier_Collection *&  x)

Create and destroy a the collections used to store Proxy*Suppliers

void TAO_CEC_EventChannel::create_proxy_collection ( TAO_CEC_ProxyPullSupplier_Collection *&  )
void TAO_CEC_EventChannel::create_proxy_collection ( TAO_CEC_ProxyPushConsumer_Collection *&  )

Create and destroy a the collections used to store Proxy*Consumers

void TAO_CEC_EventChannel::create_proxy_collection ( TAO_CEC_ProxyPullConsumer_Collection *&  )
CORBA::Policy_ptr TAO_CEC_EventChannel::create_roundtrip_timeout_policy ( const ACE_Time_Value timeout)

Forwarded to the factory.

ACE_Lock * TAO_CEC_EventChannel::create_supplier_lock ( void  )
void TAO_CEC_EventChannel::destroy ( void  ) [virtual]

Commit suicide.

void TAO_CEC_EventChannel::destroy_consumer_lock ( ACE_Lock x)
void TAO_CEC_EventChannel::destroy_proxy ( TAO_CEC_ProxyPushSupplier supplier)
void TAO_CEC_EventChannel::destroy_proxy ( TAO_CEC_ProxyPullSupplier supplier)
void TAO_CEC_EventChannel::destroy_proxy ( TAO_CEC_ProxyPushConsumer consumer)
void TAO_CEC_EventChannel::destroy_proxy ( TAO_CEC_ProxyPullConsumer consumer)
void TAO_CEC_EventChannel::destroy_proxy_collection ( TAO_CEC_ProxyPushSupplier_Collection x)
void TAO_CEC_EventChannel::destroy_proxy_collection ( TAO_CEC_ProxyPullSupplier_Collection )
void TAO_CEC_EventChannel::destroy_proxy_collection ( TAO_CEC_ProxyPushConsumer_Collection )
void TAO_CEC_EventChannel::destroy_proxy_collection ( TAO_CEC_ProxyPullConsumer_Collection )
void TAO_CEC_EventChannel::destroy_supplier_lock ( ACE_Lock x)
int TAO_CEC_EventChannel::disconnect_callbacks ( void  ) const

Should we send callback disconnect messages when a proxy is disconnected by the client

void TAO_CEC_EventChannel::disconnected ( TAO_CEC_ProxyPushConsumer consumer) [virtual]
void TAO_CEC_EventChannel::disconnected ( TAO_CEC_ProxyPullConsumer consumer) [virtual]
void TAO_CEC_EventChannel::disconnected ( TAO_CEC_ProxyPushSupplier supplier) [virtual]
void TAO_CEC_EventChannel::disconnected ( TAO_CEC_ProxyPullSupplier supplier) [virtual]
TAO_CEC_Dispatching * TAO_CEC_EventChannel::dispatching ( void  ) const

Access the dispatching module....

CosEventChannelAdmin::ConsumerAdmin_ptr TAO_CEC_EventChannel::for_consumers ( void  ) [virtual]

The default implementation is: this->consumer_admin ()->_this (env);

CosEventChannelAdmin::SupplierAdmin_ptr TAO_CEC_EventChannel::for_suppliers ( void  ) [virtual]

The default implementation is: this->supplier_admin ()->_this (env);

TAO_CEC_EventChannel::ServantRetryMap & TAO_CEC_EventChannel::get_servant_retry_map ( void  )
void TAO_CEC_EventChannel::reconnected ( TAO_CEC_ProxyPushConsumer consumer) [virtual]
void TAO_CEC_EventChannel::reconnected ( TAO_CEC_ProxyPullConsumer consumer) [virtual]
void TAO_CEC_EventChannel::reconnected ( TAO_CEC_ProxyPushSupplier supplier) [virtual]
void TAO_CEC_EventChannel::reconnected ( TAO_CEC_ProxyPullSupplier supplier) [virtual]
void TAO_CEC_EventChannel::shutdown ( void  ) [virtual]

Shutdown any internal threads, cleanup all the internal structures, flush all the messages, etc.

TAO_CEC_SupplierAdmin * TAO_CEC_EventChannel::supplier_admin ( void  ) const

Access the supplier admin implementation.

TAO_CEC_SupplierControl * TAO_CEC_EventChannel::supplier_control ( void  ) const

Access the supplier control strategy.

PortableServer::POA_ptr TAO_CEC_EventChannel::supplier_poa ( void  )

Access the supplier and consumer POAs from the factory.

int TAO_CEC_EventChannel::supplier_reconnect ( void  ) const

Can the suppliers reconnect to the EC?


Member Data Documentation

The ConsumerAdmin implementation.

Strategies to disconnect misbehaving or destroyed consumers and suppliers

Consumer/Supplier reconnection flags.

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.

Flag that indicates if we own the factory.

The pulling strategy.

The SupplierAdmin implementation.

The POAs used to activate "supplier-side" and "consumer-side" objects.


The documentation for this class was generated from the following files:
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Friends Defines