diff options
| author | Dante Niewenhuis <d.niewenhuis@hotmail.com> | 2024-09-12 15:32:47 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2024-09-12 15:32:47 +0200 |
| commit | 5047e4a25a0814f96852882f02c4017e1d5f81e7 (patch) | |
| tree | 348f064fd8e03a2a64fc5b30406e992586b4aac0 /opendc-compute/opendc-compute-failure/src | |
| parent | ad8051faa1f0a6e7f78384e9e0607e847848c033 (diff) | |
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
Diffstat (limited to 'opendc-compute/opendc-compute-failure/src')
| -rw-r--r-- | opendc-compute/opendc-compute-failure/src/main/kotlin/org/opendc/compute/failure/models/TraceBasedFailureModel.kt | 8 |
1 files changed, 3 insertions, 5 deletions
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) } |