diff options
| author | Fabian Mastenbroek <mail.fabianm@gmail.com> | 2021-01-03 20:34:29 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2021-01-03 20:34:29 +0100 |
| commit | 74a4bff83bfb6366cc193d1fc9c4a07e49649649 (patch) | |
| tree | e5ce165378b1d70fa4a9b348acbde707e1e1aaea /simulator/opendc-experiments/opendc-experiments-sc18 | |
| parent | 1e1a0fe43d46e9bd578978f85fe3c6b4b1b39577 (diff) | |
| parent | c3a0a1711360c866a38b273dcf681f3aab9ae0ae (diff) | |
Merge pull request #68 from atlarge-research/feat/event-tracer
Add experimental event tracer
Diffstat (limited to 'simulator/opendc-experiments/opendc-experiments-sc18')
| -rw-r--r-- | simulator/opendc-experiments/opendc-experiments-sc18/src/main/kotlin/org/opendc/experiments/sc18/TestExperiment.kt | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/simulator/opendc-experiments/opendc-experiments-sc18/src/main/kotlin/org/opendc/experiments/sc18/TestExperiment.kt b/simulator/opendc-experiments/opendc-experiments-sc18/src/main/kotlin/org/opendc/experiments/sc18/TestExperiment.kt index 3786eebf..1221c7d3 100644 --- a/simulator/opendc-experiments/opendc-experiments-sc18/src/main/kotlin/org/opendc/experiments/sc18/TestExperiment.kt +++ b/simulator/opendc-experiments/opendc-experiments-sc18/src/main/kotlin/org/opendc/experiments/sc18/TestExperiment.kt @@ -31,6 +31,7 @@ import org.opendc.compute.core.metal.service.ProvisioningService import org.opendc.format.environment.sc18.Sc18EnvironmentReader import org.opendc.format.trace.gwf.GwfTraceReader import org.opendc.simulator.utils.DelayControllerClockAdapter +import org.opendc.trace.core.EventTracer import org.opendc.workflows.service.StageWorkflowService import org.opendc.workflows.service.WorkflowEvent import org.opendc.workflows.service.WorkflowSchedulerMode @@ -59,6 +60,7 @@ public fun main(args: Array<String>) { val token = Channel<Boolean>() val testScope = TestCoroutineScope() val clock = DelayControllerClockAdapter(testScope) + val tracer = EventTracer(clock) val schedulerAsync = testScope.async { val environment = Sc18EnvironmentReader(object {}.javaClass.getResourceAsStream("/env/setup-test.json")) @@ -67,6 +69,7 @@ public fun main(args: Array<String>) { StageWorkflowService( this, clock, + tracer, environment.platforms[0].zones[0].services[ProvisioningService], mode = WorkflowSchedulerMode.Batch(100), jobAdmissionPolicy = NullJobAdmissionPolicy, |