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

Add comment about member replacement in Set, see #2202

Browse source
This commit is contained in:
Patrik Nordwall 2012-08-27 16:55:50 +02:00
parent 4a06719722
commit fe28f29b38
1 changed files with 5 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

6
akka-cluster/src/main/scala/akka/cluster/ClusterReadView.scala
View file

@ -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