Added embodied carbon to hosts (#326)

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.