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

=act #17738 RoundRobinRoutingLogic negative index fix after Long.MAX_VALUE

Browse source 
(cherry picked from commit 8ef10c9c3d49fa431739ba8b234be5d54d528f1b)
This commit is contained in:
Guido Medina 2015-06-19 17:52:13 +01:00 • committed by Patrik Nordwall
parent 7bfc56f3f0
commit 936436e6e3
1 changed files with 6 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

11
akka-actor/src/main/scala/akka/routing/RoundRobin.scala
View file

@ -5,8 +5,6 @@ package akka.routing
import java.util.concurrent.atomic.AtomicLong
import scala.collection.immutable
import akka.actor.ActorContext
import akka.actor.Props
import akka.dispatch.Dispatchers
import com.typesafe.config.Config
import akka.actor.SupervisorStrategy
@ -23,11 +21,14 @@ object RoundRobinRoutingLogic {
*/
@SerialVersionUID(1L)
final class RoundRobinRoutingLogic extends RoutingLogic {
val next = new AtomicLong(0)
val next = new AtomicLong
override def select(message: Any, routees: immutable.IndexedSeq[Routee]): Routee =
if (routees.isEmpty) NoRoutee
else routees((next.getAndIncrement % routees.size).asInstanceOf[Int])
if (routees.nonEmpty) {
val size = routees.size
val index = (next.getAndIncrement % size).asInstanceOf[Int]
routees(if (index < 0) size + index - 1 else index)
} else NoRoutee
}