summaryrefslogtreecommitdiff
path: root/opendc
diff options
context:
space:
mode:
Diffstat (limited to 'opendc')
-rw-r--r--opendc/opendc-experiments-sc20/src/main/kotlin/com/atlarge/opendc/experiments/sc20/experiment/monitor/ParquetExperimentMonitor.kt4
1 files changed, 3 insertions, 1 deletions
diff --git a/opendc/opendc-experiments-sc20/src/main/kotlin/com/atlarge/opendc/experiments/sc20/experiment/monitor/ParquetExperimentMonitor.kt b/opendc/opendc-experiments-sc20/src/main/kotlin/com/atlarge/opendc/experiments/sc20/experiment/monitor/ParquetExperimentMonitor.kt
index 33978aab..138905a4 100644
--- a/opendc/opendc-experiments-sc20/src/main/kotlin/com/atlarge/opendc/experiments/sc20/experiment/monitor/ParquetExperimentMonitor.kt
+++ b/opendc/opendc-experiments-sc20/src/main/kotlin/com/atlarge/opendc/experiments/sc20/experiment/monitor/ParquetExperimentMonitor.kt
@@ -63,7 +63,7 @@ class ParquetExperimentMonitor(val run: Run) : ExperimentMonitor {
driver: VirtDriver,
server: Server
) {
- logger.debug("Host ${server.uid} changed state ${server.state} [$time]")
+ logger.debug { "Host ${server.uid} changed state ${server.state} [$time]" }
val lastServerState = lastServerStates[server]
if (server.state == ServerState.SHUTOFF && lastServerState != null) {
@@ -106,6 +106,8 @@ class ParquetExperimentMonitor(val run: Run) : ExperimentMonitor {
hostServer: Server,
duration: Long
) {
+ lastServerStates[hostServer] = Pair(hostServer.state, time)
+
hostWriter.write(
HostEvent(
time,