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

on 2011-12-03 20:09 *

By rkuhn

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 10: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)

on 2011-12-07 10: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 10: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

on 2011-12-13 13:27 *

By rkuhn

Milestone changed from 2.0-M1 to 2.0-M2

on 2011-12-17 15:43 *

By viktorklang

Priority changed from Normal (3) to High (2)

on 2011-12-27 12:10 *

By viktorklang

Milestone changed from 2.0-M2 to 2.0-M3

Updating tickets (#1190, #1322, #1375, #1406, #1408, #950, #1162, #1166, #1236, #1255, #1310, #1423, #1428, #1468, #1476, #1477, #1478, #1509, #1511, #1519, #1534, #1537, #1538, #1542, #1549, #1557, #1037, #1085, #1173, #1231, #1364, #1485, #1525, #1526, #1527, #1528, #1553, #1348, #1403)

on 2012-01-10 09:35 *

By rkuhn

Status changed from New to Accepted

on 2012-01-10 12:40 *

By rk@rkuhn.info

(In revision:6fddb87fcaf38d8fa30bbf31c1d1496617436af3) fix one spurious buglet in CallingThreadDispatcher, see #1375

Branch: wip-1375-fix-CallingThreadDispatcher-∂π

on 2012-01-10 12:44 *

By rkuhn

Status changed from Accepted to Test

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 14:31 *

By rk@rkuhn.info

(In revision:6fddb87fcaf38d8fa30bbf31c1d1496617436af3) fix one spurious buglet in CallingThreadDispatcher, see #1375

Branch: master

on 2012-01-10 14:40 *

By rkuhn

Status changed from Test to Fixed

Drop the files anywhere in this page to upload them as attachments.

Add a Relation

Attachments

Related Tickets

Followers

possible bugs in CallingThreadDispatcher

Related Tickets

Add people from your team or external to follow ticket activity

Followers will receive email updates about new ticket activity or emails sent to akka+1375@tickets.assembla.com

Attachments

Related Tickets

Followers

possible bugs in CallingThreadDispatcher

Granting access, please wait...

Related Tickets

Add people from your team or external to follow ticket activity

Followers will receive email updates about new ticket activity or emails sent to akka+1375@tickets.assembla.com