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

Merge pull request #20106 from akka/wip-19536-NodeChurnSpec-patriknw

Browse source 
harden cluster.NodeChurnSpec, #19536
This commit is contained in:
Patrik Nordwall 2016-03-22 15:12:14 +01:00
commit 12db887ebb
1 changed files with 13 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

21
akka-cluster/src/multi-jvm/scala/akka/cluster/NodeChurnSpec.scala
View file

@ -63,20 +63,24 @@ abstract class NodeChurnSpec
def awaitAllMembersUp(additionaSystems: Vector[ActorSystem]): Unit = {
val numberOfMembers = roles.size + roles.size * additionaSystems.size
awaitMembersUp(numberOfMembers)
awaitAssert {
additionaSystems.foreach { s ⇒
val c = Cluster(s)
c.state.members.size should be(numberOfMembers)
c.state.members.forall(_.status == MemberStatus.Up) shouldBe true
within(20.seconds) {
awaitAssert {
additionaSystems.foreach { s ⇒
val c = Cluster(s)
c.state.members.size should be(numberOfMembers)
c.state.members.forall(_.status == MemberStatus.Up) shouldBe true
}
}
}
}
def awaitRemoved(additionaSystems: Vector[ActorSystem]): Unit = {
awaitMembersUp(roles.size, timeout = 40.seconds)
awaitAssert {
additionaSystems.foreach { s ⇒
Cluster(s).isTerminated should be(true)
within(20.seconds) {
awaitAssert {
additionaSystems.foreach { s ⇒
Cluster(s).isTerminated should be(true)
}
}
}
}
@ -87,6 +91,7 @@ abstract class NodeChurnSpec
system.eventStream.subscribe(logListener, classOf[Info])
cluster.joinSeedNodes(seedNodes)
awaitMembersUp(roles.size)
enterBarrier("stable")
}
"join and remove transient nodes without growing gossip payload" taggedAs LongRunningTest in {