TAO_RTEvent
2.3.3
|
A generic factory for EC experimentation. More...
#include <EC_Default_Factory.h>
Static Public Member Functions | |
static int | init_svcs (void) |
![]() | |
static ACE_THR_FUNC_RETURN | read_adapter (void *event_handler) |
static int | register_stdin_handler (ACE_Event_Handler *eh, ACE_Reactor *reactor, ACE_Thread_Manager *thr_mgr, int flags=THR_DETACHED) |
static int | remove_stdin_handler (ACE_Reactor *reactor, ACE_Thread_Manager *thr_mgr) |
Protected Member Functions | |
void | unsupported_option_value (const ACE_TCHAR *option_name, const ACE_TCHAR *option_value) |
TAO_EC_Queue_Full_Service_Object * | find_service_object (const ACE_TCHAR *wanted, const ACE_TCHAR *fallback) |
name of ACE_Service_Object which should be invoked when output queue becomes full More... | |
![]() | |
ACE_Event_Handler (ACE_Reactor *=0, int priority=ACE_Event_Handler::LO_PRIORITY) | |
Protected Attributes | |
int | dispatching_ |
Several flags to control the kind of object created. More... | |
int | filtering_ |
int | supplier_filtering_ |
int | timeout_ |
int | observer_ |
int | scheduling_ |
int | consumer_collection_ |
int | supplier_collection_ |
int | consumer_lock_ |
int | supplier_lock_ |
int | dispatching_threads_ |
Flags used by thread-based dispatching strategies. More... | |
int | dispatching_threads_flags_ |
number of threads; may be ignored depending on strategy; default: TAO_EC_DEFAULT_DISPATCHING_THREADS More... | |
int | dispatching_threads_priority_ |
flags for thread creation; default: TAO_EC_DEFAULT_DISPATCHING_THREADS_FLAGS More... | |
int | dispatching_threads_force_active_ |
dispatching thread priority; default: TAO_EC_DEFAULT_DISPATCHING_THREADS_PRIORITY More... | |
ACE_TString | queue_full_service_object_name_ |
create threads with innocuous default values if creation with requested values fails More... | |
ACE_CString | orbid_ |
Use this ORB to locate global resources. More... | |
int | consumer_control_ |
The consumer and supplier control policies. More... | |
int | supplier_control_ |
int | consumer_control_period_ |
The consumer and supplier control periods in usecs. More... | |
int | supplier_control_period_ |
ACE_Time_Value | consumer_control_timeout_ |
The consumer control timeout in usecs. More... | |
ACE_Time_Value | supplier_control_timeout_ |
The supplier control timeout in usecs. More... | |
int | consumer_validate_connection_ |
Validate the connection to consumer on connect. More... | |
![]() | |
Atomic_Reference_Count | reference_count_ |
Additional Inherited Members | |
![]() | |
typedef long | Reference_Count |
![]() | |
LO_PRIORITY | |
HI_PRIORITY | |
NULL_MASK | |
READ_MASK | |
WRITE_MASK | |
EXCEPT_MASK | |
ACCEPT_MASK | |
CONNECT_MASK | |
TIMER_MASK | |
QOS_MASK | |
GROUP_QOS_MASK | |
SIGNAL_MASK | |
ALL_EVENTS_MASK | |
RWE_MASK | |
DONT_CALL | |
ACE_EVENT_HANDLER_NOT_RESUMED | |
ACE_REACTOR_RESUMES_HANDLER | |
ACE_APPLICATION_RESUMES_HANDLER | |
![]() | |
typedef ACE_Atomic_Op< ACE_SYNCH_MUTEX, Reference_Count > | Atomic_Reference_Count |
A generic factory for EC experimentation.
This class allows the user to experiment with different EC configurations. Using a command-line like interface the user can specify which strategies will this factory generate. Since the class can be dynamically loaded the strategies can be set in the service configurator file.
TAO_EC_Default_Factory::TAO_EC_Default_Factory | ( | void | ) |
Constructor.
|
virtual |
destructor...
int TAO_EC_Default_Factory::consumer_collection | ( | void | ) | const |
Accessors to consumer collection flags.
|
virtual |
Create and destroy the consumer admin implementation.
Implements TAO_EC_Factory.
|
virtual |
The ConsumerControl and SupplierControl strategies are used to discard non-existent consumers and suppliers
Implements TAO_EC_Factory.
|
virtual |
Create and destroy the locking strategies for both ProxyPushConsumers and ProxyPushSuppliers
Implements TAO_EC_Factory.
|
virtual |
Create and destroy the dispatching module.
Implements TAO_EC_Factory.
Reimplemented in TAO_EC_Kokyu_Factory, TAO_EC_Sched_Factory, and TAO_EC_TPC_Factory.
|
virtual |
Create and destroy the filter builder.
Implements TAO_EC_Factory.
Reimplemented in TAO_EC_Kokyu_Factory, and TAO_EC_Sched_Factory.
|
virtual |
Create and destroy the observer strategy.
Implements TAO_EC_Factory.
|
virtual |
Create and destroy a ProxyPushConsumer.
Implements TAO_EC_Factory.
Reimplemented in TAO_EC_TPC_Factory.
|
virtual |
Create and destroy a collection of TAO_EC_ProxyPushConsumers.
Implements TAO_EC_Factory.
|
virtual |
Create and destroy a ProxyPushSupplier.
Implements TAO_EC_Factory.
Reimplemented in TAO_EC_TPC_Factory.
|
virtual |
Create and destroy a collection of TAO_EC_ProxyPushSuppliers.
Implements TAO_EC_Factory.
|
virtual |
Create and destroy the observer strategy.
Implements TAO_EC_Factory.
Reimplemented in TAO_EC_Kokyu_Factory, and TAO_EC_Sched_Factory.
|
virtual |
Create and destroy the supplier admin implementation.
Implements TAO_EC_Factory.
|
virtual |
Implements TAO_EC_Factory.
|
virtual |
Create and destroy the filter builder.
Implements TAO_EC_Factory.
|
virtual |
Implements TAO_EC_Factory.
|
virtual |
Create and destroy the timer module.
Implements TAO_EC_Factory.
Reimplemented in TAO_EC_Kokyu_Factory, and TAO_EC_Sched_Factory.
|
virtual |
Implements TAO_EC_Factory.
|
virtual |
Implements TAO_EC_Factory.
|
virtual |
Implements TAO_EC_Factory.
|
virtual |
Implements TAO_EC_Factory.
|
virtual |
Implements TAO_EC_Factory.
|
virtual |
Implements TAO_EC_Factory.
|
virtual |
Implements TAO_EC_Factory.
|
virtual |
Implements TAO_EC_Factory.
|
virtual |
Implements TAO_EC_Factory.
|
virtual |
Implements TAO_EC_Factory.
|
virtual |
Implements TAO_EC_Factory.
|
virtual |
Implements TAO_EC_Factory.
|
virtual |
Implements TAO_EC_Factory.
|
virtual |
Implements TAO_EC_Factory.
|
virtual |
Implements TAO_EC_Factory.
|
virtual |
Implements TAO_EC_Factory.
|
protected |
name of ACE_Service_Object which should be invoked when output queue becomes full
|
virtual |
Reimplemented from ACE_Shared_Object.
Reimplemented in TAO_EC_Kokyu_Factory, and TAO_EC_Sched_Factory.
|
virtual |
Reimplemented from ACE_Shared_Object.
Reimplemented in TAO_EC_Kokyu_Factory, TAO_EC_TPC_Factory, and TAO_EC_Sched_Factory.
|
static |
Helper function to register the default factory into the service configurator.
const ACE_CString & TAO_EC_Default_Factory::orb_id | ( | void | ) | const |
Accessor to ORBid.
int TAO_EC_Default_Factory::supplier_collection | ( | void | ) | const |
Accessors to supplier collection flags.
int TAO_EC_Default_Factory::supplier_filtering | ( | void | ) | const |
Accessors to supplier filtering flags.
|
protected |
Helper for agrument parsing. Prints out an error message about unsupported option value.
|
protected |
|
protected |
The consumer and supplier control policies.
|
protected |
The consumer and supplier control periods in usecs.
|
protected |
The consumer control timeout in usecs.
|
protected |
|
protected |
Validate the connection to consumer on connect.
|
protected |
Several flags to control the kind of object created.
|
protected |
Flags used by thread-based dispatching strategies.
|
protected |
number of threads; may be ignored depending on strategy; default: TAO_EC_DEFAULT_DISPATCHING_THREADS
|
protected |
dispatching thread priority; default: TAO_EC_DEFAULT_DISPATCHING_THREADS_PRIORITY
|
protected |
flags for thread creation; default: TAO_EC_DEFAULT_DISPATCHING_THREADS_FLAGS
|
protected |
|
protected |
|
protected |
Use this ORB to locate global resources.
|
protected |
create threads with innocuous default values if creation with requested values fails
|
protected |
|
protected |
|
protected |
|
protected |
|
protected |
The supplier control timeout in usecs.
|
protected |
|
protected |
|
protected |