blob: cc4e7ff1352a404b9f5ea47238e8e83428521c6d (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
|
// $Id$
#include "Task_Manager.h"
#include "ReactorTask.h"
#if ! defined (__ACE_INLINE__)
#include "Task_Manager.i"
#endif /* __ACE_INLINE__ */
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"));
}
|
