From e38e6b9341907e28d029054995cf43cbd5e8bb4d Mon Sep 17 00:00:00 2001
From: Fabian Mastenbroek <mail.fabianm@gmail.com>
Date: Tue, 30 Mar 2021 22:20:13 +0200
Subject: simulator: Add initial design of CPUFreq model

This change adds a model implementing Dynamic Voltage Frequency Scaling
(DVFS) to OpenDC.
---
 .../experiments/capelin/trace/Sc20RawParquetTraceReader.kt       | 9 +++++++++
 1 file changed, 9 insertions(+)

(limited to 'simulator/opendc-experiments')

diff --git a/simulator/opendc-experiments/opendc-experiments-capelin/src/main/kotlin/org/opendc/experiments/capelin/trace/Sc20RawParquetTraceReader.kt b/simulator/opendc-experiments/opendc-experiments-capelin/src/main/kotlin/org/opendc/experiments/capelin/trace/Sc20RawParquetTraceReader.kt
index 7ea5efe5..ffbf46d4 100644
--- a/simulator/opendc-experiments/opendc-experiments-capelin/src/main/kotlin/org/opendc/experiments/capelin/trace/Sc20RawParquetTraceReader.kt
+++ b/simulator/opendc-experiments/opendc-experiments-capelin/src/main/kotlin/org/opendc/experiments/capelin/trace/Sc20RawParquetTraceReader.kt
@@ -145,4 +145,13 @@ public class Sc20RawParquetTraceReader(private val path: File) {
      * Read the entries in the trace.
      */
     public fun read(): List<TraceEntry<SimWorkload>> = entries
+
+    /**
+     * Create a [TraceReader] instance.
+     */
+    public fun createReader(): TraceReader<SimWorkload> {
+        return object : TraceReader<SimWorkload>, Iterator<TraceEntry<SimWorkload>> by entries.iterator() {
+            override fun close() {}
+        }
+    }
 }
-- 
cgit v1.2.3