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

Handle empty availableNodes, see #2103

Browse source
This commit is contained in:
Patrik Nordwall 2012-09-13 10:54:00 +02:00
parent 4d112f0467
commit adeb4fc8b8
1 changed files with 3 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

5
akka-cluster/src/main/scala/akka/cluster/routing/ClusterRouterConfig.scala
View file

@ -186,11 +186,12 @@ private[akka] class ClusterRouteeProvider(
private def selectDeploymentTarget: Option[Address] = {
val currentRoutees = routees
if (currentRoutees.size >= settings.totalInstances) {
val currentNodes = availbleNodes
if (currentRoutees.size >= settings.totalInstances || currentNodes.isEmpty) {
None
} else {
val numberOfRouteesPerNode: Map[Address, Int] =
Map.empty[Address, Int] ++ availbleNodes.toSeq.map(_ -> 0) ++
Map.empty[Address, Int] ++ currentNodes.toSeq.map(_ -> 0) ++
currentRoutees.groupBy(fullAddress).map {
case (address, refs) ⇒ address -> refs.size
}