perf: Gossip speedup also for leaving and exiting (#32727)

patriknw · web-flow · commit 9ae003e6560f · 2025-05-27T09:10:28.000+02:00
diff --git a/akka-cluster/src/main/scala/akka/cluster/ClusterDaemon.scala b/akka-cluster/src/main/scala/akka/cluster/ClusterDaemon.scala
@@ -1287,7 +1287,7 @@ private[cluster] class ClusterCoreDaemon(publisher: ActorRef, joinConfigCompatCh
       latestGossip.overview.seen
         .count(membershipState.isInSameDc) < latestGossip.members.count(_.dataCenter == cluster.selfDataCenter) / 2
     } else {
-      latestGossip.members.exists(m => m.status == Down) ||
+      latestGossip.members.exists(m => m.status == Down || m.status == Leaving || m.status == Exiting) ||
       latestGossip.overview.seen.size < latestGossip.members.size / 2
     }
   }

Original file line number	Diff line number	Diff line change
`@@ -1287,7 +1287,7 @@ private[cluster] class ClusterCoreDaemon(publisher: ActorRef, joinConfigCompatCh`
`1287`	`1287`	`latestGossip.overview.seen`
`1288`	`1288`	`.count(membershipState.isInSameDc) < latestGossip.members.count(_.dataCenter == cluster.selfDataCenter) / 2`
`1289`	`1289`	`} else {`
`1290`		`- latestGossip.members.exists(m => m.status == Down) \|\|`
	`1290`	`+ latestGossip.members.exists(m => m.status == Down \|\| m.status == Leaving \|\| m.status == Exiting) \|\|`
`1291`	`1291`	`latestGossip.overview.seen.size < latestGossip.members.size / 2`
`1292`	`1292`	`}`
`1293`	`1293`	`}`