| | |
| | | import org.opends.server.api.SynchronizationProvider; |
| | | import org.opends.server.backends.MemoryBackend; |
| | | import org.opends.server.core.DirectoryServer; |
| | | import org.opends.server.replication.service.ReplicationBroker; |
| | | import org.opends.server.replication.common.ChangeNumberGenerator; |
| | | import org.opends.server.replication.plugin.DomainFakeCfg; |
| | | import org.opends.server.replication.plugin.MultimasterReplication; |
| | | import org.opends.server.replication.plugin.ReplicationBroker; |
| | | import org.opends.server.replication.plugin.ReplicationDomain; |
| | | import org.opends.server.replication.plugin.LDAPReplicationDomain; |
| | | import org.opends.server.replication.protocol.AddMsg; |
| | | import org.opends.server.replication.protocol.DeleteMsg; |
| | | import org.opends.server.replication.protocol.ModifyDNMsg; |
| | |
| | | public void addModDelDependencyTest() throws Exception |
| | | { |
| | | ReplicationServer replServer = null; |
| | | ReplicationDomain domain = null; |
| | | LDAPReplicationDomain domain = null; |
| | | DN baseDn = DN.decode(TEST_ROOT_DN_STRING); |
| | | SynchronizationProvider replicationPlugin = null; |
| | | short brokerId = 2; |
| | |
| | | public void moddnDelDependencyTest() throws Exception |
| | | { |
| | | ReplicationServer replServer = null; |
| | | ReplicationDomain domain = null; |
| | | LDAPReplicationDomain domain = null; |
| | | DN baseDn = DN.decode(TEST_ROOT_DN_STRING); |
| | | SynchronizationProvider replicationPlugin = null; |
| | | short brokerId = 2; |
| | |
| | | Thread.sleep(2000); |
| | | domain = MultimasterReplication.createNewDomain(domainConf); |
| | | replicationPlugin.completeSynchronizationProvider(); |
| | | |
| | | |
| | | ReplicationBroker broker = |
| | | openReplicationSession(baseDn, brokerId, 1000, replServerPort, 1000, |
| | | false, CLEAN_DB_GENERATION_ID); |
| | |
| | | assertTrue(found, "The initial entry add failed"); |
| | | |
| | | |
| | | // disable the domain to make sure that the messages are |
| | | // disable the domain to make sure that the messages are |
| | | // all sent in a row. |
| | | domain.disable(); |
| | | |
| | |
| | | public void addDelAddDependencyTest() throws Exception |
| | | { |
| | | ReplicationServer replServer = null; |
| | | ReplicationDomain domain = null; |
| | | LDAPReplicationDomain domain = null; |
| | | DN baseDn = DN.decode(TEST_ROOT_DN_STRING); |
| | | SynchronizationProvider replicationPlugin = null; |
| | | short brokerId = 2; |
| | |
| | | public void addModdnDependencyTest() throws Exception |
| | | { |
| | | ReplicationServer replServer = null; |
| | | ReplicationDomain domain = null; |
| | | LDAPReplicationDomain domain = null; |
| | | DN baseDn = DN.decode(TEST_ROOT_DN_STRING); |
| | | SynchronizationProvider replicationPlugin = null; |
| | | short brokerId = 2; |
| | |
| | | int AddSequenceLength = 30; |
| | | |
| | | cleanDB(); |
| | | |
| | | |
| | | |
| | | try |
| | | { |