diff options
Diffstat (limited to 'opendc-compute/opendc-compute-workload')
| -rw-r--r-- | opendc-compute/opendc-compute-workload/src/main/kotlin/org/opendc/compute/workload/ComputeWorkloadLoader.kt | 13 |
1 files changed, 10 insertions, 3 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 8e774acb..80996c0e 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 @@ -49,7 +49,6 @@ import kotlin.math.roundToLong /** * A helper class for loading compute workload traces into memory. * - * @param baseDir The directory containing the traces. */ public class ComputeWorkloadLoader( private val pathToFile: File, @@ -93,7 +92,7 @@ public class ComputeWorkloadLoader( val builder = fragments.computeIfAbsent( id, - ) { Builder(checkpointInterval, checkpointDuration, checkpointIntervalScaling, scalingPolicy) } + ) { Builder(checkpointInterval, checkpointDuration, checkpointIntervalScaling, scalingPolicy, id) } builder.add(durationMs, cpuUsage, cores) } @@ -202,6 +201,7 @@ public class ComputeWorkloadLoader( checkpointDuration: Long, checkpointIntervalScaling: Double, scalingPolicy: ScalingPolicy, + taskName: String, ) { /** * The total load of the trace. @@ -211,7 +211,14 @@ public class ComputeWorkloadLoader( /** * The internal builder for the trace. */ - private val builder = TraceWorkload.builder(checkpointInterval, checkpointDuration, checkpointIntervalScaling, scalingPolicy) + private val builder = + TraceWorkload.builder( + checkpointInterval, + checkpointDuration, + checkpointIntervalScaling, + scalingPolicy, + taskName, + ) /** * Add a fragment to the trace. |