From a7b0afbb5b7059274962ade234a50240677008fd Mon Sep 17 00:00:00 2001 From: Dante Niewenhuis Date: Thu, 11 Apr 2024 11:37:03 +0200 Subject: Added absolute timestamp based on the given workload to the output files (#215) --- .../kotlin/org/opendc/experiments/base/runner/ScenarioRunner.kt | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) (limited to 'opendc-experiments/opendc-experiments-base/src/main') 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 3dce2bf1..04998309 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 @@ -120,6 +120,11 @@ public fun runScenario( val partition = scenario.name + "/seed=$seed" + val workloadLoader = ComputeWorkloadLoader(File(scenario.workload.pathToFile)) + val vms = getWorkloadType(scenario.workload.type).resolve(workloadLoader, Random(seed)) + + val startTime = Duration.ofMillis(vms.minOf { it.startTime }.toEpochMilli()) + provisioner.runStep( registerComputeMonitor( serviceDomain, @@ -129,14 +134,12 @@ public fun runScenario( bufferSize = 4096, ), Duration.ofSeconds(scenario.exportModel.exportInterval), + startTime, ), ) val service = provisioner.registry.resolve(serviceDomain, ComputeService::class.java)!! - val workloadLoader = ComputeWorkloadLoader(File(scenario.workload.pathToFile)) - val vms = getWorkloadType(scenario.workload.type).resolve(workloadLoader, Random(seed)) - service.replay(timeSource, vms, seed, failureModel = scenario.failureModel) } } -- cgit v1.2.3