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_Dispatching* | dispatching (void) const |
| Access the dispatching module....
|
TAO_EC_Filter_Builder* | filter_builder (void) const |
| Access the filter builder....
|
TAO_EC_Supplier_Filter_Builder* | supplier_filter_builder (void) const |
| Access the filter builder....
|
TAO_EC_ConsumerAdmin* | consumer_admin (void) const |
| Access the consumer admin implementation, useful for controlling the activation...
|
TAO_EC_SupplierAdmin* | supplier_admin (void) const |
| Access the supplier admin implementation, useful for controlling the activation...
|
TAO_EC_Timeout_Generator* | timeout_generator (void) const |
| Access the timer module...
|
TAO_EC_Scheduling_Strategy* | scheduling_strategy (void) const |
| Access the scheduling strategy.
|
TAO_EC_ConsumerControl* | consumer_control (void) const |
| Access the client control strategies.
|
TAO_EC_SupplierControl* | supplier_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_Lock* | create_consumer_lock (void) |
| Locking strategies for the ProxyPushConsumer and ProxyPushSupplier objects.
|
void | destroy_consumer_lock (ACE_Lock*) |
ACE_Lock* | create_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 |
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.