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
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
|
#include "ace/Monitor_Control/CPU_Load_Monitor.h"
#if defined (ACE_HAS_MONITOR_FRAMEWORK) && (ACE_HAS_MONITOR_FRAMEWORK == 1)
#if defined (ACE_LINUX)
#include "ace/OS_NS_stdio.h"
#endif
#include "ace/Log_Msg.h"
#include "ace/OS_NS_string.h"
ACE_BEGIN_VERSIONED_NAMESPACE_DECL
namespace ACE
{
namespace Monitor_Control
{
const char* CPU_Load_Monitor::default_name_ =
"OS/Processor/CPULoad";
CPU_Load_Monitor::CPU_Load_Monitor (const char* name)
: Monitor_Base (name, Monitor_Control_Types::MC_NUMBER)
#if defined (ACE_HAS_WIN32_PDH)
, Windows_Monitor (ACE_TEXT("\\Processor(_Total)\\% Processor Time"))
#endif
#if defined (ACE_LINUX)
, user_ (0)
, wait_ (0)
, kernel_ (0)
, idle_ (0)
, prev_idle_ (0)
, prev_total_ (0.0)
#endif
#if defined (ACE_LINUX)
, file_ptr_ (0)
#endif
{
this->init ();
}
void
CPU_Load_Monitor::update ()
{
#if defined (ACE_HAS_WIN32_PDH)
this->update_i ();
this->receive (this->value_);
#elif defined (ACE_LINUX)
this->access_proc_stat (&this->idle_);
#elif defined (ACE_HAS_KSTAT)
this->access_kstats (&this->idle_);
#endif
#if defined (ACE_LINUX)
double delta_idle = this->idle_ - this->prev_idle_;
double total =
this->user_ + this->wait_ + this->kernel_ + this->idle_;
double delta_total = total - this->prev_total_;
if (ACE::is_equal (delta_total, 0.0))
{
/// The system hasn't updated /proc/stat since the last call
/// to update(), we must avoid dividing by 0.
return;
}
double percent_cpu_load = 100.0 - (delta_idle / delta_total * 100.0);
/// Stores value and timestamp with thread-safety.
this->receive (percent_cpu_load);
this->prev_idle_ = this->idle_;
this->prev_total_ = total;
#endif
}
const char*
CPU_Load_Monitor::default_name ()
{
return CPU_Load_Monitor::default_name_;
}
void
CPU_Load_Monitor::clear_i ()
{
#if defined (ACE_HAS_WIN32_PDH)
this->clear_impl ();
#endif
this->init ();
this->Monitor_Base::clear_i ();
}
void
CPU_Load_Monitor::init ()
{
#if defined (ACE_LINUX)
/// All data in this file are stored as running 'jiffy' totals, so we
/// get values here in the constructor to subtract for the difference
/// in subsequent calls.
this->access_proc_stat (&this->prev_idle_);
this->prev_total_ =
this->user_ + this->wait_ + this->kernel_ + this->prev_idle_;
#endif
}
#if defined (ACE_LINUX)
void
CPU_Load_Monitor::access_proc_stat (unsigned long *which_idle)
{
this->file_ptr_ = ACE_OS::fopen (ACE_TEXT ("/proc/stat"),
ACE_TEXT ("r"));
if (this->file_ptr_ == 0)
{
ACELIB_ERROR ((LM_ERROR,
ACE_TEXT ("CPU load - opening /proc/stat failed\n")));
return;
}
char *item = 0;
char *arg = 0;
while ((ACE_OS::fgets (buf_, sizeof (buf_), file_ptr_)) != 0)
{
item = ACE_OS::strtok (this->buf_, " \t\n");
arg = ACE_OS::strtok (0, "\n");
if (item == 0 || arg == 0)
{
continue;
}
if (ACE_OS::strcmp (item, "cpu") == 0)
{
sscanf (arg,
"%lu %lu %lu %lu",
&this->user_,
&this->wait_,
&this->kernel_,
which_idle);
break;
}
}
ACE_OS::fclose (this->file_ptr_);
}
#endif
}
}
ACE_END_VERSIONED_NAMESPACE_DECL
#endif /* ACE_HAS_MONITOR_FRAMEWORK==1 */
|
