Merge pull request #68 from atlarge-research/feat/event-tracer

Add experimental event tracer

1 files changed, 7 insertions, 2 deletions

diff --git a/simulator/opendc-experiments/opendc-experiments-sc20/src/test/kotlin/org/opendc/experiments/sc20/Sc20IntegrationTest.kt b/simulator/opendc-experiments/opendc-experiments-sc20/src/test/kotlin/org/opendc/experiments/sc20/Sc20IntegrationTest.kt
index 9c44edfc..72a2484a 100644
--- a/simulator/opendc-experiments/opendc-experiments-sc20/src/test/kotlin/org/opendc/experiments/sc20/Sc20IntegrationTest.kt
+++ b/simulator/opendc-experiments/opendc-experiments-sc20/src/test/kotlin/org/opendc/experiments/sc20/Sc20IntegrationTest.kt
@@ -48,6 +48,7 @@ import org.opendc.format.environment.EnvironmentReader
 import org.opendc.format.environment.sc20.Sc20ClusterEnvironmentReader
 import org.opendc.format.trace.TraceReader
 import org.opendc.simulator.utils.DelayControllerClockAdapter
+import org.opendc.trace.core.EventTracer
 import java.io.File
 import java.time.Clock
 
@@ -97,13 +98,15 @@ class Sc20IntegrationTest {
         val traceReader = createTestTraceReader()
         val environmentReader = createTestEnvironmentReader()
         lateinit var scheduler: SimVirtProvisioningService
+        val tracer = EventTracer(clock)
 
         testScope.launch {
             val res = createProvisioner(
                 this,
                 clock,
                 environmentReader,
-                allocationPolicy
+                allocationPolicy,
+                tracer
             )
             val bareMetalProvisioner = res.first
             scheduler = res.second
@@ -160,13 +163,15 @@ class Sc20IntegrationTest {
         val traceReader = createTestTraceReader(0.5, seed)
         val environmentReader = createTestEnvironmentReader("single")
         lateinit var scheduler: SimVirtProvisioningService
+        val tracer = EventTracer(clock)
 
         testScope.launch {
             val res = createProvisioner(
                 this,
                 clock,
                 environmentReader,
-                allocationPolicy
+                allocationPolicy,
+                tracer
             )
             scheduler = res.second