Kiu/Node_Exporter
Kiu/Node_Exporter
1
0
Fork 0
mirror of https://github.com/prometheus/node_exporter.git synced 2025-01-20 07:19:01 +01:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

Maintain granularity in cpu data

Browse Source 
Export cpu mode times as original uint64_t data,
and update frequency, and do the conversion to
float64 and subsequent division in go.
This commit is contained in:
stuart nelson 2016-09-20 09:10:53 +02:00
parent 57f88ac4f6
commit e942d7e234
1 changed files with 11 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
collector/cpu_dragonfly.go
View File

@ -33,7 +33,7 @@ import (
#include <stdio.h> #include <stdio.h>
int int
getCPUTimes(char **cputime) { getCPUTimes(char **cputime, long *freq) {
size_t len; size_t len;
// Get number of cpu cores. // Get number of cpu cores.
@ -50,9 +50,8 @@ getCPUTimes(char **cputime) {
// ((cur_systimer - prev_systimer) * systimer_freq) >> 32 // ((cur_systimer - prev_systimer) * systimer_freq) >> 32
// where // where
// systimer_freq = sysctl kern.cputimer.freq // systimer_freq = sysctl kern.cputimer.freq
long freq; len = sizeof(*freq);
len = sizeof(freq); if (sysctlbyname("kern.cputimer.freq", freq, &len, NULL, 0)) {
if (sysctlbyname("kern.cputimer.freq", &freq, &len, NULL, 0)) {
return -1; return -1;
} }
@ -73,11 +72,11 @@ getCPUTimes(char **cputime) {
uint64_t user, nice, sys, intr, idle; uint64_t user, nice, sys, intr, idle;
user = nice = sys = intr = idle = 0; user = nice = sys = intr = idle = 0;
for (int i = 0; i < ncpu; ++i) { for (int i = 0; i < ncpu; ++i) {
user = ((double) cp_t[i].cp_user) / freq; user = cp_t[i].cp_user;
nice = ((double) cp_t[i].cp_nice) / freq; nice = cp_t[i].cp_nice;
sys = ((double) cp_t[i].cp_sys) / freq; sys = cp_t[i].cp_sys;
intr = ((double) cp_t[i].cp_intr) / freq; intr = cp_t[i].cp_intr;
idle = ((double) cp_t[i].cp_idle) / freq; idle = cp_t[i].cp_idle;
sprintf(*cputime + strlen(*cputime), "%llu %llu %llu %llu %llu ", user, nice, sys, intr, idle ); sprintf(*cputime + strlen(*cputime), "%llu %llu %llu %llu %llu ", user, nice, sys, intr, idle );
} }
@ -122,9 +121,10 @@ func (c *statCollector) Update(ch chan<- prometheus.Metric) error {
// Look into sys/kern/kern_clock.c for details. // Look into sys/kern/kern_clock.c for details.
var cpuTimesC *C.char var cpuTimesC *C.char
var cpuTimerFreq C.long
var fieldsCount = 5 var fieldsCount = 5
if C.getCPUTimes(&cpuTimesC) == -1 { if C.getCPUTimes(&cpuTimesC, &cpuTimerFreq) == -1 {
return errors.New("could not retrieve CPU times") return errors.New("could not retrieve CPU times")
} }
@ -139,7 +139,7 @@ func (c *statCollector) Update(ch chan<- prometheus.Metric) error {
if err != nil { if err != nil {
return err return err
} }
ch <- prometheus.MustNewConstMetric(c.cpu, prometheus.CounterValue, value, cpux, cpuFields[i%fieldsCount]) ch <- prometheus.MustNewConstMetric(c.cpu, prometheus.CounterValue, value/float64(cpuTimerFreq), cpux, cpuFields[i%fieldsCount])
} }
return nil return nil