possible bugs in CallingThreadDispatcher
[ERROR] [11/22/2011 13:25:34.650] [pool-6-thread-1] [akka.testkit.CallingThreadDispatcherModelSpec$$anon$1@70a393f4] actual: stops=2 required: stops=1
java.lang.AssertionError: await failed
at akka.actor.dispatch.ActorModelSpec$.await(ActorModelSpec.scala:222)
at akka.actor.dispatch.ActorModelSpec$.assertDispatcher(ActorModelSpec.scala:147)
at akka.actor.dispatch.ActorModelSpec$$anonfun$1$$anonfun$apply$mcV$sp$7$$anonfun$apply$mcV$sp$8.apply$mcVI$sp(ActorModelSpec.scala:375)
at scala.collection.immutable.Range.foreach$mVc$sp(Range.scala:75)
at akka.actor.dispatch.ActorModelSpec$$anonfun$1$$anonfun$apply$mcV$sp$7.apply$mcV$sp(ActorModelSpec.scala:373)
at akka.actor.dispatch.ActorModelSpec$$anonfun$1$$anonfun$apply$mcV$sp$7.apply(ActorModelSpec.scala:336)
at akka.actor.dispatch.ActorModelSpec$$anonfun$1$$anonfun$apply$mcV$sp$7.apply(ActorModelSpec.scala:336)
at org.scalatest.WordSpec$$anon$2.apply(WordSpec.scala:2161)
at org.scalatest.Suite$class.withFixture(Suite.scala:1968)
Leave a comment
Just seen another strange one:
[info] LoggingReceiveSpec:
[info] A LoggingReceive
[info] - must decorate a Receive
[info] - must be added on Actor if requested
[info] - must not duplicate logging
[info] An Actor
[info] - must log AutoReceiveMessages if requested
[info] - must log LifeCycle changes if requested
[ERROR] [12/03/2011 20:52:09.671] [DefaultDispatcher-496366] [akka://lifecycle/system/testActor22] null
java.lang.NullPointerException
at akka.actor.Actor$class.apply(Actor.scala:363)
at akka.testkit.TestActor.apply(TestKit.scala:31)
at akka.actor.ActorCell.invoke(ActorCell.scala:331)
at akka.testkit.CallingThreadDispatcher.runQueue(CallingThreadDispatcher.scala:228)
at akka.testkit.CallingThreadDispatcher.dispatch(CallingThreadDispatcher.scala:194)
at akka.actor.ActorCell.tell(ActorCell.scala:182)
at akka.actor.LocalActorRef.$bang(ActorRef.scala:292)
at akka.event.EventStream.publish(EventStream.scala:33)
at akka.event.EventStream.publish(EventStream.scala:18)
at akka.event.SubchannelClassification$$anonfun$publish$1.apply(EventBus.scala:174)
at akka.event.SubchannelClassification$$anonfun$publish$1.apply(EventBus.scala:174)
at scala.collection.immutable.Set$Set1.foreach(Set.scala:86)
at akka.event.SubchannelClassification$class.publish(EventBus.scala:174)
at akka.event.EventStream.publish(EventStream.scala:18)
at akka.actor.ActorCell.doTerminate(ActorCell.scala:397)
at akka.actor.ActorCell.terminate$1(ActorCell.scala:270)
at akka.actor.ActorCell.systemInvoke(ActorCell.scala:310)
at akka.dispatch.Mailbox.processAllSystemMessages(Mailbox.scala:194)
at akka.dispatch.Mailbox.run(Mailbox.scala:148)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
at java.lang.Thread.run(Thread.java:680)
at akka.dispatch.MonitorableThread.run(ThreadPoolBuilder.scala:183)
on 2011-12-07 04:21 *
By viktorklang
Also this:
[info] - handle waves of actors *** FAILED ***
[info] Failed to count down within 30000 millis (count at 2160). Counting down from 50000 (ActorModelSpec.scala:158)
[info] org.scalatest.TestFailedException:
[info] at org.scalatest.Assertions$class.newAssertionFailedException(Assertions.scala:318)
[info] at org.scalatest.Assertions$.newAssertionFailedException(Assertions.scala:816)
[info] at org.scalatest.Assertions$class.fail(Assertions.scala:675)
[info] at org.scalatest.Assertions$.fail(Assertions.scala:816)
[info] at akka.actor.dispatch.ActorModelSpec$.assertCountDown(ActorModelSpec.scala:158)
[info] at akka.actor.dispatch.ActorModelSpec$$anonfun$1$$anonfun$apply$mcV$sp$7.flood$1(ActorModelSpec.scala:350)
[info] at akka.actor.dispatch.ActorModelSpec$$anonfun$1$$anonfun$apply$mcV$sp$7$$anonfun$apply$mcV$sp$8.apply$mcVI$sp(ActorModelSpec.scala:374)
[info] at scala.collection.immutable.Range.foreach$mVc$sp(Range.scala:78)
[info] at akka.actor.dispatch.ActorModelSpec$$anonfun$1$$anonfun$apply$mcV$sp$7.apply$mcV$sp(ActorModelSpec.scala:373)
[info] at akka.actor.dispatch.ActorModelSpec$$anonfun$1$$anonfun$apply$mcV$sp$7.apply(ActorModelSpec.scala:336)
[info] at akka.actor.dispatch.ActorModelSpec$$anonfun$1$$anonfun$apply$mcV$sp$7.apply(ActorModelSpec.scala:336)
[info] at org.scalatest.WordSpec$$anon$2.apply(WordSpec.scala:2161)
[info] at org.scalatest.Suite$class.withFixture(Suite.scala:1968)
[info] at akka.testkit.AkkaSpec.withFixture(AkkaSpec.scala:43)
[info] at org.scalatest.WordSpec$class.invokeWithFixture$1(WordSpec.scala:2158)
[info] at org.scalatest.WordSpec$$anonfun$runTest$1.apply(WordSpec.scala:2167)
[info] at org.scalatest.WordSpec$$anonfun$runTest$1.apply(WordSpec.scala:2167)
[info] at org.scalatest.SuperEngine.runTestImpl(Engine.scala:168)
[info] at org.scalatest.WordSpec$class.runTest(WordSpec.scala:2167)
[info] at akka.testkit.AkkaSpec.runTest(AkkaSpec.scala:43)
[info] at org.scalatest.WordSpec$$anonfun$runTests$1.apply(WordSpec.scala:2232)
[info] at org.scalatest.WordSpec$$anonfun$runTests$1.apply(WordSpec.scala:2232)
[info] at org.scalatest.SuperEngine$$anonfun$org$scalatest$SuperEngine$$runTestsInBranch$1.apply(Engine.scala:226)
[info] at org.scalatest.SuperEngine$$anonfun$org$scalatest$SuperEngine$$runTestsInBranch$1.apply(Engine.scala:215)
[info] at scala.collection.LinearSeqOptimized$class.foreach(LinearSeqOptimized.scala:59)
[info] at scala.collection.immutable.List.foreach(List.scala:45)
[info] at org.scalatest.SuperEngine.org$scalatest$SuperEngine$$runTestsInBranch(Engine.scala:215)
[info] at org.scalatest.SuperEngine$$anonfun$org$scalatest$SuperEngine$$runTestsInBranch$1.apply(Engine.scala:231)
[info] at org.scalatest.SuperEngine$$anonfun$org$scalatest$SuperEngine$$runTestsInBranch$1.apply(Engine.scala:215)
[info] at scala.collection.LinearSeqOptimized$class.foreach(LinearSeqOptimized.scala:59)
[info] at scala.collection.immutable.List.foreach(List.scala:45)
[info] at org.scalatest.SuperEngine.org$scalatest$SuperEngine$$runTestsInBranch(Engine.scala:215)
[info] at org.scalatest.SuperEngine.runTestsImpl(Engine.scala:282)
[info] at org.scalatest.WordSpec$class.runTests(WordSpec.scala:2232)
[info] at akka.testkit.AkkaSpec.runTests(AkkaSpec.scala:43)
[info] at org.scalatest.Suite$class.run(Suite.scala:2286)
[info] at akka.testkit.AkkaSpec.org$scalatest$WordSpec$$super$run(AkkaSpec.scala:43)
[info] at org.scalatest.WordSpec$$anonfun$run$1.apply(WordSpec.scala:2279)
[info] at org.scalatest.WordSpec$$anonfun$run$1.apply(WordSpec.scala:2279)
[info] at org.scalatest.SuperEngine.runImpl(Engine.scala:318)
[info] at org.scalatest.WordSpec$class.run(WordSpec.scala:2279)
[info] at akka.testkit.AkkaSpec.org$scalatest$BeforeAndAfterAll$$super$run(AkkaSpec.scala:43)
[info] at org.scalatest.BeforeAndAfterAll$class.run(BeforeAndAfterAll.scala:213)
[info] at akka.testkit.AkkaSpec.run(AkkaSpec.scala:43)
[info] at org.scalatest.tools.ScalaTestFramework$ScalaTestRunner.run(ScalaTestFramework.scala:148)
[info] at sbt.TestRunner.delegateRun(TestFramework.scala:61)
[info] at sbt.TestRunner.run(TestFramework.scala:55)
[info] at sbt.TestRunner.runTest$1(TestFramework.scala:75)
[info] at sbt.TestRunner.run(TestFramework.scala:84)
[info] at sbt.TestFramework$$anonfun$6$$anonfun$apply$8$$anonfun$7$$anonfun$apply$9.apply(TestFramework.scala:183)
[info] at sbt.TestFramework$$anonfun$6$$anonfun$apply$8$$anonfun$7$$anonfun$apply$9.apply(TestFramework.scala:183)
[info] at sbt.TestFramework$.sbt$TestFramework$$withContextLoader(TestFramework.scala:195)
[info] at sbt.TestFramework$$anonfun$6$$anonfun$apply$8$$anonfun$7.apply(TestFramework.scala:183)
[info] at sbt.TestFramework$$anonfun$6$$anonfun$apply$8$$anonfun$7.apply(TestFramework.scala:183)
[info] at sbt.Tests$$anonfun$makeSerial$1$$anonfun$apply$8.apply(Tests.scala:115)
[info] at sbt.Tests$$anonfun$makeSerial$1$$anonfun$apply$8.apply(Tests.scala:115)
[info] at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:194)
[info] at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:194)
[info] at scala.collection.LinearSeqOptimized$class.foreach(LinearSeqOptimized.scala:59)
[info] at scala.collection.immutable.List.foreach(List.scala:45)
[info] at scala.collection.TraversableLike$class.map(TraversableLike.scala:194)
[info] at scala.collection.immutable.List.map(List.scala:45)
[info] at sbt.Tests$$anonfun$makeSerial$1.apply(Tests.scala:115)
[info] at sbt.Tests$$anonfun$makeSerial$1.apply(Tests.scala:115)
[info] at sbt.std.Transform$$anon$3$$anonfun$apply$2.apply(System.scala:47)
[info] at sbt.std.Transform$$anon$3$$anonfun$apply$2.apply(System.scala:47)
[info] at sbt.std.Transform$$anon$5.work(System.scala:67)
[info] at sbt.Execute$$anonfun$submit$1$$anonfun$apply$1.apply(Execute.scala:221)
[info] at sbt.Execute$$anonfun$submit$1$$anonfun$apply$1.apply(Execute.scala:221)
[info] at sbt.ErrorHandling$.wideConvert(ErrorHandling.scala:13)
[info] at sbt.Execute.work(Execute.scala:227)
[info] at sbt.Execute$$anonfun$submit$1.apply(Execute.scala:221)
[info] at sbt.Execute$$anonfun$submit$1.apply(Execute.scala:221)
[info] at sbt.CompletionService$$anon$1$$anon$2.call(CompletionService.scala:26)
[info] at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
[info] at java.util.concurrent.FutureTask.run(FutureTask.java:138)
[info] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:441)
[info] at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
[info] at java.util.concurrent.FutureTask.run(FutureTask.java:138)
[info] at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
[info] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
[info] at java.lang.Thread.run(Thread.java:680)
[info] - handle waves of actors *** FAILED ***
[info] Failed to count down within 30000 millis (count at 2160). Counting down from 50000 (ActorModelSpec.scala:158)
[info] org.scalatest.TestFailedException:
[info] at org.scalatest.Assertions$class.newAssertionFailedException(Assertions.scala:318)
[info] at org.scalatest.Assertions$.newAssertionFailedException(Assertions.scala:816)
[info] at org.scalatest.Assertions$class.fail(Assertions.scala:675)
[info] at org.scalatest.Assertions$.fail(Assertions.scala:816)
[info] at akka.actor.dispatch.ActorModelSpec$.assertCountDown(ActorModelSpec.scala:158)
[info] at akka.actor.dispatch.ActorModelSpec$$anonfun$1$$anonfun$apply$mcV$sp$7.flood$1(ActorModelSpec.scala:350)
[info] at akka.actor.dispatch.ActorModelSpec$$anonfun$1$$anonfun$apply$mcV$sp$7$$anonfun$apply$mcV$sp$8.apply$mcVI$sp(ActorModelSpec.scala:374)
[info] at scala.collection.immutable.Range.foreach$mVc$sp(Range.scala:78)
[info] at akka.actor.dispatch.ActorModelSpec$$anonfun$1$$anonfun$apply$mcV$sp$7.apply$mcV$sp(ActorModelSpec.scala:373)
[info] at akka.actor.dispatch.ActorModelSpec$$anonfun$1$$anonfun$apply$mcV$sp$7.apply(ActorModelSpec.scala:336)
[info] at akka.actor.dispatch.ActorModelSpec$$anonfun$1$$anonfun$apply$mcV$sp$7.apply(ActorModelSpec.scala:336)
[info] at org.scalatest.WordSpec$$anon$2.apply(WordSpec.scala:2161)
[info] at org.scalatest.Suite$class.withFixture(Suite.scala:1968)
[info] at akka.testkit.AkkaSpec.withFixture(AkkaSpec.scala:43)
[info] at org.scalatest.WordSpec$class.invokeWithFixture$1(WordSpec.scala:2158)
[info] at org.scalatest.WordSpec$$anonfun$runTest$1.apply(WordSpec.scala:2167)
[info] at org.scalatest.WordSpec$$anonfun$runTest$1.apply(WordSpec.scala:2167)
[info] at org.scalatest.SuperEngine.runTestImpl(Engine.scala:168)
[info] at org.scalatest.WordSpec$class.runTest(WordSpec.scala:2167)
[info] at akka.testkit.AkkaSpec.runTest(AkkaSpec.scala:43)
[info] at org.scalatest.WordSpec$$anonfun$runTests$1.apply(WordSpec.scala:2232)
[info] at org.scalatest.WordSpec$$anonfun$runTests$1.apply(WordSpec.scala:2232)
[info] at org.scalatest.SuperEngine$$anonfun$org$scalatest$SuperEngine$$runTestsInBranch$1.apply(Engine.scala:226)
[info] at org.scalatest.SuperEngine$$anonfun$org$scalatest$SuperEngine$$runTestsInBranch$1.apply(Engine.scala:215)
[info] at scala.collection.LinearSeqOptimized$class.foreach(LinearSeqOptimized.scala:59)
[info] at scala.collection.immutable.List.foreach(List.scala:45)
[info] at org.scalatest.SuperEngine.org$scalatest$SuperEngine$$runTestsInBranch(Engine.scala:215)
[info] at org.scalatest.SuperEngine$$anonfun$org$scalatest$SuperEngine$$runTestsInBranch$1.apply(Engine.scala:231)
[info] at org.scalatest.SuperEngine$$anonfun$org$scalatest$SuperEngine$$runTestsInBranch$1.apply(Engine.scala:215)
[info] at scala.collection.LinearSeqOptimized$class.foreach(LinearSeqOptimized.scala:59)
[info] at scala.collection.immutable.List.foreach(List.scala:45)
[info] at org.scalatest.SuperEngine.org$scalatest$SuperEngine$$runTestsInBranch(Engine.scala:215)
[info] at org.scalatest.SuperEngine.runTestsImpl(Engine.scala:282)
[info] at org.scalatest.WordSpec$class.runTests(WordSpec.scala:2232)
[info] at akka.testkit.AkkaSpec.runTests(AkkaSpec.scala:43)
[info] at org.scalatest.Suite$class.run(Suite.scala:2286)
[info] at akka.testkit.AkkaSpec.org$scalatest$WordSpec$$super$run(AkkaSpec.scala:43)
[info] at org.scalatest.WordSpec$$anonfun$run$1.apply(WordSpec.scala:2279)
[info] at org.scalatest.WordSpec$$anonfun$run$1.apply(WordSpec.scala:2279)
[info] at org.scalatest.SuperEngine.runImpl(Engine.scala:318)
[info] at org.scalatest.WordSpec$class.run(WordSpec.scala:2279)
[info] at akka.testkit.AkkaSpec.org$scalatest$BeforeAndAfterAll$$super$run(AkkaSpec.scala:43)
[info] at org.scalatest.BeforeAndAfterAll$class.run(BeforeAndAfterAll.scala:213)
[info] at akka.testkit.AkkaSpec.run(AkkaSpec.scala:43)
[info] at org.scalatest.tools.ScalaTestFramework$ScalaTestRunner.run(ScalaTestFramework.scala:148)
[info] at sbt.TestRunner.delegateRun(TestFramework.scala:61)
[info] at sbt.TestRunner.run(TestFramework.scala:55)
[info] at sbt.TestRunner.runTest$1(TestFramework.scala:75)
[info] at sbt.TestRunner.run(TestFramework.scala:84)
[info] at sbt.TestFramework$$anonfun$6$$anonfun$apply$8$$anonfun$7$$anonfun$apply$9.apply(TestFramework.scala:183)
[info] at sbt.TestFramework$$anonfun$6$$anonfun$apply$8$$anonfun$7$$anonfun$apply$9.apply(TestFramework.scala:183)
[info] at sbt.TestFramework$.sbt$TestFramework$$withContextLoader(TestFramework.scala:195)
[info] at sbt.TestFramework$$anonfun$6$$anonfun$apply$8$$anonfun$7.apply(TestFramework.scala:183)
[info] at sbt.TestFramework$$anonfun$6$$anonfun$apply$8$$anonfun$7.apply(TestFramework.scala:183)
[info] at sbt.Tests$$anonfun$makeSerial$1$$anonfun$apply$8.apply(Tests.scala:115)
[info] at sbt.Tests$$anonfun$makeSerial$1$$anonfun$apply$8.apply(Tests.scala:115)
[info] at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:194)
[info] at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:194)
[info] at scala.collection.LinearSeqOptimized$class.foreach(LinearSeqOptimized.scala:59)
[info] at scala.collection.immutable.List.foreach(List.scala:45)
[info] at scala.collection.TraversableLike$class.map(TraversableLike.scala:194)
[info] at scala.collection.immutable.List.map(List.scala:45)
[info] at sbt.Tests$$anonfun$makeSerial$1.apply(Tests.scala:115)
[info] at sbt.Tests$$anonfun$makeSerial$1.apply(Tests.scala:115)
[info] at sbt.std.Transform$$anon$3$$anonfun$apply$2.apply(System.scala:47)
[info] at sbt.std.Transform$$anon$3$$anonfun$apply$2.apply(System.scala:47)
[info] at sbt.std.Transform$$anon$5.work(System.scala:67)
[info] at sbt.Execute$$anonfun$submit$1$$anonfun$apply$1.apply(Execute.scala:221)
[info] at sbt.Execute$$anonfun$submit$1$$anonfun$apply$1.apply(Execute.scala:221)
[info] at sbt.ErrorHandling$.wideConvert(ErrorHandling.scala:13)
[info] at sbt.Execute.work(Execute.scala:227)
[info] at sbt.Execute$$anonfun$submit$1.apply(Execute.scala:221)
[info] at sbt.Execute$$anonfun$submit$1.apply(Execute.scala:221)
[info] at sbt.CompletionService$$anon$1$$anon$2.call(CompletionService.scala:26)
[info] at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
[info] at java.util.concurrent.FutureTask.run(FutureTask.java:138)
[info] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:441)
[info] at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
[info] at java.util.concurrent.FutureTask.run(FutureTask.java:138)
[info] at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
[info] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
[info] at java.lang.Thread.run(Thread.java:680)
on 2011-12-07 04:50 *
By viktorklang
Description changed from
[ERROR] [11/22/... to
[ERROR] [11/22/...
Summary changed from possible bug in CallingThreadDispatcher to possible bugs in CallingThreadDispatcher
on 2011-12-07 04:50 *
By viktorklang
and
[INFO] [11/21/2011 12:44:02.22] [DefaultDispatcher-2126] [EventStream] shutting down: StandardOutLogger started
[INFO] [11/21/2011 12:44:02.22] [DefaultDispatcher-2126] [EventStream] all default loggers stopped
[ERROR] [11/21/2011 12:44:02.185] [DefaultDispatcher-2128] [Actor[/sys/testActor37]] null
java.lang.NullPointerException
at akka.actor.Actor$class.apply(Actor.scala:392)
at akka.testkit.TestActor.apply(TestKit.scala:31)
at akka.actor.ActorCell.invoke(ActorCell.scala:288)
at akka.testkit.CallingThreadDispatcher.runQueue(CallingThreadDispatcher.scala:216)
at akka.testkit.CallingThreadDispatcher.dispatch(CallingThreadDispatcher.scala:182)
at akka.actor.ActorCell.tell(ActorCell.scala:144)
at akka.actor.LocalActorRef.$bang(ActorRef.scala:254)
at akka.event.EventStreamSpec$MyLog$$anonfun$receive$1.apply(EventStreamSpec.scala:33)
at akka.event.EventStreamSpec$MyLog$$anonfun$receive$1.apply(EventStreamSpec.scala:30)
at akka.actor.Actor$class.apply(Actor.scala:395)
at akka.event.EventStreamSpec$MyLog.apply(EventStreamSpec.scala:28)
at akka.actor.ActorCell.invoke(ActorCell.scala:288)
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:163)
at akka.dispatch.Mailbox.run(Mailbox.scala:141)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
at java.lang.Thread.run(Thread.java:680)
at akka.dispatch.MonitorableThread.run(ThreadPoolBuilder.scala:180)
[WARN] [11/21/2011 12:44:02.186] [DefaultDispatcher-2128] [Actor[/sys/log1-EventStreamSpec$MyLog]] evict of /sys/log1-EventStreamSpec$MyLog failed
[info] EventStreamSpec:
[info] An EventStream
[info] - must manage subscriptions
[info] - must manage log levels
[info] - must manage sub-channels
[INFO] [11/21/2011 12:44:02.22] [DefaultDispatcher-2126] [EventStream] shutting down: StandardOutLogger started
[INFO] [11/21/2011 12:44:02.22] [DefaultDispatcher-2126] [EventStream] all default loggers stopped
[ERROR] [11/21/2011 12:44:02.185] [DefaultDispatcher-2128] [Actor[/sys/testActor37]] null
java.lang.NullPointerException
at akka.actor.Actor$class.apply(Actor.scala:392)
at akka.testkit.TestActor.apply(TestKit.scala:31)
at akka.actor.ActorCell.invoke(ActorCell.scala:288)
at akka.testkit.CallingThreadDispatcher.runQueue(CallingThreadDispatcher.scala:216)
at akka.testkit.CallingThreadDispatcher.dispatch(CallingThreadDispatcher.scala:182)
at akka.actor.ActorCell.tell(ActorCell.scala:144)
at akka.actor.LocalActorRef.$bang(ActorRef.scala:254)
at akka.event.EventStreamSpec$MyLog$$anonfun$receive$1.apply(EventStreamSpec.scala:33)
at akka.event.EventStreamSpec$MyLog$$anonfun$receive$1.apply(EventStreamSpec.scala:30)
at akka.actor.Actor$class.apply(Actor.scala:395)
at akka.event.EventStreamSpec$MyLog.apply(EventStreamSpec.scala:28)
at akka.actor.ActorCell.invoke(ActorCell.scala:288)
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:163)
at akka.dispatch.Mailbox.run(Mailbox.scala:141)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
at java.lang.Thread.run(Thread.java:680)
at akka.dispatch.MonitorableThread.run(ThreadPoolBuilder.scala:180)
[WARN] [11/21/2011 12:44:02.186] [DefaultDispatcher-2128] [Actor[/sys/log1-EventStreamSpec$MyLog]] evict of /sys/log1-EventStreamSpec$MyLog failed
[info] EventStreamSpec:
[info] An EventStream
[info] - must manage subscriptions
[info] - must manage log levels
[info] - must manage sub-channels
on 2012-01-10 06:40 *
By rk@rkuhn.info
(In revision:6fddb87fcaf38d8fa30bbf31c1d1496617436af3) fix one spurious buglet in CallingThreadDispatcher, see #1375
Branch: wip-1375-fix-CallingThreadDispatcher-∂π
Branch: wip-1375-fix-CallingThreadDispatcher-∂π
pushed fix for the NPEs, I believe that the other two are timing flukes: the first one is an additional shutdown which might happen if there is a 1sec hiccup during the test (GC, swapping, whathaveyou), where “normal” dispatchers are resilient because they run creation fast and processing in parallel, not everything sequentially and hence always scheduling a shutdown. The “failed to count down” one is clearly too tight timing.
on 2012-01-10 08:31 *
By rk@rkuhn.info
(In revision:6fddb87fcaf38d8fa30bbf31c1d1496617436af3) fix one spurious buglet in CallingThreadDispatcher, see #1375
Branch: master
Branch: master