/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/common/ |
H A D | MultiDomainServerState.java | 93 * @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 D | PersistentSearch.java | 261 * @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 D | AddOperation.java | 148 * @param changeNumber The change number that has been assigned to this 151 public abstract void setChangeNumber(long changeNumber); argument
|
H A D | ModifyDNOperation.java | 222 * @param changeNumber The change number that has been assigned to this 225 public void setChangeNumber(long changeNumber); argument
|
H A D | AddOperationWrapper.java | 168 public void setChangeNumber(long changeNumber) argument 170 getOperation().setChangeNumber(changeNumber);
|
H A D | ModifyDNOperationWrapper.java | 161 public void setChangeNumber(long changeNumber) { argument 162 getOperation().setChangeNumber(changeNumber);
|
/forgerock/opendj2.6.2/src/server/org/opends/server/core/ |
H A D | PersistentSearch.java | 261 * @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 D | AddOperation.java | 148 * @param changeNumber The change number that has been assigned to this 151 public abstract void setChangeNumber(long changeNumber); argument
|
H A D | ModifyDNOperation.java | 222 * @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 D | PersistentSearch.java | 261 * @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 D | AddOperation.java | 148 * @param changeNumber The change number that has been assigned to this 151 public abstract void setChangeNumber(long changeNumber); argument
|
H A D | ModifyDNOperation.java | 222 * @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 D | FileChangeNumberIndexDB.java | 172 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 D | SafeReadExpectedAcksInfo.java | 78 * @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 D | DbHandler.java | 264 * 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 D | Change.java | 33 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 D | Change.java | 32 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 D | SafeReadExpectedAcksInfo.java | 78 * @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 D | Change.java | 33 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 D | Change.java | 33 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 D | Change.java | 32 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 D | SafeReadExpectedAcksInfo.java | 78 * @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 D | DeleteMsg.java | 75 * @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 D | DeleteMsg.java | 75 * @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 D | DeleteMsg.java | 75 * @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 +
|