/forgerock/opendj-b2.6/src/server/org/opends/server/replication/plugin/ |
H A D | LDAPReplicationDomain.java | 1805 ChangeNumber changeNumber = generateChangeNumber(deleteOperation); 1807 ctx = new DeleteContext(changeNumber, modifiedEntryUUID); 1818 changeNumber, 1821 changeNumber,modifiedEntryUUID )); 2070 ChangeNumber changeNumber = generateChangeNumber(modifyDNOperation); 2079 ctx = new ModifyDnContext(changeNumber, modifiedEntryUUID, newParentId); 2155 // - create a ctx with : changeNumber, entryUUID 2158 ChangeNumber changeNumber = generateChangeNumber(modifyOperation); 2160 ctx = new ModifyContext(changeNumber, modifiedEntryUUID); 2574 ChangeNumber changeNumber 2771 updateError(ChangeNumber changeNumber) argument [all...] |
H A D | EntryHistorical.java | 233 ChangeNumber changeNumber = 252 attrHist.processLocalOrNonConflictModification(changeNumber, mod); 306 * For ADD, the historical is made of the changeNumber read from the 329 // Get the changeNumber from the attached synchronization context 344 * For ADD Operation : "dn:changeNumber:add" 363 * For MODDN Operation : "dn:changeNumber:moddn"
|
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/protocol/ |
H A D | AddMsg.java | 501 " changeNumber: " + changeNumber + 510 " changeNumber: " + changeNumber +
|
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/plugin/ |
H A D | LDAPReplicationDomain.java | 1826 ChangeNumber changeNumber = generateChangeNumber(deleteOperation); 1828 ctx = new DeleteContext(changeNumber, modifiedEntryUUID); 1839 changeNumber, 1842 changeNumber,modifiedEntryUUID )); 2091 ChangeNumber changeNumber = generateChangeNumber(modifyDNOperation); 2100 ctx = new ModifyDnContext(changeNumber, modifiedEntryUUID, newParentId); 2176 // - create a ctx with : changeNumber, entryUUID 2179 ChangeNumber changeNumber = generateChangeNumber(modifyOperation); 2181 ctx = new ModifyContext(changeNumber, modifiedEntryUUID); 2595 ChangeNumber changeNumber 2792 updateError(ChangeNumber changeNumber) argument [all...] |
H A D | EntryHistorical.java | 233 ChangeNumber changeNumber = 252 attrHist.processLocalOrNonConflictModification(changeNumber, mod); 306 * For ADD, the historical is made of the changeNumber read from the 329 // Get the changeNumber from the attached synchronization context 344 * For ADD Operation : "dn:changeNumber:add" 363 * For MODDN Operation : "dn:changeNumber:moddn"
|
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/protocol/ |
H A D | AddMsg.java | 501 " changeNumber: " + changeNumber + 510 " changeNumber: " + changeNumber +
|
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/plugin/ |
H A D | LDAPReplicationDomain.java | 1805 ChangeNumber changeNumber = generateChangeNumber(deleteOperation); 1807 ctx = new DeleteContext(changeNumber, modifiedEntryUUID); 1818 changeNumber, 1821 changeNumber,modifiedEntryUUID )); 2070 ChangeNumber changeNumber = generateChangeNumber(modifyDNOperation); 2079 ctx = new ModifyDnContext(changeNumber, modifiedEntryUUID, newParentId); 2155 // - create a ctx with : changeNumber, entryUUID 2158 ChangeNumber changeNumber = generateChangeNumber(modifyOperation); 2160 ctx = new ModifyContext(changeNumber, modifiedEntryUUID); 2574 ChangeNumber changeNumber 2771 updateError(ChangeNumber changeNumber) argument [all...] |
H A D | EntryHistorical.java | 233 ChangeNumber changeNumber = 252 attrHist.processLocalOrNonConflictModification(changeNumber, mod); 306 * For ADD, the historical is made of the changeNumber read from the 329 // Get the changeNumber from the attached synchronization context 344 * For ADD Operation : "dn:changeNumber:add" 363 * For MODDN Operation : "dn:changeNumber:moddn"
|
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/protocol/ |
H A D | AddMsg.java | 501 " changeNumber: " + changeNumber + 510 " changeNumber: " + changeNumber +
|
/forgerock/opendj-b2.6/src/server/org/opends/server/workflowelement/externalchangelog/ |
H A D | ECLSearchOperation.java | 1000 * @param changeNumber The provided replication changeNumber. 1015 ChangeNumber changeNumber, 1030 dnString = "replicationCSN=" + changeNumber + "," + serviceID + "," 1036 dnString = "changeNumber=" + draftChangenumber + "," 1099 aType = DirectoryServer.getDefaultAttributeType("changeNumber"); 1115 dateFormat.format(new Date(changeNumber.getTime()))); 1149 a = Attributes.create(aType, changeNumber.toString()); 1160 a = Attributes.create(aType, Integer.toString(changeNumber.getServerId())); 1337 // changeNumber 1011 createChangelogEntry( String serviceID, String cookie, DN targetDN, ChangeNumber changeNumber, String clearLDIFchanges, String targetUUID, List<RawAttribute> includedAttributes, int draftChangenumber, String changetype, String changeInitiatorsName) argument [all...] |
/forgerock/opendj2.6.2/src/server/org/opends/server/workflowelement/externalchangelog/ |
H A D | ECLSearchOperation.java | 1022 * @param changeNumber The provided replication changeNumber. 1037 ChangeNumber changeNumber, 1052 dnString = "replicationCSN=" + changeNumber + "," + serviceID + "," 1058 dnString = "changeNumber=" + draftChangenumber + "," 1121 aType = DirectoryServer.getDefaultAttributeType("changeNumber"); 1137 dateFormat.format(new Date(changeNumber.getTime()))); 1171 a = Attributes.create(aType, changeNumber.toString()); 1182 a = Attributes.create(aType, Integer.toString(changeNumber.getServerId())); 1359 // changeNumber 1033 createChangelogEntry( String serviceID, String cookie, DN targetDN, ChangeNumber changeNumber, String clearLDIFchanges, String targetUUID, List<RawAttribute> includedAttributes, int draftChangenumber, String changetype, String changeInitiatorsName) argument [all...] |
/forgerock/opendj2-jel-hg/src/server/org/opends/server/workflowelement/externalchangelog/ |
H A D | ECLSearchOperation.java | 1000 * @param changeNumber The provided replication changeNumber. 1015 ChangeNumber changeNumber, 1030 dnString = "replicationCSN=" + changeNumber + "," + serviceID + "," 1036 dnString = "changeNumber=" + draftChangenumber + "," 1099 aType = DirectoryServer.getDefaultAttributeType("changeNumber"); 1115 dateFormat.format(new Date(changeNumber.getTime()))); 1149 a = Attributes.create(aType, changeNumber.toString()); 1160 a = Attributes.create(aType, Integer.toString(changeNumber.getServerId())); 1337 // changeNumber 1011 createChangelogEntry( String serviceID, String cookie, DN targetDN, ChangeNumber changeNumber, String clearLDIFchanges, String targetUUID, List<RawAttribute> includedAttributes, int draftChangenumber, String changetype, String changeInitiatorsName) argument [all...] |
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/ |
H A D | SynchronizationMsgTest.java | 178 public void modifyMsgTest(ChangeNumber changeNumber, argument 188 ModifyMsg msg = new ModifyMsg(changeNumber, dn, mods, "fakeuniqueid"); 249 public void updateMsgTest(ChangeNumber changeNumber, argument 257 ModifyMsg msg = new ModifyMsg(changeNumber, dn, mods, "fakeuniqueid"); 1449 ChangeNumber changeNumber = new ChangeNumber(TimeThread.getTime(), 123, 45); 1459 msg.setChangeNumber(changeNumber); 1596 public void modMsgPerfs(ChangeNumber changeNumber, argument
|
H A D | ProtocolCompatibilityTest.java | 541 public void modifyMsgTestVLASTV2(ChangeNumber changeNumber, argument 556 public void modifyMsgTestVLASTV1(ChangeNumber changeNumber, argument 565 ModifyMsg origVlastMsg = new ModifyMsg(changeNumber, dn, mods, "fakeuniqueid");
|
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/ |
H A D | SynchronizationMsgTest.java | 178 public void modifyMsgTest(ChangeNumber changeNumber, argument 188 ModifyMsg msg = new ModifyMsg(changeNumber, dn, mods, "fakeuniqueid"); 249 public void updateMsgTest(ChangeNumber changeNumber, argument 257 ModifyMsg msg = new ModifyMsg(changeNumber, dn, mods, "fakeuniqueid"); 1449 ChangeNumber changeNumber = new ChangeNumber(TimeThread.getTime(), 123, 45); 1459 msg.setChangeNumber(changeNumber); 1596 public void modMsgPerfs(ChangeNumber changeNumber, argument
|
H A D | ProtocolCompatibilityTest.java | 541 public void modifyMsgTestVLASTV2(ChangeNumber changeNumber, argument 556 public void modifyMsgTestVLASTV1(ChangeNumber changeNumber, argument 565 ModifyMsg origVlastMsg = new ModifyMsg(changeNumber, dn, mods, "fakeuniqueid");
|
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/ |
H A D | SynchronizationMsgTest.java | 178 public void modifyMsgTest(ChangeNumber changeNumber, argument 188 ModifyMsg msg = new ModifyMsg(changeNumber, dn, mods, "fakeuniqueid"); 249 public void updateMsgTest(ChangeNumber changeNumber, argument 257 ModifyMsg msg = new ModifyMsg(changeNumber, dn, mods, "fakeuniqueid"); 1449 ChangeNumber changeNumber = new ChangeNumber(TimeThread.getTime(), 123, 45); 1459 msg.setChangeNumber(changeNumber); 1596 public void modMsgPerfs(ChangeNumber changeNumber, argument
|
H A D | ProtocolCompatibilityTest.java | 541 public void modifyMsgTestVLASTV2(ChangeNumber changeNumber, argument 556 public void modifyMsgTestVLASTV1(ChangeNumber changeNumber, argument 565 ModifyMsg origVlastMsg = new ModifyMsg(changeNumber, dn, mods, "fakeuniqueid");
|
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/core/ |
H A D | DeleteOperationTestCase.java | 209 long changeNumber = deleteOperation.getChangeNumber(); 210 deleteOperation.setChangeNumber(changeNumber);
|
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/core/ |
H A D | DeleteOperationTestCase.java | 209 long changeNumber = deleteOperation.getChangeNumber(); 210 deleteOperation.setChangeNumber(changeNumber);
|
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/core/ |
H A D | DeleteOperationTestCase.java | 209 long changeNumber = deleteOperation.getChangeNumber(); 210 deleteOperation.setChangeNumber(changeNumber);
|
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/tools/dsreplication/ |
H A D | ReplicationCliArgumentParser.java | 1902 * @param changeNumber the new value of the option 1904 public void setResetChangeNumber(String changeNumber) argument 1907 resetChangeNumber.addValue(changeNumber);
|
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/changelog/je/ |
H A D | ChangeNumberIndexerTest.java | 59 * does to compute a changeNumber. The tests setup various topologies with their 597 protected void notifyEntryAddedToChangelog(DN baseDN, long changeNumber,
|
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/changelog/je/ |
H A D | ChangeNumberIndexerTest.java | 59 * does to compute a changeNumber. The tests setup various topologies with their 597 protected void notifyEntryAddedToChangelog(DN baseDN, long changeNumber,
|
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/ |
H A D | ReplicationBackend.java | 1000 Attribute changeNumber = 1003 addAttribute(entry.getUserAttributes(), changeNumber);
|