From f16e799e0c12d3181edad1ef307cd7084216ed9f Mon Sep 17 00:00:00 2001 From: Dante Niewenhuis Date: Fri, 21 Mar 2025 08:49:43 +0100 Subject: WorkloadLoader fix (#321) --- .../src/main/kotlin/org/opendc/compute/workload/WorkloadLoader.kt | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/opendc-compute/opendc-compute-workload/src/main/kotlin/org/opendc/compute/workload/WorkloadLoader.kt b/opendc-compute/opendc-compute-workload/src/main/kotlin/org/opendc/compute/workload/WorkloadLoader.kt index c00bc768..fad4c512 100644 --- a/opendc-compute/opendc-compute-workload/src/main/kotlin/org/opendc/compute/workload/WorkloadLoader.kt +++ b/opendc-compute/opendc-compute-workload/src/main/kotlin/org/opendc/compute/workload/WorkloadLoader.kt @@ -54,6 +54,10 @@ public abstract class WorkloadLoader(private val submissionTime: String? = null) reScheduleTasks(workload) + if (fraction >= 1.0) { + return workload + } + if (fraction <= 0.0) { throw Error("The fraction of tasks to load cannot be 0.0 or lower") } @@ -73,6 +77,6 @@ public abstract class WorkloadLoader(private val submissionTime: String? = null) logger.info { "Sampled ${workload.size} VMs (fraction $fraction) into subset of ${res.size} VMs" } - return res + return res.sortedBy { it.submissionTime } } } -- cgit v1.2.3