summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/orbsvcs/Event/Task_Manager.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/Event/Task_Manager.cpp')
-rw-r--r--TAO/orbsvcs/orbsvcs/Event/Task_Manager.cpp77
1 files changed, 0 insertions, 77 deletions
diff --git a/TAO/orbsvcs/orbsvcs/Event/Task_Manager.cpp b/TAO/orbsvcs/orbsvcs/Event/Task_Manager.cpp
deleted file mode 100644
index 97e119fb425..00000000000
--- a/TAO/orbsvcs/orbsvcs/Event/Task_Manager.cpp
+++ /dev/null
@@ -1,77 +0,0 @@
-// $Id$
-
-#include "Task_Manager.h"
-#include "ReactorTask.h"
-
-#if ! defined (__ACE_INLINE__)
-#include "Task_Manager.i"
-#endif /* __ACE_INLINE__ */
-
-ACE_RCSID(Event, Task_Manager, "$Id$")
-
-ACE_Task_Manager::ACE_Task_Manager (void)
- : shutdown_ (0)
-{
- for (int i = 0; i < ACE_Scheduler_MAX_PRIORITIES; ++i)
- this->reactorTasks[i] = 0;
-}
-
-ACE_Task_Manager::~ACE_Task_Manager (void)
-{
- this->shutdown ();
-
- for (int i = 0; i < ACE_Scheduler_MAX_PRIORITIES; ++i)
- {
- if (this->reactorTasks[i] != 0)
- {
- delete this->reactorTasks[i];
- this->reactorTasks[i] = 0;
- }
- }
-}
-
-void ACE_Task_Manager::activate (void)
-{
- for (int i = 0; i < ACE_Scheduler_MAX_PRIORITIES; ++i)
- {
- if (this->reactorTasks[i] != 0)
- continue;
-
- // Convert ACE_Scheduler_Rate (it's really a period, not a rate!)
- // to a form we can easily work with.
- ACE_Time_Value period_tv;
- ORBSVCS_Time::TimeT_to_Time_Value (period_tv, ACE_Scheduler_Rates[i]);
-
- RtecScheduler::Period period = period_tv.sec () * 10000000 +
- period_tv.usec () * 10;
-
- ACE_NEW (this->reactorTasks[i], ReactorTask);
-
- if (!this->shutdown_)
- {
- this->reactorTasks[i]->thr_mgr (this->ThrMgr ());
- if (this->reactorTasks[i]->open_reactor (period) == -1)
- {
- ACE_ERROR ((LM_ERROR, "%p\n",
- "EC (%t) Task_Manager - open reactor"));
- }
- }
- }
-}
-
-void
-ACE_Task_Manager::shutdown (void)
-{
- if (this->shutdown_)
- return;
-
- this->shutdown_ = 1;
- for (int i = 0; i < ACE_Scheduler_MAX_PRIORITIES; ++i)
- {
- if (this->reactorTasks[i] != 0)
- this->reactorTasks[i]->shutdown_task ();
- }
-
- if (this->ThrMgr ()->wait () == -1)
- ACE_ERROR ((LM_DEBUG, "%p\n", "EC (%t) Task_Manager wait"));
-}