Skip to content

Commit 7180810

Browse files
Akka.Cluster.Tools: fix mutability and oldest state bugs with ClusterSingletonManager (#7298)
* fix mutability bugs with `ClusterSingletonManager` Looks like the list of available nodes was getting mangled - seems like a basic mutability issue inside the `ClusterSingletonManager`. * fixed another mutability error * explicitly re-order "oldest nodes" based on data received from OldestChangedBuffer * WIP nullability * fixed nullability issues and API approvals * removed debug logging * removed old code * fixed some nullability issues * fix racy cluster singleton restart spec
1 parent 6b6afe4 commit 7180810

File tree

5 files changed

+166
-192
lines changed

5 files changed

+166
-192
lines changed

src/contrib/cluster/Akka.Cluster.Tools.Tests/Singleton/ClusterSingletonRestart2Spec.cs

+2-2
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@ public ClusterSingletonRestart2Spec(ITestOutputHelper output) : base("""
3131
akka.loglevel = INFO
3232
akka.actor.provider = "cluster"
3333
akka.cluster.roles = [singleton]
34-
#akka.cluster.auto-down-unreachable-after = 2s
34+
akka.cluster.split-brain-resolver.stable-after = 2s
3535
akka.cluster.singleton.min-number-of-hand-over-retries = 5
3636
akka.remote {
3737
dot-netty.tcp {
@@ -120,7 +120,7 @@ await WithinAsync(TimeSpan.FromSeconds(5), () =>
120120
await Join(_sys4, _sys3);
121121

122122
// let it stabilize
123-
//Task.Delay(TimeSpan.FromSeconds(5)).Wait();
123+
await Task.Delay(TimeSpan.FromSeconds(5));
124124

125125
await WithinAsync(TimeSpan.FromSeconds(10), () =>
126126
{

0 commit comments

Comments
 (0)