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

Re-use logic for allocating shard home for remembered entities

Browse source
This commit is contained in:
Johan Andrén 2020-06-11 15:46:03 +02:00
parent d2dd80fe17
commit 9c7f16a4db
1 changed files with 1 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-cluster-sharding/src/main/scala/akka/cluster/sharding/ShardCoordinator.scala
View file

@ -1422,7 +1422,7 @@ private[akka] class DDataShardCoordinator(
if (shardIds.nonEmpty) { if (shardIds.nonEmpty) {
val newUnallocatedShards = state.unallocatedShards.union(shardIds.diff(state.shards.keySet)) val newUnallocatedShards = state.unallocatedShards.union(shardIds.diff(state.shards.keySet))
state = state.copy(unallocatedShards = newUnallocatedShards) state = state.copy(unallocatedShards = newUnallocatedShards)
newUnallocatedShards.foreach { self ! GetShardHome(_) } allocateShardHomesForRememberEntities()
} }
timers.cancel(RememberEntitiesTimeoutKey) timers.cancel(RememberEntitiesTimeoutKey)