From 5047e4a25a0814f96852882f02c4017e1d5f81e7 Mon Sep 17 00:00:00 2001 From: Dante Niewenhuis Date: Thu, 12 Sep 2024 15:32:47 +0200 Subject: Added max number of failures (#254) * Added a max failure for tasks. If tasks fail more times, they get cancelled * Added maxNumFailures to the frontend * Updated tests --- .../org/opendc/compute/failure/models/TraceBasedFailureModel.kt | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-) (limited to 'opendc-compute/opendc-compute-failure') diff --git a/opendc-compute/opendc-compute-failure/src/main/kotlin/org/opendc/compute/failure/models/TraceBasedFailureModel.kt b/opendc-compute/opendc-compute-failure/src/main/kotlin/org/opendc/compute/failure/models/TraceBasedFailureModel.kt index 28acd49a..f1ff09e9 100644 --- a/opendc-compute/opendc-compute-failure/src/main/kotlin/org/opendc/compute/failure/models/TraceBasedFailureModel.kt +++ b/opendc-compute/opendc-compute-failure/src/main/kotlin/org/opendc/compute/failure/models/TraceBasedFailureModel.kt @@ -23,7 +23,6 @@ package org.opendc.compute.failure.models import kotlinx.coroutines.delay -import kotlinx.coroutines.launch import org.opendc.compute.service.ComputeService import org.opendc.trace.Trace import org.opendc.trace.conv.FAILURE_DURATION @@ -79,12 +78,11 @@ public class TraceBasedFailureModel( override suspend fun runInjector() { do { for (failure in failureList) { - delay(failure.failureInterval - clock.millis()) + delay(failure.failureInterval) val victims = victimSelector.select(hosts, failure.failureIntensity) - scope.launch { - fault.apply(victims, failure.failureDuration) - } + + fault.apply(victims, failure.failureDuration) } } while (repeat) } -- cgit v1.2.3