From fe28f29b383379526fb043309846ef33f98cb52d Mon Sep 17 00:00:00 2001 From: Patrik Nordwall Date: Mon, 27 Aug 2012 16:55:50 +0200 Subject: [PATCH] Add comment about member replacement in Set, see #2202 --- .../src/main/scala/akka/cluster/ClusterReadView.scala | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/akka-cluster/src/main/scala/akka/cluster/ClusterReadView.scala b/akka-cluster/src/main/scala/akka/cluster/ClusterReadView.scala index 5218480e5e..ff827574d7 100644 --- a/akka-cluster/src/main/scala/akka/cluster/ClusterReadView.scala +++ b/akka-cluster/src/main/scala/akka/cluster/ClusterReadView.scala @@ -44,10 +44,14 @@ private[akka] class ClusterReadView(cluster: Cluster) extends Closeable { case MemberRemoved(member) ⇒ state = state.copy(members = state.members - member, unreachable = state.unreachable - member) case MemberUnreachable(member) ⇒ + // replace current member with new member (might have different status, only address is used in equals) state = state.copy(members = state.members - member, unreachable = state.unreachable - member + member) case MemberDowned(member) ⇒ + // replace current member with new member (might have different status, only address is used in equals) state = state.copy(members = state.members - member, unreachable = state.unreachable - member + member) - case event: MemberEvent ⇒ state = state.copy(members = state.members - event.member + event.member) + case event: MemberEvent ⇒ + // replace current member with new member (might have different status, only address is used in equals) + state = state.copy(members = state.members - event.member + event.member) case LeaderChanged(leader, convergence) ⇒ state = state.copy(leader = leader, convergence = convergence) case ConvergenceChanged(convergence) ⇒ state = state.copy(convergence = convergence) case s: CurrentClusterState ⇒ state = s