summaryrefslogtreecommitdiff
path: root/opendc-experiments/opendc-experiments-faas/src/test/kotlin
diff options
context:
space:
mode:
authorDante Niewenhuis <d.niewenhuis@hotmail.com>2024-03-05 13:23:57 +0100
committerGitHub <noreply@github.com>2024-03-05 13:23:57 +0100
commit5864cbcbfe2eb8c36ca05c3a39c7e5916aeecaec (patch)
tree5b2773b8dc21c2e1b526fb70f829c376dd80532a /opendc-experiments/opendc-experiments-faas/src/test/kotlin
parentd28002a3c151d198298574312f32f1cb43f3a660 (diff)
Updated package versions, updated web server tests. (#207)
* Updated all package versions including kotlin. Updated all web-server tests to run. * Changed the java version of the tests. OpenDC now only supports java 19. * small update * test update * new update * updated docker version to 19 * updated docker version to 19
Diffstat (limited to 'opendc-experiments/opendc-experiments-faas/src/test/kotlin')
-rw-r--r--opendc-experiments/opendc-experiments-faas/src/test/kotlin/org/opendc/experiments/faas/FaaSExperiment.kt49
-rw-r--r--opendc-experiments/opendc-experiments-faas/src/test/kotlin/org/opendc/experiments/faas/ServerlessTraceReaderTest.kt2
2 files changed, 27 insertions, 24 deletions
diff --git a/opendc-experiments/opendc-experiments-faas/src/test/kotlin/org/opendc/experiments/faas/FaaSExperiment.kt b/opendc-experiments/opendc-experiments-faas/src/test/kotlin/org/opendc/experiments/faas/FaaSExperiment.kt
index 9a3dba13..346059a8 100644
--- a/opendc-experiments/opendc-experiments-faas/src/test/kotlin/org/opendc/experiments/faas/FaaSExperiment.kt
+++ b/opendc-experiments/opendc-experiments-faas/src/test/kotlin/org/opendc/experiments/faas/FaaSExperiment.kt
@@ -46,34 +46,35 @@ class FaaSExperiment {
* Smoke test that simulates a small trace.
*/
@Test
- fun testSmoke() = runSimulation {
- val faasService = "faas.opendc.org"
+ fun testSmoke() =
+ runSimulation {
+ val faasService = "faas.opendc.org"
- Provisioner(dispatcher, seed = 0L).use { provisioner ->
- provisioner.runStep(
- setupFaaSService(
- faasService,
- { RandomRoutingPolicy() },
- { FunctionTerminationPolicyFixed(it.dispatcher, timeout = Duration.ofMinutes(10)) },
- createMachineModel(),
- coldStartModel = ColdStartModel.GOOGLE
+ Provisioner(dispatcher, seed = 0L).use { provisioner ->
+ provisioner.runStep(
+ setupFaaSService(
+ faasService,
+ { RandomRoutingPolicy() },
+ { FunctionTerminationPolicyFixed(it.dispatcher, timeout = Duration.ofMinutes(10)) },
+ createMachineModel(),
+ coldStartModel = ColdStartModel.GOOGLE,
+ ),
)
- )
- val service = provisioner.registry.resolve(faasService, FaaSService::class.java)!!
+ val service = provisioner.registry.resolve(faasService, FaaSService::class.java)!!
- val trace = ServerlessTraceReader().parse(File("src/test/resources/trace"))
- service.replay(timeSource, trace)
+ val trace = ServerlessTraceReader().parse(File("src/test/resources/trace"))
+ service.replay(timeSource, trace)
- val stats = service.getSchedulerStats()
+ val stats = service.getSchedulerStats()
- assertAll(
- { assertEquals(14, stats.totalInvocations) },
- { assertEquals(2, stats.timelyInvocations) },
- { assertEquals(12, stats.delayedInvocations) }
- )
+ assertAll(
+ { assertEquals(14, stats.totalInvocations) },
+ { assertEquals(2, stats.timelyInvocations) },
+ { assertEquals(12, stats.delayedInvocations) },
+ )
+ }
}
- }
/**
* Construct the machine model to test with.
@@ -82,8 +83,10 @@ class FaaSExperiment {
val cpuNode = ProcessingNode("Intel", "Xeon", "amd64", 2)
return MachineModel(
- /*cpus*/ List(cpuNode.coreCount) { ProcessingUnit(cpuNode, it, 1000.0) },
- /*memory*/ List(4) { MemoryUnit("Crucial", "MTA18ASF4G72AZ-3G2B1", 3200.0, 32_000) }
+ // cpus
+ List(cpuNode.coreCount) { ProcessingUnit(cpuNode, it, 1000.0) },
+ // memory
+ List(4) { MemoryUnit("Crucial", "MTA18ASF4G72AZ-3G2B1", 3200.0, 32_000) },
)
}
}
diff --git a/opendc-experiments/opendc-experiments-faas/src/test/kotlin/org/opendc/experiments/faas/ServerlessTraceReaderTest.kt b/opendc-experiments/opendc-experiments-faas/src/test/kotlin/org/opendc/experiments/faas/ServerlessTraceReaderTest.kt
index 54071791..bc4f5457 100644
--- a/opendc-experiments/opendc-experiments-faas/src/test/kotlin/org/opendc/experiments/faas/ServerlessTraceReaderTest.kt
+++ b/opendc-experiments/opendc-experiments-faas/src/test/kotlin/org/opendc/experiments/faas/ServerlessTraceReaderTest.kt
@@ -39,7 +39,7 @@ class ServerlessTraceReaderTest {
assertAll(
{ assertEquals(2, trace.size) },
{ assertEquals("004c1ea5eb15978682b00ab659aed21e2835d5287668da8d5267f751fdfbdd78", trace[0].id) },
- { assertEquals(256, trace[0].maxMemory) }
+ { assertEquals(256, trace[0].maxMemory) },
)
}
}