ClusterCockpit/cc-metric-collector
1
0
Fork 0
mirror of https://github.com/ClusterCockpit/cc-metric-collector.git synced 2024-12-25 23:19:06 +01:00
Code Issues Packages Projects Releases Wiki Activity

Simplified code

Browse Source
This commit is contained in:
Holger Obermaier 2022-01-24 11:31:45 +01:00
parent 5987901005
commit bcce471b27
1 changed files with 12 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
collectors/cpufreqMetric.go
View File

@ -15,8 +15,6 @@ import (
"golang.org/x/sys/unix"
)
var warnLog *log.Logger = log.New(os.Stderr, "Warning: ", log.LstdFlags)
//
// readOneLine reads one line from a file.
// It returns ok when file was successfully read.
@ -138,7 +136,8 @@ func (m *CPUFreqCollector) Init(config []byte) error {
m.cpus,
CPUFreqCollectorCPU{
tagSet: map[string]string{
"coreID": strings.TrimSpace(coreID),
"type": "cpu",
"type-id": strings.TrimSpace(coreID),
"packageID": strings.TrimSpace(packageID),
},
scalingCurFreqFile: scalingCurFreqFile,
@ -150,8 +149,9 @@ func (m *CPUFreqCollector) Init(config []byte) error {
numPackages := strconv.Itoa(maxPackageID + 1)
numCores := strconv.Itoa(maxCoreID + 1)
for i := range m.cpus {
m.cpus[i].tagSet["num_core"] = numCores
m.cpus[i].tagSet["num_package"] = numPackages
c := &m.cpus[i]
c.tagSet["num_core"] = numCores
c.tagSet["num_package"] = numPackages
}
m.init = true
@ -163,21 +163,23 @@ func (m *CPUFreqCollector) Read(interval time.Duration, out *[]lp.MutableMetric)
return
}
for _, cpu := range m.cpus {
now := time.Now()
for i := range m.cpus {
cpu := &m.cpus[i]
// Read current frequency
line, ok := readOneLine(cpu.scalingCurFreqFile)
if !ok {
warnLog.Printf("CPUFreqCollector.Read(): Failed to read one line from file '%s'", cpu.scalingCurFreqFile)
log.Printf("CPUFreqCollector.Read(): Failed to read one line from file '%s'", cpu.scalingCurFreqFile)
continue
}
cpuFreq, err := strconv.Atoi(line)
if err != nil {
warnLog.Printf("CPUFreqCollector.Read(): Failed to convert CPU frequency '%s': %v", line, err)
log.Printf("CPUFreqCollector.Read(): Failed to convert CPU frequency '%s': %v", line, err)
continue
}
value := map[string]interface{}{"value": cpuFreq}
y, err := lp.New("cpufreq", cpu.tagSet, value, time.Now())
y, err := lp.New("cpufreq", cpu.tagSet, map[string]interface{}{"value": cpuFreq}, now)
if err == nil {
*out = append(*out, y)
}