From ad20465a5df47b49561bb0afbdda5cd65c5da4b8 Mon Sep 17 00:00:00 2001
From: Dante Niewenhuis <d.niewenhuis@hotmail.com>
Date: Tue, 7 May 2024 12:33:39 +0200
Subject: Revamped failure models (#228)

---
 .../kotlin/org/opendc/compute/carbon/CarbonTraceLoader.kt    | 12 ++----------
 1 file changed, 2 insertions(+), 10 deletions(-)

(limited to 'opendc-compute/opendc-compute-carbon/src')

diff --git a/opendc-compute/opendc-compute-carbon/src/main/kotlin/org/opendc/compute/carbon/CarbonTraceLoader.kt b/opendc-compute/opendc-compute-carbon/src/main/kotlin/org/opendc/compute/carbon/CarbonTraceLoader.kt
index 685a1fb3..b66aedf9 100644
--- a/opendc-compute/opendc-compute-carbon/src/main/kotlin/org/opendc/compute/carbon/CarbonTraceLoader.kt
+++ b/opendc-compute/opendc-compute-carbon/src/main/kotlin/org/opendc/compute/carbon/CarbonTraceLoader.kt
@@ -22,11 +22,10 @@
 
 package org.opendc.compute.carbon
 
-import mu.KotlinLogging
 import org.opendc.trace.Trace
 import org.opendc.trace.conv.CARBON_INTENSITY_TIMESTAMP
 import org.opendc.trace.conv.CARBON_INTENSITY_VALUE
-import org.opendc.trace.conv.TABLE_CARBON_INTENSITY
+import org.opendc.trace.conv.TABLE_CARBON_INTENSITIES
 import java.io.File
 import java.lang.ref.SoftReference
 import java.time.Instant
@@ -38,11 +37,6 @@ import java.util.concurrent.ConcurrentHashMap
  * @param baseDir The directory containing the traces.
  */
 public class CarbonTraceLoader {
-    /**
-     * The logger for this instance.
-     */
-    private val logger = KotlinLogging.logger {}
-
     /**
      * The cache of workloads.
      */
@@ -54,13 +48,11 @@ public class CarbonTraceLoader {
      * Read the metadata into a workload.
      */
     private fun parseCarbon(trace: Trace): List<CarbonFragment> {
-        val reader = checkNotNull(trace.getTable(TABLE_CARBON_INTENSITY)).newReader()
+        val reader = checkNotNull(trace.getTable(TABLE_CARBON_INTENSITIES)).newReader()
 
         val startTimeCol = reader.resolve(CARBON_INTENSITY_TIMESTAMP)
         val carbonIntensityCol = reader.resolve(CARBON_INTENSITY_VALUE)
 
-        val entries = mutableListOf<CarbonFragment>()
-
         try {
             while (reader.nextRow()) {
                 val startTime = reader.getInstant(startTimeCol)!!
-- 
cgit v1.2.3