From a66ababd27f78002540f4329f770543713cc7aa6 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Jonas=20Bone=CC=81r?= Date: Mon, 28 May 2012 11:33:14 +0200 Subject: [PATCH] Decreased failure detector threshold to shorten failure detection time. MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Signed-off-by: Jonas BoneĢr --- .../scala/akka/cluster/LeaderDowningSpec.scala | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) diff --git a/akka-cluster/src/multi-jvm/scala/akka/cluster/LeaderDowningSpec.scala b/akka-cluster/src/multi-jvm/scala/akka/cluster/LeaderDowningSpec.scala index 357f360853..a8191057e7 100644 --- a/akka-cluster/src/multi-jvm/scala/akka/cluster/LeaderDowningSpec.scala +++ b/akka-cluster/src/multi-jvm/scala/akka/cluster/LeaderDowningSpec.scala @@ -18,7 +18,12 @@ object LeaderDowningNodeThatIsUnreachableMultiJvmSpec extends MultiNodeConfig { val fourth = role("fourth") commonConfig(debugConfig(on = false). - withFallback(ConfigFactory.parseString("akka.cluster.auto-down = on")). + withFallback(ConfigFactory.parseString(""" + akka.cluster { + auto-down = on + failure-detector.threshold = 4 + } + """)). withFallback(MultiNodeClusterSpec.clusterConfig)) } @@ -60,8 +65,6 @@ class LeaderDowningNodeThatIsUnreachableSpec cluster.join(node(first).address) awaitUpConvergence(numberOfMembers = 4) - - cluster.isLeader must be(false) testConductor.enter("all-up") } @@ -102,8 +105,6 @@ class LeaderDowningNodeThatIsUnreachableSpec cluster.join(node(first).address) awaitUpConvergence(numberOfMembers = 3) - - cluster.isLeader must be(false) testConductor.enter("all-up") }