summaryrefslogtreecommitdiff
path: root/opendc-compute/opendc-compute-failure/src
diff options
context:
space:
mode:
authorDante Niewenhuis <d.niewenhuis@hotmail.com>2024-08-27 13:48:46 +0200
committerGitHub <noreply@github.com>2024-08-27 13:48:46 +0200
commit3363df4c72a064e590ca98f8e01832cfa4e15a3f (patch)
tree9a938700fe08ce344ff5d0d475d0b64d7233d1fc /opendc-compute/opendc-compute-failure/src
parentc21708013f2746807f5bdb3fc47c2b47ed15b7c8 (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.kt10
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)
}
}