Searched refs:changeNumber (Results 151 - 175 of 241) sorted by relevance

12345678910

/forgerock/opendj2.6.2/src/server/org/opends/server/core/
H A DModifyDNOperationBasis.java98 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 DModifyOperationBasis.java94 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 DModifyDNOperationBasis.java98 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 DModifyOperationBasis.java94 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 DServerState.java153 * @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 DDraftCNDB.java93 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 DChangeNumberIndexer.java478 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 DServerState.java153 * @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 DServerState.java153 * @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 DDraftCNDB.java93 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 DChangeNumberIndexer.java478 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 DModifyDNMsg.java89 * @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 DLDAPUpdateMsg.java100 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 DModifyDNMsg.java89 * @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 DLDAPUpdateMsg.java100 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 DModifyDNMsg.java89 * @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 DLDAPUpdateMsg.java100 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 DPersistentServerState.java127 * @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 DPersistentServerState.java127 * @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 DPersistentServerState.java127 * @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 DChangeNumberIndexer.java461 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 DModifyOperationBasis.java94 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 DChangelogBackend.java137 * 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 DChangelogBackend.java137 * 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 DChangelogBackend.java130 * 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...]

Completed in 58 milliseconds

12345678910