IGNITE-6255 .NET: Fix TestAffinityCall to take late affinity assignment into account
This closes #2589 Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/ce2a98cd Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/ce2a98cd Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/ce2a98cd Branch: refs/heads/ignite-5896 Commit: ce2a98cdb553e9b4d052d2ab891e4ba7c0fab289 Parents: 740a9b5 Author: Pavel Tupitsyn <[email protected]> Authored: Tue Sep 5 10:39:32 2017 +0300 Committer: Pavel Tupitsyn <[email protected]> Committed: Tue Sep 5 10:39:32 2017 +0300 ---------------------------------------------------------------------- .../dotnet/Apache.Ignite.Core.Tests/Compute/ComputeApiTest.cs | 6 ++++++ 1 file changed, 6 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/ce2a98cd/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/ComputeApiTest.cs ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/ComputeApiTest.cs b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/ComputeApiTest.cs index 5427d3d..80d8716 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/ComputeApiTest.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Compute/ComputeApiTest.cs @@ -29,6 +29,7 @@ namespace Apache.Ignite.Core.Tests.Compute using Apache.Ignite.Core.Cluster; using Apache.Ignite.Core.Common; using Apache.Ignite.Core.Compute; + using Apache.Ignite.Core.Events; using Apache.Ignite.Core.Impl; using Apache.Ignite.Core.Impl.Binary; using Apache.Ignite.Core.Resource; @@ -151,6 +152,11 @@ namespace Apache.Ignite.Core.Tests.Compute _grid1 = Ignition.Start(Configuration(configs.Item1)); _grid2 = Ignition.Start(Configuration(configs.Item2)); _grid3 = Ignition.Start(Configuration(configs.Item3)); + + // Wait for rebalance. + var events = _grid1.GetEvents(); + events.EnableLocal(EventType.CacheRebalanceStopped); + events.WaitForLocal(EventType.CacheRebalanceStopped); } /// <summary>
