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
|
/*
* Copyright 2018 Google LLC
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* https://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include "scrape.h"
#include "util.h"
// limits for CPU numbers
#define MAX_CPU_ID 9999999
#define MAX_CPU_DIGITS 7
// size of input buffer for reading lines
#define BUF_SIZE 256
static void *cpu_init(int argc, char *argv[]);
static void cpu_collect(scrape_req *req, void *ctx_ptr);
const struct collector cpu_collector = {
.name = "cpu",
.collect = cpu_collect,
.init = cpu_init,
};
struct cpu_context {
long clock_tick;
};
void *cpu_init(int argc, char *argv[]) {
(void) argc; (void) argv;
long clock_tick = sysconf(_SC_CLK_TCK);
if (clock_tick <= 0) {
perror("sysconf(_SC_CLK_TCK)");
return 0;
}
struct cpu_context *ctx = malloc(sizeof *ctx);
if (!ctx)
return 0;
ctx->clock_tick = clock_tick;
return ctx;
}
void cpu_collect(scrape_req *req, void *ctx_ptr) {
struct cpu_context *ctx = ctx_ptr;
// buffers
char cpu_label[MAX_CPU_DIGITS + 1] = "";
static char *modes[] = {
"user", "nice", "system", "idle", "iowait", "irq", "softirq", "steal",
0,
};
struct label stat_labels[] = {
{ .key = "cpu", .value = cpu_label },
{ .key = "mode", .value = 0 }, // value filled by code
LABEL_END,
};
struct label freq_labels[] = {
{ .key = "cpu", .value = cpu_label },
LABEL_END,
};
char buf[BUF_SIZE];
FILE *f;
// collect node_cpu_seconds_total metrics from /proc/stat
f = fopen(PATH("/proc/stat"), "r");
if (f) {
while (fgets_line(buf, sizeof buf, f)) {
if (strncmp(buf, "cpu", 3) != 0 || (buf[3] < '0' || buf[3] > '9'))
continue;
char *at = buf + 3;
char *sep = strchr(at, ' ');
if (!sep || sep - at + 1 > (ptrdiff_t) sizeof cpu_label)
continue;
*sep = '\0';
strcpy(cpu_label, at);
at = sep + 1;
for (char **mode = modes; *mode; mode++) {
while (*at == ' ')
at++;
sep = strpbrk(at, " \n");
if (!sep)
break;
*sep = '\0';
char *endptr;
double value = strtod(at, &endptr);
if (*endptr != '\0')
break;
value /= ctx->clock_tick;
stat_labels[1].value = *mode;
scrape_write(req, "node_cpu_seconds_total", stat_labels, value);
at = sep + 1;
}
}
fclose(f);
}
// collect node_cpu_frequency_hertz metrics from /sys/devices/system/cpu/cpu*/cpufreq
for (int cpu = 0; cpu <= MAX_CPU_ID; cpu++) {
#define PATH_FORMAT PATH("/sys/devices/system/cpu/cpu%d/cpufreq/scaling_cur_freq")
char path[sizeof PATH_FORMAT - 2 + MAX_CPU_DIGITS + 1];
snprintf(path, sizeof path, PATH_FORMAT, cpu);
f = fopen(path, "r");
if (!f)
break;
if (fgets(buf, sizeof buf, f)) {
char *endptr;
double value = strtod(buf, &endptr);
if (*endptr == '\0' || *endptr == '\n') {
value *= 1000;
snprintf(cpu_label, sizeof cpu_label, "%d", cpu);
scrape_write(req, "node_cpu_frequency_hertz", freq_labels, value);
}
}
fclose(f);
}
}
#ifdef NANO_EXPORTER_TEST
void cpu_test_override_tick(void *ctx, long tick) {
((struct cpu_context *) ctx)->clock_tick = tick;
}
#endif // NANO_EXPORTER_TEST
|
