From 95c9ae8a7c4efae57caba9863dfc3e10df23c2fd Mon Sep 17 00:00:00 2001 From: Fabian Mastenbroek Date: Fri, 13 Mar 2020 20:55:55 +0100 Subject: [ci skip] feat: Prototype design for FailureInjector --- .../opendc/compute/metal/driver/SimpleBareMetalDriverTest.kt | 6 ++++++ 1 file changed, 6 insertions(+) (limited to 'opendc/opendc-compute/src') diff --git a/opendc/opendc-compute/src/test/kotlin/com/atlarge/opendc/compute/metal/driver/SimpleBareMetalDriverTest.kt b/opendc/opendc-compute/src/test/kotlin/com/atlarge/opendc/compute/metal/driver/SimpleBareMetalDriverTest.kt index 166e93b8..1a2440c2 100644 --- a/opendc/opendc-compute/src/test/kotlin/com/atlarge/opendc/compute/metal/driver/SimpleBareMetalDriverTest.kt +++ b/opendc/opendc-compute/src/test/kotlin/com/atlarge/opendc/compute/metal/driver/SimpleBareMetalDriverTest.kt @@ -34,6 +34,8 @@ import com.atlarge.opendc.compute.core.image.FlopsApplicationImage import com.atlarge.opendc.compute.metal.Node import com.atlarge.opendc.compute.metal.NodeState import com.atlarge.opendc.compute.metal.monitor.NodeMonitor +import com.atlarge.opendc.core.failure.FailureInjector +import kotlinx.coroutines.channels.Channel import kotlinx.coroutines.launch import kotlinx.coroutines.runBlocking import kotlinx.coroutines.withContext @@ -76,6 +78,10 @@ internal class SimpleBareMetalDriverTest { driver.setImage(image) driver.start() } + + + val injector = FailureInjector(listOf(driver)) + injector() } runBlocking { -- cgit v1.2.3