/forgerock/opendj2.6.2/src/server/org/opends/server/replication/plugin/ |
H A D | AttrHistorical.java | 52 * @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 D | DeleteOperationWrapper.java | 94 public final void setChangeNumber(long changeNumber) argument 96 getOperation().setChangeNumber(changeNumber);
|
H A D | DeleteOperation.java | 82 * @param changeNumber The change number that has been assigned to this 85 public abstract void setChangeNumber(long changeNumber); argument
|
H A D | ModifyOperation.java | 131 * @param changeNumber The change number that has been assigned to this 134 public abstract void setChangeNumber(long changeNumber); argument
|
H A D | ModifyOperationWrapper.java | 149 public void setChangeNumber(long changeNumber) argument 151 getOperation().setChangeNumber(changeNumber);
|
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/plugin/ |
H A D | AttrHistorical.java | 52 * @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 D | DeleteOperation.java | 82 * @param changeNumber The change number that has been assigned to this 85 public abstract void setChangeNumber(long changeNumber); argument
|
H A D | ModifyOperation.java | 131 * @param changeNumber The change number that has been assigned to this 134 public abstract void setChangeNumber(long changeNumber); argument
|
H A D | ModifyOperationWrapper.java | 149 public void setChangeNumber(long changeNumber) argument 151 getOperation().setChangeNumber(changeNumber);
|
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/ |
H A D | ReplicationIterator.java | 55 * @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 D | SafeDataExpectedAcksInfo.java | 63 * @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 D | DeleteOperation.java | 82 * @param changeNumber The change number that has been assigned to this 85 public abstract void setChangeNumber(long changeNumber); argument
|
H A D | ModifyOperation.java | 131 * @param changeNumber The change number that has been assigned to this 134 public abstract void setChangeNumber(long changeNumber); argument
|
H A D | ModifyOperationWrapper.java | 149 public void setChangeNumber(long changeNumber) argument 151 getOperation().setChangeNumber(changeNumber);
|
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/ |
H A D | ReplicationIterator.java | 55 * @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 D | SafeDataExpectedAcksInfo.java | 63 * @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 D | ReplicationIterator.java | 55 * @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 D | SafeDataExpectedAcksInfo.java | 63 * @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 D | StartECLSessionMsg.java | 99 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 D | FileChangeNumberIndexDB.java | 134 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 D | StartECLSessionMsg.java | 99 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 D | StartECLSessionMsg.java | 99 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 D | FileChangeNumberIndexDB.java | 134 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 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/opendj2.6.2/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);
|