| | |
| | | changelogs[0].remove(); |
| | | StaticUtils.recursiveDelete |
| | | (new File(DirectoryServer.getInstanceRoot(), |
| | | changelogs[0].getDbDirName())); |
| | | changelogs[0].getDbDirName())); |
| | | } |
| | | if (changelogs[1] != null) |
| | | { |
| | | changelogs[1].remove(); |
| | | StaticUtils.recursiveDelete |
| | | (new File(DirectoryServer.getInstanceRoot(), |
| | | changelogs[1].getDbDirName())); |
| | | changelogs[1].getDbDirName())); |
| | | } |
| | | if (broker1 != null) |
| | | broker1.stop(); |
| | |
| | | @Test(enabled=true, dependsOnMethods = { "searchBackend"}) |
| | | public void windowProbeTest() throws Exception |
| | | { |
| | | |
| | | |
| | | debugInfo("Starting windowProbeTest"); |
| | | final int WINDOW = 10; |
| | | |
| | | |
| | | replicationServer.clearDb(); |
| | | TestCaseUtils.initializeTestBackend(true); |
| | | |
| | |
| | | callParanoiaCheck = false; |
| | | super.classCleanUp(); |
| | | String dirName = replicationServer.getDbDirName(); |
| | | |
| | | |
| | | shutdown(); |
| | | |
| | | StaticUtils.recursiveDelete(new File(DirectoryServer.getInstanceRoot(), |
| | | dirName)); |
| | | dirName)); |
| | | |
| | | paranoiaCheck(); |
| | | } |
| | |
| | | // Not doing anything with the export file, let's delete it |
| | | File f = new File(DirectoryServer.getInstanceRoot(),exportLDIFAllFile); |
| | | f.delete(); |
| | | |
| | | |
| | | debugInfo("Export domain"); |
| | | exportTask = createExportDomainTask("dc=domain2,dc=com"); |
| | | addTask(exportTask, ResultCode.SUCCESS, null); |
| | |
| | | { |
| | | replicationServer.clearDb(); |
| | | TestCaseUtils.initializeTestBackend(true); |
| | | |
| | | |
| | | debugInfo("Starting replicationServerConnected"); |
| | | ReplicationBroker broker1 = null; |
| | | ReplicationBroker broker2 = null; |
| | |
| | | // Create and connect client1 to changelog1 |
| | | // and client2 to changelog2 |
| | | broker1 = openReplicationSession(DN.decode(TEST_ROOT_DN_STRING), |
| | | brokerIds[0], 100, changelogPorts[0], 1000, emptyOldChanges); |
| | | brokerIds[0], 100, changelogPorts[0], 3000, emptyOldChanges); |
| | | |
| | | broker2 = openReplicationSession(DN.decode(TEST_ROOT_DN_STRING), |
| | | brokerIds[1], 100, changelogPorts[1], 1000, emptyOldChanges); |
| | | brokerIds[1], 100, changelogPorts[1], 3000, emptyOldChanges); |
| | | |
| | | assertTrue(broker1.isConnected()); |
| | | assertTrue(broker2.isConnected()); |
| | |
| | | changelogs[0].remove(); |
| | | StaticUtils.recursiveDelete |
| | | (new File(DirectoryServer.getInstanceRoot(), |
| | | changelogs[0].getDbDirName())); |
| | | changelogs[0].getDbDirName())); |
| | | } |
| | | if (changelogs[1] != null) |
| | | { |
| | | changelogs[1].remove(); |
| | | StaticUtils.recursiveDelete |
| | | (new File(DirectoryServer.getInstanceRoot(), |
| | | changelogs[1].getDbDirName())); |
| | | changelogs[1].getDbDirName())); |
| | | } |
| | | if (broker1 != null) |
| | | broker1.stop(); |