Updated workload schema (#360)

1 files changed, 0 insertions, 341 deletions

diff --git a/opendc-trace/opendc-trace-api/src/test/kotlin/formats/opendc/OdcVmTraceFormatTest.kt b/opendc-trace/opendc-trace-api/src/test/kotlin/formats/opendc/OdcVmTraceFormatTest.kt
deleted file mode 100644
index f801a6ac..00000000
--- a/opendc-trace/opendc-trace-api/src/test/kotlin/formats/opendc/OdcVmTraceFormatTest.kt
+++ /dev/null
@@ -1,341 +0,0 @@
-/*
- * Copyright (c) 2021 AtLarge Research
- *
- * Permission is hereby granted, free of charge, to any person obtaining a copy
- * of this software and associated documentation files (the "Software"), to deal
- * in the Software without restriction, including without limitation the rights
- * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
- * copies of the Software, and to permit persons to whom the Software is
- * furnished to do so, subject to the following conditions:
- *
- * The above copyright notice and this permission notice shall be included in all
- * copies or substantial portions of the Software.
- *
- * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
- * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
- * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
- * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
- * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
- * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
- * SOFTWARE.
- */
-
-package formats.opendc
-
-import formats.wtf.TableReaderTestKit
-import formats.wtf.TableWriterTestKit
-import org.junit.jupiter.api.Assertions.assertFalse
-import org.junit.jupiter.api.BeforeEach
-import org.junit.jupiter.api.DisplayName
-import org.junit.jupiter.api.Nested
-import org.junit.jupiter.api.Test
-import org.junit.jupiter.params.ParameterizedTest
-import org.junit.jupiter.params.provider.ValueSource
-import org.opendc.trace.TableColumn
-import org.opendc.trace.TableReader
-import org.opendc.trace.TableWriter
-import org.opendc.trace.conv.INTERFERENCE_GROUP_MEMBERS
-import org.opendc.trace.conv.INTERFERENCE_GROUP_SCORE
-import org.opendc.trace.conv.INTERFERENCE_GROUP_TARGET
-import org.opendc.trace.conv.TABLE_INTERFERENCE_GROUPS
-import org.opendc.trace.conv.TABLE_RESOURCES
-import org.opendc.trace.conv.TABLE_RESOURCE_STATES
-import org.opendc.trace.conv.resourceCpuCapacity
-import org.opendc.trace.conv.resourceCpuCount
-import org.opendc.trace.conv.resourceDuration
-import org.opendc.trace.conv.resourceID
-import org.opendc.trace.conv.resourceMemCapacity
-import org.opendc.trace.conv.resourceStateCpuUsage
-import org.opendc.trace.conv.resourceStateTimestamp
-import org.opendc.trace.conv.resourceSubmissionTime
-import org.opendc.trace.formats.opendc.OdcVmTraceFormat
-import java.nio.file.Files
-import java.nio.file.Paths
-import java.time.Instant
-
-/**
- * Test suite for the [OdcVmTraceFormat] implementation.
- */
-@DisplayName("OdcVmTraceFormat")
-internal class OdcVmTraceFormatTest {
-    private val format = OdcVmTraceFormat()
-
-    @Test
-    fun testTables() {
-        val path = Paths.get("src/test/resources/opendc/trace-v2.2")
-
-//        assertEquals(listOf(TABLE_RESOURCES, TABLE_RESOURCE_STATES, TABLE_INTERFERENCE_GROUPS), format.getTables(path))
-    }
-
-    @Test
-    fun testTableExists() {
-        val path = Paths.get("src/test/resources/opendc/trace-v2.2")
-
-//        assertDoesNotThrow { format.getDetails(path, TABLE_RESOURCE_STATES) }
-    }
-
-    @Test
-    fun testTableDoesNotExist() {
-        val path = Paths.get("src/test/resources/opendc/trace-v2.2")
-//        assertThrows<IllegalArgumentException> { format.getDetails(path, "test") }
-    }
-
-    @ParameterizedTest
-    @ValueSource(strings = ["trace-v2.0"])
-    fun testResources(name: String) {
-        val path = Paths.get("src/test/resources/opendc/$name")
-        val reader = format.newReader(path, TABLE_RESOURCES, listOf(resourceID, resourceSubmissionTime))
-
-//        assertAll(
-//            { assertTrue(reader.nextRow()) },
-//            { assertEquals("1019", reader.getString(resourceID)) },
-//            { assertTrue(reader.nextRow()) },
-//            { assertEquals("1023", reader.getString(resourceID)) },
-//            { assertTrue(reader.nextRow()) },
-//            { assertEquals("1052", reader.getString(resourceID)) },
-//            { assertTrue(reader.nextRow()) },
-//            { assertEquals("1073", reader.getString(resourceID)) },
-//            { assertFalse(reader.nextRow()) },
-//        )
-
-        reader.close()
-    }
-
-//    @Test
-    fun testResourcesWrite() {
-        val path = Files.createTempDirectory("opendc")
-        val writer = format.newWriter(path, TABLE_RESOURCES)
-
-        writer.startRow()
-        writer.setString(resourceID, "1019")
-        writer.setInstant(resourceSubmissionTime, Instant.EPOCH)
-        writer.setInstant(resourceDuration, Instant.EPOCH)
-        writer.setInt(resourceCpuCount, 1)
-        writer.setDouble(resourceCpuCapacity, 1024.0)
-        writer.setDouble(resourceMemCapacity, 1024.0)
-        writer.endRow()
-        writer.close()
-
-        val reader = format.newReader(path, TABLE_RESOURCES, null)
-
-//        assertAll(
-//            { assertTrue(reader.nextRow()) },
-//            { assertEquals("1019", reader.getString(resourceID)) },
-//            { assertEquals(Instant.EPOCH, reader.getInstant(resourceSubmissionTime)) },
-//            { assertEquals(Instant.EPOCH, reader.getInstant(resourceDuration)) },
-//            { assertEquals(1, reader.getInt(resourceCpuCount)) },
-//            { assertEquals(1024.0, reader.getDouble(resourceCpuCapacity)) },
-//            { assertEquals(1024.0, reader.getDouble(resourceMemCapacity)) },
-//            { assertFalse(reader.nextRow()) },
-//        )
-
-        reader.close()
-    }
-
-    @ParameterizedTest
-    @ValueSource(strings = ["trace-v2.0", "trace-v2.1"])
-    fun testSmoke(name: String) {
-        val path = Paths.get("src/test/resources/opendc/$name")
-        val reader =
-            format.newReader(
-                path,
-                TABLE_RESOURCE_STATES,
-                listOf(resourceID, resourceStateTimestamp, resourceStateCpuUsage),
-            )
-//
-//        assertAll(
-//            { assertTrue(reader.nextRow()) },
-//            { assertEquals("1019", reader.getString(resourceID)) },
-//            { assertEquals(0.0, reader.getDouble(resourceStateCpuUsage), 0.01) },
-//        )
-
-        reader.close()
-    }
-
-    @Test
-    fun testResourceStatesWrite() {
-        val path = Files.createTempDirectory("opendc")
-        val writer = format.newWriter(path, TABLE_RESOURCE_STATES)
-
-        writer.startRow()
-        writer.setString(resourceID, "1019")
-        writer.setInstant(resourceStateTimestamp, Instant.EPOCH)
-        writer.setDouble(resourceStateCpuUsage, 23.0)
-        writer.setInt(resourceCpuCount, 1)
-        writer.endRow()
-        writer.close()
-
-        val reader = format.newReader(path, TABLE_RESOURCE_STATES, null)
-
-//        assertAll(
-//            { assertTrue(reader.nextRow()) },
-//            { assertEquals("1019", reader.getString(resourceID)) },
-//            { assertEquals(Instant.EPOCH, reader.getInstant(resourceStateTimestamp)) },
-//            { assertEquals(1, reader.getInt(resourceCpuCount)) },
-//            { assertEquals(23.0, reader.getDouble(resourceStateCpuUsage)) },
-//            { assertFalse(reader.nextRow()) },
-//        )
-
-        reader.close()
-    }
-
-//    @Test
-    fun testInterferenceGroups() {
-        val path = Paths.get("src/test/resources/opendc/trace-v2.1")
-        val reader =
-            format.newReader(
-                path,
-                TABLE_INTERFERENCE_GROUPS,
-                listOf(INTERFERENCE_GROUP_MEMBERS, INTERFERENCE_GROUP_TARGET, INTERFERENCE_GROUP_SCORE),
-            )
-
-//        assertAll(
-//            { assertTrue(reader.nextRow()) },
-//            { assertEquals(setOf("1019", "1023", "1052"), reader.getSet(INTERFERENCE_GROUP_MEMBERS, String::class.java)) },
-//            { assertEquals(0.0, reader.getDouble(INTERFERENCE_GROUP_TARGET)) },
-//            { assertEquals(0.8830158730158756, reader.getDouble(INTERFERENCE_GROUP_SCORE)) },
-//            { assertTrue(reader.nextRow()) },
-//            { assertEquals(setOf("1023", "1052", "1073"), reader.getSet(INTERFERENCE_GROUP_MEMBERS, String::class.java)) },
-//            { assertEquals(0.0, reader.getDouble(INTERFERENCE_GROUP_TARGET)) },
-//            { assertEquals(0.7133055555552751, reader.getDouble(INTERFERENCE_GROUP_SCORE)) },
-//            { assertFalse(reader.nextRow()) },
-//        )
-
-        reader.close()
-    }
-
-    @Test
-    fun testInterferenceGroupsEmpty() {
-        val path = Paths.get("src/test/resources/opendc/trace-v2.0")
-        val reader = format.newReader(path, TABLE_INTERFERENCE_GROUPS, listOf(INTERFERENCE_GROUP_MEMBERS))
-
-        assertFalse(reader.nextRow())
-        reader.close()
-    }
-
-    @Test
-    fun testInterferenceGroupsWrite() {
-        val path = Files.createTempDirectory("opendc")
-        val writer = format.newWriter(path, TABLE_INTERFERENCE_GROUPS)
-
-        writer.startRow()
-        writer.setSet(INTERFERENCE_GROUP_MEMBERS, setOf("a", "b", "c"))
-        writer.setDouble(INTERFERENCE_GROUP_TARGET, 0.5)
-        writer.setDouble(INTERFERENCE_GROUP_SCORE, 0.8)
-        writer.endRow()
-        writer.flush()
-
-        writer.startRow()
-        writer.setSet(INTERFERENCE_GROUP_MEMBERS, setOf("a", "b", "d"))
-        writer.setDouble(INTERFERENCE_GROUP_TARGET, 0.5)
-        writer.setDouble(INTERFERENCE_GROUP_SCORE, 0.9)
-        writer.endRow()
-        writer.close()
-
-        val reader = format.newReader(path, TABLE_INTERFERENCE_GROUPS, null)
-
-//        assertAll(
-//            { assertTrue(reader.nextRow()) },
-//            { assertEquals(setOf("a", "b", "c"), reader.getSet(INTERFERENCE_GROUP_MEMBERS, String::class.java)) },
-//            { assertEquals(0.5, reader.getDouble(INTERFERENCE_GROUP_TARGET)) },
-//            { assertEquals(0.8, reader.getDouble(INTERFERENCE_GROUP_SCORE)) },
-//            { assertTrue(reader.nextRow()) },
-//            { assertEquals(setOf("a", "b", "d"), reader.getSet(INTERFERENCE_GROUP_MEMBERS, String::class.java)) },
-//            { assertEquals(0.5, reader.getDouble(INTERFERENCE_GROUP_TARGET)) },
-//            { assertEquals(0.9, reader.getDouble(INTERFERENCE_GROUP_SCORE)) },
-//            { assertFalse(reader.nextRow()) },
-//        )
-
-        reader.close()
-    }
-
-    @DisplayName("TableReader for Resources")
-    @Nested
-    inner class ResourcesTableReaderTest : TableReaderTestKit() {
-        override lateinit var reader: TableReader
-        override lateinit var columns: List<TableColumn>
-
-        @BeforeEach
-        fun setUp() {
-            val path = Paths.get("src/test/resources/opendc/trace-v2.1")
-
-            columns = format.getDetails(path, TABLE_RESOURCES).columns
-            reader = format.newReader(path, TABLE_RESOURCES, null)
-        }
-    }
-
-    @DisplayName("TableWriter for Resources")
-    @Nested
-    inner class ResourcesTableWriterTest : TableWriterTestKit() {
-        override lateinit var writer: TableWriter
-        override lateinit var columns: List<TableColumn>
-
-        @BeforeEach
-        fun setUp() {
-            val path = Files.createTempDirectory("opendc")
-
-            columns = format.getDetails(Paths.get("src/test/resources/opendc/trace-v2.1"), TABLE_RESOURCES).columns
-            writer = format.newWriter(path, TABLE_RESOURCES)
-        }
-    }
-
-    @DisplayName("TableReader for Resource States")
-    @Nested
-    inner class ResourceStatesTableReaderTest : TableReaderTestKit() {
-        override lateinit var reader: TableReader
-        override lateinit var columns: List<TableColumn>
-
-        @BeforeEach
-        fun setUp() {
-            val path = Paths.get("src/test/resources/opendc/trace-v2.1")
-
-            columns = format.getDetails(path, TABLE_RESOURCE_STATES).columns
-            reader = format.newReader(path, TABLE_RESOURCE_STATES, null)
-        }
-    }
-
-    @DisplayName("TableWriter for Resource States")
-    @Nested
-    inner class ResourceStatesTableWriterTest : TableWriterTestKit() {
-        override lateinit var writer: TableWriter
-        override lateinit var columns: List<TableColumn>
-
-        @BeforeEach
-        fun setUp() {
-            val path = Files.createTempDirectory("opendc")
-
-            columns = format.getDetails(Paths.get("src/test/resources/opendc/trace-v2.1"), TABLE_RESOURCE_STATES).columns
-            writer = format.newWriter(path, TABLE_RESOURCE_STATES)
-        }
-    }
-
-    @DisplayName("TableReader for Interference Groups")
-    @Nested
-    inner class InterferenceGroupsTableReaderTest : TableReaderTestKit() {
-        override lateinit var reader: TableReader
-        override lateinit var columns: List<TableColumn>
-
-        @BeforeEach
-        fun setUp() {
-            val path = Paths.get("src/test/resources/opendc/trace-v2.1")
-
-            columns = format.getDetails(path, TABLE_INTERFERENCE_GROUPS).columns
-            reader = format.newReader(path, TABLE_INTERFERENCE_GROUPS, null)
-        }
-    }
-
-    @DisplayName("TableWriter for Interference Groups")
-    @Nested
-    inner class InterferenceGroupsTableWriterTest : TableWriterTestKit() {
-        override lateinit var writer: TableWriter
-        override lateinit var columns: List<TableColumn>
-
-        @BeforeEach
-        fun setUp() {
-            val path = Files.createTempDirectory("opendc")
-
-            columns = format.getDetails(Paths.get("src/test/resources/opendc/trace-v2.1"), TABLE_INTERFERENCE_GROUPS).columns
-            writer = format.newWriter(path, TABLE_INTERFERENCE_GROUPS)
-        }
-    }
-}