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

Fixed randomly failing test for Ticket #1111

Browse source
This commit is contained in:
Vasil Remeniuk 2011-08-19 18:18:31 +03:00
parent ea92c552d3
commit 63e3659971
1 changed files with 15 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

20
akka-actor-tests/src/test/scala/akka/ticket/Ticket1111Spec.scala
View file

@ -16,22 +16,32 @@ class Ticket1111Spec extends WordSpec with MustMatchers {
"return response, even if one of the connections has stopped" in {
val actor = Routing.actorOf("foo", List(newActor(0), newActor(1)),
val shutdownLatch = new CountDownLatch(1)
val actor = Routing.actorOf("foo", List(newActor(0, Some(shutdownLatch)),
newActor(1, Some(shutdownLatch))),
new ScatterGatherFirstCompletedRouter()).start()
actor ! Broadcast(Stop(Some(0)))
shutdownLatch.await(5, TimeUnit.SECONDS) must be(true)
(actor ? Broadcast(0)).get.asInstanceOf[Int] must be(1)
}
"throw an exception, if all the connections have stopped" in {
val actor = Routing.actorOf("foo", List(newActor(0), newActor(1)),
val shutdownLatch = new CountDownLatch(2)
val actor = Routing.actorOf("foo", List(newActor(0, Some(shutdownLatch)),
newActor(1, Some(shutdownLatch))),
new ScatterGatherFirstCompletedRouter()).start()
actor ! Broadcast(Stop())
shutdownLatch.await(5, TimeUnit.SECONDS) must be(true)
(intercept[RoutingException] {
actor ? Broadcast(0)
}) must not be (null)
@ -144,10 +154,10 @@ class Ticket1111Spec extends WordSpec with MustMatchers {
case class Stop(id: Option[Int] = None)
def newActor(id: Int) = actorOf(new Actor {
def newActor(id: Int, shudownLatch: Option[CountDownLatch] = None) = actorOf(new Actor {
def receive = {
case Stop(None) ⇒ self.stop()
case Stop(Some(_id)) if (_id == id) ⇒ self.stop()
case Stop(None) ⇒ self.stop(); shudownLatch.map(_.countDown())
case Stop(Some(_id)) if (_id == id) ⇒ self.stop(); shudownLatch.map(_.countDown())
case _id: Int if (_id == id) ⇒
case _ ⇒ Thread sleep 100 * id; self tryReply id
}