Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

NO-JIRA speed-up replicated failback test

This commit is contained in:
franz1981 2021-08-12 15:25:58 +02:00
parent 44dd84d704
commit c629289e9b
1 changed files with 11 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/failover/FailoverTest.java
View File

@ -933,13 +933,18 @@ public class FailoverTest extends FailoverTestBase {
beforeRestart(liveServer);
liveServer.start();
Assert.assertTrue("live initialized...", liveServer.getServer().waitForActivation(40, TimeUnit.SECONDS));
int i = 0;
while (!backupServer.isStarted() && i++ < 100) {
Thread.sleep(100);
if (isReplicated) {
// wait until it switch role again
Wait.assertTrue(() -> backupServer.getServer().getHAPolicy().isBackup());
// wait until started
Wait.assertTrue(backupServer::isStarted);
// wait until is an in-sync replica
Wait.assertTrue(backupServer.getServer()::isReplicaSync);
} else {
Wait.assertTrue(backupServer::isStarted);
backupServer.getServer().waitForActivation(5, TimeUnit.SECONDS);
Assert.assertTrue(backupServer.isStarted());
}
backupServer.getServer().waitForActivation(5, TimeUnit.SECONDS);
Assert.assertTrue(backupServer.isStarted());
if (isReplicated) {
FileMoveManager moveManager = new FileMoveManager(backupServer.getServer().getConfiguration().getJournalLocation(), 0);
// backup has not had a chance to restart as a backup and cleanup