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

Making sure that theres no allocation for ActorRef.invoke()

Browse source
This commit is contained in:
Viktor Klang 2011-03-16 21:40:02 +01:00
parent f1654a3831
commit d935965989
1 changed files with 21 additions and 18 deletions
Download patch file Download diff file Expand all files Collapse all files

39
akka-actor/src/main/scala/akka/actor/ActorRef.scala
View file

@ -806,28 +806,31 @@ class LocalActorRef private[akka] (
/**
* Callback for the dispatcher. This is the single entry point to the user Actor implementation.
*/
protected[akka] def invoke(messageHandle: MessageInvocation): Unit = guard.withGuard {
if (!isShutdown) {
currentMessage = messageHandle
try {
protected[akka] def invoke(messageHandle: MessageInvocation): Unit = {
guard.lock.lock
try {
if (!isShutdown) {
currentMessage = messageHandle
try {
cancelReceiveTimeout // FIXME: leave this here?
actor(messageHandle.message)
currentMessage = null // reset current message after successful invocation
try {
cancelReceiveTimeout // FIXME: leave this here?
actor(messageHandle.message)
currentMessage = null // reset current message after successful invocation
} catch {
case e: InterruptedException =>
currentMessage = null // received message while actor is shutting down, ignore
case e =>
handleExceptionInDispatch(e, messageHandle.message)
} finally {
checkReceiveTimeout // Reschedule receive timeout
}
} catch {
case e: InterruptedException =>
currentMessage = null // received message while actor is shutting down, ignore
case e =>
handleExceptionInDispatch(e, messageHandle.message)
} finally {
checkReceiveTimeout // Reschedule receive timeout
case e: Throwable =>
EventHandler notify EventHandler.Error(e, this, messageHandle.message.toString)
throw e
}
} catch {
case e: Throwable =>
EventHandler notify EventHandler.Error(e, this, messageHandle.message.toString)
throw e
}
}
} finally { guard.lock.unlock }
}
protected[akka] def handleTrapExit(dead: ActorRef, reason: Throwable) {