Main Page   Namespace List   Class Hierarchy   Alphabetical List   Compound List   File List   Namespace Members   Compound Members   File Members   Related Pages  

TAO_EC_Event_Channel Class Reference

The RtecEventChannelAdmin::EventChannel implementation. More...

#include <EC_Event_Channel.h>

Inheritance diagram for TAO_EC_Event_Channel

Inheritance graph
[legend]
Collaboration diagram for TAO_EC_Event_Channel:

Collaboration graph
[legend]
List of all members.

Public Methods

 TAO_EC_Event_Channel (const TAO_EC_Event_Channel_Attributes& attributes, TAO_EC_Factory* factory = 0, int own_factory = 0)
virtual ~TAO_EC_Event_Channel (void)
 destructor.

virtual void activate (CORBA::Environment &env = TAO_default_environment ())
 Start the internal threads (if any), etc. After this call the EC can be used.

virtual void shutdown (CORBA::Environment &env = TAO_default_environment ())
 Shutdown any internal threads, cleanup all the internal structures, flush all the messages, etc.

TAO_EC_Dispatchingdispatching (void) const
 Access the dispatching module....

TAO_EC_Filter_Builderfilter_builder (void) const
 Access the filter builder....

TAO_EC_Supplier_Filter_Buildersupplier_filter_builder (void) const
 Access the filter builder....

TAO_EC_ConsumerAdminconsumer_admin (void) const
 Access the consumer admin implementation, useful for controlling the activation...

TAO_EC_SupplierAdminsupplier_admin (void) const
 Access the supplier admin implementation, useful for controlling the activation...

TAO_EC_Timeout_Generatortimeout_generator (void) const
 Access the timer module...

TAO_EC_Scheduling_Strategyscheduling_strategy (void) const
 Access the scheduling strategy.

TAO_EC_ConsumerControlconsumer_control (void) const
 Access the client control strategies.

TAO_EC_SupplierControlsupplier_control (void) const
void create_proxy (TAO_EC_ProxyPushSupplier*&)
 Create and destroy a ProxyPushSupplier.

void destroy_proxy (TAO_EC_ProxyPushSupplier*)
void create_proxy (TAO_EC_ProxyPushConsumer*&)
 Create and destroy a ProxyPushConsumer.

void destroy_proxy (TAO_EC_ProxyPushConsumer*)
void create_proxy_collection (TAO_EC_ProxyPushSupplier_Collection*&)
 Create and destroy a the collections used to store ProxyPushSuppliers.

void destroy_proxy_collection (TAO_EC_ProxyPushSupplier_Collection*)
void create_proxy_collection (TAO_EC_ProxyPushConsumer_Collection*&)
 Create and destroy a the collections used to store ProxyPushConsumers.

void destroy_proxy_collection (TAO_EC_ProxyPushConsumer_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)
 Locking strategies for the ProxyPushConsumer and ProxyPushSupplier objects.

void destroy_consumer_lock (ACE_Lock*)
ACE_Lockcreate_supplier_lock (void)
void destroy_supplier_lock (ACE_Lock*)
virtual void connected (TAO_EC_ProxyPushConsumer*, CORBA::Environment&)
 Used to inform the EC that a Consumer has connected or disconnected from it.

virtual void reconnected (TAO_EC_ProxyPushConsumer*, CORBA::Environment&)
virtual void disconnected (TAO_EC_ProxyPushConsumer*, CORBA::Environment&)
virtual void connected (TAO_EC_ProxyPushSupplier*, CORBA::Environment&)
 Used to inform the EC that a Supplier has connected or disconnected from it.

virtual void reconnected (TAO_EC_ProxyPushSupplier*, CORBA::Environment&)
virtual void disconnected (TAO_EC_ProxyPushSupplier*, CORBA::Environment&)
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
 Should we send callback disconnect messages when a proxy is disconnected by the client.

CORBA::Object_ptr scheduler (void)
 Obtain the scheduler, the user must release.

int busy_hwm (void) const
 Control the concurrency of the delayed connect/disconnect operations.

int max_write_delay (void) const

Detailed Description

The RtecEventChannelAdmin::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 EC_Factory.


Constructor & Destructor Documentation

TAO_EC_Event_Channel::TAO_EC_Event_Channel ( const TAO_EC_Event_Channel_Attributes & attributes,
TAO_EC_Factory * factory = 0,
int own_factory = 0 ) [inline]
 

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_EC_Default_Resource_Factory

TAO_EC_Event_Channel::~TAO_EC_Event_Channel ( void ) [virtual]
 

destructor.


Member Function Documentation

void TAO_EC_Event_Channel::activate ( CORBA::Environment & env = TAO_default_environment () ) [virtual]
 

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

ACE_INLINE int TAO_EC_Event_Channel::busy_hwm ( void ) const
 

Control the concurrency of the delayed connect/disconnect operations.

void TAO_EC_Event_Channel::connected ( TAO_EC_ProxyPushSupplier * supplier,
CORBA::Environment & ACE_TRY_ENV ) [virtual]
 

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

void TAO_EC_Event_Channel::connected ( TAO_EC_ProxyPushConsumer * consumer,
CORBA::Environment & ACE_TRY_ENV ) [virtual]
 

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

ACE_INLINE TAO_EC_ConsumerAdmin * TAO_EC_Event_Channel::consumer_admin ( void ) const
 

Access the consumer admin implementation, useful for controlling the activation...

ACE_INLINE TAO_EC_ConsumerControl * TAO_EC_Event_Channel::consumer_control ( void ) const
 

Access the client control strategies.

ACE_INLINE PortableServer::POA_ptr TAO_EC_Event_Channel::consumer_poa ( void )
 

ACE_INLINE int TAO_EC_Event_Channel::consumer_reconnect ( void ) const
 

Can the consumers reconnect to the EC?

ACE_INLINE ACE_Lock * TAO_EC_Event_Channel::create_consumer_lock ( void )
 

Locking strategies for the ProxyPushConsumer and ProxyPushSupplier objects.

ACE_INLINE void TAO_EC_Event_Channel::create_proxy ( TAO_EC_ProxyPushConsumer *& x )
 

Create and destroy a ProxyPushConsumer.

ACE_INLINE void TAO_EC_Event_Channel::create_proxy ( TAO_EC_ProxyPushSupplier *& x )
 

Create and destroy a ProxyPushSupplier.

ACE_INLINE void TAO_EC_Event_Channel::create_proxy_collection ( TAO_EC_ProxyPushConsumer_Collection *& x )
 

Create and destroy a the collections used to store ProxyPushConsumers.

ACE_INLINE void TAO_EC_Event_Channel::create_proxy_collection ( TAO_EC_ProxyPushSupplier_Collection *& x )
 

Create and destroy a the collections used to store ProxyPushSuppliers.

ACE_INLINE ACE_Lock * TAO_EC_Event_Channel::create_supplier_lock ( void )
 

ACE_INLINE void TAO_EC_Event_Channel::destroy_consumer_lock ( ACE_Lock * x )
 

ACE_INLINE void TAO_EC_Event_Channel::destroy_proxy ( TAO_EC_ProxyPushConsumer * consumer )
 

ACE_INLINE void TAO_EC_Event_Channel::destroy_proxy ( TAO_EC_ProxyPushSupplier * supplier )
 

ACE_INLINE void TAO_EC_Event_Channel::destroy_proxy_collection ( TAO_EC_ProxyPushConsumer_Collection * x )
 

ACE_INLINE void TAO_EC_Event_Channel::destroy_proxy_collection ( TAO_EC_ProxyPushSupplier_Collection * x )
 

ACE_INLINE void TAO_EC_Event_Channel::destroy_supplier_lock ( ACE_Lock * x )
 

ACE_INLINE int TAO_EC_Event_Channel::disconnect_callbacks ( void ) const
 

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

void TAO_EC_Event_Channel::disconnected ( TAO_EC_ProxyPushSupplier * supplier,
CORBA::Environment & ACE_TRY_ENV ) [virtual]
 

void TAO_EC_Event_Channel::disconnected ( TAO_EC_ProxyPushConsumer * consumer,
CORBA::Environment & ACE_TRY_ENV ) [virtual]
 

ACE_INLINE TAO_EC_Dispatching * TAO_EC_Event_Channel::dispatching ( void ) const
 

Access the dispatching module....

ACE_INLINE TAO_EC_Filter_Builder * TAO_EC_Event_Channel::filter_builder ( void ) const
 

Access the filter builder....

ACE_INLINE int TAO_EC_Event_Channel::max_write_delay ( void ) const
 

void TAO_EC_Event_Channel::reconnected ( TAO_EC_ProxyPushSupplier * supplier,
CORBA::Environment & ACE_TRY_ENV ) [virtual]
 

void TAO_EC_Event_Channel::reconnected ( TAO_EC_ProxyPushConsumer * consumer,
CORBA::Environment & ACE_TRY_ENV ) [virtual]
 

ACE_INLINE CORBA::Object_ptr TAO_EC_Event_Channel::scheduler ( void )
 

Obtain the scheduler, the user must release.

ACE_INLINE TAO_EC_Scheduling_Strategy * TAO_EC_Event_Channel::scheduling_strategy ( void ) const
 

Access the scheduling strategy.

void TAO_EC_Event_Channel::shutdown ( CORBA::Environment & env = TAO_default_environment () ) [virtual]
 

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

ACE_INLINE TAO_EC_SupplierAdmin * TAO_EC_Event_Channel::supplier_admin ( void ) const
 

Access the supplier admin implementation, useful for controlling the activation...

ACE_INLINE TAO_EC_SupplierControl * TAO_EC_Event_Channel::supplier_control ( void ) const
 

ACE_INLINE TAO_EC_Supplier_Filter_Builder * TAO_EC_Event_Channel::supplier_filter_builder ( void ) const
 

Access the filter builder....

ACE_INLINE PortableServer::POA_ptr TAO_EC_Event_Channel::supplier_poa ( void )
 

Access the supplier and consumer POAs from the factory.

ACE_INLINE int TAO_EC_Event_Channel::supplier_reconnect ( void ) const
 

Can the suppliers reconnect to the EC?

ACE_INLINE TAO_EC_Timeout_Generator * TAO_EC_Event_Channel::timeout_generator ( void ) const
 

Access the timer module...


The documentation for this class was generated from the following files:
Generated at Wed Nov 21 12:06:56 2001 for TAO_RTEvent by doxygen1.2.3 written by Dimitri van Heesch, © 1997-2000