Searched refs:changeNumber (Results 51 - 75 of 241) sorted by relevance

12345678910

/forgerock/opendj2.6.2/src/server/org/opends/server/replication/plugin/
H A DPendingChange.java42 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 DFakeDelOperation.java52 * @param changeNumber The ChangeNumber of the operation.
55 public FakeDelOperation(String dn, ChangeNumber changeNumber, argument
58 super(changeNumber);
H A DRemotePendingChanges.java115 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 DPendingChange.java42 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 DFakeDelOperation.java52 * @param changeNumber The ChangeNumber of the operation.
55 public FakeDelOperation(String dn, ChangeNumber changeNumber, argument
58 super(changeNumber);
H A DRemotePendingChanges.java113 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 DDraftCNData.java50 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 DExpectedAcksInfo.java60 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 DDraftCNData.java50 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 DExpectedAcksInfo.java60 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 DDraftCNData.java50 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 DExpectedAcksInfo.java60 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 DFakeDelOperation.java52 * @param changeNumber The ChangeNumber of the operation.
55 public FakeDelOperation(String dn, ChangeNumber changeNumber, argument
58 super(changeNumber);
H A DRemotePendingChanges.java113 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 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/replication/protocol/
H A DUpdateMsg.java51 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 DUpdateMsg.java51 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 DUpdateMsg.java51 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 DReader.java49 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 DReader.java48 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 DReader.java49 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 DReader.java49 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 DReader.java48 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 DDeleteOperationWrapper.java94 public final void setChangeNumber(long changeNumber) argument
96 getOperation().setChangeNumber(changeNumber);
/forgerock/opendj2.6.2/src/server/org/opends/server/core/
H A DDeleteOperationWrapper.java94 public final void setChangeNumber(long changeNumber) argument
96 getOperation().setChangeNumber(changeNumber);

Completed in 103 milliseconds

12345678910