[ignite] branch master updated: IGNITE-12136 Test ClusterReadOnlyModeTest is flaky. - Fixes #6835.

[irakov]

This is an automated email from the ASF dual-hosted git repository.

irakov pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite.git


The following commit(s) were added to refs/heads/master by this push:
     new 1eccb2d  IGNITE-12136 Test ClusterReadOnlyModeTest is flaky. - Fixes 
#6835.
1eccb2d is described below

commit 1eccb2d648e42fd25f3abdf85db95dcdf36aeaea
Author: Sergey Antonov <antonovserge...@gmail.com>
AuthorDate: Tue Sep 3 20:54:57 2019 +0300

    IGNITE-12136 Test ClusterReadOnlyModeTest is flaky. - Fixes #6835.
    
    Signed-off-by: Ivan Rakov <ira...@apache.org>
---
 .../ignite/internal/processors/cache/ClusterReadOnlyModeTest.java | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/ClusterReadOnlyModeTest.java
 
b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/ClusterReadOnlyModeTest.java
index e826f73..327a3f5 100644
--- 
a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/ClusterReadOnlyModeTest.java
+++ 
b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/ClusterReadOnlyModeTest.java
@@ -129,7 +129,7 @@ public class ClusterReadOnlyModeTest extends 
ClusterReadOnlyModeAbstractTest {
 
                         firstPackLatch.countDown();
 
-                        readOnlyEnabled.await(5, TimeUnit.SECONDS);
+                        assertTrue(cacheName, readOnlyEnabled.await(60, 
TimeUnit.SECONDS));
 
                         doLoad(streamer, 100, 1000000, manualFlush);
 
@@ -148,13 +148,13 @@ public class ClusterReadOnlyModeTest extends 
ClusterReadOnlyModeAbstractTest {
                 }));
             }
 
-            firstPackLatch.await(5, TimeUnit.SECONDS);
+            assertTrue(firstPackLatch.await(60, TimeUnit.SECONDS));
 
             changeClusterReadOnlyMode(true);
 
             readOnlyEnabled.countDown();
 
-            finishLatch.await(5, TimeUnit.SECONDS);
+            assertTrue(finishLatch.await(60, TimeUnit.SECONDS));
 
             assertEquals("exceptions: " + eMap, cacheNames().size(), 
eMap.size());
 
@@ -181,7 +181,7 @@ public class ClusterReadOnlyModeTest extends 
ClusterReadOnlyModeAbstractTest {
             IgniteInternalFuture<?> fut = futs.get(cacheName);
 
             try {
-                fut.get(5, TimeUnit.SECONDS);
+                fut.get(15, TimeUnit.SECONDS);
             }
             catch (Exception e) {
                 log.error("Failed to get future " + cacheName, e);