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

=rem #17151 Add missing barrier in RemoteNodeRestartGate

Browse source
This commit is contained in:
Patrik Nordwall 2015-04-08 15:28:16 +02:00
parent ea2219950d
commit 863920db48
1 changed files with 4 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

7
akka-remote-tests/src/multi-jvm/scala/akka/remote/RemoteNodeRestartGateSpec.scala
View file

@ -61,9 +61,12 @@ abstract class RemoteNodeRestartGateSpec
"RemoteNodeRestartGate" must {
"allow restarted node to pass through gate" taggedAs LongRunningTest in {
system.actorOf(Props[Subject], "subject")
enterBarrier("subject-started")
runOn(first) {
val secondAddress = node(second).address
system.actorOf(Props[Subject], "subject")
identify(second, "subject")
@ -90,8 +93,6 @@ abstract class RemoteNodeRestartGateSpec
val addr = system.asInstanceOf[ExtendedActorSystem].provider.getDefaultAddress
val firstAddress = node(first).address
system.actorOf(Props[Subject], "subject")
enterBarrier("gated")
Await.ready(system.whenTerminated, 10.seconds)