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

Merge pull request #1506 from akka/wip-3390-remotenodedeathwatch-failure-ban

Browse source 
Add a barrier in RemoteNodeDeathWatchSpec to compensate for connection time #3390
This commit is contained in:
Björn Antonsson 2013-05-30 05:21:22 -07:00
commit 279c601cca
1 changed files with 3 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

3
akka-remote-tests/src/multi-jvm/scala/akka/remote/RemoteNodeDeathWatchSpec.scala
View file

@ -118,6 +118,7 @@ abstract class RemoteNodeDeathWatchSpec
watcher ! WatchIt(subject)
expectMsg(1 second, Ack)
subject ! "hello1"
enterBarrier("hello1-message-sent")
enterBarrier("watch-established-1")
sleep()
@ -128,6 +129,7 @@ abstract class RemoteNodeDeathWatchSpec
val subject = system.actorOf(Props(classOf[ProbeActor], testActor), "subject1")
enterBarrier("actors-started-1")
enterBarrier("hello1-message-sent")
expectMsg(3 seconds, "hello1")
enterBarrier("watch-established-1")
@ -137,6 +139,7 @@ abstract class RemoteNodeDeathWatchSpec
runOn(third) {
enterBarrier("actors-started-1")
enterBarrier("hello1-message-sent")
enterBarrier("watch-established-1")
}