fix

akkadotnet · Jun 29, 2016 · 1ee1f03 · 1ee1f03
1 parent 214c56a
commit 1ee1f03
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 3 deletions.
diff --git a/src/core/Akka.Cluster.Tests.MultiNode/LeaderDowningAllOtherNodesSpec.cs b/src/core/Akka.Cluster.Tests.MultiNode/LeaderDowningAllOtherNodesSpec.cs
@@ -31,7 +31,7 @@ public LeaderDowningAllOtherNodesConfig()
                 .WithFallback(ConfigurationFactory.ParseString(@"
                     akka.cluster.failure-detector.monitored-by-nr-of-members = 2
                     akka.cluster.auto-down-unreachable-after = 1s"))
-                .WithFallback(MultiNodeClusterSpec.ClusterConfigWithFailureDetectorPuppet());
+                .WithFallback(MultiNodeClusterSpec.ClusterConfig());
         }
     }
 
@@ -64,6 +64,7 @@ public void LeaderDowningAllOtherNodesSpecs()
 
         public void A_Cluster_of_6_nodes_with_monitored_by_nr_of_members_2_must_setup()
         {
+            // start some
             AwaitClusterUp(Roles.ToArray());
             EnterBarrier("after-1");
         }
@@ -82,7 +83,7 @@ public void A_Cluster_of_6_nodes_with_monitored_by_nr_of_members_2_must_remove_a
                 }
             }, _config.First);
             EnterBarrier("all-other-shutdown");
-            AwaitMembersUp(numbersOfMembers: 1, canNotBePartOfMemberRing: shutdownAddresses, timeout: 30.Seconds());
+            AwaitMembersUp(numbersOfMembers: 1, canNotBePartOfMemberRing: shutdownAddresses, timeout: 40.Seconds());
         }
     }
 }
diff --git a/src/core/Akka.Cluster/ClusterHeartbeat.cs b/src/core/Akka.Cluster/ClusterHeartbeat.cs
@@ -478,7 +478,7 @@ public ImmutableHashSet<UniqueAddress> Receivers(UniqueAddress sender)
 
                 IImmutableSet<UniqueAddress> slice = remaining == 0 
                     ? slice1 
-                    : take(remaining, NodeRing().Where(c => !c.Equals(sender)).GetEnumerator(), slice1).Item2;
+                    : take(remaining, NodeRing().Until(sender).Where(c => !c.Equals(sender)).GetEnumerator(), slice1).Item2;
 
                 return slice.ToImmutableHashSet();
             }