From 4c87d700c38f9eb9496b8bb50806d49ba4058f54 Mon Sep 17 00:00:00 2001 From: Roland Date: Fri, 23 Sep 2011 09:58:04 +0200 Subject: [PATCH] reorder detach vs. terminated=true --- .../test/scala/akka/actor/dispatch/ActorModelSpec.scala | 7 ++++++- akka-actor/src/main/scala/akka/actor/ActorCell.scala | 2 +- 2 files changed, 7 insertions(+), 2 deletions(-) diff --git a/akka-actor-tests/src/test/scala/akka/actor/dispatch/ActorModelSpec.scala b/akka-actor-tests/src/test/scala/akka/actor/dispatch/ActorModelSpec.scala index 8f462da426..c73ef35f84 100644 --- a/akka-actor-tests/src/test/scala/akka/actor/dispatch/ActorModelSpec.scala +++ b/akka-actor-tests/src/test/scala/akka/actor/dispatch/ActorModelSpec.scala @@ -384,7 +384,12 @@ abstract class ActorModelSpec extends JUnitSuite { (1 to num) foreach { _ ⇒ newTestActor ! cachedMessage } - assertCountDown(cachedMessage.latch, Testing.testTime(10000), "Should process " + num + " countdowns") + try { + assertCountDown(cachedMessage.latch, Testing.testTime(10000), "Should process " + num + " countdowns") + } catch { + case e ⇒ + EventHandler.error(null, cachedMessage.latch.getCount()) + } } for (run ← 1 to 3) { flood(10000) diff --git a/akka-actor/src/main/scala/akka/actor/ActorCell.scala b/akka-actor/src/main/scala/akka/actor/ActorCell.scala index 7448c3976d..6159ca223b 100644 --- a/akka-actor/src/main/scala/akka/actor/ActorCell.scala +++ b/akka-actor/src/main/scala/akka/actor/ActorCell.scala @@ -256,9 +256,9 @@ private[akka] class ActorCell( receiveTimeout = None cancelReceiveTimeout Actor.registry.unregister(self) + dispatcher.detach(this) isTerminated = true terminated = isTerminated - dispatcher.detach(this) try { val a = actor.get if (Actor.debugLifecycle) EventHandler.debug(a, "stopping")