diff options
| author | Dante Niewenhuis <d.niewenhuis@hotmail.com> | 2025-10-02 16:19:43 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2025-10-02 16:19:43 +0200 |
| commit | cb95cb2a5b24ae62c33962c988e89daf9a1a3e91 (patch) | |
| tree | 4f9d3c9ffea61783389fdb5c5485d08e505c0341 /opendc-compute/opendc-compute-workload/src/main/kotlin/org | |
| parent | 48ddc082ea301f54717a8ab7c54023f73220e4eb (diff) | |
Changed the input of "nature" to a boolean to safe space and make loading faster. (#375)
Diffstat (limited to 'opendc-compute/opendc-compute-workload/src/main/kotlin/org')
2 files changed, 6 insertions, 6 deletions
diff --git a/opendc-compute/opendc-compute-workload/src/main/kotlin/org/opendc/compute/workload/ComputeWorkloadLoader.kt b/opendc-compute/opendc-compute-workload/src/main/kotlin/org/opendc/compute/workload/ComputeWorkloadLoader.kt index 5db2b43b..57f2efc0 100644 --- a/opendc-compute/opendc-compute-workload/src/main/kotlin/org/opendc/compute/workload/ComputeWorkloadLoader.kt +++ b/opendc-compute/opendc-compute-workload/src/main/kotlin/org/opendc/compute/workload/ComputeWorkloadLoader.kt @@ -36,13 +36,13 @@ import org.opendc.trace.conv.TASK_CHILDREN import org.opendc.trace.conv.TASK_CPU_CAPACITY import org.opendc.trace.conv.TASK_CPU_COUNT import org.opendc.trace.conv.TASK_DEADLINE +import org.opendc.trace.conv.TASK_DEFERRABLE import org.opendc.trace.conv.TASK_DURATION import org.opendc.trace.conv.TASK_GPU_CAPACITY import org.opendc.trace.conv.TASK_GPU_COUNT import org.opendc.trace.conv.TASK_ID import org.opendc.trace.conv.TASK_MEM_CAPACITY import org.opendc.trace.conv.TASK_NAME -import org.opendc.trace.conv.TASK_NATURE import org.opendc.trace.conv.TASK_PARENTS import org.opendc.trace.conv.TASK_SUBMISSION_TIME import java.io.File @@ -136,7 +136,7 @@ public class ComputeWorkloadLoader( val gpuCoreCountCol = reader.resolve(TASK_GPU_COUNT) // Assuming GPU cores are also present val parentsCol = reader.resolve(TASK_PARENTS) val childrenCol = reader.resolve(TASK_CHILDREN) - val natureCol = reader.resolve(TASK_NATURE) + val deferrableCol = reader.resolve(TASK_DEFERRABLE) val deadlineCol = reader.resolve(TASK_DEADLINE) val entries = mutableListOf<Task>() @@ -174,10 +174,10 @@ public class ComputeWorkloadLoader( val parents = reader.getSet(parentsCol, Int::class.java) // No dependencies in the trace val children = reader.getSet(childrenCol, Int::class.java) // No dependencies in the trace - var nature = reader.getString(natureCol) + var deferrable = reader.getBoolean(deferrableCol) var deadline = reader.getLong(deadlineCol) if (deferAll) { - nature = "deferrable" + deferrable = true deadline = submissionTime + (3 * duration) } @@ -199,7 +199,7 @@ public class ComputeWorkloadLoader( gpuCoreCount, gpuUsage, gpuMemory, - nature, + deferrable, deadline, builder.build(), ), diff --git a/opendc-compute/opendc-compute-workload/src/main/kotlin/org/opendc/compute/workload/Task.kt b/opendc-compute/opendc-compute-workload/src/main/kotlin/org/opendc/compute/workload/Task.kt index a988d774..705730a0 100644 --- a/opendc-compute/opendc-compute-workload/src/main/kotlin/org/opendc/compute/workload/Task.kt +++ b/opendc-compute/opendc-compute-workload/src/main/kotlin/org/opendc/compute/workload/Task.kt @@ -49,7 +49,7 @@ public data class Task( val gpuCount: Int = 0, val gpuCapacity: Double = 0.0, val gpuMemCapacity: Long = 0L, - val nature: String?, + val deferrable: Boolean, var deadline: Long, val trace: TraceWorkload, ) |