Searched refs:changeNumber (Results 76 - 100 of 241) sorted by relevance

12345678910

/forgerock/opendj2.6.2/src/server/org/opends/server/replication/plugin/
H A DAttrHistorical.java52 * @param changeNumber The changeNumber associated to the operation.
59 Iterator<Modification> modsIterator, ChangeNumber changeNumber,
71 * @param changeNumber The changeNumber of the operation to process
75 ChangeNumber changeNumber, Modification mod);
58 replayOperation( Iterator<Modification> modsIterator, ChangeNumber changeNumber, Entry modifiedEntry, Modification mod) argument
74 processLocalOrNonConflictModification( ChangeNumber changeNumber, Modification mod) argument
/forgerock/opendj2-jel-hg/src/server/org/opends/server/core/
H A DDeleteOperationWrapper.java94 public final void setChangeNumber(long changeNumber) argument
96 getOperation().setChangeNumber(changeNumber);
H A DDeleteOperation.java82 * @param changeNumber The change number that has been assigned to this
85 public abstract void setChangeNumber(long changeNumber); argument
H A DModifyOperation.java131 * @param changeNumber The change number that has been assigned to this
134 public abstract void setChangeNumber(long changeNumber); argument
H A DModifyOperationWrapper.java149 public void setChangeNumber(long changeNumber) argument
151 getOperation().setChangeNumber(changeNumber);
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/plugin/
H A DAttrHistorical.java52 * @param changeNumber The changeNumber associated to the operation.
59 Iterator<Modification> modsIterator, ChangeNumber changeNumber,
71 * @param changeNumber The changeNumber of the operation to process
75 ChangeNumber changeNumber, Modification mod);
58 replayOperation( Iterator<Modification> modsIterator, ChangeNumber changeNumber, Entry modifiedEntry, Modification mod) argument
74 processLocalOrNonConflictModification( ChangeNumber changeNumber, Modification mod) argument
/forgerock/opendj-b2.6/src/server/org/opends/server/core/
H A DDeleteOperation.java82 * @param changeNumber The change number that has been assigned to this
85 public abstract void setChangeNumber(long changeNumber); argument
H A DModifyOperation.java131 * @param changeNumber The change number that has been assigned to this
134 public abstract void setChangeNumber(long changeNumber); argument
H A DModifyOperationWrapper.java149 public void setChangeNumber(long changeNumber) argument
151 getOperation().setChangeNumber(changeNumber);
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/
H A DReplicationIterator.java55 * @param changeNumber The ChangeNumber after which the iterator must start.
58 * with changeNumber number.
62 int id, ReplicationDB db, ChangeNumber changeNumber, DbHandler dbh)
67 this.lastNonNullCurrentCN = changeNumber;
71 cursor = db.openReadCursor(changeNumber);
85 cursor = db.openReadCursor(changeNumber);
61 ReplicationIterator( int id, ReplicationDB db, ChangeNumber changeNumber, DbHandler dbh) argument
H A DSafeDataExpectedAcksInfo.java63 * @param changeNumber The change number of the assured update message
70 public SafeDataExpectedAcksInfo(ChangeNumber changeNumber, argument
74 super(changeNumber, requesterServerHandler, AssuredMode.SAFE_DATA_MODE,
122 AckMsg ack = new AckMsg(changeNumber);
/forgerock/opendj2.6.2/src/server/org/opends/server/core/
H A DDeleteOperation.java82 * @param changeNumber The change number that has been assigned to this
85 public abstract void setChangeNumber(long changeNumber); argument
H A DModifyOperation.java131 * @param changeNumber The change number that has been assigned to this
134 public abstract void setChangeNumber(long changeNumber); argument
H A DModifyOperationWrapper.java149 public void setChangeNumber(long changeNumber) argument
151 getOperation().setChangeNumber(changeNumber);
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/
H A DReplicationIterator.java55 * @param changeNumber The ChangeNumber after which the iterator must start.
58 * with changeNumber number.
62 int id, ReplicationDB db, ChangeNumber changeNumber, DbHandler dbh)
67 this.lastNonNullCurrentCN = changeNumber;
71 cursor = db.openReadCursor(changeNumber);
85 cursor = db.openReadCursor(changeNumber);
61 ReplicationIterator( int id, ReplicationDB db, ChangeNumber changeNumber, DbHandler dbh) argument
H A DSafeDataExpectedAcksInfo.java63 * @param changeNumber The change number of the assured update message
70 public SafeDataExpectedAcksInfo(ChangeNumber changeNumber, argument
74 super(changeNumber, requesterServerHandler, AssuredMode.SAFE_DATA_MODE,
122 AckMsg ack = new AckMsg(changeNumber);
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/
H A DReplicationIterator.java55 * @param changeNumber The ChangeNumber after which the iterator must start.
58 * with changeNumber number.
62 int id, ReplicationDB db, ChangeNumber changeNumber, DbHandler dbh)
67 this.lastNonNullCurrentCN = changeNumber;
71 cursor = db.openReadCursor(changeNumber);
85 cursor = db.openReadCursor(changeNumber);
61 ReplicationIterator( int id, ReplicationDB db, ChangeNumber changeNumber, DbHandler dbh) argument
H A DSafeDataExpectedAcksInfo.java63 * @param changeNumber The change number of the assured update message
70 public SafeDataExpectedAcksInfo(ChangeNumber changeNumber, argument
74 super(changeNumber, requesterServerHandler, AssuredMode.SAFE_DATA_MODE,
122 AckMsg ack = new AckMsg(changeNumber);
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/protocol/
H A DStartECLSessionMsg.java99 private ChangeNumber changeNumber; field in class:StartECLSessionMsg
156 // replication changeNumber
160 changeNumber = new ChangeNumber(changenumberStr);
205 changeNumber = new ChangeNumber(0,0,0);
232 changeNumber.toString().getBytes("UTF-8");
283 " changeNumber=" + changeNumber +
333 return changeNumber;
338 * @param changeNumber the provided replication change number.
340 public void setChangeNumber(ChangeNumber changeNumber) argument
[all...]
/forgerock/opendj2/src/server/org/opends/server/replication/server/changelog/file/
H A DFileChangeNumberIndexDB.java134 final long changeNumber = nextChangeNumber();
136 new ChangeNumberIndexRecord(changeNumber, record.getBaseDN(), record.getCSN());
138 newestChangeNumber = changeNumber;
144 return changeNumber;
268 final String changeNumber = String.valueOf(readChangeNumber(isFirst));
269 return Attributes.create(attributeName, changeNumber);
345 final long changeNumber = reader.getLong();
350 return Record.from(changeNumber, new ChangeNumberIndexRecord(changeNumber, baseDN, csn));
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/protocol/
H A DStartECLSessionMsg.java99 private ChangeNumber changeNumber; field in class:StartECLSessionMsg
156 // replication changeNumber
160 changeNumber = new ChangeNumber(changenumberStr);
205 changeNumber = new ChangeNumber(0,0,0);
232 changeNumber.toString().getBytes("UTF-8");
283 " changeNumber=" + changeNumber +
333 return changeNumber;
338 * @param changeNumber the provided replication change number.
340 public void setChangeNumber(ChangeNumber changeNumber) argument
[all...]
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/protocol/
H A DStartECLSessionMsg.java99 private ChangeNumber changeNumber; field in class:StartECLSessionMsg
156 // replication changeNumber
160 changeNumber = new ChangeNumber(changenumberStr);
205 changeNumber = new ChangeNumber(0,0,0);
232 changeNumber.toString().getBytes("UTF-8");
283 " changeNumber=" + changeNumber +
333 return changeNumber;
338 * @param changeNumber the provided replication change number.
340 public void setChangeNumber(ChangeNumber changeNumber) argument
[all...]
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/changelog/file/
H A DFileChangeNumberIndexDB.java134 final long changeNumber = nextChangeNumber();
136 new ChangeNumberIndexRecord(changeNumber, record.getBaseDN(), record.getCSN());
138 newestChangeNumber = changeNumber;
144 return changeNumber;
268 final String changeNumber = String.valueOf(readChangeNumber(isFirst));
269 return Attributes.create(attributeName, changeNumber);
345 final long changeNumber = reader.getLong();
350 return Record.from(changeNumber, new ChangeNumberIndexRecord(changeNumber, baseDN, csn));
/forgerock/opendj-b2.6/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/opendj2.6.2/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);

Completed in 85 milliseconds

12345678910