From 698a64615d0eef8994fc1eaf0a3b71da194e1dcd Mon Sep 17 00:00:00 2001 From: Dante Niewenhuis Date: Tue, 19 Nov 2024 10:57:37 +0100 Subject: Small update to trace-based failure models (#271) * Added startPoint to TraceBasedFailureModel.kt, this decides where in the trace, the model should start. Added repeat to TraceBasedFailureModel.kt. This decides if the trace should be repeated when finished * spotless applied * Fixed some issues with the failure shuffling * applied spotless --- .../kotlin/org/opendc/experiments/base/ScenarioIntegrationTest.kt | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) (limited to 'opendc-experiments/opendc-experiments-base/src/test/kotlin/org/opendc') diff --git a/opendc-experiments/opendc-experiments-base/src/test/kotlin/org/opendc/experiments/base/ScenarioIntegrationTest.kt b/opendc-experiments/opendc-experiments-base/src/test/kotlin/org/opendc/experiments/base/ScenarioIntegrationTest.kt index bffd9624..abf16fef 100644 --- a/opendc-experiments/opendc-experiments-base/src/test/kotlin/org/opendc/experiments/base/ScenarioIntegrationTest.kt +++ b/opendc-experiments/opendc-experiments-base/src/test/kotlin/org/opendc/experiments/base/ScenarioIntegrationTest.kt @@ -135,7 +135,11 @@ class ScenarioIntegrationTest { val workload = createTestWorkload("single_task", 1.0, seed) val topology = createTopology("single.json") val monitor = monitor - val failureModelSpec = TraceBasedFailureModelSpec("src/test/resources/failureTraces/single_failure.parquet") + val failureModelSpec = + TraceBasedFailureModelSpec( + "src/test/resources/failureTraces/single_failure.parquet", + repeat = false, + ) Provisioner(dispatcher, seed).use { provisioner -> provisioner.runSteps( @@ -145,6 +149,8 @@ class ScenarioIntegrationTest { ) val service = provisioner.registry.resolve("compute.opendc.org", ComputeService::class.java)!! + service.setTasksExpected(workload.size) + service.replay(timeSource, workload, failureModelSpec = failureModelSpec, seed = seed) } -- cgit v1.2.3