summaryrefslogtreecommitdiff
path: root/opendc-experiments/opendc-experiments-base/src/main
diff options
context:
space:
mode:
Diffstat (limited to 'opendc-experiments/opendc-experiments-base/src/main')
-rw-r--r--opendc-experiments/opendc-experiments-base/src/main/kotlin/org/opendc/experiments/base/runner/ScenarioReplayer.kt12
1 files changed, 11 insertions, 1 deletions
diff --git a/opendc-experiments/opendc-experiments-base/src/main/kotlin/org/opendc/experiments/base/runner/ScenarioReplayer.kt b/opendc-experiments/opendc-experiments-base/src/main/kotlin/org/opendc/experiments/base/runner/ScenarioReplayer.kt
index d56e4e4b..72042f3c 100644
--- a/opendc-experiments/opendc-experiments-base/src/main/kotlin/org/opendc/experiments/base/runner/ScenarioReplayer.kt
+++ b/opendc-experiments/opendc-experiments-base/src/main/kotlin/org/opendc/experiments/base/runner/ScenarioReplayer.kt
@@ -129,6 +129,15 @@ public suspend fun ComputeService.replay(
TaskNature(false)
}
+ val flavorMeta = mutableMapOf<String, Any>()
+
+ if (entry.cpuCapacity > 0.0) {
+ flavorMeta["cpu-capacity"] = entry.cpuCapacity
+ }
+ if (entry.gpuCapacity > 0.0) {
+ flavorMeta["gpu-capacity"] = entry.gpuCapacity
+ }
+
launch {
val task =
client.newTask(
@@ -140,7 +149,8 @@ public suspend fun ComputeService.replay(
entry.name,
entry.cpuCount,
entry.memCapacity,
- if (entry.cpuCapacity > 0.0) mapOf("cpu-capacity" to entry.cpuCapacity) else emptyMap(),
+ entry.gpuCount,
+ flavorMeta,
),
workload,
meta,