From 215582b726dafcd88f60f4f26109fe667b8f0031 Mon Sep 17 00:00:00 2001
From: Nikita Koksharov <nkoksharov@redisson.pro>
Date: Fri, 5 Jun 2020 11:28:07 +0300
Subject: [PATCH] refactoring

---
 .../src/test/java/org/redisson/RedissonTest.java  | 15 ++++++++-------
 1 file changed, 8 insertions(+), 7 deletions(-)

diff --git a/redisson/src/test/java/org/redisson/RedissonTest.java b/redisson/src/test/java/org/redisson/RedissonTest.java
index 50e82c5de..304db752a 100644
--- a/redisson/src/test/java/org/redisson/RedissonTest.java
+++ b/redisson/src/test/java/org/redisson/RedissonTest.java
@@ -528,7 +528,7 @@ public class RedissonTest {
         
         System.out.println("master " + master.getRedisServerAddressAndPort() + " has been stopped!");
         
-        Thread.sleep(TimeUnit.SECONDS.toMillis(30));
+        Thread.sleep(TimeUnit.SECONDS.toMillis(40));
         
         RedisProcess newMaster = null;
         Collection<RedisClusterMaster> newMasterNodes = redisson.getRedisNodes(RedisNodes.CLUSTER).getMasters();
@@ -540,7 +540,7 @@ public class RedissonTest {
         }
         
         assertThat(newMaster).isNotNull();
-        
+
         for (RFuture<?> rFuture : futures) {
             rFuture.awaitUninterruptibly();
             if (!rFuture.isSuccess()) {
@@ -687,7 +687,7 @@ public class RedissonTest {
         CountDownLatch latch = new CountDownLatch(1);
         Thread t = new Thread() {
             public void run() {
-                for (int i = 0; i < 200; i++) {
+                for (int i = 0; i < 600; i++) {
                     RFuture<?> f1 = redisson.getBucket("i" + i).getAsync();
                     futures.add(f1);
                     try {
@@ -706,10 +706,10 @@ public class RedissonTest {
         t.start();
         t.join(1000);
 
-        slave.stop();
+        slave.restart(20);
         System.out.println("slave " + slave.getRedisServerAddressAndPort() + " has been stopped!");
 
-        assertThat(latch.await(30, TimeUnit.SECONDS)).isTrue();
+        assertThat(latch.await(60, TimeUnit.SECONDS)).isTrue();
 
         int errors = 0;
         int success = 0;
@@ -718,6 +718,7 @@ public class RedissonTest {
         for (RFuture<?> rFuture : futures) {
             rFuture.awaitUninterruptibly();
             if (!rFuture.isSuccess()) {
+                rFuture.cause().printStackTrace();
                 errors++;
             } else {
                 success++;
@@ -728,8 +729,8 @@ public class RedissonTest {
         process.shutdown();
 
         assertThat(readonlyErrors).isZero();
-        assertThat(errors).isLessThan(50);
-        assertThat(success).isGreaterThan(150);
+        assertThat(errors).isLessThan(70);
+        assertThat(success).isGreaterThan(600 - 70);
     }