fix: improve the resilience to power conversion.

Author: mcolmant

powerapi-core/src/main/scala/org/powerapi/module/cpu/dvfs/CpuDvfsFormula.scala

@@ -69,7 +69,15 @@ class CpuDvfsFormula(eventBus: MessageBus, muid: UUID, target: Target, tdp: Doub
 
     val totalTime = timeInStates.times.values.sum
 
-    if (totalTime != 0) (totalPower / totalTime.toDouble).W
-    else 0.W
+    try {
+      if (totalTime != 0) (totalPower / totalTime.toDouble).W
+      else 0.W
+    }
+
+    catch {
+      case _: Exception =>
+        log.warning("The power value is out of range. Skip.")
+        0.W
+    }
   }
 }

powerapi-core/src/main/scala/org/powerapi/module/cpu/simple/CpuSimpleFormula.scala

@@ -50,7 +50,16 @@ class CpuSimpleFormula(eventBus: MessageBus, muid: UUID, target: Target, tdp: Do
 
   def handler: Actor.Receive = LoggingReceive {
     case msg: SimpleUsageReport =>
-      val power = ((tdp * tdpFactor) * msg.targetRatio.ratio).W
+      val power = {
+        try {
+          ((tdp * tdpFactor) * msg.targetRatio.ratio).W
+        }
+        catch {
+          case _: Exception =>
+            log.warning("The power value is out of range. Skip.")
+            0.W
+        }
+      }
       publishRawPowerReport(msg.muid, msg.target, power, "cpu", msg.tick)(eventBus)
   }
 }

powerapi-core/src/main/scala/org/powerapi/module/disk/simple/DiskSimpleFormula.scala

@@ -75,7 +75,18 @@ class DiskSimpleFormula(eventBus: MessageBus, muid: UUID, target: Target, interv
         readPower.getOrElse(0.0) + writePower.getOrElse(0.0)
       }
 
-      publishRawPowerReport(muid, target, powers.sum.W, "disk", msg.tick)(eventBus)
+      val accPower = {
+        try {
+          powers.sum.W
+        }
+        catch {
+          case _: Exception =>
+            log.warning("The power value is out of range. Skip.")
+            0.W
+        }
+      }
+
+      publishRawPowerReport(muid, target, accPower, "disk", msg.tick)(eventBus)
       context.become(compute(now) orElse formulaDefault)
   }
 }

powerapi-core/src/main/scala/org/powerapi/module/extpowermeter/ExtPowerMeterSensor.scala

@@ -77,7 +77,14 @@ abstract class ExtPowerMeterSensor(eventBus: MessageBus, muid: UUID, target: Tar
     report match {
       case Some(r) =>
         val activePower = r.power.toMilliWatts - idlePower.toMilliWatts
-        if (activePower > 0) activePower.mW else 0.mW
+        try {
+          if (activePower > 0) activePower.mW else 0.mW
+        }
+        catch {
+          case _: Exception =>
+            log.warning("The power value is out of range. Skip.")
+            0.W
+        }
       case _ =>
         0.mW
     }

powerapi-core/src/main/scala/org/powerapi/module/extpowermeter/powerspy/PowerSpyPMeter.scala

@@ -69,7 +69,14 @@ class PowerSpyPMeter(mac: String, interval: FiniteDuration) extends ExternalPMet
                 while (running) {
                   pSpy.readRealTime() match {
                     case Some(rtValue) if eventBus.isDefined =>
-                      publishPowerSpyRawPowerReport(rtValue.power.W)(eventBus.get)
+                      try {
+                        publishPowerSpyRawPowerReport(rtValue.power.W)(eventBus.get)
+                      }
+                      catch {
+                        case _: Exception =>
+                          log.warn("The power value is out of range. Skip.")
+                          0.W
+                      }
                     case _ =>
 
                   }

powerapi-core/src/main/scala/org/powerapi/module/libpfm/LibpfmFormula.scala

@@ -64,7 +64,18 @@ class LibpfmFormula(eventBus: MessageBus, muid: UUID, target: Target, formula: M
         }
       }
 
-      publishRawPowerReport(muid, target, powers.sum.W, "cpu", msg.tick)(eventBus)
+      val accPower = {
+        try {
+          powers.sum.W
+        }
+        catch {
+          case _: Exception =>
+            log.warning("The power value is out of range. Skip.")
+            0.W
+        }
+      }
+
+      publishRawPowerReport(muid, target, accPower, "cpu", msg.tick)(eventBus)
 
       context.become(compute(now) orElse formulaDefault)
   }

powerapi-core/src/main/scala/org/powerapi/module/libpfm/cycles/LibpfmCoreCyclesFormula.scala

@@ -79,7 +79,18 @@ class LibpfmCoreCyclesFormula(eventBus: MessageBus, muid: UUID, target: Target,
         formula.zipWithIndex.foldLeft(0d)((acc, tuple) => acc + (tuple._1 * math.pow(scaledCycles, tuple._2)))
       }
 
-      publishRawPowerReport(muid, target, powers.sum.W, "cpu", msg.tick)(eventBus)
+      val accPower = {
+        try {
+          powers.sum.W
+        }
+        catch {
+          case _: Exception =>
+            log.warning("The power value is out of range. Skip.")
+            0.W
+        }
+      }
+
+      publishRawPowerReport(muid, target, accPower, "cpu", msg.tick)(eventBus)
       context.become(compute(now) orElse formulaDefault)
   }
 }