diff options
| author | thrall <thrall@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2004-05-18 19:08:43 +0000 |
|---|---|---|
| committer | thrall <thrall@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2004-05-18 19:08:43 +0000 |
| commit | 1b7e8e9dc3d4d4045510c54c300f4f9897953962 (patch) | |
| tree | 63cbeebc302cbaad11c7eca52f98728e05692940 | |
| parent | a9e9c1e404652758c9f41a5a0f434e4027858421 (diff) | |
| download | ATCD-1b7e8e9dc3d4d4045510c54c300f4f9897953962.tar.gz | |
Changed to use Kokyu/Dispatch_Deferrer's ACE_Reactor in Reactor_Task
| -rw-r--r-- | TAO/orbsvcs/examples/RtEC/Federated_Kokyu/chain_test/Kokyu_EC.cpp | 27 |
1 files changed, 16 insertions, 11 deletions
diff --git a/TAO/orbsvcs/examples/RtEC/Federated_Kokyu/chain_test/Kokyu_EC.cpp b/TAO/orbsvcs/examples/RtEC/Federated_Kokyu/chain_test/Kokyu_EC.cpp index 3e0732f9d6a..c3a2067fc41 100644 --- a/TAO/orbsvcs/examples/RtEC/Federated_Kokyu/chain_test/Kokyu_EC.cpp +++ b/TAO/orbsvcs/examples/RtEC/Federated_Kokyu/chain_test/Kokyu_EC.cpp @@ -1,16 +1,19 @@ // $Id$ +#include "orbsvcs/Sched/Reconfig_Scheduler.h" +#include "orbsvcs/Runtime_Scheduler.h" +#include "orbsvcs/Event_Service_Constants.h" +#include "orbsvcs/Event_Utilities.h" +#include "orbsvcs/Scheduler_Factory.h" +#include "orbsvcs/Event/EC_Event_Channel.h" +#include "orbsvcs/Event/EC_Default_Factory.h" +#include "orbsvcs/Event/EC_Kokyu_Factory.h" +#include "ace/OS_NS_strings.h" //for ACE_OS::strcasecmp +#include "ace/OS_NS_sys_time.h" // for ACE_OS::gettimeofday + +#include "Kokyu/Dispatch_Deferrer.h" + #include "Kokyu_EC.h" -#include <orbsvcs/Sched/Reconfig_Scheduler.h> -#include <orbsvcs/Runtime_Scheduler.h> -#include <orbsvcs/Event_Service_Constants.h> -#include <orbsvcs/Event_Utilities.h> -#include <orbsvcs/Scheduler_Factory.h> -#include <orbsvcs/Event/EC_Event_Channel.h> -#include <orbsvcs/Event/EC_Default_Factory.h> -#include <orbsvcs/Event/EC_Kokyu_Factory.h> -#include <ace/OS_NS_strings.h> //for ACE_OS::strcasecmp -#include <ace/OS_NS_sys_time.h> // for ACE_OS::gettimeofday namespace { @@ -494,7 +497,9 @@ Reactor_Task::initialize(void) this->react_ = reactor; */ - this->react_ = ACE_Reactor::instance(); + //this->react_ = ACE_Reactor::instance(); + this->react_ = Kokyu::Dispatch_Deferrer::Singleton_Reactor::instance(); + //assume reactor is already opened! this->initialized_ = 1; |