summaryrefslogtreecommitdiff
path: root/simulator/opendc-runner-web
diff options
context:
space:
mode:
authorFabian Mastenbroek <mail.fabianm@gmail.com>2021-01-03 20:34:29 +0100
committerGitHub <noreply@github.com>2021-01-03 20:34:29 +0100
commit74a4bff83bfb6366cc193d1fc9c4a07e49649649 (patch)
treee5ce165378b1d70fa4a9b348acbde707e1e1aaea /simulator/opendc-runner-web
parent1e1a0fe43d46e9bd578978f85fe3c6b4b1b39577 (diff)
parentc3a0a1711360c866a38b273dcf681f3aab9ae0ae (diff)
Merge pull request #68 from atlarge-research/feat/event-tracer
Add experimental event tracer
Diffstat (limited to 'simulator/opendc-runner-web')
-rw-r--r--simulator/opendc-runner-web/src/main/kotlin/org/opendc/runner/web/Main.kt5
1 files changed, 4 insertions, 1 deletions
diff --git a/simulator/opendc-runner-web/src/main/kotlin/org/opendc/runner/web/Main.kt b/simulator/opendc-runner-web/src/main/kotlin/org/opendc/runner/web/Main.kt
index 2117b675..7796019a 100644
--- a/simulator/opendc-runner-web/src/main/kotlin/org/opendc/runner/web/Main.kt
+++ b/simulator/opendc-runner-web/src/main/kotlin/org/opendc/runner/web/Main.kt
@@ -50,6 +50,7 @@ import org.opendc.experiments.sc20.trace.Sc20ParquetTraceReader
import org.opendc.experiments.sc20.trace.Sc20RawParquetTraceReader
import org.opendc.format.trace.sc20.Sc20PerformanceInterferenceReader
import org.opendc.simulator.utils.DelayControllerClockAdapter
+import org.opendc.trace.core.EventTracer
import java.io.File
import kotlin.coroutines.coroutineContext
import kotlin.random.Random
@@ -238,13 +239,15 @@ public class RunnerCli : CliktCommand(name = "runner") {
val topologyId = scenario.getEmbedded(listOf("topology", "topologyId"), ObjectId::class.java)
val environment = TopologyParser(topologies, topologyId)
val monitor = WebExperimentMonitor()
+ val tracer = EventTracer(clock)
testScope.launch {
val (bareMetalProvisioner, scheduler) = createProvisioner(
this,
clock,
environment,
- allocationPolicy
+ allocationPolicy,
+ tracer
)
val failureDomain = if (operational.getBoolean("failuresEnabled")) {