summaryrefslogtreecommitdiff
path: root/opendc-trace/opendc-trace-gwf/src/test
diff options
context:
space:
mode:
authorDante Niewenhuis <d.niewenhuis@hotmail.com>2024-04-16 09:29:53 +0200
committerGitHub <noreply@github.com>2024-04-16 09:29:53 +0200
commitfff89d25bd3c7b874e68261d21695c473c30ed7d (patch)
treebe368dd745e8119dbdefd9cd0b012c7ff9080a7a /opendc-trace/opendc-trace-gwf/src/test
parenta7b0afbb5b7059274962ade234a50240677008fd (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.kt122
-rw-r--r--opendc-trace/opendc-trace-gwf/src/test/resources/trace.gwf71
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