| | |
| | | import org.opends.messages.Message; |
| | | import org.opends.messages.Severity; |
| | | import org.opends.server.TestCaseUtils; |
| | | import org.opends.server.core.DirectoryServer; |
| | | import org.opends.server.loggers.debug.DebugTracer; |
| | | import org.opends.server.replication.ReplicationTestCase; |
| | | import org.opends.server.replication.common.CSN; |
| | |
| | | + "ds-cfg-receive-status: true\n" |
| | | + "ds-cfg-window-size: " + WINDOW_SIZE; |
| | | |
| | | synchroServerEntry = TestCaseUtils.entryFromLdifString(synchroServerLdif); |
| | | DirectoryServer.getConfigHandler().addEntry(synchroServerEntry, null); |
| | | assertNotNull(DirectoryServer.getConfigEntry(synchroServerEntry.getDN()), |
| | | "Unable to add the synchronized server"); |
| | | configEntryList.add(synchroServerEntry.getDN()); |
| | | addSynchroServerEntry(synchroServerLdif); |
| | | |
| | | replDomain = LDAPReplicationDomain.retrievesReplicationDomain(baseDN); |
| | | |
| | | if (replDomain != null) |
| | | { |
| | | debugInfo("ReplicationDomain: Import/Export is running ? " + |
| | |
| | | DN synchroServerDN = DN.decode(synchroServerStringDN); |
| | | deleteEntry(synchroServerDN); |
| | | synchroServerEntry = null; |
| | | configEntryList.remove(configEntryList.indexOf(synchroServerDN)); |
| | | configEntriesToCleanup.remove(synchroServerDN); |
| | | } |
| | | |
| | | private int getChangelogPort(int changelogID) throws Exception |