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

Adding a flooding test to reproduce error reported by user

Browse source
This commit is contained in:
Viktor Klang 2010-10-25 14:26:12 +02:00
parent dc958f6942
commit 79ea0f8c3f
1 changed files with 19 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

19
akka-actor/src/test/scala/dispatch/ActorModelSpec.scala
View file

@ -23,6 +23,7 @@ object ActorModelSpec {
case class Increment(counter: AtomicLong) extends ActorModelMessage
case class Await(latch: CountDownLatch) extends ActorModelMessage
case class Meet(acknowledge: CountDownLatch, waitFor: CountDownLatch) extends ActorModelMessage
case class CountDownNStop(latch: CountDownLatch) extends ActorModelMessage
case object Restart extends ActorModelMessage
val Ping = "Ping"
@ -45,6 +46,7 @@ object ActorModelSpec {
case Forward(to,msg) => ack; to.forward(msg)
case CountDown(latch) => ack; latch.countDown()
case Increment(count) => ack; count.incrementAndGet()
case CountDownNStop(l)=> ack; l.countDown; self.stop
case Restart => ack; throw new Exception("Restart requested")
}
}
@ -264,6 +266,23 @@ abstract class ActorModelSpec extends JUnitSuite {
assertRefDefaultZero(a)(registers = 1,unregisters = 1, msgsReceived = 1, msgsProcessed = 1,
suspensions = 1, resumes = 1)
}
@Test def dispatcherShouldHandleWavesOfActors {
implicit val dispatcher = newInterceptedDispatcher
def flood(num: Int) {
val cachedMessage = CountDownNStop(new CountDownLatch(num))
(1 to num) foreach {
_ => newTestActor.start ! cachedMessage
}
assertCountDown(cachedMessage.latch,10000, "Should process " + num + " countdowns")
}
for(run <- 1 to 3) {
flood(10000)
Thread.sleep(dispatcher.timeoutMs * 2)
assertDispatcher(dispatcher)(starts = run, stops = run)
}
}
}
class ExecutorBasedEventDrivenDispatcherModelTest extends ActorModelSpec {