/forgerock/opendj2.6.2/src/server/org/opends/server/replication/plugin/ |
H A D | PendingChange.java | 42 private ChangeNumber changeNumber; field in class:PendingChange 51 * @param changeNumber the ChangeNumber of use 55 public PendingChange(ChangeNumber changeNumber, argument 59 this.changeNumber = changeNumber; 89 return changeNumber; 133 * @param changeNumber The ChangeNumber to add in the list of dependencies 136 public void addDependency(ChangeNumber changeNumber) argument 142 dependencyState.update(changeNumber);
|
H A D | FakeDelOperation.java | 52 * @param changeNumber The ChangeNumber of the operation. 55 public FakeDelOperation(String dn, ChangeNumber changeNumber, argument 58 super(changeNumber);
|
H A D | RemotePendingChanges.java | 115 ChangeNumber changeNumber = update.getChangeNumber(); 116 return pendingChanges.put(changeNumber, 117 new PendingChange(changeNumber, null, update)) == null; 123 * @param changeNumber The ChangeNumber of the update message that must be 126 public synchronized void commit(ChangeNumber changeNumber) argument 128 PendingChange curChange = pendingChanges.get(changeNumber); 211 ChangeNumber changeNumber = OperationContext.getChangeNumber(op); 212 PendingChange change = pendingChanges.get(changeNumber); 218 if (pendingChange.getChangeNumber().older(changeNumber)) 301 ChangeNumber changeNumber [all...] |
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/plugin/ |
H A D | PendingChange.java | 42 private ChangeNumber changeNumber; field in class:PendingChange 51 * @param changeNumber the ChangeNumber of use 55 public PendingChange(ChangeNumber changeNumber, argument 59 this.changeNumber = changeNumber; 89 return changeNumber; 133 * @param changeNumber The ChangeNumber to add in the list of dependencies 136 public void addDependency(ChangeNumber changeNumber) argument 142 dependencyState.update(changeNumber);
|
H A D | FakeDelOperation.java | 52 * @param changeNumber The ChangeNumber of the operation. 55 public FakeDelOperation(String dn, ChangeNumber changeNumber, argument 58 super(changeNumber);
|
H A D | RemotePendingChanges.java | 113 ChangeNumber changeNumber = update.getChangeNumber(); 114 pendingChanges.put(changeNumber, new PendingChange(changeNumber, null, 121 * @param changeNumber The ChangeNumber of the update message that must be 124 public synchronized void commit(ChangeNumber changeNumber) argument 126 PendingChange curChange = pendingChanges.get(changeNumber); 209 ChangeNumber changeNumber = OperationContext.getChangeNumber(op); 210 PendingChange change = pendingChanges.get(changeNumber); 216 if (pendingChange.getChangeNumber().older(changeNumber)) 299 ChangeNumber changeNumber [all...] |
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/ |
H A D | DraftCNData.java | 50 ChangeNumber changeNumber; field in class:DraftCNData 56 * @param changeNumber The replication change number. 59 String serviceID, ChangeNumber changeNumber) 63 + FIELD_SEPARATOR + changeNumber; 92 changeNumber = new ChangeNumber(str[2]); 138 return this.changeNumber; 160 buffer.append("] [changeNumber=").append(changeNumber).append("]"); 58 DraftCNData(String value, String serviceID, ChangeNumber changeNumber) argument
|
H A D | ExpectedAcksInfo.java | 60 protected ChangeNumber changeNumber = null; field in class:ExpectedAcksInfo 95 * @param changeNumber The change number of the assured update message 101 protected ExpectedAcksInfo(ChangeNumber changeNumber, argument 107 this.changeNumber = changeNumber;
|
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/ |
H A D | DraftCNData.java | 50 ChangeNumber changeNumber; field in class:DraftCNData 56 * @param changeNumber The replication change number. 59 String serviceID, ChangeNumber changeNumber) 63 + FIELD_SEPARATOR + changeNumber; 92 changeNumber = new ChangeNumber(str[2]); 138 return this.changeNumber; 160 buffer.append("] [changeNumber=").append(changeNumber).append("]"); 58 DraftCNData(String value, String serviceID, ChangeNumber changeNumber) argument
|
H A D | ExpectedAcksInfo.java | 60 protected ChangeNumber changeNumber = null; field in class:ExpectedAcksInfo 95 * @param changeNumber The change number of the assured update message 101 protected ExpectedAcksInfo(ChangeNumber changeNumber, argument 107 this.changeNumber = changeNumber;
|
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/ |
H A D | DraftCNData.java | 50 ChangeNumber changeNumber; field in class:DraftCNData 56 * @param changeNumber The replication change number. 59 String serviceID, ChangeNumber changeNumber) 63 + FIELD_SEPARATOR + changeNumber; 92 changeNumber = new ChangeNumber(str[2]); 138 return this.changeNumber; 160 buffer.append("] [changeNumber=").append(changeNumber).append("]"); 58 DraftCNData(String value, String serviceID, ChangeNumber changeNumber) argument
|
H A D | ExpectedAcksInfo.java | 60 protected ChangeNumber changeNumber = null; field in class:ExpectedAcksInfo 95 * @param changeNumber The change number of the assured update message 101 protected ExpectedAcksInfo(ChangeNumber changeNumber, argument 107 this.changeNumber = changeNumber;
|
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/plugin/ |
H A D | FakeDelOperation.java | 52 * @param changeNumber The ChangeNumber of the operation. 55 public FakeDelOperation(String dn, ChangeNumber changeNumber, argument 58 super(changeNumber);
|
H A D | RemotePendingChanges.java | 113 ChangeNumber changeNumber = update.getChangeNumber(); 114 pendingChanges.put(changeNumber, new PendingChange(changeNumber, null, 121 * @param changeNumber The ChangeNumber of the update message that must be 124 public synchronized void commit(ChangeNumber changeNumber) argument 126 PendingChange curChange = pendingChanges.get(changeNumber); 209 ChangeNumber changeNumber = OperationContext.getChangeNumber(op); 210 PendingChange change = pendingChanges.get(changeNumber); 216 if (pendingChange.getChangeNumber().older(changeNumber)) 299 ChangeNumber changeNumber [all...] |
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/replication/protocol/ |
H A D | UpdateMsg.java | 51 protected ChangeNumber changeNumber; field in class:UpdateMsg 115 * @param changeNumber The ChangeNumber associated with the change 119 public UpdateMsg(ChangeNumber changeNumber, byte[] payload) argument 123 this.changeNumber = changeNumber; 132 return changeNumber; 164 changeNumber.equals(((UpdateMsg) obj).changeNumber); 173 return changeNumber.hashCode(); 181 return changeNumber [all...] |
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/protocol/ |
H A D | UpdateMsg.java | 51 protected ChangeNumber changeNumber; field in class:UpdateMsg 115 * @param changeNumber The ChangeNumber associated with the change 119 public UpdateMsg(ChangeNumber changeNumber, byte[] payload) argument 123 this.changeNumber = changeNumber; 132 return changeNumber; 164 changeNumber.equals(((UpdateMsg) obj).changeNumber); 173 return changeNumber.hashCode(); 181 return changeNumber [all...] |
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/protocol/ |
H A D | UpdateMsg.java | 51 protected ChangeNumber changeNumber; field in class:UpdateMsg 115 * @param changeNumber The ChangeNumber associated with the change 119 public UpdateMsg(ChangeNumber changeNumber, byte[] payload) argument 123 this.changeNumber = changeNumber; 132 return changeNumber; 164 changeNumber.equals(((UpdateMsg) obj).changeNumber); 173 return changeNumber.hashCode(); 181 return changeNumber [all...] |
/forgerock/opendj-b2.6/tests/staf-tests/shared/java/ldapjdk/ |
H A D | Reader.java | 49 int changeNumber = 0; 82 new String[] {"changeNumber", "changeLogCookie"} , 88 attr = entry.getAttribute("changeNumber"); 91 EclReadAndPlay.println("DEBUG", "Found changeNumber " + changeNumberString 95 if ( ( changeNumber == 0 ) || ( changeNumber > c ) ) { 96 EclReadAndPlay.println("DEBUG", "Setting changeNumber to " + ++c ); 97 changeNumber = c; 101 changeNumber = EclReadAndPlay.INITIAL_CHANGENUMBER; 116 if ( ( changeNumber [all...] |
/forgerock/opendj2/tests/staf-tests/shared/java/ldapjdk/ |
H A D | Reader.java | 48 int changeNumber = 0; 81 new String[] {"changeNumber", "changeLogCookie"} , 87 attr = entry.getAttribute("changeNumber"); 90 EclReadAndPlay.println("DEBUG", "Found changeNumber " + changeNumberString 94 if ( ( changeNumber == 0 ) || ( changeNumber > c ) ) { 95 EclReadAndPlay.println("DEBUG", "Setting changeNumber to " + ++c ); 96 changeNumber = c; 100 changeNumber = EclReadAndPlay.INITIAL_CHANGENUMBER; 115 if ( ( changeNumber [all...] |
/forgerock/opendj2.6.2/tests/staf-tests/shared/java/ldapjdk/ |
H A D | Reader.java | 49 int changeNumber = 0; 82 new String[] {"changeNumber", "changeLogCookie"} , 88 attr = entry.getAttribute("changeNumber"); 91 EclReadAndPlay.println("DEBUG", "Found changeNumber " + changeNumberString 95 if ( ( changeNumber == 0 ) || ( changeNumber > c ) ) { 96 EclReadAndPlay.println("DEBUG", "Setting changeNumber to " + ++c ); 97 changeNumber = c; 101 changeNumber = EclReadAndPlay.INITIAL_CHANGENUMBER; 116 if ( ( changeNumber [all...] |
/forgerock/opendj2-jel-hg/tests/staf-tests/shared/java/ldapjdk/ |
H A D | Reader.java | 49 int changeNumber = 0; 82 new String[] {"changeNumber", "changeLogCookie"} , 88 attr = entry.getAttribute("changeNumber"); 91 EclReadAndPlay.println("DEBUG", "Found changeNumber " + changeNumberString 95 if ( ( changeNumber == 0 ) || ( changeNumber > c ) ) { 96 EclReadAndPlay.println("DEBUG", "Setting changeNumber to " + ++c ); 97 changeNumber = c; 101 changeNumber = EclReadAndPlay.INITIAL_CHANGENUMBER; 116 if ( ( changeNumber [all...] |
/forgerock/opendj2-hg/tests/staf-tests/shared/java/ldapjdk/ |
H A D | Reader.java | 48 int changeNumber = 0; 81 new String[] {"changeNumber", "changeLogCookie"} , 87 attr = entry.getAttribute("changeNumber"); 90 EclReadAndPlay.println("DEBUG", "Found changeNumber " + changeNumberString 94 if ( ( changeNumber == 0 ) || ( changeNumber > c ) ) { 95 EclReadAndPlay.println("DEBUG", "Setting changeNumber to " + ++c ); 96 changeNumber = c; 100 changeNumber = EclReadAndPlay.INITIAL_CHANGENUMBER; 115 if ( ( changeNumber [all...] |
/forgerock/opendj-b2.6/src/server/org/opends/server/core/ |
H A D | DeleteOperationWrapper.java | 94 public final void setChangeNumber(long changeNumber) argument 96 getOperation().setChangeNumber(changeNumber);
|
/forgerock/opendj2.6.2/src/server/org/opends/server/core/ |
H A D | DeleteOperationWrapper.java | 94 public final void setChangeNumber(long changeNumber) argument 96 getOperation().setChangeNumber(changeNumber);
|