From 289cd3b6bc9d86b017dbb1ce6c50d346841a0ee6 Mon Sep 17 00:00:00 2001
From: Fabian Mastenbroek <mail.fabianm@gmail.com>
Date: Thu, 26 Aug 2021 10:33:42 +0200
Subject: refactor(capelin): Make ExperimentMonitor optional for trace
 processing

---
 .../main/kotlin/org/opendc/experiments/capelin/ExperimentHelpers.kt   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

(limited to 'opendc-experiments/opendc-experiments-capelin/src')

diff --git a/opendc-experiments/opendc-experiments-capelin/src/main/kotlin/org/opendc/experiments/capelin/ExperimentHelpers.kt b/opendc-experiments/opendc-experiments-capelin/src/main/kotlin/org/opendc/experiments/capelin/ExperimentHelpers.kt
index 46e11056..9d23a5dd 100644
--- a/opendc-experiments/opendc-experiments-capelin/src/main/kotlin/org/opendc/experiments/capelin/ExperimentHelpers.kt
+++ b/opendc-experiments/opendc-experiments-capelin/src/main/kotlin/org/opendc/experiments/capelin/ExperimentHelpers.kt
@@ -255,7 +255,7 @@ suspend fun processTrace(
     reader: TraceReader<SimWorkload>,
     scheduler: ComputeService,
     chan: Channel<Unit>,
-    monitor: ExperimentMonitor
+    monitor: ExperimentMonitor? = null,
 ) {
     val client = scheduler.newClient()
     val image = client.newImage("vm-image")
@@ -289,7 +289,7 @@ suspend fun processTrace(
                     suspendCancellableCoroutine { cont ->
                         server.watch(object : ServerWatcher {
                             override fun onStateChanged(server: Server, newState: ServerState) {
-                                monitor.reportVmStateChange(clock.millis(), server, newState)
+                                monitor?.reportVmStateChange(clock.millis(), server, newState)
 
                                 if (newState == ServerState.TERMINATED) {
                                     cont.resume(Unit)
-- 
cgit v1.2.3