Use timer_getCycleClock in likwidMetric

Co-authored-by: exterr2f <Robert.Externbrink@rub.de>

collectors/README.md

@@ -33,8 +33,10 @@ In contrast to the configuration files for sinks and receivers, the collectors c
 * [`topprocs`](./topprocsMetric.md)
 * [`nfs3stat`](./nfs3Metric.md)
 * [`nfs4stat`](./nfs4Metric.md)
+* [`nfsiostat`](./nfsiostatMetric.md)
 * [`cpufreq`](./cpufreqMetric.md)
 * [`cpufreq_cpuinfo`](./cpufreqCpuinfoMetric.md)
+* [`schedstat`](./schedstatMetric.md)
 * [`numastats`](./numastatsMetric.md)
 * [`gpfs`](./gpfsMetric.md)
 * [`beegfs_meta`](./beegfsmetaMetric.md)

collectors/likwidMetric.go

@@ -190,12 +190,8 @@ func getBaseFreq() float64 {
 	}
 
 	if math.IsNaN(freq) {
-		C.power_init(0)
+		C.timer_init()
-		info := C.get_powerInfo()
+		freq = float64(C.timer_getCycleClock()) / 1e3
-		if float64(info.baseFrequency) != 0 {
-			freq = float64(info.baseFrequency)
-		}
-		C.power_finalize()
 	}
 	return freq * 1e3
 }

receivers/natsReceiver.go

@@ -91,20 +91,21 @@ func (r *NatsReceiver) _NatsReceive(m *nats.Msg) {
 				return
 			}
 
-			y, _ := lp.NewMessage(
+			y, err := lp.NewMessage(
 				string(measurement),
 				tags,
 				nil,
 				fields,
 				t,
 			)
-
+			if err == nil {
 				m, err := r.mp.ProcessMessage(y)
-			if err == nil && m != nil {
+				if err == nil && m != nil && r.sink != nil {
 					r.sink <- m
 				}
 			}
 		}
+	}
 }
 
 // Close closes the connection to the NATS server