| | |
| | | AddSequenceLength*5+100, null); |
| | | replServer = new ReplicationServer(conf); |
| | | |
| | | ReplicationBroker broker = |
| | | openReplicationSession(baseDN, brokerId, 1000, replServerPort, 1000, |
| | | false, CLEAN_DB_GENERATION_ID); |
| | | ReplicationBroker broker = openReplicationSession( |
| | | baseDN, brokerId, 1000, replServerPort, 1000, CLEAN_DB_GENERATION_ID); |
| | | |
| | | Thread.sleep(2000); |
| | | // send a sequence of add operation |
| | |
| | | domain = MultimasterReplication.createNewDomain(domainConf); |
| | | domain.start(); |
| | | |
| | | ReplicationBroker broker = |
| | | openReplicationSession(baseDN, brokerId, 1000, replServerPort, 1000, |
| | | false, CLEAN_DB_GENERATION_ID); |
| | | ReplicationBroker broker = openReplicationSession( |
| | | baseDN, brokerId, 1000, replServerPort, 1000, CLEAN_DB_GENERATION_ID); |
| | | |
| | | // add an entry to play with. |
| | | entry.removeAttribute(uidType); |
| | |
| | | 0, 5*AddSequenceLength+100, null); |
| | | replServer = new ReplicationServer(conf); |
| | | |
| | | ReplicationBroker broker = |
| | | openReplicationSession(baseDN, brokerId, 100, replServerPort, 1000, |
| | | false, CLEAN_DB_GENERATION_ID); |
| | | ReplicationBroker broker = openReplicationSession( |
| | | baseDN, brokerId, 100, replServerPort, 1000, CLEAN_DB_GENERATION_ID); |
| | | |
| | | // send a sequence of add/del/add operations |
| | | CSNGenerator gen = new CSNGenerator(brokerId, 0L); |
| | |
| | | 0, 5*AddSequenceLength+100, null); |
| | | replServer = new ReplicationServer(conf); |
| | | |
| | | ReplicationBroker broker = |
| | | openReplicationSession(baseDN, brokerId, 100, replServerPort, 1000, |
| | | false, CLEAN_DB_GENERATION_ID); |
| | | ReplicationBroker broker = openReplicationSession( |
| | | baseDN, brokerId, 100, replServerPort, 1000, CLEAN_DB_GENERATION_ID); |
| | | |
| | | |
| | | DN addDN = TEST_ROOT_DN; |