From 3363df4c72a064e590ca98f8e01832cfa4e15a3f Mon Sep 17 00:00:00 2001 From: Dante Niewenhuis Date: Tue, 27 Aug 2024 13:48:46 +0200 Subject: Renamed input files and internally server is changed to task (#246) * Updated SimTrace to use a single ArrayDeque instead of three separate lists for deadline, cpuUsage, and coreCount * Renamed input files to tasks.parquet and fragments.parquet. Renamed server to task. OpenDC nows exports tasks.parquet instead of server.parquet --- .../org/opendc/compute/failure/hostfault/StartStopHostFault.kt | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) (limited to 'opendc-compute/opendc-compute-failure/src') diff --git a/opendc-compute/opendc-compute-failure/src/main/kotlin/org/opendc/compute/failure/hostfault/StartStopHostFault.kt b/opendc-compute/opendc-compute-failure/src/main/kotlin/org/opendc/compute/failure/hostfault/StartStopHostFault.kt index 7b86df07..f4273d2c 100644 --- a/opendc-compute/opendc-compute-failure/src/main/kotlin/org/opendc/compute/failure/hostfault/StartStopHostFault.kt +++ b/opendc-compute/opendc-compute-failure/src/main/kotlin/org/opendc/compute/failure/hostfault/StartStopHostFault.kt @@ -41,14 +41,14 @@ public class StartStopHostFault( val client: ComputeClient = service.newClient() for (host in victims) { - val servers = host.instances + val tasks = host.instances - val sortedServers = servers.sortedBy { it.name } - val snapshots = sortedServers.map { (it.meta["workload"] as SimWorkload).snapshot() } + val sortedTasks = tasks.sortedBy { it.name } + val snapshots = sortedTasks.map { (it.meta["workload"] as SimWorkload).snapshot() } host.fail() - for ((server, snapshot) in servers.zip(snapshots)) { - client.rescheduleServer(server, snapshot) + for ((task, snapshot) in sortedTasks.zip(snapshots)) { + client.rescheduleTask(task, snapshot) } } -- cgit v1.2.3