diff options
| author | Dante Niewenhuis <d.niewenhuis@hotmail.com> | 2025-03-21 08:49:43 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2025-03-21 08:49:43 +0100 |
| commit | f16e799e0c12d3181edad1ef307cd7084216ed9f (patch) | |
| tree | 781604592279a7b3f8844e3e92bd2fa1808dad5c /opendc-compute/opendc-compute-workload/src/main/kotlin/org | |
| parent | 29ec804965fa71d19073195248fbd2bfedd735c5 (diff) | |
WorkloadLoader fix (#321)
Diffstat (limited to 'opendc-compute/opendc-compute-workload/src/main/kotlin/org')
| -rw-r--r-- | opendc-compute/opendc-compute-workload/src/main/kotlin/org/opendc/compute/workload/WorkloadLoader.kt | 6 |
1 files changed, 5 insertions, 1 deletions
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 } } } |