From f3e578a2a43c99997dbf35e09debfde255a4ae22 Mon Sep 17 00:00:00 2001 From: Dante Niewenhuis Date: Sun, 3 Nov 2024 20:00:26 +0100 Subject: Rewritten the Carbon model (#260) --- .../src/main/kotlin/org/opendc/web/runner/OpenDCRunner.kt | 12 +++++++----- 1 file changed, 7 insertions(+), 5 deletions(-) (limited to 'opendc-web/opendc-web-runner/src') diff --git a/opendc-web/opendc-web-runner/src/main/kotlin/org/opendc/web/runner/OpenDCRunner.kt b/opendc-web/opendc-web-runner/src/main/kotlin/org/opendc/web/runner/OpenDCRunner.kt index ca42f566..7ceb32e6 100644 --- a/opendc-web/opendc-web-runner/src/main/kotlin/org/opendc/web/runner/OpenDCRunner.kt +++ b/opendc-web/opendc-web-runner/src/main/kotlin/org/opendc/web/runner/OpenDCRunner.kt @@ -272,21 +272,23 @@ public class OpenDCRunner( val topology = listOf(ClusterSpec("cluster", topologyHosts, powerSourceSpec)) Provisioner(dispatcher, seed).use { provisioner -> + + val workload = + trace(scenario.workload.trace.id).sampleByLoad(scenario.workload.samplingFraction) + val vms = workload.resolve(workloadLoader, Random(seed)) + val startTime = vms.minOf { it.submissionTime }.toEpochMilli() + provisioner.runSteps( setupComputeService( serviceDomain, { createComputeScheduler(scenario.schedulerName, Random(it.seeder.nextLong())) }, ), registerComputeMonitor(serviceDomain, monitor), - setupHosts(serviceDomain, topology), + setupHosts(serviceDomain, topology, startTime), ) val service = provisioner.registry.resolve(serviceDomain, ComputeService::class.java)!! - val workload = - trace(scenario.workload.trace.id).sampleByLoad(scenario.workload.samplingFraction) - val vms = workload.resolve(workloadLoader, Random(seed)) - val phenomena = scenario.phenomena val failureModel = if (phenomena.failures) { -- cgit v1.2.3