summaryrefslogtreecommitdiff
path: root/opendc/opendc-core/src/main
diff options
context:
space:
mode:
Diffstat (limited to 'opendc/opendc-core/src/main')
-rw-r--r--opendc/opendc-core/src/main/kotlin/com/atlarge/opendc/core/failure/CorrelatedFaultInjector.kt6
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()