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

Quick fix for unreachable exiting, see #3266

Browse source
This commit is contained in:
Patrik Nordwall 2013-04-24 11:08:52 +02:00
parent 33a8808a6d
commit 293c97c71d
1 changed files with 1 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-cluster/src/main/scala/akka/cluster/ClusterDaemon.scala
View file

@ -850,7 +850,7 @@ private[cluster] final class ClusterCoreDaemon(publisher: ActorRef) extends Acto
val localUnreachableMembers = localGossip.overview.unreachable val localUnreachableMembers = localGossip.overview.unreachable
val newlyDetectedUnreachableMembers = localMembers filterNot { member ⇒ val newlyDetectedUnreachableMembers = localMembers filterNot { member ⇒
member.uniqueAddress == selfUniqueAddress || failureDetector.isAvailable(member.address) member.uniqueAddress == selfUniqueAddress || member.status == Exiting || failureDetector.isAvailable(member.address)
} }
if (newlyDetectedUnreachableMembers.nonEmpty) { if (newlyDetectedUnreachableMembers.nonEmpty) {