ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject ignite git commit: 5578
Date Wed, 02 Aug 2017 08:23:20 GMT
Repository: ignite
Updated Branches:
  refs/heads/ignite-5578 079474297 -> ee7062e4e


5578


Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/ee7062e4
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/ee7062e4
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/ee7062e4

Branch: refs/heads/ignite-5578
Commit: ee7062e4e673bd23cbbe3ffdc35c046f085aba3b
Parents: 0794742
Author: sboikov <sboikov@gridgain.com>
Authored: Wed Aug 2 11:23:13 2017 +0300
Committer: sboikov <sboikov@gridgain.com>
Committed: Wed Aug 2 11:23:13 2017 +0300

----------------------------------------------------------------------
 .../cache/distributed/CacheExchangeMergeTest.java      | 13 ++++++++-----
 1 file changed, 8 insertions(+), 5 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/ee7062e4/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/CacheExchangeMergeTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/CacheExchangeMergeTest.java
b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/CacheExchangeMergeTest.java
index 891f860..499399f 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/CacheExchangeMergeTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/CacheExchangeMergeTest.java
@@ -80,6 +80,9 @@ public class CacheExchangeMergeTest extends GridCommonAbstractTest {
     private static TcpDiscoveryIpFinder ipFinder = new TcpDiscoveryVmIpFinder(true);
 
     /** */
+    private static final long WAIT_SECONDS = 15;
+
+    /** */
     private ThreadLocal<Boolean> client = new ThreadLocal<>();
 
     /** */
@@ -494,7 +497,7 @@ public class CacheExchangeMergeTest extends GridCommonAbstractTest {
 
         IgniteInternalFuture<?> fut = startGrids(srv0, srvs, 2);
 
-        if (latch != null && !latch.await(15, TimeUnit.SECONDS))
+        if (latch != null && !latch.await(WAIT_SECONDS, TimeUnit.SECONDS))
             fail("Failed to wait for expected messages.");
 
         stopGrid(getTestIgniteInstanceName(0), true, false);
@@ -537,7 +540,7 @@ public class CacheExchangeMergeTest extends GridCommonAbstractTest {
 
         IgniteInternalFuture<?> fut = startGrids(srv0, srvs, startNodes);
 
-        if (latch != null && !latch.await(5, TimeUnit.SECONDS))
+        if (latch != null && !latch.await(WAIT_SECONDS, TimeUnit.SECONDS))
             fail("Failed to wait for expected messages.");
 
         stopGrid(getTestIgniteInstanceName(0), true, false);
@@ -571,7 +574,7 @@ public class CacheExchangeMergeTest extends GridCommonAbstractTest {
             }
         }, 2, "start-node");
 
-        if (latch != null && !latch.await(5, TimeUnit.SECONDS))
+        if (latch != null && !latch.await(WAIT_SECONDS, TimeUnit.SECONDS))
             fail("Failed to wait for expected messages.");
 
         stopGrid(getTestIgniteInstanceName(0), true, false);
@@ -611,7 +614,7 @@ public class CacheExchangeMergeTest extends GridCommonAbstractTest {
 
         waitForExchangeStart(ignite(0), nodes + 1);
 
-        if (latch != null && !latch.await(5, TimeUnit.SECONDS))
+        if (latch != null && !latch.await(WAIT_SECONDS, TimeUnit.SECONDS))
             fail("Failed to wait for expected messages.");
 
         stopGrid(0);
@@ -1001,7 +1004,7 @@ public class CacheExchangeMergeTest extends GridCommonAbstractTest {
                 }
             }, "start-node-" + nodeIdx);
 
-            if (!latch.await(5, TimeUnit.SECONDS))
+            if (!latch.await(WAIT_SECONDS, TimeUnit.SECONDS))
                 fail();
 
             fut.add(fut0);


Mime
View raw message