Searched refs:changeNumber (Results 101 - 125 of 241) sorted by relevance

12345678910

/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/common/
H A DMultiDomainServerState.java93 * @param changeNumber The provided ChangeNumber.
97 public boolean update(String serviceId, ChangeNumber changeNumber) argument
99 if (changeNumber == null)
104 int serverId = changeNumber.getServerId();
109 if (changeNumber.newer(oldServerState.getMaxChangeNumber(serverId)))
111 oldServerState.update(changeNumber);
/forgerock/opendj-b2.6/src/server/org/opends/server/core/
H A DPersistentSearch.java261 * @param changeNumber
266 public void processAdd(Entry entry, long changeNumber) argument
334 PersistentSearchChangeType.ADD, changeNumber));
377 * @param changeNumber
382 public void processDelete(Entry entry, long changeNumber) argument
447 PersistentSearchChangeType.DELETE, changeNumber));
490 * @param changeNumber
495 public void processModify(Entry entry, long changeNumber) argument
497 processModify(entry, changeNumber, entry);
507 * @param changeNumber
514 processModify(Entry entry, long changeNumber, Entry oldEntry) argument
630 processModifyDN(Entry entry, long changeNumber, DN oldDN) argument
[all...]
H A DAddOperation.java148 * @param changeNumber The change number that has been assigned to this
151 public abstract void setChangeNumber(long changeNumber); argument
H A DModifyDNOperation.java222 * @param changeNumber The change number that has been assigned to this
225 public void setChangeNumber(long changeNumber); argument
H A DAddOperationWrapper.java168 public void setChangeNumber(long changeNumber) argument
170 getOperation().setChangeNumber(changeNumber);
H A DModifyDNOperationWrapper.java161 public void setChangeNumber(long changeNumber) { argument
162 getOperation().setChangeNumber(changeNumber);
/forgerock/opendj2.6.2/src/server/org/opends/server/core/
H A DPersistentSearch.java261 * @param changeNumber
266 public void processAdd(Entry entry, long changeNumber) argument
334 PersistentSearchChangeType.ADD, changeNumber));
377 * @param changeNumber
382 public void processDelete(Entry entry, long changeNumber) argument
447 PersistentSearchChangeType.DELETE, changeNumber));
490 * @param changeNumber
495 public void processModify(Entry entry, long changeNumber) argument
497 processModify(entry, changeNumber, entry);
507 * @param changeNumber
514 processModify(Entry entry, long changeNumber, Entry oldEntry) argument
630 processModifyDN(Entry entry, long changeNumber, DN oldDN) argument
[all...]
H A DAddOperation.java148 * @param changeNumber The change number that has been assigned to this
151 public abstract void setChangeNumber(long changeNumber); argument
H A DModifyDNOperation.java222 * @param changeNumber The change number that has been assigned to this
225 public void setChangeNumber(long changeNumber); argument
/forgerock/opendj2-jel-hg/src/server/org/opends/server/core/
H A DPersistentSearch.java261 * @param changeNumber
266 public void processAdd(Entry entry, long changeNumber) argument
334 PersistentSearchChangeType.ADD, changeNumber));
377 * @param changeNumber
382 public void processDelete(Entry entry, long changeNumber) argument
447 PersistentSearchChangeType.DELETE, changeNumber));
490 * @param changeNumber
495 public void processModify(Entry entry, long changeNumber) argument
497 processModify(entry, changeNumber, entry);
507 * @param changeNumber
514 processModify(Entry entry, long changeNumber, Entry oldEntry) argument
630 processModifyDN(Entry entry, long changeNumber, DN oldDN) argument
[all...]
H A DAddOperation.java148 * @param changeNumber The change number that has been assigned to this
151 public abstract void setChangeNumber(long changeNumber); argument
H A DModifyDNOperation.java222 * @param changeNumber The change number that has been assigned to this
225 public void setChangeNumber(long changeNumber); argument
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/changelog/file/
H A DFileChangeNumberIndexDB.java172 final long changeNumber = nextChangeNumber();
174 new ChangeNumberIndexRecord(changeNumber, record.getBaseDN(), record.getCSN());
176 newestChangeNumber = changeNumber;
182 return changeNumber;
314 private Attribute toAttribute(final ChangeNumberType cnType, long changeNumber) argument
316 return Attributes.create(cnType.getAttributeName(), String.valueOf(changeNumber));
382 * the new changeNumber for for the first change in the changelog
426 final long changeNumber = reader.readLong();
431 return Record.from(changeNumber, new ChangeNumberIndexRecord(changeNumber, baseD
[all...]
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/
H A DSafeReadExpectedAcksInfo.java78 * @param changeNumber The change number of the assured update message
87 public SafeReadExpectedAcksInfo(ChangeNumber changeNumber, argument
91 super(changeNumber, requesterServerHandler, AssuredMode.SAFE_READ_MODE,
209 AckMsg ack = new AckMsg(changeNumber);
H A DDbHandler.java264 * by a given changeNumber.
266 * @param changeNumber The position where the iterator must start.
270 * by a given changeNumber.
274 * with changeNumber number.
276 public ReplicationIterator generateIterator(ChangeNumber changeNumber) argument
279 if (changeNumber == null)
283 return new ReplicationIterator(serverId, db, changeNumber, this);
425 // Find the last changeNumber before the trimDate, in the Database.
447 ChangeNumber changeNumber = cursor.nextChangeNumber();
448 if (changeNumber
[all...]
/forgerock/opendj-b2.6/tests/staf-tests/shared/java/ldapjdk/
H A DChange.java33 int changeNumber = 0; field in class:Change
58 attr = entry.getAttribute("changeNumber");
60 throw new Exception("No value found for changeNumber");
63 changeNumber = Integer.parseInt(changeNumberValue);
161 return ("change number " + changeNumber + " (csn="+csn +")");
/forgerock/opendj2/tests/staf-tests/shared/java/ldapjdk/
H A DChange.java32 int changeNumber = 0; field in class:Change
57 attr = entry.getAttribute("changeNumber");
59 throw new Exception("No value found for changeNumber");
62 changeNumber = Integer.parseInt(changeNumberValue);
160 return ("change number " + changeNumber + " (csn="+csn +")");
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/
H A DSafeReadExpectedAcksInfo.java78 * @param changeNumber The change number of the assured update message
87 public SafeReadExpectedAcksInfo(ChangeNumber changeNumber, argument
91 super(changeNumber, requesterServerHandler, AssuredMode.SAFE_READ_MODE,
209 AckMsg ack = new AckMsg(changeNumber);
/forgerock/opendj2.6.2/tests/staf-tests/shared/java/ldapjdk/
H A DChange.java33 int changeNumber = 0; field in class:Change
58 attr = entry.getAttribute("changeNumber");
60 throw new Exception("No value found for changeNumber");
63 changeNumber = Integer.parseInt(changeNumberValue);
161 return ("change number " + changeNumber + " (csn="+csn +")");
/forgerock/opendj2-jel-hg/tests/staf-tests/shared/java/ldapjdk/
H A DChange.java33 int changeNumber = 0; field in class:Change
58 attr = entry.getAttribute("changeNumber");
60 throw new Exception("No value found for changeNumber");
63 changeNumber = Integer.parseInt(changeNumberValue);
161 return ("change number " + changeNumber + " (csn="+csn +")");
/forgerock/opendj2-hg/tests/staf-tests/shared/java/ldapjdk/
H A DChange.java32 int changeNumber = 0; field in class:Change
57 attr = entry.getAttribute("changeNumber");
59 throw new Exception("No value found for changeNumber");
62 changeNumber = Integer.parseInt(changeNumberValue);
160 return ("change number " + changeNumber + " (csn="+csn +")");
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/
H A DSafeReadExpectedAcksInfo.java78 * @param changeNumber The change number of the assured update message
87 public SafeReadExpectedAcksInfo(ChangeNumber changeNumber, argument
91 super(changeNumber, requesterServerHandler, AssuredMode.SAFE_READ_MODE,
209 AckMsg ack = new AckMsg(changeNumber);
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/protocol/
H A DDeleteMsg.java75 * @param changeNumber The change number with which the message must be
79 public DeleteMsg(String dn, ChangeNumber changeNumber, String entryUUID) argument
81 super(new DeleteContext(changeNumber, entryUUID), dn);
258 " changeNumber: " + changeNumber +
267 " changeNumber: " + changeNumber +
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/protocol/
H A DDeleteMsg.java75 * @param changeNumber The change number with which the message must be
79 public DeleteMsg(String dn, ChangeNumber changeNumber, String entryUUID) argument
81 super(new DeleteContext(changeNumber, entryUUID), dn);
258 " changeNumber: " + changeNumber +
267 " changeNumber: " + changeNumber +
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/protocol/
H A DDeleteMsg.java75 * @param changeNumber The change number with which the message must be
79 public DeleteMsg(String dn, ChangeNumber changeNumber, String entryUUID) argument
81 super(new DeleteContext(changeNumber, entryUUID), dn);
258 " changeNumber: " + changeNumber +
267 " changeNumber: " + changeNumber +

Completed in 47 milliseconds

12345678910