TAO_EC_Default_Factory Class Reference

A generic factory for EC experimentation. More...

#include <EC_Default_Factory.h>

Inheritance diagram for TAO_EC_Default_Factory:

[legend]Collaboration diagram for TAO_EC_Default_Factory:

[legend]List of all members.

Public Member Functions
	TAO_EC_Default_Factory (void)
	Constructor.
virtual	~TAO_EC_Default_Factory (void)
	destructor...
virtual int	init (int argc, ACE_TCHAR *argv[])
virtual int	fini (void)
virtual TAO_EC_Dispatching *	create_dispatching (TAO_EC_Event_Channel_Base *)
	Create and destroy the dispatching module.
virtual void	destroy_dispatching (TAO_EC_Dispatching *)
virtual TAO_EC_Filter_Builder *	create_filter_builder (TAO_EC_Event_Channel_Base *)
	Create and destroy the filter builder.
virtual void	destroy_filter_builder (TAO_EC_Filter_Builder *)
virtual TAO_EC_Supplier_Filter_Builder *	create_supplier_filter_builder (TAO_EC_Event_Channel_Base *)
	Create and destroy the filter builder.
virtual void	destroy_supplier_filter_builder (TAO_EC_Supplier_Filter_Builder *)
virtual TAO_EC_ConsumerAdmin *	create_consumer_admin (TAO_EC_Event_Channel_Base *)
	Create and destroy the consumer admin implementation.
virtual void	destroy_consumer_admin (TAO_EC_ConsumerAdmin *)
virtual TAO_EC_SupplierAdmin *	create_supplier_admin (TAO_EC_Event_Channel_Base *)
	Create and destroy the supplier admin implementation.
virtual void	destroy_supplier_admin (TAO_EC_SupplierAdmin *)
virtual TAO_EC_ProxyPushSupplier *	create_proxy_push_supplier (TAO_EC_Event_Channel_Base *)
	Create and destroy a ProxyPushSupplier.
virtual void	destroy_proxy_push_supplier (TAO_EC_ProxyPushSupplier *)
virtual TAO_EC_ProxyPushConsumer *	create_proxy_push_consumer (TAO_EC_Event_Channel_Base *)
	Create and destroy a ProxyPushConsumer.
virtual void	destroy_proxy_push_consumer (TAO_EC_ProxyPushConsumer *)
virtual TAO_EC_Timeout_Generator *	create_timeout_generator (TAO_EC_Event_Channel_Base *)
	Create and destroy the timer module.
virtual void	destroy_timeout_generator (TAO_EC_Timeout_Generator *)
virtual TAO_EC_ObserverStrategy *	create_observer_strategy (TAO_EC_Event_Channel_Base *)
	Create and destroy the observer strategy.
virtual void	destroy_observer_strategy (TAO_EC_ObserverStrategy *)
virtual TAO_EC_Scheduling_Strategy *	create_scheduling_strategy (TAO_EC_Event_Channel_Base *)
	Create and destroy the observer strategy.
virtual void	destroy_scheduling_strategy (TAO_EC_Scheduling_Strategy *)
virtual TAO_EC_ProxyPushConsumer_Collection *	create_proxy_push_consumer_collection (TAO_EC_Event_Channel_Base *)
	Create and destroy a collection of TAO_EC_ProxyPushConsumers.
virtual void	destroy_proxy_push_consumer_collection (TAO_EC_ProxyPushConsumer_Collection *)
virtual TAO_EC_ProxyPushSupplier_Collection *	create_proxy_push_supplier_collection (TAO_EC_Event_Channel_Base *)
	Create and destroy a collection of TAO_EC_ProxyPushSuppliers.
virtual void	destroy_proxy_push_supplier_collection (TAO_EC_ProxyPushSupplier_Collection *)
virtual ACE_Lock *	create_consumer_lock (void)
virtual void	destroy_consumer_lock (ACE_Lock *)
virtual ACE_Lock *	create_supplier_lock (void)
virtual void	destroy_supplier_lock (ACE_Lock *)
virtual TAO_EC_ConsumerControl *	create_consumer_control (TAO_EC_Event_Channel_Base *)
virtual void	destroy_consumer_control (TAO_EC_ConsumerControl *)
virtual TAO_EC_SupplierControl *	create_supplier_control (TAO_EC_Event_Channel_Base *)
virtual void	destroy_supplier_control (TAO_EC_SupplierControl *)
int	consumer_collection (void) const
	Accessors to consumer collection flags.
int	supplier_collection (void) const
	Accessors to supplier collection flags.
int	supplier_filtering (void) const
	Accessors to supplier filtering flags.
const ACE_CString &	orb_id (void) const
	Accessor to ORBid.
Static Public Member Functions
static int	init_svcs (void)
Protected Member Functions
void	unsupported_option_value (const char *option_name, const char *option_value)
TAO_EC_Queue_Full_Service_Object *	find_service_object (const char *wanted, const char *fallback)
	name of ACE_Service_Object which should be invoked when output queue becomes full
Protected Attributes
int	dispatching_
	Several flags to control the kind of object created.
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.
int	dispatching_threads_flags_
	number of threads; may be ignored depending on strategy; default: TAO_EC_DEFAULT_DISPATCHING_THREADS
int	dispatching_threads_priority_
	flags for thread creation; default: TAO_EC_DEFAULT_DISPATCHING_THREADS_FLAGS
int	dispatching_threads_force_active_
	dispatching thread priority; default: TAO_EC_DEFAULT_DISPATCHING_THREADS_PRIORITY
ACE_CString	queue_full_service_object_name_
	create threads with innocuous default values if creation with requested values fails
ACE_CString	orbid_
	Use this ORB to locate global resources.
int	consumer_control_
	The consumer and supplier control policies.
int	supplier_control_
int	consumer_control_period_
	The consumer and supplier control periods in usecs.
int	supplier_control_period_
ACE_Time_Value	consumer_control_timeout_
	The consumer control timeout in usecs.
ACE_Time_Value	supplier_control_timeout_
	The supplier control timeout in usecs.
int	consumer_validate_connection_
	Validate the connection to consumer on connect.

---

Detailed Description

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.

Definition at line 47 of file EC_Default_Factory.h.

---

Constructor & Destructor Documentation

TAO_BEGIN_VERSIONED_NAMESPACE_DECL ACE_INLINE TAO_EC_Default_Factory::TAO_EC_Default_Factory

(

void

)

Constructor.

Definition at line 8 of file EC_Default_Factory.inl.

  :  dispatching_ (TAO_EC_DEFAULT_DISPATCHING),
     filtering_ (TAO_EC_DEFAULT_CONSUMER_FILTER),
     supplier_filtering_ (TAO_EC_DEFAULT_SUPPLIER_FILTER),
     timeout_ (TAO_EC_DEFAULT_TIMEOUT),
     observer_ (TAO_EC_DEFAULT_OBSERVER),
     scheduling_ (TAO_EC_DEFAULT_SCHEDULING),
     consumer_collection_ (TAO_EC_DEFAULT_CONSUMER_COLLECTION),
     supplier_collection_ (TAO_EC_DEFAULT_SUPPLIER_COLLECTION),
     consumer_lock_ (TAO_EC_DEFAULT_CONSUMER_LOCK),
     supplier_lock_ (TAO_EC_DEFAULT_SUPPLIER_LOCK),
     dispatching_threads_ (TAO_EC_DEFAULT_DISPATCHING_THREADS),
     dispatching_threads_flags_ (TAO_EC_DEFAULT_DISPATCHING_THREADS_FLAGS),
     dispatching_threads_priority_ (TAO_EC_DEFAULT_DISPATCHING_THREADS_PRIORITY),
     dispatching_threads_force_active_ (TAO_EC_DEFAULT_DISPATCHING_THREADS_FORCE_ACTIVE),
     queue_full_service_object_name_ (TAO_EC_DEFAULT_QUEUE_FULL_SERVICE_OBJECT_NAME),
     orbid_ (TAO_EC_DEFAULT_ORB_ID),
     consumer_control_ (TAO_EC_DEFAULT_CONSUMER_CONTROL),
     supplier_control_ (TAO_EC_DEFAULT_SUPPLIER_CONTROL),
     consumer_control_period_ (TAO_EC_DEFAULT_CONSUMER_CONTROL_PERIOD),
     supplier_control_period_ (TAO_EC_DEFAULT_SUPPLIER_CONTROL_PERIOD),
     consumer_control_timeout_ (0, TAO_EC_DEFAULT_CONSUMER_CONTROL_TIMEOUT),
     supplier_control_timeout_ (0, TAO_EC_DEFAULT_SUPPLIER_CONTROL_TIMEOUT),
     consumer_validate_connection_ (TAO_EC_DEFAULT_CONSUMER_VALIDATE_CONNECTION)
{
}

TAO_BEGIN_VERSIONED_NAMESPACE_DECL TAO_EC_Default_Factory::~TAO_EC_Default_Factory

(

void

)

[virtual]

destructor...

Definition at line 46 of file EC_Default_Factory.cpp.

{
}

---

Member Function Documentation

ACE_INLINE int TAO_EC_Default_Factory::consumer_collection

(

void

)

const

Accessors to consumer collection flags.

Definition at line 36 of file EC_Default_Factory.inl.

References consumer_collection_.

{
  return this->consumer_collection_;
}

TAO_EC_ConsumerAdmin * TAO_EC_Default_Factory::create_consumer_admin

(

TAO_EC_Event_Channel_Base *

)

[virtual]

Create and destroy the consumer admin implementation.

Implements TAO_EC_Factory.

Definition at line 624 of file EC_Default_Factory.cpp.

{
  return new TAO_EC_ConsumerAdmin (ec);
}

TAO_EC_ConsumerControl * TAO_EC_Default_Factory::create_consumer_control

(

TAO_EC_Event_Channel_Base *

)

[virtual]

The ConsumerControl and SupplierControl strategies are used to discard non-existent consumers and suppliers

Implements TAO_EC_Factory.

Definition at line 980 of file EC_Default_Factory.cpp.

References consumer_control_timeout_, TAO_Pseudo_Var_T< T >::in(), and CORBA::ORB_init().

{
  if (this->consumer_control_ == 0)
    return new TAO_EC_ConsumerControl ();
  else if (this->consumer_control_ == 1)
    {
      int argc = 0;
      char **argv = 0;
      CORBA::ORB_var orb =
        CORBA::ORB_init (argc, argv, this->orbid_.c_str ());

      ACE_Time_Value rate (0, this->consumer_control_period_);
      return new TAO_EC_Reactive_ConsumerControl (rate, consumer_control_timeout_, ec, orb.in ());
    }
  return 0;
}

ACE_Lock * TAO_EC_Default_Factory::create_consumer_lock

(

void

)

[virtual]

Create and destroy the locking strategies for both ProxyPushConsumers and ProxyPushSuppliers

Implements TAO_EC_Factory.

Definition at line 944 of file EC_Default_Factory.cpp.

{
  if (this->consumer_lock_ == 0)
    return new ACE_Lock_Adapter<ACE_Null_Mutex>;
  else if (this->consumer_lock_ == 1)
    return new ACE_Lock_Adapter<TAO_SYNCH_MUTEX> ();
  else if (this->consumer_lock_ == 2)
    return new ACE_Lock_Adapter<TAO_SYNCH_RECURSIVE_MUTEX> ();
  return 0;
}

TAO_EC_Dispatching * TAO_EC_Default_Factory::create_dispatching

(

TAO_EC_Event_Channel_Base *

)

[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.

Definition at line 565 of file EC_Default_Factory.cpp.

References find_service_object(), and TAO_EC_DEFAULT_QUEUE_FULL_SERVICE_OBJECT_NAME.

Referenced by TAO_EC_Sched_Factory::create_dispatching(), and TAO_EC_Kokyu_Factory::create_dispatching().

{
  if (this->dispatching_ == 0)
    return new TAO_EC_Reactive_Dispatching ();
  else if (this->dispatching_ == 1)
    {
      TAO_EC_Queue_Full_Service_Object* so =
        this->find_service_object (this->queue_full_service_object_name_.fast_rep(),
                                   TAO_EC_DEFAULT_QUEUE_FULL_SERVICE_OBJECT_NAME);
      return new TAO_EC_MT_Dispatching (this->dispatching_threads_,
                                        this->dispatching_threads_flags_,
                                        this->dispatching_threads_priority_,
                                        this->dispatching_threads_force_active_,
                                        so);
    }
  return 0;
}

TAO_EC_Filter_Builder * TAO_EC_Default_Factory::create_filter_builder

(

TAO_EC_Event_Channel_Base *

)

[virtual]

Create and destroy the filter builder.

Implements TAO_EC_Factory.

Reimplemented in TAO_EC_Kokyu_Factory, and TAO_EC_Sched_Factory.

Definition at line 590 of file EC_Default_Factory.cpp.

Referenced by TAO_EC_Sched_Factory::create_filter_builder(), and TAO_EC_Kokyu_Factory::create_filter_builder().

{
  if (this->filtering_ == 0)
    return new TAO_EC_Null_Filter_Builder ();
  else if (this->filtering_ == 1)
    return new TAO_EC_Basic_Filter_Builder (ec);
  else if (this->filtering_ == 2)
    return new TAO_EC_Prefix_Filter_Builder (ec);
  return 0;
}

TAO_EC_ObserverStrategy * TAO_EC_Default_Factory::create_observer_strategy

(

TAO_EC_Event_Channel_Base *

)

[virtual]

Create and destroy the observer strategy.

Implements TAO_EC_Factory.

Definition at line 699 of file EC_Default_Factory.cpp.

References ACE_NEW_RETURN.

{
  if (this->observer_ == 0)
    return new TAO_EC_Null_ObserverStrategy;
  else if (this->observer_ == 1)
    {
      // @@ The lock should also be under control of the user...
      ACE_Lock* lock = 0;
      ACE_NEW_RETURN (lock, ACE_Lock_Adapter<TAO_SYNCH_MUTEX>, 0);
      return new TAO_EC_Basic_ObserverStrategy (ec, lock);
    }
  else if (this->observer_ == 2)
    {
      // @@ The lock should also be under control of the user...
      ACE_Lock* lock = 0;
      ACE_NEW_RETURN (lock, ACE_Lock_Adapter<TAO_SYNCH_MUTEX>, 0);
      return new TAO_EC_Reactive_ObserverStrategy (ec, lock);
    }
  return 0;
}

TAO_EC_ProxyPushConsumer * TAO_EC_Default_Factory::create_proxy_push_consumer

(

TAO_EC_Event_Channel_Base *

)

[virtual]

Create and destroy a ProxyPushConsumer.

Implements TAO_EC_Factory.

Reimplemented in TAO_EC_TPC_Factory.

Definition at line 660 of file EC_Default_Factory.cpp.

{
  return new TAO_EC_Default_ProxyPushConsumer (ec);
}

TAO_EC_ProxyPushConsumer_Collection * TAO_EC_Default_Factory::create_proxy_push_consumer_collection

(

TAO_EC_Event_Channel_Base *

)

[virtual]

Create and destroy a collection of TAO_EC_ProxyPushConsumers.

Implements TAO_EC_Factory.

Definition at line 758 of file EC_Default_Factory.cpp.

References ACE_NULL_SYNCH, ACE_SYNCH, and TAO_SYNCH_MUTEX.

{
  if (this->consumer_collection_ == 0x000)
    return new TAO_ESF_Immediate_Changes<TAO_EC_ProxyPushConsumer,
      TAO_ESF_Proxy_List<TAO_EC_ProxyPushConsumer>,
      TAO_EC_Consumer_List_Iterator,
      TAO_SYNCH_MUTEX> ();
  else if (this->consumer_collection_ == 0x001)
    return new TAO_ESF_Copy_On_Read<TAO_EC_ProxyPushConsumer,
      TAO_ESF_Proxy_List<TAO_EC_ProxyPushConsumer>,
      TAO_EC_Consumer_List_Iterator,
      TAO_SYNCH_MUTEX> ();
  else if (this->consumer_collection_ == 0x002)
    return new TAO_ESF_Copy_On_Write<TAO_EC_ProxyPushConsumer,
      TAO_ESF_Proxy_List<TAO_EC_ProxyPushConsumer>,
      TAO_EC_Consumer_List_Iterator,
      ACE_SYNCH> ();
  else if (this->consumer_collection_ == 0x003)
    return new TAO_ESF_Delayed_Changes<TAO_EC_ProxyPushConsumer,
      TAO_ESF_Proxy_List<TAO_EC_ProxyPushConsumer>,
      TAO_EC_Consumer_List_Iterator,
      ACE_SYNCH> ();
  else if (this->consumer_collection_ == 0x010)
    return new TAO_ESF_Immediate_Changes<TAO_EC_ProxyPushConsumer,
      TAO_ESF_Proxy_RB_Tree<TAO_EC_ProxyPushConsumer>,
      TAO_EC_Consumer_RB_Tree_Iterator,
      TAO_SYNCH_MUTEX> ();
  else if (this->consumer_collection_ == 0x011)
    return new TAO_ESF_Copy_On_Read<TAO_EC_ProxyPushConsumer,
      TAO_ESF_Proxy_RB_Tree<TAO_EC_ProxyPushConsumer>,
      TAO_EC_Consumer_RB_Tree_Iterator,
      TAO_SYNCH_MUTEX> ();
  else if (this->consumer_collection_ == 0x012)
    return new TAO_ESF_Copy_On_Write<TAO_EC_ProxyPushConsumer,
      TAO_ESF_Proxy_RB_Tree<TAO_EC_ProxyPushConsumer>,
      TAO_EC_Consumer_RB_Tree_Iterator,
      ACE_SYNCH> ();
  else if (this->consumer_collection_ == 0x013)
    return new TAO_ESF_Delayed_Changes<TAO_EC_ProxyPushConsumer,
      TAO_ESF_Proxy_RB_Tree<TAO_EC_ProxyPushConsumer>,
      TAO_EC_Consumer_RB_Tree_Iterator,
      ACE_SYNCH> ();
  else if (this->consumer_collection_ == 0x100)
    return new TAO_ESF_Immediate_Changes<TAO_EC_ProxyPushConsumer,
      TAO_ESF_Proxy_List<TAO_EC_ProxyPushConsumer>,
      TAO_EC_Consumer_List_Iterator,
      ACE_Null_Mutex> ();
  else if (this->consumer_collection_ == 0x101)
    return new TAO_ESF_Copy_On_Read<TAO_EC_ProxyPushConsumer,
      TAO_ESF_Proxy_List<TAO_EC_ProxyPushConsumer>,
      TAO_EC_Consumer_List_Iterator,
      ACE_Null_Mutex> ();
  else if (this->consumer_collection_ == 0x102)
    return new TAO_ESF_Copy_On_Write<TAO_EC_ProxyPushConsumer,
      TAO_ESF_Proxy_List<TAO_EC_ProxyPushConsumer>,
      TAO_EC_Consumer_List_Iterator,
      ACE_NULL_SYNCH> ();
  else if (this->consumer_collection_ == 0x103)
    return new TAO_ESF_Delayed_Changes<TAO_EC_ProxyPushConsumer,
      TAO_ESF_Proxy_List<TAO_EC_ProxyPushConsumer>,
      TAO_EC_Consumer_List_Iterator,
      ACE_NULL_SYNCH> ();
  else if (this->consumer_collection_ == 0x110)
    return new TAO_ESF_Immediate_Changes<TAO_EC_ProxyPushConsumer,
      TAO_ESF_Proxy_RB_Tree<TAO_EC_ProxyPushConsumer>,
      TAO_EC_Consumer_RB_Tree_Iterator,
      ACE_Null_Mutex> ();
  else if (this->consumer_collection_ == 0x111)
    return new TAO_ESF_Copy_On_Read<TAO_EC_ProxyPushConsumer,
      TAO_ESF_Proxy_RB_Tree<TAO_EC_ProxyPushConsumer>,
      TAO_EC_Consumer_RB_Tree_Iterator,
      ACE_Null_Mutex> ();
  else if (this->consumer_collection_ == 0x112)
    return new TAO_ESF_Copy_On_Write<TAO_EC_ProxyPushConsumer,
      TAO_ESF_Proxy_RB_Tree<TAO_EC_ProxyPushConsumer>,
      TAO_EC_Consumer_RB_Tree_Iterator,
      ACE_NULL_SYNCH> ();
  else if (this->consumer_collection_ == 0x113)
    return new TAO_ESF_Delayed_Changes<TAO_EC_ProxyPushConsumer,
      TAO_ESF_Proxy_RB_Tree<TAO_EC_ProxyPushConsumer>,
      TAO_EC_Consumer_RB_Tree_Iterator,
      ACE_NULL_SYNCH> ();

  return 0;
}

TAO_EC_ProxyPushSupplier * TAO_EC_Default_Factory::create_proxy_push_supplier

(

TAO_EC_Event_Channel_Base *

)

[virtual]

Create and destroy a ProxyPushSupplier.

Implements TAO_EC_Factory.

Reimplemented in TAO_EC_TPC_Factory.

Definition at line 648 of file EC_Default_Factory.cpp.

References consumer_validate_connection_.

{
  return new TAO_EC_Default_ProxyPushSupplier (ec, consumer_validate_connection_);
}

TAO_EC_ProxyPushSupplier_Collection * TAO_EC_Default_Factory::create_proxy_push_supplier_collection

(

TAO_EC_Event_Channel_Base *

)

[virtual]

Create and destroy a collection of TAO_EC_ProxyPushSuppliers.

Implements TAO_EC_Factory.

Definition at line 851 of file EC_Default_Factory.cpp.

References ACE_NULL_SYNCH, ACE_SYNCH, and TAO_SYNCH_MUTEX.

{
  if (this->supplier_collection_ == 0x000)
    return new TAO_ESF_Immediate_Changes<TAO_EC_ProxyPushSupplier,
      TAO_ESF_Proxy_List<TAO_EC_ProxyPushSupplier>,
      TAO_EC_Supplier_List_Iterator,
      TAO_SYNCH_MUTEX> ();
  else if (this->supplier_collection_ == 0x001)
    return new TAO_ESF_Copy_On_Read<TAO_EC_ProxyPushSupplier,
      TAO_ESF_Proxy_List<TAO_EC_ProxyPushSupplier>,
      TAO_EC_Supplier_List_Iterator,
      TAO_SYNCH_MUTEX> ();
  else if (this->supplier_collection_ == 0x002)
    return new TAO_ESF_Copy_On_Write<TAO_EC_ProxyPushSupplier,
      TAO_ESF_Proxy_List<TAO_EC_ProxyPushSupplier>,
      TAO_EC_Supplier_List_Iterator,
      ACE_SYNCH> ();
  else if (this->supplier_collection_ == 0x003)
    return new TAO_ESF_Delayed_Changes<TAO_EC_ProxyPushSupplier,
      TAO_ESF_Proxy_List<TAO_EC_ProxyPushSupplier>,
      TAO_EC_Supplier_List_Iterator,
      ACE_SYNCH> ();
  else if (this->supplier_collection_ == 0x010)
    return new TAO_ESF_Immediate_Changes<TAO_EC_ProxyPushSupplier,
      TAO_ESF_Proxy_RB_Tree<TAO_EC_ProxyPushSupplier>,
      TAO_EC_Supplier_RB_Tree_Iterator,
      TAO_SYNCH_MUTEX> ();
  else if (this->supplier_collection_ == 0x011)
    return new TAO_ESF_Copy_On_Read<TAO_EC_ProxyPushSupplier,
      TAO_ESF_Proxy_RB_Tree<TAO_EC_ProxyPushSupplier>,
      TAO_EC_Supplier_RB_Tree_Iterator,
      TAO_SYNCH_MUTEX> ();
  else if (this->supplier_collection_ == 0x012)
    return new TAO_ESF_Copy_On_Write<TAO_EC_ProxyPushSupplier,
      TAO_ESF_Proxy_RB_Tree<TAO_EC_ProxyPushSupplier>,
      TAO_EC_Supplier_RB_Tree_Iterator,
      ACE_SYNCH> ();
  else if (this->supplier_collection_ == 0x013)
    return new TAO_ESF_Delayed_Changes<TAO_EC_ProxyPushSupplier,
      TAO_ESF_Proxy_RB_Tree<TAO_EC_ProxyPushSupplier>,
      TAO_EC_Supplier_RB_Tree_Iterator,
      ACE_SYNCH> ();
  else if (this->supplier_collection_ == 0x100)
    return new TAO_ESF_Immediate_Changes<TAO_EC_ProxyPushSupplier,
      TAO_ESF_Proxy_List<TAO_EC_ProxyPushSupplier>,
      TAO_EC_Supplier_List_Iterator,
      ACE_Null_Mutex> ();
  else if (this->supplier_collection_ == 0x101)
    return new TAO_ESF_Copy_On_Read<TAO_EC_ProxyPushSupplier,
      TAO_ESF_Proxy_List<TAO_EC_ProxyPushSupplier>,
      TAO_EC_Supplier_List_Iterator,
      ACE_Null_Mutex> ();
  else if (this->supplier_collection_ == 0x102)
    return new TAO_ESF_Copy_On_Write<TAO_EC_ProxyPushSupplier,
      TAO_ESF_Proxy_List<TAO_EC_ProxyPushSupplier>,
      TAO_EC_Supplier_List_Iterator,
      ACE_NULL_SYNCH> ();
  else if (this->supplier_collection_ == 0x103)
    return new TAO_ESF_Delayed_Changes<TAO_EC_ProxyPushSupplier,
      TAO_ESF_Proxy_List<TAO_EC_ProxyPushSupplier>,
      TAO_EC_Supplier_List_Iterator,
      ACE_NULL_SYNCH> ();
  else if (this->supplier_collection_ == 0x110)
    return new TAO_ESF_Immediate_Changes<TAO_EC_ProxyPushSupplier,
      TAO_ESF_Proxy_RB_Tree<TAO_EC_ProxyPushSupplier>,
      TAO_EC_Supplier_RB_Tree_Iterator,
      ACE_Null_Mutex> ();
  else if (this->supplier_collection_ == 0x111)
    return new TAO_ESF_Copy_On_Read<TAO_EC_ProxyPushSupplier,
      TAO_ESF_Proxy_RB_Tree<TAO_EC_ProxyPushSupplier>,
      TAO_EC_Supplier_RB_Tree_Iterator,
      ACE_Null_Mutex> ();
  else if (this->supplier_collection_ == 0x112)
    return new TAO_ESF_Copy_On_Write<TAO_EC_ProxyPushSupplier,
      TAO_ESF_Proxy_RB_Tree<TAO_EC_ProxyPushSupplier>,
      TAO_EC_Supplier_RB_Tree_Iterator,
      ACE_NULL_SYNCH> ();
  else if (this->supplier_collection_ == 0x113)
    return new TAO_ESF_Delayed_Changes<TAO_EC_ProxyPushSupplier,
      TAO_ESF_Proxy_RB_Tree<TAO_EC_ProxyPushSupplier>,
      TAO_EC_Supplier_RB_Tree_Iterator,
      ACE_NULL_SYNCH> ();

  return 0;
}

TAO_EC_Scheduling_Strategy * TAO_EC_Default_Factory::create_scheduling_strategy

(

TAO_EC_Event_Channel_Base *

)

[virtual]

Create and destroy the observer strategy.

Implements TAO_EC_Factory.

Reimplemented in TAO_EC_Kokyu_Factory, and TAO_EC_Sched_Factory.

Definition at line 727 of file EC_Default_Factory.cpp.

Referenced by TAO_EC_Kokyu_Factory::create_scheduling_strategy().

{
  if (this->scheduling_ == 0)
    return new TAO_EC_Null_Scheduling;
  else if (this->scheduling_ == 1)
    return new TAO_EC_Group_Scheduling;
  return 0;
}

TAO_EC_SupplierAdmin * TAO_EC_Default_Factory::create_supplier_admin

(

TAO_EC_Event_Channel_Base *

)

[virtual]

Create and destroy the supplier admin implementation.

Implements TAO_EC_Factory.

Definition at line 636 of file EC_Default_Factory.cpp.

{
  return new TAO_EC_SupplierAdmin (ec);
}

TAO_EC_SupplierControl * TAO_EC_Default_Factory::create_supplier_control

(

TAO_EC_Event_Channel_Base *

)

[virtual]

Implements TAO_EC_Factory.

Definition at line 1004 of file EC_Default_Factory.cpp.

References TAO_Pseudo_Var_T< T >::in(), CORBA::ORB_init(), and supplier_control_timeout_.

{
  if (this->supplier_control_ == 0)
    return new TAO_EC_SupplierControl ();
  else if (this->supplier_control_ == 1)
    {
      int argc = 0;
      char **argv = 0;
      CORBA::ORB_var orb =
        CORBA::ORB_init (argc, argv, this->orbid_.c_str ());

      ACE_Time_Value rate (0, this->supplier_control_period_);
      return new TAO_EC_Reactive_SupplierControl (rate, supplier_control_timeout_, ec, orb.in ());
    }
  return 0;
}

TAO_EC_Supplier_Filter_Builder * TAO_EC_Default_Factory::create_supplier_filter_builder

(

TAO_EC_Event_Channel_Base *

)

[virtual]

Create and destroy the filter builder.

Implements TAO_EC_Factory.

Definition at line 608 of file EC_Default_Factory.cpp.

{
  if (this->supplier_filtering_ == 0)
    return new TAO_EC_Trivial_Supplier_Filter_Builder (ec);
  else if (this->supplier_filtering_ == 1)
    return new TAO_EC_Per_Supplier_Filter_Builder (ec);
  return 0;
}

ACE_Lock * TAO_EC_Default_Factory::create_supplier_lock

(

void

)

[virtual]

Implements TAO_EC_Factory.

Definition at line 962 of file EC_Default_Factory.cpp.

{
  if (this->supplier_lock_ == 0)
    return new ACE_Lock_Adapter<ACE_Null_Mutex>;
  else if (this->supplier_lock_ == 1)
    return new ACE_Lock_Adapter<TAO_SYNCH_MUTEX> ();
  else if (this->supplier_lock_ == 2)
    return new ACE_Lock_Adapter<TAO_SYNCH_RECURSIVE_MUTEX> ();
  return 0;
}

TAO_EC_Timeout_Generator * TAO_EC_Default_Factory::create_timeout_generator

(

TAO_EC_Event_Channel_Base *

)

[virtual]

Create and destroy the timer module.

Implements TAO_EC_Factory.

Reimplemented in TAO_EC_Kokyu_Factory, and TAO_EC_Sched_Factory.

Definition at line 672 of file EC_Default_Factory.cpp.

References CORBA::ORB_init(), and ACE_Event_Handler::reactor().

Referenced by TAO_EC_Sched_Factory::create_timeout_generator(), and TAO_EC_Kokyu_Factory::create_timeout_generator().

{
  if (this->timeout_ == 0)
    {
      int argc = 0;
      char **argv = 0;
      CORBA::ORB_var orb =
        CORBA::ORB_init (argc, argv, this->orbid_.c_str ());

      ACE_Reactor *reactor = orb->orb_core ()->reactor ();
      return new TAO_EC_Reactive_Timeout_Generator (reactor);
    }
#if 0
  else if (this->timeout_ == 1)
    {
    }
#endif
  return 0;
}

void TAO_EC_Default_Factory::destroy_consumer_admin

(

TAO_EC_ConsumerAdmin *

)

[virtual]

Implements TAO_EC_Factory.

Definition at line 630 of file EC_Default_Factory.cpp.

{
  delete x;
}

void TAO_EC_Default_Factory::destroy_consumer_control

(

TAO_EC_ConsumerControl *

)

[virtual]

Implements TAO_EC_Factory.

Definition at line 998 of file EC_Default_Factory.cpp.

{
  delete x;
}

void TAO_EC_Default_Factory::destroy_consumer_lock

(

ACE_Lock *

)

[virtual]

Implements TAO_EC_Factory.

Definition at line 956 of file EC_Default_Factory.cpp.

{
  delete x;
}

void TAO_EC_Default_Factory::destroy_dispatching

(

TAO_EC_Dispatching *

)

[virtual]

Implements TAO_EC_Factory.

Definition at line 584 of file EC_Default_Factory.cpp.

{
  delete x;
}

void TAO_EC_Default_Factory::destroy_filter_builder

(

TAO_EC_Filter_Builder *

)

[virtual]

Implements TAO_EC_Factory.

Definition at line 602 of file EC_Default_Factory.cpp.

{
  delete x;
}

void TAO_EC_Default_Factory::destroy_observer_strategy

(

TAO_EC_ObserverStrategy *

)

[virtual]

Implements TAO_EC_Factory.

Definition at line 721 of file EC_Default_Factory.cpp.

{
  delete x;
}

void TAO_EC_Default_Factory::destroy_proxy_push_consumer

(

TAO_EC_ProxyPushConsumer *

)

[virtual]

Implements TAO_EC_Factory.

Definition at line 666 of file EC_Default_Factory.cpp.

{
  delete x;
}

void TAO_EC_Default_Factory::destroy_proxy_push_consumer_collection

(

TAO_EC_ProxyPushConsumer_Collection *

)

[virtual]

Implements TAO_EC_Factory.

Definition at line 845 of file EC_Default_Factory.cpp.

{
  delete x;
}

void TAO_EC_Default_Factory::destroy_proxy_push_supplier

(

TAO_EC_ProxyPushSupplier *

)

[virtual]

Implements TAO_EC_Factory.

Definition at line 654 of file EC_Default_Factory.cpp.

{
  delete x;
}

void TAO_EC_Default_Factory::destroy_proxy_push_supplier_collection

(

TAO_EC_ProxyPushSupplier_Collection *

)

[virtual]

Implements TAO_EC_Factory.

Definition at line 938 of file EC_Default_Factory.cpp.

{
  delete x;
}

void TAO_EC_Default_Factory::destroy_scheduling_strategy

(

TAO_EC_Scheduling_Strategy *

)

[virtual]

Implements TAO_EC_Factory.

Definition at line 737 of file EC_Default_Factory.cpp.

{
  delete x;
}

void TAO_EC_Default_Factory::destroy_supplier_admin

(

TAO_EC_SupplierAdmin *

)

[virtual]

Implements TAO_EC_Factory.

Definition at line 642 of file EC_Default_Factory.cpp.

{
  delete x;
}

void TAO_EC_Default_Factory::destroy_supplier_control

(

TAO_EC_SupplierControl *

)

[virtual]

Implements TAO_EC_Factory.

Definition at line 1022 of file EC_Default_Factory.cpp.

{
  delete x;
}

void TAO_EC_Default_Factory::destroy_supplier_filter_builder

(

TAO_EC_Supplier_Filter_Builder *

)

[virtual]

Implements TAO_EC_Factory.

Definition at line 618 of file EC_Default_Factory.cpp.

{
  delete x;
}

void TAO_EC_Default_Factory::destroy_supplier_lock

(

ACE_Lock *

)

[virtual]

Implements TAO_EC_Factory.

Definition at line 974 of file EC_Default_Factory.cpp.

{
  delete x;
}

void TAO_EC_Default_Factory::destroy_timeout_generator

(

TAO_EC_Timeout_Generator *

)

[virtual]

Implements TAO_EC_Factory.

Definition at line 693 of file EC_Default_Factory.cpp.

{
  delete x;
}

TAO_EC_Queue_Full_Service_Object * TAO_EC_Default_Factory::find_service_object	(	const char *	wanted,
		const char *	fallback
	)			[protected]

name of ACE_Service_Object which should be invoked when output queue becomes full

Definition at line 536 of file EC_Default_Factory.cpp.

References ACE_OS::abort(), ACE_ERROR, ACE_Dynamic_Service< TYPE >::instance(), and LM_ERROR.

Referenced by TAO_EC_TPC_Factory::create_dispatching(), and create_dispatching().

{
  TAO_EC_Queue_Full_Service_Object* so = 0;
  so = ACE_Dynamic_Service<TAO_EC_Queue_Full_Service_Object>::instance (wanted);
  if (so != 0)
    return so;

  ACE_ERROR ((LM_ERROR,
              "EC (%P|%t) EC_Default_Factory::find_service_object "
              "unable to find queue full service object '%s'; "
              "using '%s' instead\n",
              wanted,
              fallback));

  so = ACE_Dynamic_Service<TAO_EC_Queue_Full_Service_Object>::instance (fallback);
  if (so != 0)
    return so;

  ACE_ERROR ((LM_ERROR,
              "EC (%P|%t) EC_Default_Factory::find_service_object "
                      "unable find default queue full service object '%s'; "
                      "aborting.\n",
                      fallback));
  ACE_OS::abort ();
  return 0; // superfluous return to de-warn; we should never reach here
}

int TAO_EC_Default_Factory::fini

(

void

)

[virtual]

Reimplemented from ACE_Shared_Object.

Reimplemented in TAO_EC_Kokyu_Factory, and TAO_EC_Sched_Factory.

Definition at line 528 of file EC_Default_Factory.cpp.

{
  return 0;
}

int TAO_EC_Default_Factory::init	(	int	argc,
		ACE_TCHAR *	argv[]
	)			[virtual]

Reimplemented from ACE_Shared_Object.

Reimplemented in TAO_EC_Kokyu_Factory, TAO_EC_Sched_Factory, and TAO_EC_TPC_Factory.

Definition at line 71 of file EC_Default_Factory.cpp.

References ACE_DEBUG, ACE_ERROR, ACE_SCHED_FIFO, ACE_TEXT(), ACE_TEXT_ALWAYS_CHAR, ACE_TEXT_CHAR_TO_TCHAR, ACE_OS::atoi(), ACE_Arg_Shifter_T< CHAR_TYPE >::consume_arg(), consumer_collection_, consumer_control_, consumer_control_period_, consumer_control_timeout_, consumer_lock_, consumer_validate_connection_, TAO_EC_Thread_Flags::default_priority(), dispatching_, dispatching_threads_, dispatching_threads_flags_, dispatching_threads_priority_, filtering_, TAO_EC_Thread_Flags::flags(), ACE_OS::free(), ACE_Arg_Shifter_T< CHAR_TYPE >::get_current(), ACE_Arg_Shifter_T< CHAR_TYPE >::is_anything_left(), ACE_Arg_Shifter_T< CHAR_TYPE >::is_parameter_next(), LM_DEBUG, LM_ERROR, ACE_Sched_Params::next_priority(), observer_, ACE_Event_Handler::priority(), ACE_Sched_Params::priority_max(), ACE_Sched_Params::priority_min(), queue_full_service_object_name_, scheduling_, ACE_String_Base< CHAR >::set(), ACE_OS::strcasecmp(), ACE_OS::strdup(), ACE_OS::strncmp(), ACE_OS::strtok_r(), ACE_OS::strtol(), ACE_OS::strtoul(), supplier_collection_, supplier_control_, supplier_control_period_, supplier_control_timeout_, supplier_filtering_, supplier_lock_, timeout_, unsupported_option_value(), and ACE_Time_Value::usec().

Referenced by TAO_EC_TPC_Factory::init(), TAO_EC_Sched_Factory::init(), and TAO_EC_Kokyu_Factory::init().

{
  ACE_Arg_Shifter arg_shifter (argc, argv);

  int priority =
    (ACE_Sched_Params::priority_min (ACE_SCHED_FIFO) +
     ACE_Sched_Params::priority_max (ACE_SCHED_FIFO)) / 2;
  this->dispatching_threads_priority_ =
    ACE_Sched_Params::next_priority (ACE_SCHED_FIFO, priority);

  while (arg_shifter.is_anything_left ())
    {
      const ACE_TCHAR *arg = arg_shifter.get_current ();

      if (ACE_OS::strcasecmp (arg, ACE_TEXT("-ECDispatching")) == 0)
        {
          arg_shifter.consume_arg ();

          if (arg_shifter.is_parameter_next ())
            {
              const ACE_TCHAR* opt = arg_shifter.get_current ();
              if (ACE_OS::strcasecmp (opt, ACE_TEXT("reactive")) == 0)
                this->dispatching_ = 0;
              else if (ACE_OS::strcasecmp (opt, ACE_TEXT("mt")) == 0)
                this->dispatching_ = 1;
              else
                  this->unsupported_option_value ("-ECDispatching", opt);
              arg_shifter.consume_arg ();
            }
        }
      else if (ACE_OS::strcasecmp (arg, ACE_TEXT("-ECDispatchingThreadFlags")) == 0)
        {
          arg_shifter.consume_arg ();

          // Need to be in the form of <flags>:<priority>
          if (arg_shifter.is_parameter_next ())
            {
              const ACE_TCHAR* s = arg_shifter.get_current ();
              // need to parse the flags...ugh
              ACE_TCHAR* opt = ACE_OS::strdup (s);

              ACE_TCHAR* aux;
              ACE_TCHAR* flags = ACE_OS::strtok_r (opt, ACE_TEXT_CHAR_TO_TCHAR(":"), &aux);

              TAO_EC_Thread_Flags tf(ACE_TEXT_ALWAYS_CHAR (flags)); // parse and set up
              this->dispatching_threads_flags_ = tf.flags ();

              ACE_TCHAR* arg = ACE_OS::strtok_r (0, ACE_TEXT_CHAR_TO_TCHAR(":"), &aux);
              if (arg)
                {
                  long prio = ACE_OS::strtol (arg, 0, 0);

                  this->dispatching_threads_priority_ = prio;
                }
              else
                {
                  // Should we set the default priority?
                  this->dispatching_threads_priority_ = tf.default_priority ();
                }
              ACE_OS::free (opt);
              arg_shifter.consume_arg ();
            }
        }

      else if (ACE_OS::strcasecmp (arg, ACE_TEXT("-ECDispatchingThreads")) == 0)
        {
          arg_shifter.consume_arg ();

          if (arg_shifter.is_parameter_next ())
            {
              const ACE_TCHAR* opt = arg_shifter.get_current ();
              this->dispatching_threads_ = ACE_OS::atoi (opt);
              arg_shifter.consume_arg ();
            }
        }

      else if (ACE_OS::strcasecmp (arg, ACE_TEXT("-ECFiltering")) == 0)
        {
          arg_shifter.consume_arg ();

          if (arg_shifter.is_parameter_next ())
            {
              const ACE_TCHAR* opt = arg_shifter.get_current ();
              if (ACE_OS::strcasecmp (opt, ACE_TEXT("null")) == 0)
                this->filtering_ = 0;
              else if (ACE_OS::strcasecmp (opt, ACE_TEXT("basic")) == 0)
                this->filtering_ = 1;
              else if (ACE_OS::strcasecmp (opt, ACE_TEXT("prefix")) == 0)
                this->filtering_ = 2;
              else
                  this->unsupported_option_value ("-ECFiltering", opt);
              arg_shifter.consume_arg ();
            }
        }

      else if (ACE_OS::strcasecmp (arg, ACE_TEXT("-ECSupplierFilter")) == 0
               // @@ TODO remove, only for backwards compatibility
               || ACE_OS::strcasecmp (arg, ACE_TEXT("-ECSupplierFiltering")) == 0)
        {
          arg_shifter.consume_arg ();

          if (arg_shifter.is_parameter_next ())
            {
              const ACE_TCHAR* opt = arg_shifter.get_current ();
              if (ACE_OS::strcasecmp (opt, ACE_TEXT("null")) == 0)
                this->supplier_filtering_ = 0;
              else if (ACE_OS::strcasecmp (opt, ACE_TEXT("per-supplier")) == 0)
                this->supplier_filtering_ = 1;
              else
                  this->unsupported_option_value ("-ECSupplierFilter", opt);
              arg_shifter.consume_arg ();
            }
        }

      else if (ACE_OS::strcasecmp (arg, ACE_TEXT("-ECTimeout")) == 0)
        {
          arg_shifter.consume_arg ();

          if (arg_shifter.is_parameter_next ())
            {
              const ACE_TCHAR* opt = arg_shifter.get_current ();
              if (ACE_OS::strcasecmp (opt, ACE_TEXT("reactive")) == 0)
                this->timeout_ = 0;
              else
                  this->unsupported_option_value ("-ECTimeout", opt);
              arg_shifter.consume_arg ();
            }
        }

      else if (ACE_OS::strcasecmp (arg, ACE_TEXT("-ECObserver")) == 0)
        {
          arg_shifter.consume_arg ();

          if (arg_shifter.is_parameter_next ())
            {
              const ACE_TCHAR* opt = arg_shifter.get_current ();
              if (ACE_OS::strcasecmp (opt, ACE_TEXT("null")) == 0)
                this->observer_ = 0;
              else if (ACE_OS::strcasecmp (opt, ACE_TEXT("basic")) == 0)
                this->observer_ = 1;
              else if (ACE_OS::strcasecmp (opt, ACE_TEXT("reactive")) == 0)
                this->observer_ = 2;
              else
                  this->unsupported_option_value ("-ECObserver", opt);
              arg_shifter.consume_arg ();
            }
        }

      else if (ACE_OS::strcasecmp (arg, ACE_TEXT("-ECScheduling")) == 0)
        {
          arg_shifter.consume_arg ();

          if (arg_shifter.is_parameter_next ())
            {
              const ACE_TCHAR* opt = arg_shifter.get_current ();
              if (ACE_OS::strcasecmp (opt, ACE_TEXT("null")) == 0)
                this->scheduling_ = 0;
              else if (ACE_OS::strcasecmp (opt, ACE_TEXT("group")) == 0)
                this->scheduling_ = 1;
              else
                  this->unsupported_option_value ("-ECScheduling", opt);
              arg_shifter.consume_arg ();
            }
        }

      else if (ACE_OS::strcasecmp (arg, ACE_TEXT("-ECProxyPushConsumerCollection")) == 0)
        {
          arg_shifter.consume_arg ();

          if (arg_shifter.is_parameter_next ())
            {
              const ACE_TCHAR *current_arg = arg_shifter.get_current ();
              ACE_TCHAR *opt = ACE_OS::strdup (current_arg);
              int collection_type = 0;
              int synch_type = 0;
              int iteration_type = 0;

              ACE_TCHAR* aux;
              for (ACE_TCHAR* arg = ACE_OS::strtok_r (opt, ACE_TEXT(":"), &aux);
                   arg != 0;
                   arg = ACE_OS::strtok_r (0, ACE_TEXT(":"), &aux))
                {
                  if (ACE_OS::strcasecmp (arg, ACE_TEXT("mt")) == 0)
                    synch_type = 0;
                  else if (ACE_OS::strcasecmp (arg, ACE_TEXT("st")) == 0)
                    synch_type = 1;
                  else if (ACE_OS::strcasecmp (arg, ACE_TEXT("list")) == 0)
                    collection_type = 0;
                  else if (ACE_OS::strcasecmp (arg, ACE_TEXT("rb_tree")) == 0)
                    collection_type = 1;
                  else if (ACE_OS::strcasecmp (arg, ACE_TEXT("immediate")) == 0)
                    iteration_type = 0;
                  else if (ACE_OS::strcasecmp (arg, ACE_TEXT("copy_on_read")) == 0)
                    iteration_type = 1;
                  else if (ACE_OS::strcasecmp (arg, ACE_TEXT("copy_on_write")) == 0)
                    iteration_type = 2;
                  else if (ACE_OS::strcasecmp (arg, ACE_TEXT("delayed")) == 0)
                    iteration_type = 3;
                  else
                    ACE_ERROR ((LM_ERROR,
                                "EC_Default_Factory - "
                                "Unknown consumer collection modifier <%s>.\n", arg));
                }
              ACE_OS::free (opt);
              this->consumer_collection_ =
                 (synch_type << 8) |(collection_type << 4) | iteration_type;
              arg_shifter.consume_arg ();
            }
        }

      else if (ACE_OS::strcasecmp (arg, ACE_TEXT("-ECProxyPushSupplierCollection")) == 0)
        {
          arg_shifter.consume_arg ();

          if (arg_shifter.is_parameter_next ())
            {
              const ACE_TCHAR* current_arg = arg_shifter.get_current();
              ACE_TCHAR* opt = ACE_OS::strdup(current_arg);
              int collection_type = 0;
              int synch_type = 0;
              int iteration_type = 0;

              ACE_TCHAR* aux;
              for (ACE_TCHAR* arg = ACE_OS::strtok_r (opt, ACE_TEXT(":"), &aux);
                   arg != 0;
                   arg = ACE_OS::strtok_r (0, ACE_TEXT(":"), &aux))
                {
                  if (ACE_OS::strcasecmp (arg, ACE_TEXT("mt")) == 0)
                    synch_type = 0;
                  else if (ACE_OS::strcasecmp (arg, ACE_TEXT("st")) == 0)
                    synch_type = 1;
                  else if (ACE_OS::strcasecmp (arg, ACE_TEXT("list")) == 0)
                    collection_type = 0;
                  else if (ACE_OS::strcasecmp (arg, ACE_TEXT("rb_tree")) == 0)
                    collection_type = 1;
                  else if (ACE_OS::strcasecmp (arg, ACE_TEXT("immediate")) == 0)
                    iteration_type = 0;
                  else if (ACE_OS::strcasecmp (arg, ACE_TEXT("copy_on_read")) == 0)
                    iteration_type = 1;
                  else if (ACE_OS::strcasecmp (arg, ACE_TEXT("copy_on_write")) == 0)
                    iteration_type = 2;
                  else if (ACE_OS::strcasecmp (arg, ACE_TEXT("delayed")) == 0)
                    iteration_type = 3;
                  else
                    ACE_ERROR ((LM_ERROR,
                                "EC_Default_Factory - "
                                "Unknown supplier collection modifier <%s>.\n", arg));
                }
              ACE_OS::free(opt);
              this->supplier_collection_ =
                (synch_type << 8) | (collection_type << 4) | iteration_type;
              arg_shifter.consume_arg ();
            }
        }

      else if (ACE_OS::strcasecmp (arg, ACE_TEXT("-ECProxyConsumerLock")) == 0)
        {
          arg_shifter.consume_arg ();

          if (arg_shifter.is_parameter_next ())
            {
              const ACE_TCHAR* opt = arg_shifter.get_current ();
              if (ACE_OS::strcasecmp (opt, ACE_TEXT("null")) == 0)
                this->consumer_lock_ = 0;
              else if (ACE_OS::strcasecmp (opt, ACE_TEXT("thread")) == 0)
                this->consumer_lock_ = 1;
              else if (ACE_OS::strcasecmp (opt, ACE_TEXT("recursive")) == 0)
                this->consumer_lock_ = 2;
              else
                this->unsupported_option_value ("-ECProxyConsumerLock", opt);
              arg_shifter.consume_arg ();
            }
        }

      else if (ACE_OS::strcasecmp (arg, ACE_TEXT("-ECProxySupplierLock")) == 0)
        {
          arg_shifter.consume_arg ();

          if (arg_shifter.is_parameter_next ())
            {
              const ACE_TCHAR* opt = arg_shifter.get_current ();
              if (ACE_OS::strcasecmp (opt, ACE_TEXT("null")) == 0)
                this->supplier_lock_ = 0;
              else if (ACE_OS::strcasecmp (opt, ACE_TEXT("thread")) == 0)
                this->supplier_lock_ = 1;
              else if (ACE_OS::strcasecmp (opt, ACE_TEXT("recursive")) == 0)
                this->supplier_lock_ = 2;
              else
                this->unsupported_option_value ("-ECProxySupplierLock", opt);
              arg_shifter.consume_arg ();
            }
        }

      else if (ACE_OS::strcasecmp (arg, ACE_TEXT("-ECUseORBId")) == 0)
        {
          arg_shifter.consume_arg ();

          if (arg_shifter.is_parameter_next ())
            {
              // Save argument for later use
              this->orbid_ = ACE_TEXT_ALWAYS_CHAR(arg_shifter.get_current ());
              arg_shifter.consume_arg ();
            }
        }

      else if (ACE_OS::strcasecmp (arg, ACE_TEXT("-ECConsumerControl")) == 0)
        {
          arg_shifter.consume_arg ();

          if (arg_shifter.is_parameter_next ())
            {
              const ACE_TCHAR* opt = arg_shifter.get_current ();
              if (ACE_OS::strcasecmp (opt, ACE_TEXT("null")) == 0)
                this->consumer_control_ = 0;
              else if (ACE_OS::strcasecmp (opt, ACE_TEXT("reactive")) == 0)
                this->consumer_control_ = 1;
              else
                this->unsupported_option_value ("-ECConsumerControl", opt);
              arg_shifter.consume_arg ();
            }
        }

      else if (ACE_OS::strcasecmp (arg, ACE_TEXT("-ECSupplierControl")) == 0)
        {
          arg_shifter.consume_arg ();

          if (arg_shifter.is_parameter_next ())
            {
              const ACE_TCHAR* opt = arg_shifter.get_current ();
              if (ACE_OS::strcasecmp (opt, ACE_TEXT("null")) == 0)
                this->supplier_control_ = 0;
              else if (ACE_OS::strcasecmp (opt, ACE_TEXT("reactive")) == 0)
                this->supplier_control_ = 1;
              else
                this->unsupported_option_value ("-ECSupplierControl", opt);
              arg_shifter.consume_arg ();
            }
        }

      else if (ACE_OS::strcasecmp (arg, ACE_TEXT("-ECConsumerControlPeriod")) == 0)
        {
          arg_shifter.consume_arg ();

          if (arg_shifter.is_parameter_next ())
            {
              const ACE_TCHAR* opt = arg_shifter.get_current ();
              this->consumer_control_period_ = ACE_OS::atoi (opt);
              arg_shifter.consume_arg ();
            }
        }

      else if (ACE_OS::strcasecmp (arg, ACE_TEXT("-ECSupplierControlPeriod")) == 0)
        {
          arg_shifter.consume_arg ();

          if (arg_shifter.is_parameter_next ())
            {
              const ACE_TCHAR* opt = arg_shifter.get_current ();
              this->supplier_control_period_ = ACE_OS::atoi (opt);
              arg_shifter.consume_arg ();
            }
        }

      else if (ACE_OS::strcasecmp (arg, ACE_TEXT("-ECConsumerControlTimeout")) == 0)
        {
          arg_shifter.consume_arg ();

          if (arg_shifter.is_parameter_next ())
            {
              const ACE_TCHAR* opt = arg_shifter.get_current ();
              unsigned long timeout = ACE_OS::strtoul(opt, 0, 10);
              this->consumer_control_timeout_.usec(timeout);
              arg_shifter.consume_arg ();
            }
        }

      else if (ACE_OS::strcasecmp (arg, ACE_TEXT("-ECSupplierControlTimeout")) == 0)
        {
          arg_shifter.consume_arg ();

          if (arg_shifter.is_parameter_next ())
            {
              const ACE_TCHAR* opt = arg_shifter.get_current ();
              unsigned long timeout = ACE_OS::strtoul(opt, 0, 10);
              this->supplier_control_timeout_.usec(timeout);
              arg_shifter.consume_arg ();
            }
        }

      else if (ACE_OS::strcasecmp (arg, ACE_TEXT("-ECConsumerValidateConnection")) == 0)
        {
          arg_shifter.consume_arg ();

          if (arg_shifter.is_parameter_next ())
            {
              const ACE_TCHAR* opt = arg_shifter.get_current ();
              this->consumer_validate_connection_ = ACE_OS::atoi (opt);
              arg_shifter.consume_arg ();
            }
        }

      else if (ACE_OS::strcasecmp (arg, ACE_TEXT("-ECPushSupplierSet")) == 0)
        {
          ACE_ERROR ((LM_ERROR,
                      "EC_Default_Factory - "
                      "obsolete option <%s>, ignored\n", arg));
          arg_shifter.consume_arg ();
        }

      else if (ACE_OS::strcasecmp (arg, ACE_TEXT("-ECQueueFullServiceObject")) == 0)
        {
          arg_shifter.consume_arg ();
          if (arg_shifter.is_parameter_next ())
            {
              const char* opt = arg_shifter.get_current ();
              this->queue_full_service_object_name_.set(opt);
              arg_shifter.consume_arg ();
            }
        }

      else if (ACE_OS::strcasecmp (arg, ACE_TEXT("-ECConsumerAdminLock")) == 0)
        {
          ACE_ERROR ((LM_ERROR,
                      "EC_Default_Factory - "
                      "obsolete option <%s>, ignored\n", arg));
          arg_shifter.consume_arg ();
        }

      else if (ACE_OS::strcasecmp (arg, ACE_TEXT("-ECSupplierAdminLock")) == 0)
        {
          ACE_ERROR ((LM_ERROR,
                      "EC_Default_Factory - "
                      "obsolete option <%s>, ignored\n", arg));
          arg_shifter.consume_arg ();
        }

      else if (ACE_OS::strncmp (arg, ACE_TEXT("-EC"), 3) == 0)
        {
          arg_shifter.consume_arg ();
          ACE_ERROR ((LM_ERROR,
                      "EC_Default_Factory - "
                      "unknown option <%s>\n",
                      arg));
        }
      else
        {
          arg_shifter.consume_arg ();
          ACE_DEBUG ((LM_DEBUG,
                      "EC_Default_Factory - "
                      "ignoring option <%s>\n",
                      arg));
        }
    }
  return 0;
}

int TAO_EC_Default_Factory::init_svcs

(

void

)

[static]

Helper function to register the default factory into the service configurator.

Reimplemented in TAO_EC_Kokyu_Factory, and TAO_EC_TPC_Factory.

Definition at line 51 of file EC_Default_Factory.cpp.

References TAO_EC_Simple_Queue_Full_Action::init_svcs(), and ACE_Service_Config::static_svcs().

{
  TAO_EC_Simple_Queue_Full_Action::init_svcs();
  return ACE_Service_Config::static_svcs ()->
    insert (&ace_svc_desc_TAO_EC_Default_Factory);
}

ACE_INLINE const ACE_CString & TAO_EC_Default_Factory::orb_id

(

void

)

const

Accessor to ORBid.

Definition at line 54 of file EC_Default_Factory.inl.

References orbid_.

{
  return this->orbid_;
}

ACE_INLINE int TAO_EC_Default_Factory::supplier_collection

(

void

)

const

Accessors to supplier collection flags.

Definition at line 42 of file EC_Default_Factory.inl.

References supplier_collection_.

{
  return this->supplier_collection_;
}

ACE_INLINE int TAO_EC_Default_Factory::supplier_filtering

(

void

)

const

Accessors to supplier filtering flags.

Definition at line 48 of file EC_Default_Factory.inl.

References supplier_filtering_.

{
  return this->supplier_filtering_;
}

void TAO_EC_Default_Factory::unsupported_option_value	(	const char *	option_name,
		const char *	option_value
	)			[protected]

Helper for agrument parsing. Prints out an error message about unsupported option value.

Definition at line 59 of file EC_Default_Factory.cpp.

References ACE_ERROR, and LM_ERROR.

Referenced by init().

{
  ACE_ERROR ((LM_ERROR,
              "EC_Default_Factory - "
              "Unsupported <%s> option value: <%s>. "
              "Ignoring this option - using defaults instead.\n",
              option_name,
              option_value));
}

---

Member Data Documentation

int TAO_EC_Default_Factory::consumer_collection_ [protected]

Definition at line 154 of file EC_Default_Factory.h.

Referenced by consumer_collection(), and init().

int TAO_EC_Default_Factory::consumer_control_ [protected]

The consumer and supplier control policies.

Definition at line 172 of file EC_Default_Factory.h.

Referenced by init().

int TAO_EC_Default_Factory::consumer_control_period_ [protected]

The consumer and supplier control periods in usecs.

Definition at line 176 of file EC_Default_Factory.h.

Referenced by init().

ACE_Time_Value TAO_EC_Default_Factory::consumer_control_timeout_ [protected]

The consumer control timeout in usecs.

Definition at line 180 of file EC_Default_Factory.h.

Referenced by create_consumer_control(), and init().

int TAO_EC_Default_Factory::consumer_lock_ [protected]

Definition at line 156 of file EC_Default_Factory.h.

Referenced by init().

int TAO_EC_Default_Factory::consumer_validate_connection_ [protected]

Validate the connection to consumer on connect.

Definition at line 186 of file EC_Default_Factory.h.

Referenced by create_proxy_push_supplier(), and init().

int TAO_EC_Default_Factory::dispatching_ [protected]

Several flags to control the kind of object created.

Definition at line 148 of file EC_Default_Factory.h.

Referenced by TAO_EC_Sched_Factory::init(), TAO_EC_Kokyu_Factory::init(), and init().

int TAO_EC_Default_Factory::dispatching_threads_ [protected]

Flags used by thread-based dispatching strategies.

Definition at line 160 of file EC_Default_Factory.h.

Referenced by init().

int TAO_EC_Default_Factory::dispatching_threads_flags_ [protected]

number of threads; may be ignored depending on strategy; default: TAO_EC_DEFAULT_DISPATCHING_THREADS

Definition at line 161 of file EC_Default_Factory.h.

Referenced by init().

int TAO_EC_Default_Factory::dispatching_threads_force_active_ [protected]

dispatching thread priority; default: TAO_EC_DEFAULT_DISPATCHING_THREADS_PRIORITY

Definition at line 163 of file EC_Default_Factory.h.

int TAO_EC_Default_Factory::dispatching_threads_priority_ [protected]

flags for thread creation; default: TAO_EC_DEFAULT_DISPATCHING_THREADS_FLAGS

Definition at line 162 of file EC_Default_Factory.h.

Referenced by init().

int TAO_EC_Default_Factory::filtering_ [protected]

Definition at line 149 of file EC_Default_Factory.h.

Referenced by TAO_EC_Sched_Factory::init(), TAO_EC_Kokyu_Factory::init(), and init().

int TAO_EC_Default_Factory::observer_ [protected]

Definition at line 152 of file EC_Default_Factory.h.

Referenced by init().

ACE_CString TAO_EC_Default_Factory::orbid_ [protected]

Use this ORB to locate global resources.

Definition at line 169 of file EC_Default_Factory.h.

Referenced by orb_id().

ACE_CString TAO_EC_Default_Factory::queue_full_service_object_name_ [protected]

create threads with innocuous default values if creation with requested values fails

Definition at line 164 of file EC_Default_Factory.h.

Referenced by init().

int TAO_EC_Default_Factory::scheduling_ [protected]

Definition at line 153 of file EC_Default_Factory.h.

Referenced by TAO_EC_Sched_Factory::init(), TAO_EC_Kokyu_Factory::init(), and init().

int TAO_EC_Default_Factory::supplier_collection_ [protected]

Definition at line 155 of file EC_Default_Factory.h.

Referenced by init(), and supplier_collection().

int TAO_EC_Default_Factory::supplier_control_ [protected]

Definition at line 173 of file EC_Default_Factory.h.

Referenced by init().

int TAO_EC_Default_Factory::supplier_control_period_ [protected]

Definition at line 177 of file EC_Default_Factory.h.

Referenced by init().

ACE_Time_Value TAO_EC_Default_Factory::supplier_control_timeout_ [protected]

The supplier control timeout in usecs.

Definition at line 183 of file EC_Default_Factory.h.

Referenced by create_supplier_control(), and init().

int TAO_EC_Default_Factory::supplier_filtering_ [protected]

Definition at line 150 of file EC_Default_Factory.h.

Referenced by init(), and supplier_filtering().

int TAO_EC_Default_Factory::supplier_lock_ [protected]

Definition at line 157 of file EC_Default_Factory.h.

Referenced by init().

int TAO_EC_Default_Factory::timeout_ [protected]

Definition at line 151 of file EC_Default_Factory.h.

Referenced by TAO_EC_Sched_Factory::init(), TAO_EC_Kokyu_Factory::init(), and init().

---

The documentation for this class was generated from the following files:

• EC_Default_Factory.h
• EC_Default_Factory.cpp
• EC_Default_Factory.inl

---