diff options
| author | Dante Niewenhuis <d.niewenhuis@hotmail.com> | 2024-11-01 15:33:29 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2024-11-01 15:33:29 +0100 |
| commit | 6fa203b9187b474816e7719baed8c97eadd689cb (patch) | |
| tree | 37591e7372a14f192c80c9d203a8b965fa48a47d /opendc-experiments/opendc-experiments-base/src/main | |
| parent | 7511fb768fab68d542adf5bbfb15e32300156c7e (diff) | |
Updated computeService to force the simulation to stop when all tasks are finished (#259)
Diffstat (limited to 'opendc-experiments/opendc-experiments-base/src/main')
| -rw-r--r-- | opendc-experiments/opendc-experiments-base/src/main/kotlin/org/opendc/experiments/base/runner/ScenarioRunner.kt | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/opendc-experiments/opendc-experiments-base/src/main/kotlin/org/opendc/experiments/base/runner/ScenarioRunner.kt b/opendc-experiments/opendc-experiments-base/src/main/kotlin/org/opendc/experiments/base/runner/ScenarioRunner.kt index df5aabf7..d803fd7e 100644 --- a/opendc-experiments/opendc-experiments-base/src/main/kotlin/org/opendc/experiments/base/runner/ScenarioRunner.kt +++ b/opendc-experiments/opendc-experiments-base/src/main/kotlin/org/opendc/experiments/base/runner/ScenarioRunner.kt @@ -109,7 +109,11 @@ public fun runScenario( val startTime = Duration.ofMillis(tasks.minOf { it.submissionTime }.toEpochMilli()) addExportModel(provisioner, serviceDomain, scenario, seed, startTime, carbonTrace, scenario.id) + val monitor = provisioner.getMonitor() + val service = provisioner.registry.resolve(serviceDomain, ComputeService::class.java)!! + service.setMetricReader(monitor) + service.setTasksExpected(tasks.size) service.replay( timeSource, tasks, |