diff options
| author | Dante Niewenhuis <d.niewenhuis@hotmail.com> | 2024-08-27 13:48:46 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2024-08-27 13:48:46 +0200 |
| commit | 3363df4c72a064e590ca98f8e01832cfa4e15a3f (patch) | |
| tree | 9a938700fe08ce344ff5d0d475d0b64d7233d1fc /opendc-compute/opendc-compute-failure/src | |
| parent | c21708013f2746807f5bdb3fc47c2b47ed15b7c8 (diff) | |
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
Diffstat (limited to 'opendc-compute/opendc-compute-failure/src')
| -rw-r--r-- | opendc-compute/opendc-compute-failure/src/main/kotlin/org/opendc/compute/failure/hostfault/StartStopHostFault.kt | 10 |
1 files changed, 5 insertions, 5 deletions
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) } } |
