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

ease debugging of SupervisorHierarchySpec with more precise logging

Browse source
This commit is contained in:
Roland 2012-08-08 17:15:39 +02:00
parent d4ce9e6750
commit 5a42a46ea5
1 changed files with 4 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

8
akka-actor-tests/src/test/scala/akka/actor/SupervisorHierarchySpec.scala
View file

@ -167,7 +167,7 @@ object SupervisorHierarchySpec {
// do not scrap children
if (preRestartCalled) abort("preRestart called twice")
else {
log :+= Event("preRestart")
log :+= Event("preRestart " + cause)
preRestartCalled = true
cause match {
case f: Failure ⇒
@ -196,7 +196,7 @@ object SupervisorHierarchySpec {
case (f: Failure, orig) ⇒
if (f.depth > 0) {
setFlags(f.directive)
log :+= Event("escalating " + f)
log :+= Event("escalating " + f + " from " + sender)
throw f.copy(depth = f.depth - 1)
}
val prefix = orig match {
@ -206,7 +206,7 @@ object SupervisorHierarchySpec {
log :+= Event(prefix + f + " to " + sender)
if (myLevel > 3 && f.failPost == 0 && f.stop) Stop else f.directive
case (_, x) ⇒
log :+= Event("unhandled exception" + Logging.stackTraceFor(x))
log :+= Event("unhandled exception from " + sender + Logging.stackTraceFor(x))
sender ! Dump(0)
context.system.scheduler.scheduleOnce(1 second, self, Dump(0))
Resume
@ -215,7 +215,7 @@ object SupervisorHierarchySpec {
override def postRestart(cause: Throwable) {
val state = stateCache.get(self)
log = state.log
log :+= Event("restarted " + suspendCount)
log :+= Event("restarted " + suspendCount + " " + cause)
state.kids foreach {
case (child, kidSize) ⇒
val name = child.path.name