| | |
| | | * |
| | | * Copyright 2006-2010 Sun Microsystems, Inc. |
| | | * Portions Copyright 2011-2016 ForgeRock AS. |
| | | * Portions Copyright 2023-2025 3A Systems, LLC. |
| | | */ |
| | | package org.opends.server.replication; |
| | | |
| | |
| | | String rsDir = "generationIdTest" + replServerId + testCase + "Db"; |
| | | ReplicationServer replicationServer = new ReplicationServer( |
| | | new ReplServerFakeConfiguration(rsPort, rsDir, 0, replServerId, 0, 1000, servers)); |
| | | Thread.sleep(2000); |
| | | Thread.sleep(3000); |
| | | return replicationServer; |
| | | } |
| | | |
| | |
| | | private void waitForStableGenerationId(final long expectedGenId) throws Exception |
| | | { |
| | | TestTimer timer = new TestTimer.Builder() |
| | | .maxSleep(20, SECONDS) |
| | | .maxSleep(30, SECONDS) |
| | | .sleepTimes(100, MILLISECONDS) |
| | | .toTimer(); |
| | | timer.repeatUntilSuccess(new CallableVoid() |