diff options
| author | Dante Niewenhuis <d.niewenhuis@hotmail.com> | 2025-01-10 14:34:50 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2025-01-10 14:34:50 +0100 |
| commit | 192ca10f332c58d38d129709c64dd69c284683f5 (patch) | |
| tree | 489d182bdc114631e37a5bb8306fceb529f374c2 /opendc-compute/opendc-compute-simulator/src | |
| parent | f71e07f55a5176c5bd5447cdb3bcfebf2f5f47ee (diff) | |
Restructured Testing files (#287)
Diffstat (limited to 'opendc-compute/opendc-compute-simulator/src')
| -rw-r--r-- | opendc-compute/opendc-compute-simulator/src/main/kotlin/org/opendc/compute/simulator/internal/Guest.kt | 30 |
1 files changed, 19 insertions, 11 deletions
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) + } + } } /** |