diff options
| author | Dante Niewenhuis <d.niewenhuis@hotmail.com> | 2024-04-16 09:29:53 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2024-04-16 09:29:53 +0200 |
| commit | fff89d25bd3c7b874e68261d21695c473c30ed7d (patch) | |
| tree | be368dd745e8119dbdefd9cd0b012c7ff9080a7a /opendc-trace/opendc-trace-gwf/src/test | |
| parent | a7b0afbb5b7059274962ade234a50240677008fd (diff) | |
Revamped the trace system. All TraceFormat files are now in the api m… (#216)
* Revamped the trace system. All TraceFormat files are now in the api module. This fixes some problems with not being able to use types of traces
* applied spotless
Diffstat (limited to 'opendc-trace/opendc-trace-gwf/src/test')
| -rw-r--r-- | opendc-trace/opendc-trace-gwf/src/test/kotlin/org/opendc/trace/gwf/GwfTraceFormatTest.kt | 122 | ||||
| -rw-r--r-- | opendc-trace/opendc-trace-gwf/src/test/resources/trace.gwf | 71 |
2 files changed, 0 insertions, 193 deletions
diff --git a/opendc-trace/opendc-trace-gwf/src/test/kotlin/org/opendc/trace/gwf/GwfTraceFormatTest.kt b/opendc-trace/opendc-trace-gwf/src/test/kotlin/org/opendc/trace/gwf/GwfTraceFormatTest.kt deleted file mode 100644 index 9c97547a..00000000 --- a/opendc-trace/opendc-trace-gwf/src/test/kotlin/org/opendc/trace/gwf/GwfTraceFormatTest.kt +++ /dev/null @@ -1,122 +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 org.opendc.trace.gwf - -import org.junit.jupiter.api.Assertions.assertAll -import org.junit.jupiter.api.Assertions.assertDoesNotThrow -import org.junit.jupiter.api.Assertions.assertEquals -import org.junit.jupiter.api.Assertions.assertTrue -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.api.assertThrows -import org.opendc.trace.TableColumn -import org.opendc.trace.TableReader -import org.opendc.trace.conv.TABLE_TASKS -import org.opendc.trace.conv.TASK_ID -import org.opendc.trace.conv.TASK_PARENTS -import org.opendc.trace.conv.TASK_RUNTIME -import org.opendc.trace.conv.TASK_SUBMIT_TIME -import org.opendc.trace.conv.TASK_WORKFLOW_ID -import org.opendc.trace.testkit.TableReaderTestKit -import java.nio.file.Paths -import java.time.Duration -import java.time.Instant - -/** - * Test suite for the [GwfTraceFormat] class. - */ -@DisplayName("GWF TraceFormat") -internal class GwfTraceFormatTest { - private val format = GwfTraceFormat() - - @Test - fun testTables() { - val path = Paths.get(checkNotNull(GwfTraceFormatTest::class.java.getResource("/trace.gwf")).toURI()) - - assertEquals(listOf(TABLE_TASKS), format.getTables(path)) - } - - @Test - fun testTableExists() { - val path = Paths.get(checkNotNull(GwfTraceFormatTest::class.java.getResource("/trace.gwf")).toURI()) - assertDoesNotThrow { format.getDetails(path, TABLE_TASKS) } - } - - @Test - fun testTableDoesNotExist() { - val path = Paths.get(checkNotNull(GwfTraceFormatTest::class.java.getResource("/trace.gwf")).toURI()) - - assertThrows<IllegalArgumentException> { format.getDetails(path, "test") } - } - - @Test - fun testTableReader() { - val path = Paths.get(checkNotNull(GwfTraceFormatTest::class.java.getResource("/trace.gwf")).toURI()) - val reader = format.newReader(path, TABLE_TASKS, null) - - assertAll( - { assertTrue(reader.nextRow()) }, - { assertEquals("0", reader.getString(TASK_WORKFLOW_ID)) }, - { assertEquals("1", reader.getString(TASK_ID)) }, - { assertEquals(Instant.ofEpochSecond(16), reader.getInstant(TASK_SUBMIT_TIME)) }, - { assertEquals(Duration.ofSeconds(11), reader.getDuration(TASK_RUNTIME)) }, - { assertEquals(emptySet<String>(), reader.getSet(TASK_PARENTS, String::class.java)) }, - ) - } - - @Test - fun testReadingRowWithDependencies() { - val path = Paths.get(checkNotNull(GwfTraceFormatTest::class.java.getResource("/trace.gwf")).toURI()) - val reader = format.newReader(path, TABLE_TASKS, null) - - // Move to row 7 - for (x in 1..6) - reader.nextRow() - - assertAll( - { assertTrue(reader.nextRow()) }, - { assertEquals("0", reader.getString(TASK_WORKFLOW_ID)) }, - { assertEquals("7", reader.getString(TASK_ID)) }, - { assertEquals(Instant.ofEpochSecond(87), reader.getInstant(TASK_SUBMIT_TIME)) }, - { assertEquals(Duration.ofSeconds(11), reader.getDuration(TASK_RUNTIME)) }, - { assertEquals(setOf("4", "5", "6"), reader.getSet(TASK_PARENTS, String::class.java)) }, - ) - } - - @DisplayName("TableReader for Tasks") - @Nested - inner class TasksTableReaderTest : TableReaderTestKit() { - override lateinit var reader: TableReader - override lateinit var columns: List<TableColumn> - - @BeforeEach - fun setUp() { - val path = Paths.get(checkNotNull(GwfTraceFormatTest::class.java.getResource("/trace.gwf")).toURI()) - - columns = format.getDetails(path, TABLE_TASKS).columns - reader = format.newReader(path, TABLE_TASKS, null) - } - } -} diff --git a/opendc-trace/opendc-trace-gwf/src/test/resources/trace.gwf b/opendc-trace/opendc-trace-gwf/src/test/resources/trace.gwf deleted file mode 100644 index 2f99616d..00000000 --- a/opendc-trace/opendc-trace-gwf/src/test/resources/trace.gwf +++ /dev/null @@ -1,71 +0,0 @@ -WorkflowID, JobID , SubmitTime, RunTime , NProcs , ReqNProcs , Dependencies -0 , 1 , 16 , 11 , 1 , 1 , -0 , 2 , 40 , 11 , 1 , 1 , 1 -0 , 3 , 40 , 11 , 1 , 1 , 1 -0 , 4 , 64 , 11 , 1 , 1 , 2 -0 , 5 , 63 , 11 , 1 , 1 , 3 -0 , 6 , 64 , 11 , 1 , 1 , 3 -0 , 7 , 87 , 11 , 1 , 1 , 4 5 6 -1 , 8 , 4 , 11 , 1 , 1 , -1 , 9 , 15 , 11 , 1 , 1 , 8 -1 , 10 , 15 , 11 , 1 , 1 , 8 -1 , 11 , 27 , 11 , 1 , 1 , 9 -1 , 12 , 27 , 11 , 1 , 1 , 10 -1 , 13 , 27 , 11 , 1 , 1 , 10 -1 , 14 , 38 , 11 , 1 , 1 , 12 11 13 -2 , 15 , 3 , 11 , 1 , 1 , -2 , 16 , 27 , 11 , 1 , 1 , 15 -2 , 17 , 27 , 11 , 1 , 1 , 15 -2 , 18 , 52 , 11 , 1 , 1 , 16 -2 , 19 , 51 , 11 , 1 , 1 , 17 -2 , 20 , 51 , 11 , 1 , 1 , 17 -2 , 21 , 75 , 11 , 1 , 1 , 20 18 19 -3 , 22 , 3 , 11 , 1 , 1 , -3 , 23 , 27 , 11 , 1 , 1 , 22 -3 , 24 , 27 , 11 , 1 , 1 , 22 -3 , 25 , 51 , 11 , 1 , 1 , 23 -3 , 26 , 50 , 11 , 1 , 1 , 24 -3 , 27 , 51 , 11 , 1 , 1 , 24 -3 , 28 , 75 , 11 , 1 , 1 , 25 27 26 -4 , 29 , 3 , 11 , 1 , 1 , -4 , 30 , 27 , 11 , 1 , 1 , 29 -4 , 31 , 27 , 11 , 1 , 1 , 29 -4 , 32 , 50 , 11 , 1 , 1 , 30 -4 , 33 , 50 , 11 , 1 , 1 , 31 -4 , 34 , 51 , 11 , 1 , 1 , 31 -4 , 35 , 74 , 11 , 1 , 1 , 33 32 34 -5 , 36 , 3 , 11 , 1 , 1 , -5 , 37 , 27 , 11 , 1 , 1 , 36 -5 , 38 , 26 , 11 , 1 , 1 , 36 -5 , 39 , 51 , 11 , 1 , 1 , 37 -5 , 40 , 50 , 11 , 1 , 1 , 38 -5 , 41 , 50 , 11 , 1 , 1 , 38 -5 , 42 , 74 , 11 , 1 , 1 , 39 40 41 -6 , 43 , 4 , 11 , 1 , 1 , -6 , 44 , 27 , 11 , 1 , 1 , 43 -6 , 45 , 27 , 11 , 1 , 1 , 43 -6 , 46 , 51 , 11 , 1 , 1 , 44 -6 , 47 , 51 , 11 , 1 , 1 , 45 -6 , 48 , 51 , 11 , 1 , 1 , 45 -6 , 49 , 75 , 11 , 1 , 1 , 46 47 48 -7 , 50 , 3 , 0 , 1 , 1 , -7 , 51 , 17 , 0 , 1 , 1 , 50 -7 , 52 , 17 , 0 , 1 , 1 , 50 -7 , 53 , 30 , 0 , 1 , 1 , 51 -7 , 54 , 30 , 0 , 1 , 1 , 52 -7 , 55 , 31 , 0 , 1 , 1 , 52 -7 , 56 , 44 , 0 , 1 , 1 , 55 54 53 -8 , 57 , 3 , 11 , 1 , 1 , -8 , 58 , 26 , 11 , 1 , 1 , 57 -8 , 59 , 27 , 11 , 1 , 1 , 57 -8 , 60 , 50 , 11 , 1 , 1 , 58 -8 , 61 , 51 , 11 , 1 , 1 , 59 -8 , 62 , 50 , 11 , 1 , 1 , 59 -8 , 63 , 74 , 11 , 1 , 1 , 62 61 60 -9 , 64 , 3 , 11 , 1 , 1 , -9 , 65 , 27 , 11 , 1 , 1 , 64 -9 , 66 , 27 , 11 , 1 , 1 , 64 -9 , 67 , 51 , 11 , 1 , 1 , 65 -9 , 68 , 50 , 11 , 1 , 1 , 66 -9 , 69 , 51 , 11 , 1 , 1 , 66 -9 , 70 , 74 , 11 , 1 , 1 , 68 69 67 |
