raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

Added longer waiting time to wait for leader hand-off and convergence on new leader in the LeaderLeavingSpec. Fixes #2254

Browse source
This commit is contained in:
Jonas Bonér 2012-06-20 11:03:03 +02:00
parent f5fb24719d
commit 803b37d015
2 changed files with 6 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

8
akka-cluster/src/multi-jvm/scala/akka/cluster/LeaderLeavingSpec.scala
View file

@ -39,6 +39,8 @@ abstract class LeaderLeavingSpec
lazy val secondAddress = node(second).address
lazy val thirdAddress = node(third).address
val leaderHandoffWaitingTime = 30.seconds.dilated
"A LEADER that is LEAVING" must {
"be moved to LEAVING, then to EXITING, then to REMOVED, then be shut down and then a new LEADER should be elected" taggedAs LongRunningTest in {
@ -72,13 +74,13 @@ abstract class LeaderLeavingSpec
awaitCond(cluster.latestGossip.members.exists(m => m.status == MemberStatus.Exiting && m.address == oldLeaderAddress)) // wait on EXITING
// verify that the LEADER is no longer part of the 'members' set
awaitCond(cluster.latestGossip.members.forall(_.address != oldLeaderAddress))
awaitCond(cluster.latestGossip.members.forall(_.address != oldLeaderAddress), leaderHandoffWaitingTime)
// verify that the LEADER is not part of the 'unreachable' set
awaitCond(cluster.latestGossip.overview.unreachable.forall(_.address != oldLeaderAddress))
awaitCond(cluster.latestGossip.overview.unreachable.forall(_.address != oldLeaderAddress), leaderHandoffWaitingTime)
// verify that we have a new LEADER
awaitCond(cluster.leader != oldLeaderAddress)
awaitCond(cluster.leader != oldLeaderAddress, leaderHandoffWaitingTime)
}
enterBarrier("finished")

3
akka-cluster/src/multi-jvm/scala/akka/cluster/TransitionSpec.scala
View file

@ -20,8 +20,7 @@ object TransitionMultiJvmSpec extends MultiNodeConfig {
val fifth = role("fifth")
commonConfig(debugConfig(on = false).
withFallback(ConfigFactory.parseString(
"akka.cluster.periodic-tasks-initial-delay = 300 s # turn off all periodic tasks")).
withFallback(ConfigFactory.parseString("akka.cluster.periodic-tasks-initial-delay = 300 s # turn off all periodic tasks")).
withFallback(MultiNodeClusterSpec.clusterConfig))
}