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

Fix failing UnreachableNodeJoinsAgainSpec

Browse source 
* Shutting down test conductor controller is never a good idea
This commit is contained in:
Patrik Nordwall 2013-04-17 22:20:51 +02:00
parent d6d64b1c1a
commit d2939fa39a
1 changed files with 3 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

7
akka-cluster/src/multi-jvm/scala/akka/cluster/UnreachableNodeJoinsAgainSpec.scala
View file

@ -59,9 +59,8 @@ abstract class UnreachableNodeJoinsAgainSpec
roles.filterNot(_ == role) roles.filterNot(_ == role)
} }
lazy val sortedRoles = roles.sorted lazy val master = second
lazy val master = sortedRoles(0) lazy val victim = fourth
lazy val victim = sortedRoles(1)
var endBarrierNumber = 0 var endBarrierNumber = 0
def endBarrier(): Unit = { def endBarrier(): Unit = {
@ -91,7 +90,7 @@ abstract class UnreachableNodeJoinsAgainSpec
enterBarrier("unplug_victim") enterBarrier("unplug_victim")
val allButVictim = allBut(victim, sortedRoles) val allButVictim = allBut(victim, roles)
runOn(victim) { runOn(victim) {
allButVictim.foreach(markNodeAsUnavailable(_)) allButVictim.foreach(markNodeAsUnavailable(_))
within(30 seconds) { within(30 seconds) {