diff --git a/backend/src/main/java/net/laprun/sustainability/power/sensors/macos/powermetrics/AppleSiliconCPU.java b/backend/src/main/java/net/laprun/sustainability/power/sensors/macos/powermetrics/AppleSiliconCPU.java index faf02043..b07f2f45 100644 --- a/backend/src/main/java/net/laprun/sustainability/power/sensors/macos/powermetrics/AppleSiliconCPU.java +++ b/backend/src/main/java/net/laprun/sustainability/power/sensors/macos/powermetrics/AppleSiliconCPU.java @@ -6,7 +6,6 @@ import java.util.HashMap; import java.util.List; -import io.quarkus.logging.Log; import net.laprun.sustainability.power.SensorMetadata; class AppleSiliconCPU extends CPU { @@ -66,7 +65,6 @@ public boolean doneExtractingPowerComponents(String line, HashMap uncheckedStream(long pid) throws Exception { return periodicSensorCheck.map(measures -> measures.getOrDefault(registeredPID)); } + @SuppressWarnings("UnusedReturnValue") public Cancellable startTrackingApp(String appName, long pid, String session) throws Exception { - final var tracked = uncheckedStream(pid).subscribe().with(m -> persistence.save(m, appName, session)); + final var tracked = uncheckedStream(pid) + .filter(m -> SensorMeasure.missing != m) + .subscribe() + .with(m -> persistence.save(m, appName, session)); manuallyTrackedProcesses.put(pid, tracked); return tracked; } diff --git a/persistence/src/main/java/net/laprun/sustainability/power/persistence/Persistence.java b/persistence/src/main/java/net/laprun/sustainability/power/persistence/Persistence.java index 1c5b5ef6..2f67389c 100644 --- a/persistence/src/main/java/net/laprun/sustainability/power/persistence/Persistence.java +++ b/persistence/src/main/java/net/laprun/sustainability/power/persistence/Persistence.java @@ -22,7 +22,7 @@ public Measure save(SensorMeasure measure, String appName, String session) { persisted.startTime = measure.startMs(); persisted.endTime = measure.endMs(); persisted.persist(); - Log.infof("Persisted %s, measure duration: %sms", persisted, persisted.endTime - persisted.startTime); + Log.debugf("Persisted %s, measure duration: %sms", persisted, persisted.endTime - persisted.startTime); return persisted; }