diff options
| author | Fabian Mastenbroek <mail.fabianm@gmail.com> | 2020-04-03 20:30:27 +0200 |
|---|---|---|
| committer | Fabian Mastenbroek <mail.fabianm@gmail.com> | 2020-04-03 20:30:27 +0200 |
| commit | 843a22e09f32f498d7d5b4782b54c5639375ee20 (patch) | |
| tree | d9aaf09de4222d79c139ecedabf7f8c7d47b7738 /opendc/opendc-core/src | |
| parent | 993da5586c23a8cf9c29f5970cc84284e847b408 (diff) | |
feat: Move to ERROR state on failure
Diffstat (limited to 'opendc/opendc-core/src')
| -rw-r--r-- | opendc/opendc-core/src/main/kotlin/com/atlarge/opendc/core/failure/CorrelatedFaultInjector.kt | 6 |
1 files changed, 0 insertions, 6 deletions
diff --git a/opendc/opendc-core/src/main/kotlin/com/atlarge/opendc/core/failure/CorrelatedFaultInjector.kt b/opendc/opendc-core/src/main/kotlin/com/atlarge/opendc/core/failure/CorrelatedFaultInjector.kt index f46ce512..2904fbec 100644 --- a/opendc/opendc-core/src/main/kotlin/com/atlarge/opendc/core/failure/CorrelatedFaultInjector.kt +++ b/opendc/opendc-core/src/main/kotlin/com/atlarge/opendc/core/failure/CorrelatedFaultInjector.kt @@ -99,13 +99,9 @@ public class CorrelatedFaultInjector( delay(d.toLong()) - val n = lognvariate(sizeScale, sizeShape).toInt() val targets = active.shuffled(random).take(n) - println("[${simulationContext.clock.instant()}] FAIL $targets") - - for (failureDomain in targets) { active -= failureDomain failureDomain.fail() @@ -120,8 +116,6 @@ public class CorrelatedFaultInjector( delay(df.toLong()) - println("[${simulationContext.clock.instant()}] RECOVER $targets") - for (failureDomain in targets) { failureDomain.recover() |