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

ClusterSpec, race between MemberRemoved and MemberExited, #23449 (#24105)

Browse source
This commit is contained in:
Patrik Nordwall 2017-12-05 15:12:19 +01:00 • committed by Konrad `ktoso` Malawski
parent 3dda73c1ea
commit 52f30a8043
1 changed files with 12 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

16
akka-cluster/src/test/scala/akka/cluster/ClusterSpec.scala
View file

@ -160,8 +160,12 @@ class ClusterSpec extends AkkaSpec(ClusterSpec.config) with ImplicitSender {
CoordinatedShutdown(sys2).run(CoordinatedShutdown.UnknownReason) CoordinatedShutdown(sys2).run(CoordinatedShutdown.UnknownReason)
probe.expectMsgType[MemberLeft] probe.expectMsgType[MemberLeft]
probe.expectMsgType[MemberExited] // MemberExited might not be published before MemberRemoved
probe.expectMsgType[MemberRemoved] val removed = probe.fishForMessage() {
case _: MemberExited ⇒ false
case _: MemberRemoved ⇒ true
}.asInstanceOf[MemberRemoved]
removed.previousStatus should ===(MemberStatus.Exiting)
} finally { } finally {
shutdown(sys2) shutdown(sys2)
} }
@ -183,8 +187,12 @@ class ClusterSpec extends AkkaSpec(ClusterSpec.config) with ImplicitSender {
Cluster(sys2).leave(Cluster(sys2).selfAddress) Cluster(sys2).leave(Cluster(sys2).selfAddress)
probe.expectMsgType[MemberLeft] probe.expectMsgType[MemberLeft]
probe.expectMsgType[MemberExited] // MemberExited might not be published before MemberRemoved
probe.expectMsgType[MemberRemoved] val removed = probe.fishForMessage() {
case _: MemberExited ⇒ false
case _: MemberRemoved ⇒ true
}.asInstanceOf[MemberRemoved]
removed.previousStatus should ===(MemberStatus.Exiting)
Await.result(sys2.whenTerminated, 10.seconds) Await.result(sys2.whenTerminated, 10.seconds)
Cluster(sys2).isTerminated should ===(true) Cluster(sys2).isTerminated should ===(true)
CoordinatedShutdown(sys2).shutdownReason() should ===(Some(CoordinatedShutdown.ClusterLeavingReason)) CoordinatedShutdown(sys2).shutdownReason() should ===(Some(CoordinatedShutdown.ClusterLeavingReason))