diff options
| author | Dante Niewenhuis <d.niewenhuis@hotmail.com> | 2024-11-03 20:00:26 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2024-11-03 20:00:26 +0100 |
| commit | f3e578a2a43c99997dbf35e09debfde255a4ae22 (patch) | |
| tree | 312dde871072cff0468d2a5a11cd671d85063220 /opendc-web | |
| parent | 6fa203b9187b474816e7719baed8c97eadd689cb (diff) | |
Rewritten the Carbon model (#260)
Diffstat (limited to 'opendc-web')
| -rw-r--r-- | opendc-web/opendc-web-runner/src/main/kotlin/org/opendc/web/runner/OpenDCRunner.kt | 12 |
1 files changed, 7 insertions, 5 deletions
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) { |