summaryrefslogtreecommitdiff
path: root/opendc-faas
diff options
context:
space:
mode:
authorFabian Mastenbroek <mail.fabianm@gmail.com>2022-10-05 14:10:11 +0200
committerFabian Mastenbroek <mail.fabianm@gmail.com>2022-10-05 14:10:11 +0200
commitbe176910eb870209576326ffaad8bf21241fccbd (patch)
tree3903d8aed5e87850c92e1b2dce8379ea99bdfa6d /opendc-faas
parentc214a7fe0d46ecc23a71f9237b20281c0ca1c929 (diff)
refactor(sim/core): Rename runBlockingSimulation to runSimulation
This change renames the method `runBlockingSimulation` to `runSimulation` to put more emphasis on the simulation part of the method. The blocking part is not that important, but this behavior is still described in the method documentation.
Diffstat (limited to 'opendc-faas')
-rw-r--r--opendc-faas/opendc-faas-service/src/test/kotlin/org/opendc/faas/service/FaaSServiceTest.kt22
-rw-r--r--opendc-faas/opendc-faas-simulator/src/test/kotlin/org/opendc/faas/simulator/SimFaaSServiceTest.kt4
2 files changed, 13 insertions, 13 deletions
diff --git a/opendc-faas/opendc-faas-service/src/test/kotlin/org/opendc/faas/service/FaaSServiceTest.kt b/opendc-faas/opendc-faas-service/src/test/kotlin/org/opendc/faas/service/FaaSServiceTest.kt
index dc296c20..28234cf4 100644
--- a/opendc-faas/opendc-faas-service/src/test/kotlin/org/opendc/faas/service/FaaSServiceTest.kt
+++ b/opendc-faas/opendc-faas-service/src/test/kotlin/org/opendc/faas/service/FaaSServiceTest.kt
@@ -31,7 +31,7 @@ import org.opendc.faas.api.FaaSFunction
import org.opendc.faas.service.deployer.FunctionDeployer
import org.opendc.faas.service.deployer.FunctionInstance
import org.opendc.faas.service.deployer.FunctionInstanceState
-import org.opendc.simulator.kotlin.runBlockingSimulation
+import org.opendc.simulator.kotlin.runSimulation
import java.util.*
/**
@@ -40,7 +40,7 @@ import java.util.*
internal class FaaSServiceTest {
@Test
- fun testClientState() = runBlockingSimulation {
+ fun testClientState() = runSimulation {
val service = FaaSService(coroutineContext, clock, mockk(), mockk(), mockk())
val client = assertDoesNotThrow { service.newClient() }
@@ -54,7 +54,7 @@ internal class FaaSServiceTest {
}
@Test
- fun testClientInvokeUnknown() = runBlockingSimulation {
+ fun testClientInvokeUnknown() = runSimulation {
val service = FaaSService(coroutineContext, clock, mockk(), mockk(), mockk())
val client = service.newClient()
@@ -63,7 +63,7 @@ internal class FaaSServiceTest {
}
@Test
- fun testClientFunctionCreation() = runBlockingSimulation {
+ fun testClientFunctionCreation() = runSimulation {
val service = FaaSService(coroutineContext, clock, mockk(), mockk(), mockk())
val client = service.newClient()
@@ -74,7 +74,7 @@ internal class FaaSServiceTest {
}
@Test
- fun testClientFunctionQuery() = runBlockingSimulation {
+ fun testClientFunctionQuery() = runSimulation {
val service = FaaSService(coroutineContext, clock, mockk(), mockk(), mockk())
val client = service.newClient()
@@ -87,7 +87,7 @@ internal class FaaSServiceTest {
}
@Test
- fun testClientFunctionFindById() = runBlockingSimulation {
+ fun testClientFunctionFindById() = runSimulation {
val service = FaaSService(coroutineContext, clock, mockk(), mockk(), mockk())
val client = service.newClient()
@@ -100,7 +100,7 @@ internal class FaaSServiceTest {
}
@Test
- fun testClientFunctionFindByName() = runBlockingSimulation {
+ fun testClientFunctionFindByName() = runSimulation {
val service = FaaSService(coroutineContext, clock, mockk(), mockk(), mockk())
val client = service.newClient()
@@ -113,7 +113,7 @@ internal class FaaSServiceTest {
}
@Test
- fun testClientFunctionDuplicateName() = runBlockingSimulation {
+ fun testClientFunctionDuplicateName() = runSimulation {
val service = FaaSService(coroutineContext, clock, mockk(), mockk(), mockk())
val client = service.newClient()
@@ -124,7 +124,7 @@ internal class FaaSServiceTest {
}
@Test
- fun testClientFunctionDelete() = runBlockingSimulation {
+ fun testClientFunctionDelete() = runSimulation {
val service = FaaSService(coroutineContext, clock, mockk(), mockk(), mockk())
val client = service.newClient()
@@ -138,7 +138,7 @@ internal class FaaSServiceTest {
}
@Test
- fun testClientFunctionCannotInvokeDeleted() = runBlockingSimulation {
+ fun testClientFunctionCannotInvokeDeleted() = runSimulation {
val service = FaaSService(coroutineContext, clock, mockk(), mockk(), mockk())
val client = service.newClient()
@@ -150,7 +150,7 @@ internal class FaaSServiceTest {
}
@Test
- fun testClientFunctionInvoke() = runBlockingSimulation {
+ fun testClientFunctionInvoke() = runSimulation {
val deployer = mockk<FunctionDeployer>()
val service = FaaSService(coroutineContext, clock, deployer, mockk(), mockk(relaxUnitFun = true))
diff --git a/opendc-faas/opendc-faas-simulator/src/test/kotlin/org/opendc/faas/simulator/SimFaaSServiceTest.kt b/opendc-faas/opendc-faas-simulator/src/test/kotlin/org/opendc/faas/simulator/SimFaaSServiceTest.kt
index 0f3bb87f..317eb0aa 100644
--- a/opendc-faas/opendc-faas-simulator/src/test/kotlin/org/opendc/faas/simulator/SimFaaSServiceTest.kt
+++ b/opendc-faas/opendc-faas-simulator/src/test/kotlin/org/opendc/faas/simulator/SimFaaSServiceTest.kt
@@ -42,7 +42,7 @@ import org.opendc.simulator.compute.model.ProcessingNode
import org.opendc.simulator.compute.model.ProcessingUnit
import org.opendc.simulator.compute.workload.SimRuntimeWorkload
import org.opendc.simulator.compute.workload.SimWorkload
-import org.opendc.simulator.kotlin.runBlockingSimulation
+import org.opendc.simulator.kotlin.runSimulation
import java.time.Duration
import java.util.*
@@ -64,7 +64,7 @@ internal class SimFaaSServiceTest {
}
@Test
- fun testSmoke() = runBlockingSimulation {
+ fun testSmoke() = runSimulation {
val random = Random(0)
val workload = spyk(object : SimFaaSWorkload, SimWorkload by SimRuntimeWorkload(1000) {
override suspend fun invoke() {