summaryrefslogtreecommitdiff
path: root/opendc-experiments/opendc-experiments-capelin/src/test
diff options
context:
space:
mode:
authorFabian Mastenbroek <mail.fabianm@gmail.com>2021-11-16 15:49:46 +0100
committerFabian Mastenbroek <mail.fabianm@gmail.com>2021-11-16 15:49:46 +0100
commit1cfd967d6d27f339b264449ff2a1adeb705de598 (patch)
tree6dc98eb37c05f7b07adff1d4e085f16c35727f6b /opendc-experiments/opendc-experiments-capelin/src/test
parent381c7589cbf01ca6ed321c58c8a3a9cbea6ebd84 (diff)
feat(workflow): Add helper tools for workflow simulations
This change adds a new module, opendc-workflow-workload that contains helper code for constructing workflow simulations using OpenDC.
Diffstat (limited to 'opendc-experiments/opendc-experiments-capelin/src/test')
-rw-r--r--opendc-experiments/opendc-experiments-capelin/src/test/kotlin/org/opendc/experiments/capelin/CapelinIntegrationTest.kt8
1 files changed, 4 insertions, 4 deletions
diff --git a/opendc-experiments/opendc-experiments-capelin/src/test/kotlin/org/opendc/experiments/capelin/CapelinIntegrationTest.kt b/opendc-experiments/opendc-experiments-capelin/src/test/kotlin/org/opendc/experiments/capelin/CapelinIntegrationTest.kt
index 1a8948f3..eedc3131 100644
--- a/opendc-experiments/opendc-experiments-capelin/src/test/kotlin/org/opendc/experiments/capelin/CapelinIntegrationTest.kt
+++ b/opendc-experiments/opendc-experiments-capelin/src/test/kotlin/org/opendc/experiments/capelin/CapelinIntegrationTest.kt
@@ -83,7 +83,7 @@ class CapelinIntegrationTest {
@Test
fun testLarge() = runBlockingSimulation {
val workload = createTestWorkload(1.0)
- val runner = ComputeWorkloadRunner(
+ val runner = ComputeServiceHelper(
coroutineContext,
clock,
computeScheduler
@@ -131,7 +131,7 @@ class CapelinIntegrationTest {
val seed = 1
val workload = createTestWorkload(0.25, seed)
- val simulator = ComputeWorkloadRunner(
+ val simulator = ComputeServiceHelper(
coroutineContext,
clock,
computeScheduler
@@ -180,7 +180,7 @@ class CapelinIntegrationTest {
.read(perfInterferenceInput)
.withSeed(seed.toLong())
- val simulator = ComputeWorkloadRunner(
+ val simulator = ComputeServiceHelper(
coroutineContext,
clock,
computeScheduler,
@@ -222,7 +222,7 @@ class CapelinIntegrationTest {
@Test
fun testFailures() = runBlockingSimulation {
val seed = 1
- val simulator = ComputeWorkloadRunner(
+ val simulator = ComputeServiceHelper(
coroutineContext,
clock,
computeScheduler,