Debugging racy ClusterShardingDeliveryGracefulShutdown MNTR spec (#7218)

* fix assembly version and name of ClusterShardingDeliverySpec * harden spec
akkadotnet · May 31, 2024 · f9666a1 · f9666a1
1 parent 5956b82
commit f9666a1
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 6 deletions.
diff --git a/src/Directory.Build.props b/src/Directory.Build.props
@@ -2,7 +2,7 @@
   <PropertyGroup>
     <Copyright>Copyright © 2013-2023 Akka.NET Team</Copyright>
     <Authors>Akka.NET Team</Authors>
-    <VersionPrefix>1.5.15</VersionPrefix>
+    <VersionPrefix>1.5.19</VersionPrefix>
     <PackageIcon>akkalogo.png</PackageIcon>
     <PackageProjectUrl>https://github.com/akkadotnet/akka.net</PackageProjectUrl>
     <PackageLicenseUrl>https://github.com/akkadotnet/akka.net/blob/master/LICENSE</PackageLicenseUrl>

diff --git a/....Cluster.Sharding.Tests.MultiNode/Delivery/ClusterShardingDeliveryGracefulShutdownSpec.cs b/....Cluster.Sharding.Tests.MultiNode/Delivery/ClusterShardingDeliveryGracefulShutdownSpec.cs
@@ -189,7 +189,7 @@ private IActorRef StartSharding()
         #endregion
 
         [MultiNodeFact]
-        public void ClusterShardingGracefulShutdownSpecs()
+        public void ClusterShardingDeliveryGracefulShutdownSpecs()
         {
             Cluster_sharding_must_join_cluster();
             Cluster_sharding_must_start_some_shards_in_both_regions();
@@ -276,12 +276,12 @@ private void Cluster_sharding_must_gracefully_shutdown_the_oldest_region()
                     var producer = CreateProducer("p-2");
                     AwaitAssert(() =>
                     {
-                        var responses = Enumerable.Range(1, 20).Select(n =>
+                        var maxCount = 20;
+                        foreach(var n in Enumerable.Range(1, maxCount))
                         {
                             producer.Tell(n, TestActor);
-                            return ExpectMsg(n, TimeSpan.FromSeconds(1));
-                        }).ToImmutableHashSet();
-
+                        }
+                        var responses = ReceiveN(maxCount, TimeSpan.FromSeconds(2));
                         responses.Count.Should().Be(20);
                     });
                 }, Config.Second);