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
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
|
//$Id$
#include "Periodic_Task.h"
#include "ace/Arg_Shifter.h"
#include "ace/High_Res_Timer.h"
#include "tao/debug.h"
#include "Task_Stats.h"
Periodic_Task::Periodic_Task (void)
:barrier_ (0),
task_priority_ (0),
period_ (0),
exec_time_ (0),
phase_ (0),
iter_ (0),
load_ (0),
task_stats_ (0)
{
}
Periodic_Task::~Periodic_Task ()
{
delete task_stats_;
}
int
Periodic_Task::init_task (ACE_Arg_Shifter& arg_shifter)
{
const ACE_TCHAR *current_arg = 0;
while (arg_shifter.is_anything_left ())
{
if ((current_arg = arg_shifter.get_the_parameter ("-JobName")))
{
name_ = current_arg;
arg_shifter.consume_arg ();
}
else if ((current_arg = arg_shifter.get_the_parameter ("-Priority")))
{
task_priority_ = ACE_OS::atoi (current_arg);
arg_shifter.consume_arg ();
}
else if ((current_arg = arg_shifter.get_the_parameter ("-Period")))
{
period_ = ACE_OS::atoi (current_arg);
arg_shifter.consume_arg ();
}
else if ((current_arg = arg_shifter.get_the_parameter ("-ExecTime")))
{
exec_time_ = ACE_OS::atoi (current_arg);
arg_shifter.consume_arg ();
}
else if ((current_arg = arg_shifter.get_the_parameter ("-Phase")))
{
phase_ = ACE_OS::atoi (current_arg);
arg_shifter.consume_arg ();
}
else if ((current_arg = arg_shifter.get_the_parameter ("-Iter")))
{
iter_ = ACE_OS::atoi (current_arg);
arg_shifter.consume_arg ();
// create the stat object.
ACE_NEW_RETURN (task_stats_, Task_Stats (iter_), -1);
if (task_stats_->init () == -1)
return -1;
}
else if ((current_arg = arg_shifter.get_the_parameter ("-Load")))
{
load_ = ACE_OS::atoi (current_arg);
arg_shifter.consume_arg ();
return 0;
}
else
{
ACE_DEBUG ((LM_DEBUG, "parse Task unknown option %s\n",
arg_shifter.get_current ()));
if (TAO_debug_level > 0)
ACE_DEBUG ((LM_DEBUG, "name %s, priority %d, period %duS, exec_time %duS, phase %duS, iter %d, load %d\n",
name_.c_str(), task_priority_, period_, exec_time_, phase_, iter_, load_));
break;
}
}
return 0;
}
const char*
Periodic_Task::job (void)
{
return name_.c_str ();
}
void
Periodic_Task::job (Job_ptr job)
{
job_ = Job::_duplicate (job);
}
void
Periodic_Task::dump_stats (ACE_TCHAR* msg)
{
char buf[BUFSIZ];
ACE_OS::sprintf (buf, "%s%s", name_.c_str (),".dat");
ACE_CString fname (buf);
ACE_OS::sprintf (buf,"#%s #name %s, priority %d, period %ld, exec_time %ld, phase %ld, iter_ %d , load_ %d",
msg, name_.c_str(), task_priority_, period_, exec_time_, phase_, iter_, load_);
task_stats_->dump_samples (fname.c_str (), buf,
ACE_High_Res_Timer::global_scale_factor ());
}
|
