summaryrefslogtreecommitdiff
path: root/opendc-compute/opendc-compute-simulator/src/main
diff options
context:
space:
mode:
Diffstat (limited to 'opendc-compute/opendc-compute-simulator/src/main')
-rw-r--r--opendc-compute/opendc-compute-simulator/src/main/kotlin/org/opendc/compute/simulator/telemetry/ComputeMetricReader.kt2
-rw-r--r--opendc-compute/opendc-compute-simulator/src/main/kotlin/org/opendc/compute/simulator/telemetry/parquet/ParquetComputeMonitor.kt16
2 files changed, 6 insertions, 12 deletions
diff --git a/opendc-compute/opendc-compute-simulator/src/main/kotlin/org/opendc/compute/simulator/telemetry/ComputeMetricReader.kt b/opendc-compute/opendc-compute-simulator/src/main/kotlin/org/opendc/compute/simulator/telemetry/ComputeMetricReader.kt
index 83899678..59c0ed0e 100644
--- a/opendc-compute/opendc-compute-simulator/src/main/kotlin/org/opendc/compute/simulator/telemetry/ComputeMetricReader.kt
+++ b/opendc-compute/opendc-compute-simulator/src/main/kotlin/org/opendc/compute/simulator/telemetry/ComputeMetricReader.kt
@@ -196,7 +196,7 @@ public class ComputeMetricReader(
if (toMonitor[OutputFiles.SERVICE] == true) {
this.serviceTableReader.record(now)
- monitor.record(this.serviceTableReader.copy())
+ this.monitor.record(this.serviceTableReader.copy())
}
if (printFrequency != null && loggCounter % printFrequency == 0) {
diff --git a/opendc-compute/opendc-compute-simulator/src/main/kotlin/org/opendc/compute/simulator/telemetry/parquet/ParquetComputeMonitor.kt b/opendc-compute/opendc-compute-simulator/src/main/kotlin/org/opendc/compute/simulator/telemetry/parquet/ParquetComputeMonitor.kt
index 4fb930e1..ab893158 100644
--- a/opendc-compute/opendc-compute-simulator/src/main/kotlin/org/opendc/compute/simulator/telemetry/parquet/ParquetComputeMonitor.kt
+++ b/opendc-compute/opendc-compute-simulator/src/main/kotlin/org/opendc/compute/simulator/telemetry/parquet/ParquetComputeMonitor.kt
@@ -44,7 +44,6 @@ public class ParquetComputeMonitor(
private val batteryExporter: Exporter<BatteryTableReader>?,
private val serviceExporter: Exporter<ServiceTableReader>?,
) : ComputeMonitor, AutoCloseable {
- // FIXME: Include GPU
override fun record(reader: HostTableReader) {
hostExporter?.write(reader)
}
@@ -179,16 +178,11 @@ public class ParquetComputeMonitor(
}
return ParquetComputeMonitor(
- hostExporter =
- hostExporter,
- taskExporter =
- taskExporter,
- powerSourceExporter =
- powerSourceExporter,
- batteryExporter =
- batteryExporter,
- serviceExporter =
- serviceExporter,
+ hostExporter = hostExporter,
+ taskExporter = taskExporter,
+ powerSourceExporter = powerSourceExporter,
+ batteryExporter = batteryExporter,
+ serviceExporter = serviceExporter,
)
}
}