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

harden SurviveNetworkInstabilitySpec #18767

Browse source
This commit is contained in:
Patrik Nordwall 2016-08-23 17:51:57 +02:00 • committed by Johan Andrén
parent a397696f05
commit 0aca351d81
1 changed files with 13 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

16
akka-cluster/src/multi-jvm/scala/akka/cluster/SurviveNetworkInstabilitySpec.scala
View file

@ -330,9 +330,19 @@ abstract class SurviveNetworkInstabilitySpec
runOn(side1AfterJoin: _*) { runOn(side1AfterJoin: _*) {
// side2 removed // side2 removed
val expected = (side1AfterJoin map address).toSet val expected = (side1AfterJoin map address).toSet
awaitAssert(clusterView.members.map(_.address) should ===(expected)) awaitAssert {
awaitAssert(clusterView.members.collectFirst { case m if m.address == address(eighth) ⇒ m.status } should ===( // repeat the downing in case it was not successful, which may
Some(MemberStatus.Up))) // happen if the removal was reverted due to gossip merge, see issue #18767
runOn(fourth) {
for (role2 ← side2) {
cluster.down(role2)
}
}
clusterView.members.map(_.address) should ===(expected)
clusterView.members.collectFirst { case m if m.address == address(eighth) ⇒ m.status } should ===(
Some(MemberStatus.Up))
}
} }
enterBarrier("side2-removed") enterBarrier("side2-removed")