diff options
Diffstat (limited to 'opendc/opendc-core')
| -rw-r--r-- | opendc/opendc-core/src/main/kotlin/com/atlarge/opendc/core/failure/CorrelatedFaultInjector.kt | 3 |
1 files changed, 2 insertions, 1 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 2904fbec..50261db5 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 @@ -31,6 +31,7 @@ import kotlinx.coroutines.delay import kotlinx.coroutines.ensureActive import kotlinx.coroutines.launch import kotlin.math.exp +import kotlin.math.max import kotlin.random.Random import kotlin.random.asJavaRandom @@ -107,7 +108,7 @@ public class CorrelatedFaultInjector( failureDomain.fail() } - val df = lognvariate(dScale, dShape) * 6e4 + val df = max(lognvariate(dScale, dShape) * 6e4, 15 * 6e4) // Handle long overflow if (simulationContext.clock.millis() + df <= 0) { |