Skip to content

Commit

Permalink
Change Node1 name to Leader
Browse files Browse the repository at this point in the history
  • Loading branch information
Arkatufus committed Apr 9, 2024
1 parent 21789cd commit e5d8ce4
Showing 1 changed file with 6 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,7 @@ namespace Akka.Cluster.Tests.MultiNode.SBR;

public class DownUnreachableIndirectlyConnected15NodeSpecConfig : MultiNodeConfig
{
public RoleName Node1 { get; }
public RoleName Leader { get; }
public RoleName Node2 { get; }
public RoleName Node3 { get; }
public RoleName Node4 { get; }
Expand All @@ -44,7 +44,7 @@ public class DownUnreachableIndirectlyConnected15NodeSpecConfig : MultiNodeConfi

public DownUnreachableIndirectlyConnected15NodeSpecConfig()
{
Node1 = Role("node1");
Leader = Role("leader");
Node2 = Role("node2");
Node3 = Role("node3");
Node4 = Role("node4");
Expand All @@ -62,7 +62,7 @@ public DownUnreachableIndirectlyConnected15NodeSpecConfig()

Nodes = new[]
{
Node1, Node2, Node3, Node4, Node5,
Leader, Node2, Node3, Node4, Node5,
Node6, Node7, Node8, Node9, Node10,
Node11, Node12, Node13, Node14, Node15
};
Expand Down Expand Up @@ -120,12 +120,12 @@ public async Task A_5_node_cluster_with_down_all_when_unstable_should_down_all_w
RunOn(() =>
{
cluster.Join(cluster.SelfAddress);
}, _config.Node1);
}, _config.Leader);
EnterBarrier("node1 joined");

RunOn(() =>
{
cluster.Join(Node(_config.Node1).Address);
cluster.Join(Node(_config.Leader).Address);
},
_config.Node2,
_config.Node3,
Expand Down Expand Up @@ -168,7 +168,7 @@ await RunOnAsync(async () =>
}
await Task.WhenAll(tasks);

}, _config.Node1);
}, _config.Leader);

EnterBarrier("long-delay-process-kill");

Expand Down

0 comments on commit e5d8ce4

Please sign in to comment.