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

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)
     }