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

Clarified the code, removing a negation that could be overlooked

Browse source
This commit is contained in:
Viktor Klang 2012-01-21 13:12:30 +01:00
parent 61e0bd568b
commit e523d5418c
1 changed files with 2 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

4
akka-actor/src/main/scala/akka/dispatch/Mailbox.scala
View file

@ -175,14 +175,14 @@ private[akka] abstract class Mailbox(val actor: ActorCell) extends MessageQueue
*/ */
@tailrec private final def processMailbox( @tailrec private final def processMailbox(
left: Int = java.lang.Math.max(dispatcher.throughput, 1), left: Int = java.lang.Math.max(dispatcher.throughput, 1),
deadlineNs: Long = if (dispatcher.isThroughputDeadlineTimeDefined) System.nanoTime + dispatcher.throughputDeadlineTime.toNanos else 0L): Unit = deadlineNs: Long = if (dispatcher.isThroughputDeadlineTimeDefined == true) System.nanoTime + dispatcher.throughputDeadlineTime.toNanos else 0L): Unit =
if (shouldProcessMessage) { if (shouldProcessMessage) {
val next = dequeue() val next = dequeue()
if (next ne null) { if (next ne null) {
if (Mailbox.debug) println(actor.self + " processing message " + next) if (Mailbox.debug) println(actor.self + " processing message " + next)
actor invoke next actor invoke next
processAllSystemMessages() processAllSystemMessages()
if ((left > 1) && ((!dispatcher.isThroughputDeadlineTimeDefined) || (System.nanoTime - deadlineNs) < 0)) if ((left > 1) && ((dispatcher.isThroughputDeadlineTimeDefined == false) || (System.nanoTime - deadlineNs) < 0))
processMailbox(left - 1, deadlineNs) processMailbox(left - 1, deadlineNs)
} }
} }