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
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
|
/*
* pcp interface
* e.g. IRIX
*/
#include <net-snmp/net-snmp-config.h>
#include <net-snmp/net-snmp-includes.h>
#include <net-snmp/agent/net-snmp-agent-includes.h>
#include <net-snmp/agent/hardware/cpu.h>
#include <unistd.h>
#include <pcp/pmapi.h>
/*
* Performance Metrics Name Space Map
* Built by pmgenmap from the file irix_kernstats.pcp
*/
char *kernstats[] = {
#define NCPU 0
"hinv.ncpu",
#define CPUTYPE 1
"hinv.cputype",
#define CPUIDLE 2
"kernel.all.cpu.idle",
#define CPUINTR 3
"kernel.all.cpu.intr",
#define CPUSYS 4
"kernel.all.cpu.sys",
#define CPUUSER 5
"kernel.all.cpu.user",
#define CPUWAIT 6
"kernel.all.cpu.wait.total",
#define PAGESIN 7
"swap.pagesin",
#define PAGESOUT 8
"swap.pagesout",
#define SWAPIN 9
"swap.in",
#define SWAPOUT 10
"swap.out",
#define INTR 11
"kernel.all.intr.non_vme",
#define CTXT 12
"kernel.all.kswitch"
};
# define MAX_MID 17
pmResult *resp;
pmID pmidlist[MAX_MID];
int numpmid;
int pmInitDone = 0;
/* initialize pcp if necessary */
void init_pcp () {
int err;
if (pmInitDone == 1) {
return;
}
snmp_log_perror("Initializing pcp");
numpmid = sizeof(kernstats)/sizeof(kernstats[0]);
/* Load default namespace */
if ((err=pmLoadNameSpace(PM_NS_DEFAULT)) < 0) {
snmp_log_perror("pmLoadNameSpace returned an error.");
snmp_log_perror(pmErrStr(err));
exit (1);
}
/* get mappings between internal IDs and external IDs */
if ((err=pmLookupName(numpmid, kernstats, pmidlist)) < 0) {
snmp_log_perror("pmLookupName returned an error.");
snmp_log_perror(pmErrStr(err));
exit (1);
}
/* specify a context to use */
/* a type of PM_CONTEXT_HOST lets you specify a hostname */
/* a type of PM_CONTEXT_LOCAL should ignore the string param */
if ((err=pmNewContext(PM_CONTEXT_LOCAL,"localhost")) < 0) {
snmp_log_perror("pmNewContext returned error opening a LOCAL Context");
snmp_log_perror(pmErrStr(err));
if ((err=pmNewContext(PM_CONTEXT_HOST,"localhost")) < 0) {
snmp_log_perror("pmNewContext returned error opening a HOST Context");
snmp_log_perror(pmErrStr(err));
exit(1);
}
}
snmp_log_perror ("done initializing pcp");
pmInitDone = 1;
}
/*
* Initialise the list of CPUs on the system
* (including descriptions)
*/
void init_cpu_pcp( void ) {
int i, n = 0;
char tstr[1024];
int err;
netsnmp_cpu_info *cpu;
init_pcp();
/* At this stage, pmidlist contains the PMID for my metrics of interest */
cpu = netsnmp_cpu_get_byIdx( -1, 1 );
strcpy(cpu->name, "Overall CPU statistics");
if ((err=pmFetch(numpmid, pmidlist, &resp)) < 0) {
snmp_log_perror ("init_cpu_pcp: pmFetch returned error");
snmp_log_perror (pmErrStr(err));
exit (1);
}
cpu_num = resp->vset[NCPU]->vlist[0].value.lval;
pmFreeResult(resp);
for (i=0; i<cpu_num ; i++) {
cpu = netsnmp_cpu_get_byIdx( i, 1 );
sprintf(tstr, "cpu%d",i);
strcpy(cpu->name, tstr);
strcpy(cpu->descr, "An electronic chip that makes the computer work");
}
}
/*void _cpu_load_swap_etc( char *buff, netsnmp_cpu_info *cpu );*/
/*
* Load the latest CPU usage statistics
*/
int netsnmp_cpu_arch_load( netsnmp_cache *cache, void *magic ) {
int err;
/*static char *buff = NULL;*/
static int first = 1;
netsnmp_cpu_info* cpu;
init_pcp();
/*
* CPU statistics (overall and per-CPU)
*/
if ((err=pmFetch(numpmid, pmidlist, &resp)) < 0) {
snmp_log_perror ("netsnmp_cpu_arch_load: pmFetch returned an error.");
snmp_log_perror (pmErrStr(err));
exit (1);
}
cpu = netsnmp_cpu_get_byIdx( -1, 0 );
if (!cpu) {
snmp_log_perror ("netsnmp_cpu_arch_load: netsnmp_cpu_get_byIdx failed!");
exit(1);
}
cpu->wait_ticks = (unsigned long long)resp->vset[CPUWAIT]->vlist[0].value.lval / 10;
cpu->intrpt_ticks = (unsigned long long)resp->vset[CPUINTR]->vlist[0].value.lval / 10;
/*cpu->sirq_ticks = (unsigned long)csoftll / 10;*/
cpu->user_ticks = (unsigned long long)resp->vset[CPUUSER]->vlist[0].value.lval / 10;
/*cpu->nice_ticks = (unsigned long)cicell / 10;*/
cpu->sys_ticks = (unsigned long long)resp->vset[CPUSYS]->vlist[0].value.lval / 10;
cpu->idle_ticks = (unsigned long long)resp->vset[CPUIDLE]->vlist[0].value.lval / 10;
/*
* Interrupt/Context Switch statistics
* XXX - Do these really belong here ?
*/
/*cpu = netsnmp_cpu_get_byIdx( -1, 0 );*/
/*_cpu_load_swap_etc( buff, cpu );*/
cpu->pageIn = (unsigned long long)resp->vset[PAGESIN]->vlist[0].value.lval;
cpu->pageOut = (unsigned long long)resp->vset[PAGESOUT]->vlist[0].value.lval;
cpu->swapIn = (unsigned long long)resp->vset[SWAPIN]->vlist[0].value.lval;
cpu->swapOut = (unsigned long long)resp->vset[SWAPOUT]->vlist[0].value.lval;
cpu->nInterrupts = (unsigned long long)resp->vset[INTR]->vlist[0].value.lval;
cpu->nCtxSwitches = (unsigned long long)resp->vset[CTXT]->vlist[0].value.lval;
/*
* XXX - TODO: extract per-CPU statistics
* (Into separate netsnmp_cpu_info data structures)
*/
/* free pcp response */
pmFreeResult(resp);
first = 0;
return 0;
}
|
