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

Avoid loop when not flightrecording

Browse source
This commit is contained in:
Johan Andrén 2020-06-11 17:00:51 +02:00
parent aa874d610f
commit 0475c11a1b
1 changed files with 7 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

12
akka-cluster-sharding/src/main/scala/akka/cluster/sharding/Shard.scala
View file

@ -587,11 +587,13 @@ private[akka] class Shard(
storingStarts.mkString(", "),
storingStops.mkString(", "))
storingStarts.foreach { entityId =>
flightRecorder.rememberEntityAdd(entityId)
}
storingStops.foreach { id =>
flightRecorder.rememberEntityRemove(id)
if (flightRecorder != NoOpShardingFlightRecorder) {
storingStarts.foreach { entityId =>
flightRecorder.rememberEntityAdd(entityId)
}
storingStops.foreach { id =>
flightRecorder.rememberEntityRemove(id)
}
}
val startTimeNanos = System.nanoTime()
val update = RememberEntitiesShardStore.Update(started = storingStarts, stopped = storingStops)