HORNETQ-1513 - [Testsuite] Replicated failover tests fails on slower …

…machines
hornetq · Jan 26, 2016 · fabbf37 · fabbf37
1 parent e819b64
commit fabbf37
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/...tion-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/FailoverTest.java b/...tion-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/FailoverTest.java
@@ -675,13 +675,13 @@ public void testWithoutUsingTheBackup() throws Exception
       backupServer.stop(); // Backup stops!
       beforeRestart(backupServer);
       backupServer.start();
-      assertTrue(backupServer.getServer().waitForBackupSync(10, TimeUnit.SECONDS));
+      assertTrue(backupServer.getServer().waitForBackupSync(40, TimeUnit.SECONDS));
       backupServer.stop(); // Backup stops!
 
       liveServer.stop();
       beforeRestart(liveServer);
       liveServer.start();
-      liveServer.getServer().waitForActivation(10, TimeUnit.SECONDS);
+      liveServer.getServer().waitForActivation(40, TimeUnit.SECONDS);
 
       ClientSession session2 = createSession(sf, false, false);
       session2.start();
@@ -727,7 +727,7 @@ private void simpleReplication(boolean doFailBack) throws Exception
          adaptLiveConfigForReplicatedFailBack(liveServer.getServer().getConfiguration());
          beforeRestart(liveServer);
          liveServer.start();
-         assertTrue("live initialized...", liveServer.getServer().waitForActivation(15, TimeUnit.SECONDS));
+         assertTrue("live initialized...", liveServer.getServer().waitForActivation(40, TimeUnit.SECONDS));
          int i = 0;
          while (backupServer.isStarted() && i++ < 100)
          {
@@ -740,7 +740,7 @@ private void simpleReplication(boolean doFailBack) throws Exception
          backupServer.stop();
          beforeRestart(backupServer);
          backupServer.start();
-         assertTrue(backupServer.getServer().waitForActivation(10, TimeUnit.SECONDS));
+         assertTrue(backupServer.getServer().waitForActivation(40, TimeUnit.SECONDS));
       }
 
       ClientSession session2 = createSession(sf, false, false);

diff --git a/...rnetq/tests/integration/cluster/failover/ReplicatedLargeMessageWithDelayFailoverTest.java b/...rnetq/tests/integration/cluster/failover/ReplicatedLargeMessageWithDelayFailoverTest.java
@@ -31,7 +31,7 @@ protected void crash(ClientSession... sessions) throws Exception
    protected void crash(boolean waitFailure, ClientSession... sessions) throws Exception
    {
       syncDelay.deliverUpToDateMsg();
-      waitForBackup(null, 5);
+      waitForBackup(null, 30);
       super.crash(waitFailure, sessions);
    }