From d823cd1eb16d175fb778c9f6c9282aa16f1a25ff Mon Sep 17 00:00:00 2001 From: Dante Niewenhuis Date: Tue, 14 Nov 2023 13:28:02 +0100 Subject: Updated TraceReader, Simulation now continues until all tasks are done --- .../src/main/kotlin/org/opendc/compute/simulator/internal/Guest.kt | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) (limited to 'opendc-compute/opendc-compute-simulator') 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 02766cb1..354eb3d0 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 @@ -32,6 +32,7 @@ import org.opendc.compute.simulator.SimWorkloadMapper import org.opendc.simulator.compute.SimMachineContext import org.opendc.simulator.compute.kernel.SimHypervisor import org.opendc.simulator.compute.kernel.SimVirtualMachine +import org.opendc.simulator.compute.workload.SimWorkload import java.time.Duration import java.time.Instant import java.time.InstantSource @@ -169,7 +170,8 @@ internal class Guest( onStart() - val workload = mapper.createWorkload(server) + val workload: SimWorkload = mapper.createWorkload(server) + workload.setOffset(clock.millis()) val meta = mapOf("driver" to host, "server" to server) + server.meta ctx = machine.startWorkload(workload, meta) { cause -> onStop(if (cause != null) ServerState.ERROR else ServerState.TERMINATED) -- cgit v1.2.3