| | |
| | | |
| | | // delete the entries to clean the database |
| | | delMsg = |
| | | new DeleteMsg("uid=reallynewrdn,ou=People," + TEST_ROOT_DN_STRING, |
| | | gen.newChangeNumber(), user1entryUUID); |
| | | broker.publish(delMsg); |
| | | resultEntry = getEntry( |
| | | DN.decode("uid=reallynewrdn,ou=People," + TEST_ROOT_DN_STRING), 10000, false); |
| | | |
| | | // check that the delete operation has been applied |
| | | assertNull(resultEntry, |
| | | "The DELETE replication message was not replayed"); |
| | | |
| | | delMsg = |
| | | new DeleteMsg("entryUUID = " + user1entrysecondUUID + "+" + |
| | | DN.decode(user1dn).getRDN().toString() + |
| | | ",ou=People," + TEST_ROOT_DN_STRING, |
| | |
| | | assertNull(resultEntry, |
| | | "The DELETE replication message was not replayed"); |
| | | |
| | | delMsg = |
| | | new DeleteMsg("uid=reallynewrdn,ou=People," + TEST_ROOT_DN_STRING, |
| | | gen.newChangeNumber(), user1entryUUID); |
| | | broker.publish(delMsg); |
| | | resultEntry = getEntry( |
| | | DN.decode("uid=reallynewrdn,ou=People," + TEST_ROOT_DN_STRING), 10000, false); |
| | | |
| | | // check that the delete operation has been applied |
| | | assertNull(resultEntry, |
| | | "The DELETE replication message was not replayed"); |
| | | |
| | | /* |
| | | * When replaying add operations it is possible that the parent entry has |
| | | * been renamed before and that another entry have taken the former dn of |
| | |
| | | |
| | | // check that the 2 conflicting entries have been correctly marked |
| | | assertTrue(checkEntryHasAttribute(conflictDomain2dn, |
| | | LDAPReplicationDomain.DS_SYNC_CONFLICT, domain1dn, 1000, true)); |
| | | LDAPReplicationDomain.DS_SYNC_CONFLICT, domain2dn, 1000, true)); |
| | | assertTrue(checkEntryHasAttribute(conflictDomain3dn, |
| | | LDAPReplicationDomain.DS_SYNC_CONFLICT, domain1dn, 1000, true)); |
| | | LDAPReplicationDomain.DS_SYNC_CONFLICT, domain3dn, 1000, true)); |
| | | |
| | | // check that unresolved conflict count has been incremented |
| | | assertEquals(getMonitorDelta(), 1); |