From 192ca10f332c58d38d129709c64dd69c284683f5 Mon Sep 17 00:00:00 2001 From: Dante Niewenhuis Date: Fri, 10 Jan 2025 14:34:50 +0100 Subject: Restructured Testing files (#287) --- .../org/opendc/compute/simulator/internal/Guest.kt | 30 ++++++++++++++-------- 1 file changed, 19 insertions(+), 11 deletions(-) (limited to 'opendc-compute') diff --git a/opendc-compute/opendc-compute-simulator/src/main/kotlin/org/opendc/compute/simulator/internal/Guest.kt b/opendc-compute/opendc-compute-simulator/src/main/kotlin/org/opendc/compute/simulator/internal/Guest.kt index 3a2416a8..ee2cb319 100644 --- a/opendc-compute/opendc-compute-simulator/src/main/kotlin/org/opendc/compute/simulator/internal/Guest.kt +++ b/opendc-compute/opendc-compute-simulator/src/main/kotlin/org/opendc/compute/simulator/internal/Guest.kt @@ -108,18 +108,26 @@ public class Guest( 0, 0.0, ) - val newChainWorkload = - ChainWorkload( - ArrayList(listOf(task.workload)), - task.workload.checkpointInterval, - task.workload.checkpointDuration, - task.workload.checkpointIntervalScaling, - ) - virtualMachine = - simMachine.startWorkload(newChainWorkload) { cause -> - onStop(if (cause != null) TaskState.FAILED else TaskState.COMPLETED) - } + if (task.workload is TraceWorkload) { + val newChainWorkload = + ChainWorkload( + ArrayList(listOf(task.workload)), + task.workload.checkpointInterval, + task.workload.checkpointDuration, + task.workload.checkpointIntervalScaling, + ) + + virtualMachine = + simMachine.startWorkload(newChainWorkload) { cause -> + onStop(if (cause != null) TaskState.FAILED else TaskState.COMPLETED) + } + } else { + virtualMachine = + simMachine.startWorkload(task.workload) { cause -> + onStop(if (cause != null) TaskState.FAILED else TaskState.COMPLETED) + } + } } /** -- cgit v1.2.3