summaryrefslogtreecommitdiff
path: root/simulator/opendc-format/src/main
diff options
context:
space:
mode:
Diffstat (limited to 'simulator/opendc-format/src/main')
-rw-r--r--simulator/opendc-format/src/main/kotlin/org/opendc/format/trace/sc20/Sc20TraceReader.kt1
-rw-r--r--simulator/opendc-format/src/main/kotlin/org/opendc/format/trace/swf/SwfTraceReader.kt22
-rw-r--r--simulator/opendc-format/src/main/kotlin/org/opendc/format/trace/wtf/WtfTraceReader.kt2
3 files changed, 11 insertions, 14 deletions
diff --git a/simulator/opendc-format/src/main/kotlin/org/opendc/format/trace/sc20/Sc20TraceReader.kt b/simulator/opendc-format/src/main/kotlin/org/opendc/format/trace/sc20/Sc20TraceReader.kt
index 6d854fef..66efbcd0 100644
--- a/simulator/opendc-format/src/main/kotlin/org/opendc/format/trace/sc20/Sc20TraceReader.kt
+++ b/simulator/opendc-format/src/main/kotlin/org/opendc/format/trace/sc20/Sc20TraceReader.kt
@@ -64,7 +64,6 @@ public class Sc20TraceReader(
val timestampCol = 0
val cpuUsageCol = 1
val coreCol = 12
- val vmIdCol = 19
val provisionedMemoryCol = 20
val traceInterval = 5 * 60 * 1000L
diff --git a/simulator/opendc-format/src/main/kotlin/org/opendc/format/trace/swf/SwfTraceReader.kt b/simulator/opendc-format/src/main/kotlin/org/opendc/format/trace/swf/SwfTraceReader.kt
index f7b8a072..52d41c44 100644
--- a/simulator/opendc-format/src/main/kotlin/org/opendc/format/trace/swf/SwfTraceReader.kt
+++ b/simulator/opendc-format/src/main/kotlin/org/opendc/format/trace/swf/SwfTraceReader.kt
@@ -64,17 +64,17 @@ public class SwfTraceReader(
val sliceDuration = 5 * 60L
- var jobNumber = -1L
- var submitTime = -1L
- var waitTime = -1L
- var runTime = -1L
- var cores = -1
- var memory = -1L
- var slicedWaitTime = -1L
- var flopsPerSecond = -1L
- var flopsPartialSlice = -1L
- var flopsFullSlice = -1L
- var runtimePartialSliceRemainder = -1L
+ var jobNumber: Long
+ var submitTime: Long
+ var waitTime: Long
+ var runTime: Long
+ var cores: Int
+ var memory: Long
+ var slicedWaitTime: Long
+ var flopsPerSecond: Long
+ var flopsPartialSlice: Long
+ var flopsFullSlice: Long
+ var runtimePartialSliceRemainder: Long
BufferedReader(FileReader(file)).use { reader ->
reader.lineSequence()
diff --git a/simulator/opendc-format/src/main/kotlin/org/opendc/format/trace/wtf/WtfTraceReader.kt b/simulator/opendc-format/src/main/kotlin/org/opendc/format/trace/wtf/WtfTraceReader.kt
index e43d68d8..b2931468 100644
--- a/simulator/opendc-format/src/main/kotlin/org/opendc/format/trace/wtf/WtfTraceReader.kt
+++ b/simulator/opendc-format/src/main/kotlin/org/opendc/format/trace/wtf/WtfTraceReader.kt
@@ -70,8 +70,6 @@ public class WtfTraceReader(path: String) : TraceReader<Job> {
val dependencies = (nextRecord.get("parents") as ArrayList<GenericRecord>).map {
it.get("item") as Long
}
- val inputSize: Long = 0
- val outputSize: Long = 0
val flops: Long = 4100 * (runtime / 1000) * cores