Searched refs:changeNumber (Results 201 - 225 of 241) sorted by relevance

12345678910

/forgerock/opendj-b2.6/src/server/org/opends/server/replication/plugin/
H A DLDAPReplicationDomain.java1805 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 DEntryHistorical.java233 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 DAddMsg.java501 " changeNumber: " + changeNumber +
510 " changeNumber: " + changeNumber +
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/plugin/
H A DLDAPReplicationDomain.java1826 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 DEntryHistorical.java233 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 DAddMsg.java501 " changeNumber: " + changeNumber +
510 " changeNumber: " + changeNumber +
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/plugin/
H A DLDAPReplicationDomain.java1805 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 DEntryHistorical.java233 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 DAddMsg.java501 " changeNumber: " + changeNumber +
510 " changeNumber: " + changeNumber +
/forgerock/opendj-b2.6/src/server/org/opends/server/workflowelement/externalchangelog/
H A DECLSearchOperation.java1000 * @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 DECLSearchOperation.java1022 * @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 DECLSearchOperation.java1000 * @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 DSynchronizationMsgTest.java178 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 DProtocolCompatibilityTest.java541 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 DSynchronizationMsgTest.java178 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 DProtocolCompatibilityTest.java541 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 DSynchronizationMsgTest.java178 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 DProtocolCompatibilityTest.java541 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 DDeleteOperationTestCase.java209 long changeNumber = deleteOperation.getChangeNumber();
210 deleteOperation.setChangeNumber(changeNumber);
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/core/
H A DDeleteOperationTestCase.java209 long changeNumber = deleteOperation.getChangeNumber();
210 deleteOperation.setChangeNumber(changeNumber);
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/core/
H A DDeleteOperationTestCase.java209 long changeNumber = deleteOperation.getChangeNumber();
210 deleteOperation.setChangeNumber(changeNumber);
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/tools/dsreplication/
H A DReplicationCliArgumentParser.java1902 * @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 DChangeNumberIndexerTest.java59 * 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 DChangeNumberIndexerTest.java59 * 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 DReplicationBackend.java1000 Attribute changeNumber =
1003 addAttribute(entry.getUserAttributes(), changeNumber);

Completed in 109 milliseconds

12345678910