-
Notifications
You must be signed in to change notification settings - Fork 1k
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Implemented LeaderDowningAllOtherNodesSpec
- Loading branch information
1 parent
297ac0e
commit 1bae754
Showing
5 changed files
with
279 additions
and
93 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
88 changes: 88 additions & 0 deletions
88
src/core/Akka.Cluster.Tests.MultiNode/LeaderDowningAllOtherNodesSpec.cs
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,88 @@ | ||
| using System; | ||
| using System.Collections.Immutable; | ||
| using System.Linq; | ||
| using Akka.Cluster.TestKit; | ||
| using Akka.Configuration; | ||
| using Akka.Remote.TestKit; | ||
| using Akka.Util.Internal; | ||
| using FluentAssertions; | ||
|
|
||
| namespace Akka.Cluster.Tests.MultiNode | ||
| { | ||
| public class LeaderDowningAllOtherNodesConfig : MultiNodeConfig | ||
| { | ||
| public RoleName First { get; } | ||
| public RoleName Second { get; } | ||
| public RoleName Third { get; } | ||
| public RoleName Fourth { get; } | ||
| public RoleName Fifth { get; } | ||
| public RoleName Sixth { get; } | ||
|
|
||
| public LeaderDowningAllOtherNodesConfig() | ||
| { | ||
| First = Role("first"); | ||
| Second = Role("second"); | ||
| Third = Role("third"); | ||
| Fourth = Role("fourth"); | ||
| Fifth = Role("fifth"); | ||
| Sixth = Role("sixth"); | ||
|
|
||
| CommonConfig = DebugConfig(false) | ||
| .WithFallback(ConfigurationFactory.ParseString(@" | ||
| akka.cluster.failure-detector.monitored-by-nr-of-members = 2 | ||
| akka.cluster.auto-down-unreachable-after = 1s")) | ||
| .WithFallback(MultiNodeClusterSpec.ClusterConfigWithFailureDetectorPuppet()); | ||
| } | ||
| } | ||
|
|
||
| public class LeaderDowningAllOtherNodesSpecNode1 : LeaderDowningAllOtherNodesSpec { } | ||
| public class LeaderDowningAllOtherNodesSpecNode2 : LeaderDowningAllOtherNodesSpec { } | ||
| public class LeaderDowningAllOtherNodesSpecNode3 : LeaderDowningAllOtherNodesSpec { } | ||
| public class LeaderDowningAllOtherNodesSpecNode4 : LeaderDowningAllOtherNodesSpec { } | ||
| public class LeaderDowningAllOtherNodesSpecNode5 : LeaderDowningAllOtherNodesSpec { } | ||
| public class LeaderDowningAllOtherNodesSpecNode6 : LeaderDowningAllOtherNodesSpec { } | ||
|
|
||
| public abstract class LeaderDowningAllOtherNodesSpec : MultiNodeClusterSpec | ||
| { | ||
| private readonly LeaderDowningAllOtherNodesConfig _config; | ||
|
|
||
| protected LeaderDowningAllOtherNodesSpec() : this(new LeaderDowningAllOtherNodesConfig()) | ||
| { | ||
| } | ||
|
|
||
| protected LeaderDowningAllOtherNodesSpec(LeaderDowningAllOtherNodesConfig config) : base(config) | ||
| { | ||
| _config = config; | ||
| } | ||
|
|
||
| [MultiNodeFact] | ||
| public void LeaderDowningAllOtherNodesSpecs() | ||
| { | ||
| A_Cluster_of_6_nodes_with_monitored_by_nr_of_members_2_must_setup(); | ||
| A_Cluster_of_6_nodes_with_monitored_by_nr_of_members_2_must_remove_all_shutdown_nodes(); | ||
| } | ||
|
|
||
| public void A_Cluster_of_6_nodes_with_monitored_by_nr_of_members_2_must_setup() | ||
| { | ||
| AwaitClusterUp(Roles.ToArray()); | ||
| EnterBarrier("after-1"); | ||
| } | ||
|
|
||
| public void A_Cluster_of_6_nodes_with_monitored_by_nr_of_members_2_must_remove_all_shutdown_nodes() | ||
| { | ||
| var others = Roles.Drop(1).ToList(); | ||
| var shutdownAddresses = others.Select(c => GetAddress(c)).ToImmutableHashSet(); | ||
| EnterBarrier("before-all-other-shutdown"); | ||
|
|
||
| RunOn(() => | ||
| { | ||
| foreach (var node in others) | ||
| { | ||
| TestConductor.Exit(node, 0).Wait(); | ||
| } | ||
| }, _config.First); | ||
| EnterBarrier("all-other-shutdown"); | ||
| AwaitMembersUp(numbersOfMembers: 1, canNotBePartOfMemberRing: shutdownAddresses, timeout: 30.Seconds()); | ||
| } | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.