| | |
| | | ReplicationServer replServer = null; |
| | | LDAPReplicationDomain domain = null; |
| | | DN baseDn = DN.decode(TEST_ROOT_DN_STRING); |
| | | SynchronizationProvider replicationPlugin = null; |
| | | int brokerId = 2; |
| | | int serverId = 1; |
| | | int replServerId = 81; |
| | |
| | | int replServerPort = socket.getLocalPort(); |
| | | socket.close(); |
| | | |
| | | replicationPlugin = new MultimasterReplication(); |
| | | DirectoryServer.registerSynchronizationProvider(replicationPlugin); |
| | | ReplServerFakeConfiguration conf = |
| | | new ReplServerFakeConfiguration(replServerPort, "dependencyTestAddModDelDependencyTestDb", |
| | | 0, replServerId, 0, |
| | |
| | | domainConf.setHeartbeatInterval(100000); |
| | | |
| | | domain = MultimasterReplication.createNewDomain(domainConf); |
| | | replicationPlugin.completeSynchronizationProvider(); |
| | | domain.start(); |
| | | |
| | | // check that last entry in sequence got added. |
| | | Entry lastEntry = getEntry(DN.decode(addDn), 30000, true); |
| | |
| | | |
| | | if (domain != null) |
| | | MultimasterReplication.deleteDomain(baseDn); |
| | | |
| | | if (replicationPlugin != null) |
| | | DirectoryServer.deregisterSynchronizationProvider(replicationPlugin); |
| | | } |
| | | } |
| | | |
| | |
| | | ReplicationServer replServer = null; |
| | | LDAPReplicationDomain domain = null; |
| | | DN baseDn = DN.decode(TEST_ROOT_DN_STRING); |
| | | SynchronizationProvider replicationPlugin = null; |
| | | int brokerId = 2; |
| | | int serverId = 1; |
| | | int replServerId = 82; |
| | |
| | | int replServerPort = socket.getLocalPort(); |
| | | socket.close(); |
| | | |
| | | replicationPlugin = new MultimasterReplication(); |
| | | DirectoryServer.registerSynchronizationProvider(replicationPlugin); |
| | | ReplServerFakeConfiguration conf = |
| | | new ReplServerFakeConfiguration(replServerPort, "dependencyTestModdnDelDependencyTestDb", |
| | | 0, replServerId, 0, |
| | |
| | | |
| | | Thread.sleep(2000); |
| | | domain = MultimasterReplication.createNewDomain(domainConf); |
| | | replicationPlugin.completeSynchronizationProvider(); |
| | | domain.start(); |
| | | |
| | | ReplicationBroker broker = |
| | | openReplicationSession(baseDn, brokerId, 1000, replServerPort, 1000, |
| | |
| | | |
| | | if (domain != null) |
| | | MultimasterReplication.deleteDomain(baseDn); |
| | | |
| | | if (replicationPlugin != null) |
| | | DirectoryServer.deregisterSynchronizationProvider(replicationPlugin); |
| | | } |
| | | |
| | | } |
| | |
| | | ReplicationServer replServer = null; |
| | | LDAPReplicationDomain domain = null; |
| | | DN baseDn = DN.decode(TEST_ROOT_DN_STRING); |
| | | SynchronizationProvider replicationPlugin = null; |
| | | int brokerId = 2; |
| | | int serverId = 1; |
| | | int replServerId = 83; |
| | |
| | | int replServerPort = socket.getLocalPort(); |
| | | socket.close(); |
| | | |
| | | replicationPlugin = new MultimasterReplication(); |
| | | DirectoryServer.registerSynchronizationProvider(replicationPlugin); |
| | | ReplServerFakeConfiguration conf = |
| | | new ReplServerFakeConfiguration(replServerPort, "dependencyTestAddDelAddDependencyTestDb", 0, |
| | | replServerId, |
| | |
| | | new DomainFakeCfg(baseDn, serverId, replServers); |
| | | |
| | | domain = MultimasterReplication.createNewDomain(domainConf); |
| | | replicationPlugin.completeSynchronizationProvider(); |
| | | domain.start(); |
| | | |
| | | // check that all entries have been deleted and added |
| | | // again by checking that they do have the correct entryuuid |
| | |
| | | |
| | | if (domain != null) |
| | | MultimasterReplication.deleteDomain(baseDn); |
| | | |
| | | if (replicationPlugin != null) |
| | | DirectoryServer.deregisterSynchronizationProvider(replicationPlugin); |
| | | } |
| | | } |
| | | |
| | |
| | | ReplicationServer replServer = null; |
| | | LDAPReplicationDomain domain = null; |
| | | DN baseDn = DN.decode(TEST_ROOT_DN_STRING); |
| | | SynchronizationProvider replicationPlugin = null; |
| | | int brokerId = 2; |
| | | int serverId = 1; |
| | | int replServerId = 84; |
| | |
| | | int replServerPort = socket.getLocalPort(); |
| | | socket.close(); |
| | | |
| | | replicationPlugin = new MultimasterReplication(); |
| | | DirectoryServer.registerSynchronizationProvider(replicationPlugin); |
| | | ReplServerFakeConfiguration conf = |
| | | new ReplServerFakeConfiguration(replServerPort, "dependencyTestAddModdnDependencyTestDb", 0, |
| | | replServerId, |
| | |
| | | new DomainFakeCfg(baseDn, serverId, replServers); |
| | | |
| | | domain = MultimasterReplication.createNewDomain(domainConf); |
| | | replicationPlugin.completeSynchronizationProvider(); |
| | | domain.start(); |
| | | |
| | | // check that all entries have been renamed |
| | | for (sequence = 1; sequence<=AddSequenceLength; sequence ++) |
| | |
| | | |
| | | if (domain != null) |
| | | MultimasterReplication.deleteDomain(baseDn); |
| | | |
| | | if (replicationPlugin != null) |
| | | DirectoryServer.deregisterSynchronizationProvider(replicationPlugin); |
| | | } |
| | | } |
| | | |