diff options
| author | thrall <thrall@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2003-04-14 18:44:29 +0000 |
|---|---|---|
| committer | thrall <thrall@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2003-04-14 18:44:29 +0000 |
| commit | 1ec7c59b3e35418bece2eeb7863c93acd9b7906e (patch) | |
| tree | 2015b7dc994d92e89bdf3fa7793686ec5e0cbe0a | |
| parent | 25cd22646de052c5282c60ece7122fe0991938e1 (diff) | |
| download | ATCD-1ec7c59b3e35418bece2eeb7863c93acd9b7906e.tar.gz | |
Service now uses EC_Kokyu_Factory and ec_impl.activate() comes after compute_scheduling()
| -rw-r--r-- | TAO/orbsvcs/examples/RtEC/EC2_Schedule/Service.cpp | 18 |
1 files changed, 11 insertions, 7 deletions
diff --git a/TAO/orbsvcs/examples/RtEC/EC2_Schedule/Service.cpp b/TAO/orbsvcs/examples/RtEC/EC2_Schedule/Service.cpp index 29885ea4803..b4372b58f2b 100644 --- a/TAO/orbsvcs/examples/RtEC/EC2_Schedule/Service.cpp +++ b/TAO/orbsvcs/examples/RtEC/EC2_Schedule/Service.cpp @@ -3,12 +3,11 @@ #include "orbsvcs/Sched/Reconfig_Scheduler.h" #include "orbsvcs/Runtime_Scheduler.h" #include "orbsvcs/Event/Module_Factory.h" -//#include "orbsvcs/Event/Event_Channel.h" #include "orbsvcs/Event_Service_Constants.h" #include "orbsvcs/Event_Utilities.h" #include "orbsvcs/Event/EC_Event_Channel.h" #include "orbsvcs/Event/EC_Default_Factory.h" -#include "orbsvcs/Event/EC_Sched_Factory.h" +#include "orbsvcs/Event/EC_Kokyu_Factory.h" #include "Consumer.h" #include "Supplier.h" @@ -31,7 +30,7 @@ main (int argc, char* argv[]) { //TAO_EC_Default_Factory::init_svcs (); - TAO_EC_Sched_Factory::init_svcs (); + TAO_EC_Kokyu_Factory::init_svcs (); ACE_DECLARE_NEW_CORBA_ENV; @@ -134,10 +133,10 @@ main (int argc, char* argv[]) attributes.scheduler = scheduler.in (); // no need to dup TAO_EC_Event_Channel ec_impl (attributes); - ACE_DEBUG ((LM_DEBUG, "activating EC\n")); - ec_impl.activate (ACE_ENV_SINGLE_ARG_PARAMETER); - ACE_TRY_CHECK; - ACE_DEBUG ((LM_DEBUG, "EC activated\n")); + //ACE_DEBUG ((LM_DEBUG, "activating EC\n")); + //ec_impl.activate (ACE_ENV_SINGLE_ARG_PARAMETER); + //ACE_TRY_CHECK; + //ACE_DEBUG ((LM_DEBUG, "EC activated\n")); RtecEventChannelAdmin::EventChannel_var event_channel = ec_impl._this (ACE_ENV_SINGLE_ARG_PARAMETER); @@ -373,6 +372,11 @@ main (int argc, char* argv[]) // **************************************************************** + ACE_DEBUG ((LM_DEBUG, "activating EC\n")); + ec_impl.activate (ACE_ENV_SINGLE_ARG_PARAMETER); + ACE_TRY_CHECK; + ACE_DEBUG ((LM_DEBUG, "EC activated\n")); + ACE_DEBUG ((LM_DEBUG, "Pushing events\n")); // Generate a few events.... |