Backport #5976 - Fix sharding tolerant reader (#5978)

akkadotnet · Jun 1, 2022 · a7c17e2 · a7c17e2
1 parent 9063439
commit a7c17e2
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/src/contrib/cluster/Akka.Cluster.Sharding/PersistentShardCoordinator.cs b/src/contrib/cluster/Akka.Cluster.Sharding/PersistentShardCoordinator.cs
@@ -109,7 +109,12 @@ protected override bool ReceiveRecover(object message)
                             if (State.RegionProxies.Contains(proxyTerminated.RegionProxy))
                                 State = State.Updated(evt);
                             return true;
-                        case ShardHomeAllocated _:
+                        case ShardHomeAllocated homeAllocated:
+                            // if we already have identical ShardHomeAllocated data, skip processing it
+                            // addresses https://github.com/akkadotnet/akka.net/issues/5604
+                            if (State.Shards.TryGetValue(homeAllocated.Shard, out var currentShardRegion)
+                                && Equals(homeAllocated.Region, currentShardRegion))
+                                return true;
                             State = State.Updated(evt);
                             return true;
                         case ShardHomeDeallocated _: