You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sb...@apache.org on 2017/04/19 08:45:46 UTC
[05/50] [abbrv] ignite git commit: .NET: Fix MessagingTest flakiness
.NET: Fix MessagingTest flakiness
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/dbcb02aa
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/dbcb02aa
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/dbcb02aa
Branch: refs/heads/ignite-4929
Commit: dbcb02aa04b94fef0d498a8c633bc769a7a6fb57
Parents: 84479b5
Author: Pavel Tupitsyn <pt...@apache.org>
Authored: Tue Apr 18 16:01:49 2017 +0300
Committer: Pavel Tupitsyn <pt...@apache.org>
Committed: Tue Apr 18 16:01:49 2017 +0300
----------------------------------------------------------------------
.../dotnet/Apache.Ignite.Core.Tests/MessagingTest.cs | 13 ++++++++-----
1 file changed, 8 insertions(+), 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/dbcb02aa/modules/platforms/dotnet/Apache.Ignite.Core.Tests/MessagingTest.cs
----------------------------------------------------------------------
diff --git a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/MessagingTest.cs b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/MessagingTest.cs
index 8b57c81..a35aeff 100644
--- a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/MessagingTest.cs
+++ b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/MessagingTest.cs
@@ -256,7 +256,7 @@ namespace Apache.Ignite.Core.Tests
messaging.Send(NextMessage());
- Thread.Sleep(MessagingTestHelper.MessageTimeout);
+ Thread.Sleep(MessagingTestHelper.SleepTimeout);
// Check that unsubscription worked properly
Assert.AreEqual(sharedResult, Thread.VolatileRead(ref sharedReceived));
@@ -392,7 +392,7 @@ namespace Apache.Ignite.Core.Tests
messaging.Send(NextMessage()); // send a message to make filters return false
- Thread.Sleep(MessagingTestHelper.MessageTimeout); // wait for all to unsubscribe
+ Thread.Sleep(MessagingTestHelper.SleepTimeout); // wait for all to unsubscribe
MessagingTestHelper.ListenResult = true;
@@ -403,7 +403,7 @@ namespace Apache.Ignite.Core.Tests
var lastMsg = NextMessage();
messaging.Send(lastMsg);
- Thread.Sleep(MessagingTestHelper.MessageTimeout);
+ Thread.Sleep(MessagingTestHelper.SleepTimeout);
// Check that unsubscription worked properly
var sharedResult = MessagingTestHelper.ReceivedMessages.ToArray();
@@ -476,7 +476,7 @@ namespace Apache.Ignite.Core.Tests
(grid ?? _grid1).GetMessaging().SendAll(NextMessage(), topic);
- Thread.Sleep(MessagingTestHelper.MessageTimeout);
+ Thread.Sleep(MessagingTestHelper.SleepTimeout);
MessagingTestHelper.AssertFailures();
}
@@ -534,7 +534,10 @@ namespace Apache.Ignite.Core.Tests
public static volatile bool ListenResult = true;
/** */
- public static readonly TimeSpan MessageTimeout = TimeSpan.FromMilliseconds(700);
+ public static readonly TimeSpan MessageTimeout = TimeSpan.FromMilliseconds(5000);
+
+ /** */
+ public static readonly TimeSpan SleepTimeout = TimeSpan.FromMilliseconds(50);
/// <summary>
/// Clears received message information.