TAO_EC_TPC_Factory Class Reference

A generic factory for EC experimentation. More...

#include <EC_TPC_Factory.h>

Inheritance diagram for TAO_EC_TPC_Factory:

[legend]Collaboration diagram for TAO_EC_TPC_Factory:

[legend]List of all members.

Public Member Functions
	TAO_EC_TPC_Factory (void)
	Constructor.
virtual	~TAO_EC_TPC_Factory (void)
	destructor...
virtual int	init (int argc, char *argv[])
virtual TAO_EC_Dispatching *	create_dispatching (TAO_EC_Event_Channel_Base *)
	Create and destroy the dispatching module.
virtual TAO_EC_ProxyPushSupplier *	create_proxy_push_supplier (TAO_EC_Event_Channel_Base *)
	Create and destroy a ProxyPushSupplier.
virtual TAO_EC_ProxyPushConsumer *	create_proxy_push_consumer (TAO_EC_Event_Channel_Base *)
	Create and destroy a ProxyPushConsumer.
Static Public Member Functions
static int	init_svcs (void)

---

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 32 of file EC_TPC_Factory.h.

---

Constructor & Destructor Documentation

TAO_EC_TPC_Factory::TAO_EC_TPC_Factory

(

void

)

Constructor.

Definition at line 21 of file EC_TPC_Factory.cpp.

{
  TAO_EC_TPC_debug_level = 0;
}

TAO_EC_TPC_Factory::~TAO_EC_TPC_Factory

(

void

)

[virtual]

destructor...

Definition at line 26 of file EC_TPC_Factory.cpp.

{
}

---

Member Function Documentation

TAO_EC_Dispatching * TAO_EC_TPC_Factory::create_dispatching

(

TAO_EC_Event_Channel_Base *

)

[virtual]

Create and destroy the dispatching module.

Reimplemented from TAO_EC_Default_Factory.

Definition at line 81 of file EC_TPC_Factory.cpp.

References ACE_DEBUG, TAO_EC_Default_Factory::find_service_object(), LM_DEBUG, TAO_EC_DEFAULT_QUEUE_FULL_SERVICE_OBJECT_NAME, and TAO_EC_TPC_debug_level.

{
  if (TAO_EC_TPC_debug_level > 0)
    ACE_DEBUG ((LM_DEBUG, "EC (%P|%t) EC_TPC_Factory::create_dispatching\n"));

  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_TPC_Dispatching (this->dispatching_threads_,
                                     this->dispatching_threads_flags_,
                                     this->dispatching_threads_priority_,
                                     this->dispatching_threads_force_active_,
                                     so);
}

TAO_EC_ProxyPushConsumer * TAO_EC_TPC_Factory::create_proxy_push_consumer

(

TAO_EC_Event_Channel_Base *

)

[virtual]

Create and destroy a ProxyPushConsumer.

Reimplemented from TAO_EC_Default_Factory.

Definition at line 108 of file EC_TPC_Factory.cpp.

References ACE_DEBUG, LM_DEBUG, and TAO_EC_TPC_debug_level.

{
  if (TAO_EC_TPC_debug_level > 0)
    ACE_DEBUG ((LM_DEBUG, "EC (%P|%t) EC_TPC_Factory::create_proxy_push_consumer\n"));
  return new TAO_EC_TPC_ProxyPushConsumer (ec);
}

TAO_EC_ProxyPushSupplier * TAO_EC_TPC_Factory::create_proxy_push_supplier

(

TAO_EC_Event_Channel_Base *

)

[virtual]

Create and destroy a ProxyPushSupplier.

Reimplemented from TAO_EC_Default_Factory.

Definition at line 99 of file EC_TPC_Factory.cpp.

References ACE_DEBUG, LM_DEBUG, and TAO_EC_TPC_debug_level.

{
  if (TAO_EC_TPC_debug_level > 0)
    ACE_DEBUG ((LM_DEBUG, "EC (%P|%t) EC_TPC_Factory::create_proxy_push_supplier\n"));
  return new TAO_EC_TPC_ProxyPushSupplier (ec, this->consumer_validate_connection_);
}

int TAO_EC_TPC_Factory::init	(	int	argc,
		char *	argv[]
	)			[virtual]

Reimplemented from TAO_EC_Default_Factory.

Definition at line 39 of file EC_TPC_Factory.cpp.

References ACE_DEBUG, ACE_Arg_Shifter_T< CHAR_TYPE >::consume_arg(), ACE_Arg_Shifter_T< CHAR_TYPE >::get_current(), ACE_Arg_Shifter_T< CHAR_TYPE >::ignore_arg(), TAO_EC_Default_Factory::init(), ACE_Arg_Shifter_T< CHAR_TYPE >::is_anything_left(), ACE_Arg_Shifter_T< CHAR_TYPE >::is_parameter_next(), LM_ERROR, ACE_OS::strcasecmp(), and TAO_EC_TPC_debug_level.

{
  ACE_Arg_Shifter arg_shifter (argc, argv);

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

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

          if (arg_shifter.is_parameter_next ())
            {
              // Here we print out a message indicating that this
              // option isn't valid with this factory and that it's
              // being ignored.

              ACE_DEBUG ((LM_ERROR,
                            "EC_TPC_Factory - "
                          "-ECDispatching not supported with TPC_Factory; ignoring the option and using thread-per-consumer dispatch strategy\n"));
              arg_shifter.consume_arg ();
            }
        }
      if (ACE_OS::strcasecmp (arg, "-ECTPCDebug") == 0)
        {
          arg_shifter.consume_arg ();
          ++TAO_EC_TPC_debug_level;
        }
      else
        {
          arg_shifter.ignore_arg ();
        }

    }

  return TAO_EC_Default_Factory::init (argc, argv);
}

int TAO_EC_TPC_Factory::init_svcs

(

void

)

[static]

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

Reimplemented from TAO_EC_Default_Factory.

Definition at line 31 of file EC_TPC_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_TPC_Factory);
}

---

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

• EC_TPC_Factory.h
• EC_TPC_Factory.cpp

---