/forgerock/opendj2.6.2/src/server/org/opends/server/core/ |
H A D | ModifyDNOperationBasis.java | 98 private long changeNumber; field in class:ModifyDNOperationBasis 144 changeNumber = -1; 194 changeNumber = -1; 405 return changeNumber; 412 public final void setChangeNumber(long changeNumber) argument 414 this.changeNumber = changeNumber;
|
H A D | ModifyOperationBasis.java | 94 private long changeNumber; field in class:ModifyOperationBasis 439 return changeNumber; 445 public void setChangeNumber(long changeNumber) argument 447 this.changeNumber = changeNumber;
|
/forgerock/opendj2-jel-hg/src/server/org/opends/server/core/ |
H A D | ModifyDNOperationBasis.java | 98 private long changeNumber; field in class:ModifyDNOperationBasis 144 changeNumber = -1; 194 changeNumber = -1; 405 return changeNumber; 412 public final void setChangeNumber(long changeNumber) argument 414 this.changeNumber = changeNumber;
|
H A D | ModifyOperationBasis.java | 94 private long changeNumber; field in class:ModifyOperationBasis 439 return changeNumber; 445 public void setChangeNumber(long changeNumber) argument 447 this.changeNumber = changeNumber;
|
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/common/ |
H A D | ServerState.java | 153 * @param changeNumber The committed ChangeNumber. 157 public boolean update(ChangeNumber changeNumber) argument 159 if (changeNumber == null) 166 int id = changeNumber.getServerId(); 168 if (oldCN == null || changeNumber.newer(oldCN)) 170 list.put(id,changeNumber);
|
/forgerock/opendj2/src/server/org/opends/server/replication/server/changelog/je/ |
H A D | DraftCNDB.java | 93 final long changeNumber = record.getChangeNumber(); 94 DatabaseEntry key = new ReplicationDraftCNKey(changeNumber); 95 DatabaseEntry data = new DraftCNData(changeNumber, record.getBaseDN().toNormalizedString(), record.getCSN()); 149 * @param changeNumber The change number from which the cursor must start. 154 public DraftCNDBCursor openReadCursor(long changeNumber) argument 157 return new DraftCNDBCursor(changeNumber);
|
H A D | ChangeNumberIndexer.java | 478 final long changeNumber = changelogDB.getChangeNumberIndexDB() 481 notifyEntryAddedToChangelog(baseDN, changeNumber, cookie, msg); 515 * @param changeNumber 527 protected void notifyEntryAddedToChangelog(DN baseDN, long changeNumber, argument 530 ChangelogBackend.getInstance().notifyChangeNumberEntryAdded(baseDN, changeNumber, cookie.toString(), msg);
|
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/common/ |
H A D | ServerState.java | 153 * @param changeNumber The committed ChangeNumber. 157 public boolean update(ChangeNumber changeNumber) argument 159 if (changeNumber == null) 166 int id = changeNumber.getServerId(); 168 if (oldCN == null || changeNumber.newer(oldCN)) 170 list.put(id,changeNumber);
|
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/common/ |
H A D | ServerState.java | 153 * @param changeNumber The committed ChangeNumber. 157 public boolean update(ChangeNumber changeNumber) argument 159 if (changeNumber == null) 166 int id = changeNumber.getServerId(); 168 if (oldCN == null || changeNumber.newer(oldCN)) 170 list.put(id,changeNumber);
|
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/changelog/je/ |
H A D | DraftCNDB.java | 93 final long changeNumber = record.getChangeNumber(); 94 DatabaseEntry key = new ReplicationDraftCNKey(changeNumber); 95 DatabaseEntry data = new DraftCNData(changeNumber, record.getBaseDN().toNormalizedString(), record.getCSN()); 149 * @param changeNumber The change number from which the cursor must start. 154 public DraftCNDBCursor openReadCursor(long changeNumber) argument 157 return new DraftCNDBCursor(changeNumber);
|
H A D | ChangeNumberIndexer.java | 478 final long changeNumber = changelogDB.getChangeNumberIndexDB() 481 notifyEntryAddedToChangelog(baseDN, changeNumber, cookie, msg); 515 * @param changeNumber 527 protected void notifyEntryAddedToChangelog(DN baseDN, long changeNumber, argument 530 ChangelogBackend.getInstance().notifyChangeNumberEntryAdded(baseDN, changeNumber, cookie.toString(), msg);
|
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/protocol/ |
H A D | ModifyDNMsg.java | 89 * @param changeNumber The changeNumberto use for building the message. 98 public ModifyDNMsg(String dn, ChangeNumber changeNumber, String entryUUID, argument 102 super(new ModifyDnContext(changeNumber, entryUUID, newSuperiorEntryUUID), 115 * @param changeNumber The changeNumberto use for building the message. 125 public ModifyDNMsg(String dn, ChangeNumber changeNumber, String entryUUID, argument 129 this(dn, changeNumber, entryUUID, newSuperiorEntryUUID, deleteOldRdn, 558 " changeNumber: " + changeNumber + 570 " changeNumber: " + changeNumber [all...] |
H A D | LDAPUpdateMsg.java | 100 this.changeNumber = ctx.getChangeNumber(); 118 this.changeNumber = cn; 480 /* Read the changeNumber */ 485 changeNumber = new ChangeNumber(changeNumberStr); 542 /* read the changeNumber */ 547 changeNumber = new ChangeNumber(changeNumberStr);
|
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/protocol/ |
H A D | ModifyDNMsg.java | 89 * @param changeNumber The changeNumberto use for building the message. 98 public ModifyDNMsg(String dn, ChangeNumber changeNumber, String entryUUID, argument 102 super(new ModifyDnContext(changeNumber, entryUUID, newSuperiorEntryUUID), 115 * @param changeNumber The changeNumberto use for building the message. 125 public ModifyDNMsg(String dn, ChangeNumber changeNumber, String entryUUID, argument 129 this(dn, changeNumber, entryUUID, newSuperiorEntryUUID, deleteOldRdn, 558 " changeNumber: " + changeNumber + 570 " changeNumber: " + changeNumber [all...] |
H A D | LDAPUpdateMsg.java | 100 this.changeNumber = ctx.getChangeNumber(); 118 this.changeNumber = cn; 480 /* Read the changeNumber */ 485 changeNumber = new ChangeNumber(changeNumberStr); 542 /* read the changeNumber */ 547 changeNumber = new ChangeNumber(changeNumberStr);
|
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/protocol/ |
H A D | ModifyDNMsg.java | 89 * @param changeNumber The changeNumberto use for building the message. 98 public ModifyDNMsg(String dn, ChangeNumber changeNumber, String entryUUID, argument 102 super(new ModifyDnContext(changeNumber, entryUUID, newSuperiorEntryUUID), 115 * @param changeNumber The changeNumberto use for building the message. 125 public ModifyDNMsg(String dn, ChangeNumber changeNumber, String entryUUID, argument 129 this(dn, changeNumber, entryUUID, newSuperiorEntryUUID, deleteOldRdn, 558 " changeNumber: " + changeNumber + 570 " changeNumber: " + changeNumber [all...] |
H A D | LDAPUpdateMsg.java | 100 this.changeNumber = ctx.getChangeNumber(); 118 this.changeNumber = cn; 480 /* Read the changeNumber */ 485 changeNumber = new ChangeNumber(changeNumberStr); 542 /* read the changeNumber */ 547 changeNumber = new ChangeNumber(changeNumberStr);
|
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/plugin/ |
H A D | PersistentServerState.java | 127 * @param changeNumber The committed ChangeNumber. 131 public boolean update(ChangeNumber changeNumber) argument 133 return state.update(changeNumber); 291 ChangeNumber changeNumber = new ChangeNumber(value.toString()); 292 update(changeNumber);
|
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/plugin/ |
H A D | PersistentServerState.java | 127 * @param changeNumber The committed ChangeNumber. 131 public boolean update(ChangeNumber changeNumber) argument 133 return state.update(changeNumber); 291 ChangeNumber changeNumber = new ChangeNumber(value.toString()); 292 update(changeNumber);
|
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/plugin/ |
H A D | PersistentServerState.java | 127 * @param changeNumber The committed ChangeNumber. 131 public boolean update(ChangeNumber changeNumber) argument 133 return state.update(changeNumber); 291 ChangeNumber changeNumber = new ChangeNumber(value.toString()); 292 update(changeNumber);
|
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/changelog/file/ |
H A D | ChangeNumberIndexer.java | 461 final long changeNumber = changelogDB.getChangeNumberIndexDB() 468 notifyEntryAddedToChangelog(baseDN, changeNumber, cookie, msg); 522 * @param changeNumber 534 protected void notifyEntryAddedToChangelog(DN baseDN, long changeNumber, argument 537 ChangelogBackend.getInstance().notifyChangeNumberEntryAdded(baseDN, changeNumber, cookie.toString(), msg);
|
/forgerock/opendj-b2.6/src/server/org/opends/server/core/ |
H A D | ModifyOperationBasis.java | 94 private long changeNumber; field in class:ModifyOperationBasis 439 return changeNumber; 445 public void setChangeNumber(long changeNumber) argument 447 this.changeNumber = changeNumber;
|
/forgerock/opendj2/src/server/org/opends/server/backends/ |
H A D | ChangelogBackend.java | 137 * the ReplicaDBs. The <code>changeNumber</code> attribute is not returned with 142 * <code>changeNumber</code> attribute value is set from the content of 186 private static final String CHANGE_NUMBER_ATTR = "changeNumber"; 469 * @param changeNumber 481 public void notifyChangeNumberEntryAdded(DN baseDN, long changeNumber, String cookieString, UpdateMsg updateMsg) argument 491 // changeNumber entry can be shared with multiple persistent searches 492 final Entry changeNumberEntry = createEntryFromMsg(baseDN, changeNumber, cookieString, updateMsg); 497 entrySender.persistentSearchSendEntry(changeNumber, changeNumberEntry); 746 * @param changeNumber 751 boolean changeNumberIsInRange(long changeNumber) argument 1307 createEntryFromMsg(final DN baseDN, final long changeNumber, final String cookie, final UpdateMsg msg) argument 1335 createAddMsg(final DN baseDN, final long changeNumber, final String cookie, final UpdateMsg msg) argument 1376 createModifyMsg(final DN baseDN, final long changeNumber, final String cookie, final UpdateMsg msg) argument 1462 createChangelogEntry(final DN baseDN, final long changeNumber, final String cookie, final LDAPUpdateMsg msg, final String ldifChanges, final String changeType, final String changeInitiatorsName) argument 1798 persistentSearchSendEntry(long changeNumber, Entry entry) argument [all...] |
/forgerock/opendj2-hg/src/server/org/opends/server/backends/ |
H A D | ChangelogBackend.java | 137 * the ReplicaDBs. The <code>changeNumber</code> attribute is not returned with 142 * <code>changeNumber</code> attribute value is set from the content of 186 private static final String CHANGE_NUMBER_ATTR = "changeNumber"; 469 * @param changeNumber 481 public void notifyChangeNumberEntryAdded(DN baseDN, long changeNumber, String cookieString, UpdateMsg updateMsg) argument 491 // changeNumber entry can be shared with multiple persistent searches 492 final Entry changeNumberEntry = createEntryFromMsg(baseDN, changeNumber, cookieString, updateMsg); 497 entrySender.persistentSearchSendEntry(changeNumber, changeNumberEntry); 746 * @param changeNumber 751 boolean changeNumberIsInRange(long changeNumber) argument 1307 createEntryFromMsg(final DN baseDN, final long changeNumber, final String cookie, final UpdateMsg msg) argument 1335 createAddMsg(final DN baseDN, final long changeNumber, final String cookie, final UpdateMsg msg) argument 1376 createModifyMsg(final DN baseDN, final long changeNumber, final String cookie, final UpdateMsg msg) argument 1462 createChangelogEntry(final DN baseDN, final long changeNumber, final String cookie, final LDAPUpdateMsg msg, final String ldifChanges, final String changeType, final String changeInitiatorsName) argument 1798 persistentSearchSendEntry(long changeNumber, Entry entry) argument [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/backends/ |
H A D | ChangelogBackend.java | 130 * the ReplicaDBs. The <code>changeNumber</code> attribute is not returned with 135 * <code>changeNumber</code> attribute value is set from the content of 179 private static final String CHANGE_NUMBER_ATTR = "changeNumber"; 430 * @param changeNumber 442 public void notifyChangeNumberEntryAdded(DN baseDN, long changeNumber, String cookieString, UpdateMsg updateMsg) argument 453 // changeNumber entry can be shared with multiple persistent searches 454 final Entry changeNumberEntry = createEntryFromMsg(baseDN, changeNumber, cookieString, updateMsg); 459 entrySender.persistentSearchSendEntry(changeNumber, changeNumberEntry); 701 // It is probably "changeNumber=xxx,cn=changelog", use equality filter 1160 private static Entry createEntryFromMsg(final DN baseDN, final long changeNumber, fina argument 1188 createAddMsg(final DN baseDN, final long changeNumber, final String cookie, final UpdateMsg msg) argument 1229 createModifyMsg(final DN baseDN, final long changeNumber, final String cookie, final UpdateMsg msg) argument 1315 createChangelogEntry(final DN baseDN, final long changeNumber, final String cookie, final LDAPUpdateMsg msg, final String ldifChanges, final String changeType, final String changeInitiatorsName) argument 1638 changeNumberIsInRange(long changeNumber) argument 1665 persistentSearchSendEntry(long changeNumber, Entry entry) argument [all...] |