| /forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/ |
| H A D | ReplicationKey.java | 46 * @param changeNumber The changeNumber to use.
48 public ReplicationKey(ChangeNumber changeNumber) argument
52 this.setData(changeNumber.toString().getBytes("UTF-8"));
|
| /forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/protocol/ |
| H A D | AddContext.java | 46 * @param changeNumber The change number of the add operation.
50 public AddContext(ChangeNumber changeNumber, String entryUUID, argument
53 super(changeNumber, entryUUID);
|
| H A D | ModifyDnContext.java | 43 * @param changeNumber The change number of the operation.
49 public ModifyDnContext(ChangeNumber changeNumber, String entryUUID, argument
52 super(changeNumber, entryUUID);
|
| H A D | ChangeTimeHeartbeatMsg.java | 50 private final ChangeNumber changeNumber; field in class:ChangeTimeHeartbeatMsg
63 this.changeNumber = cn;
75 return changeNumber;
104 changeNumber = ChangeNumber.valueOf(reader
109 changeNumber = ChangeNumber.valueOf(reader
140 changeNumber.toByteString(builder);
148 builder.append(changeNumber.toString());
|
| H A D | AckMsg.java | 65 private ChangeNumber changeNumber; field in class:AckMsg
87 * @param changeNumber The ChangeNumber used to build the AckMsg.
89 public AckMsg(ChangeNumber changeNumber) argument
91 this.changeNumber = changeNumber;
97 * @param changeNumber The ChangeNumber used to build the AckMsg.
103 public AckMsg(ChangeNumber changeNumber, boolean hasTimeout, argument
106 this.changeNumber = changeNumber;
173 /* Read the changeNumber */
[all...] |
| /forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/ |
| H A D | ReplicationKey.java | 46 * @param changeNumber The changeNumber to use.
48 public ReplicationKey(ChangeNumber changeNumber) argument
52 this.setData(changeNumber.toString().getBytes("UTF-8"));
|
| /forgerock/opendj2/src/server/org/opends/server/controls/ |
| H A D | EntryChangeNotificationControl.java | 76 long changeNumber = -1;
102 changeNumber = reader.readInteger();
123 previousDN, changeNumber);
151 private long changeNumber; field in class:EntryChangeNotificationControl
165 * @param changeNumber The change number for the associated change, or a
170 long changeNumber)
176 this.changeNumber = changeNumber;
194 * @param changeNumber The change number for the associated change, or a
199 DN previousDN, long changeNumber)
168 EntryChangeNotificationControl(boolean isCritical, PersistentSearchChangeType changeType, long changeNumber) argument
197 EntryChangeNotificationControl(boolean isCritical, PersistentSearchChangeType changeType, DN previousDN, long changeNumber) argument
218 EntryChangeNotificationControl(PersistentSearchChangeType changeType, long changeNumber) argument
237 EntryChangeNotificationControl(PersistentSearchChangeType changeType, DN previousDN, long changeNumber) argument
[all...] |
| /forgerock/opendj-b2.6/src/server/org/opends/server/controls/ |
| H A D | EntryChangeNotificationControl.java | 76 long changeNumber = -1;
102 changeNumber = reader.readInteger();
123 previousDN, changeNumber);
151 private long changeNumber; field in class:EntryChangeNotificationControl
165 * @param changeNumber The change number for the associated change, or a
170 long changeNumber)
176 this.changeNumber = changeNumber;
194 * @param changeNumber The change number for the associated change, or a
199 DN previousDN, long changeNumber)
168 EntryChangeNotificationControl(boolean isCritical, PersistentSearchChangeType changeType, long changeNumber) argument
197 EntryChangeNotificationControl(boolean isCritical, PersistentSearchChangeType changeType, DN previousDN, long changeNumber) argument
218 EntryChangeNotificationControl(PersistentSearchChangeType changeType, long changeNumber) argument
237 EntryChangeNotificationControl(PersistentSearchChangeType changeType, DN previousDN, long changeNumber) argument
[all...] |
| /forgerock/opendj2.6.2/src/server/org/opends/server/controls/ |
| H A D | EntryChangeNotificationControl.java | 76 long changeNumber = -1;
102 changeNumber = reader.readInteger();
123 previousDN, changeNumber);
151 private long changeNumber; field in class:EntryChangeNotificationControl
165 * @param changeNumber The change number for the associated change, or a
170 long changeNumber)
176 this.changeNumber = changeNumber;
194 * @param changeNumber The change number for the associated change, or a
199 DN previousDN, long changeNumber)
168 EntryChangeNotificationControl(boolean isCritical, PersistentSearchChangeType changeType, long changeNumber) argument
197 EntryChangeNotificationControl(boolean isCritical, PersistentSearchChangeType changeType, DN previousDN, long changeNumber) argument
218 EntryChangeNotificationControl(PersistentSearchChangeType changeType, long changeNumber) argument
237 EntryChangeNotificationControl(PersistentSearchChangeType changeType, DN previousDN, long changeNumber) argument
[all...] |
| /forgerock/opendj2-jel-hg/src/server/org/opends/server/controls/ |
| H A D | EntryChangeNotificationControl.java | 76 long changeNumber = -1;
102 changeNumber = reader.readInteger();
123 previousDN, changeNumber);
151 private long changeNumber; field in class:EntryChangeNotificationControl
165 * @param changeNumber The change number for the associated change, or a
170 long changeNumber)
176 this.changeNumber = changeNumber;
194 * @param changeNumber The change number for the associated change, or a
199 DN previousDN, long changeNumber)
168 EntryChangeNotificationControl(boolean isCritical, PersistentSearchChangeType changeType, long changeNumber) argument
197 EntryChangeNotificationControl(boolean isCritical, PersistentSearchChangeType changeType, DN previousDN, long changeNumber) argument
218 EntryChangeNotificationControl(PersistentSearchChangeType changeType, long changeNumber) argument
237 EntryChangeNotificationControl(PersistentSearchChangeType changeType, DN previousDN, long changeNumber) argument
[all...] |
| /forgerock/opendj2-hg/src/server/org/opends/server/controls/ |
| H A D | EntryChangeNotificationControl.java | 76 long changeNumber = -1;
102 changeNumber = reader.readInteger();
123 previousDN, changeNumber);
151 private long changeNumber; field in class:EntryChangeNotificationControl
165 * @param changeNumber The change number for the associated change, or a
170 long changeNumber)
176 this.changeNumber = changeNumber;
194 * @param changeNumber The change number for the associated change, or a
199 DN previousDN, long changeNumber)
168 EntryChangeNotificationControl(boolean isCritical, PersistentSearchChangeType changeType, long changeNumber) argument
197 EntryChangeNotificationControl(boolean isCritical, PersistentSearchChangeType changeType, DN previousDN, long changeNumber) argument
218 EntryChangeNotificationControl(PersistentSearchChangeType changeType, long changeNumber) argument
237 EntryChangeNotificationControl(PersistentSearchChangeType changeType, DN previousDN, long changeNumber) argument
[all...] |
| /forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/controls/ |
| H A D | EntryChangeNotificationControl.java | 70 long changeNumber = -1;
94 changeNumber = reader.readInteger();
112 previousDN, changeNumber);
136 private long changeNumber; field in class:EntryChangeNotificationControl
150 * @param changeNumber The change number for the associated change, or a
155 long changeNumber)
161 this.changeNumber = changeNumber;
179 * @param changeNumber The change number for the associated change, or a
184 DN previousDN, long changeNumber)
153 EntryChangeNotificationControl(boolean isCritical, PersistentSearchChangeType changeType, long changeNumber) argument
182 EntryChangeNotificationControl(boolean isCritical, PersistentSearchChangeType changeType, DN previousDN, long changeNumber) argument
203 EntryChangeNotificationControl(PersistentSearchChangeType changeType, long changeNumber) argument
222 EntryChangeNotificationControl(PersistentSearchChangeType changeType, DN previousDN, long changeNumber) argument
[all...] |
| /forgerock/opendj-b2.6/src/server/org/opends/server/replication/protocol/ |
| H A D | ChangeTimeHeartbeatMsg.java | 50 private final ChangeNumber changeNumber; field in class:ChangeTimeHeartbeatMsg
63 this.changeNumber = cn;
75 return changeNumber;
104 changeNumber = ChangeNumber.valueOf(reader
109 changeNumber = ChangeNumber.valueOf(reader
140 changeNumber.toByteString(builder);
148 builder.append(changeNumber.toString());
|
| H A D | AckMsg.java | 65 private ChangeNumber changeNumber; field in class:AckMsg
87 * @param changeNumber The ChangeNumber used to build the AckMsg.
89 public AckMsg(ChangeNumber changeNumber) argument
91 this.changeNumber = changeNumber;
97 * @param changeNumber The ChangeNumber used to build the AckMsg.
103 public AckMsg(ChangeNumber changeNumber, boolean hasTimeout, argument
106 this.changeNumber = changeNumber;
173 /* Read the changeNumber */
[all...] |
| /forgerock/opendj2.6.2/src/server/org/opends/server/replication/protocol/ |
| H A D | ChangeTimeHeartbeatMsg.java | 50 private final ChangeNumber changeNumber; field in class:ChangeTimeHeartbeatMsg
63 this.changeNumber = cn;
75 return changeNumber;
104 changeNumber = ChangeNumber.valueOf(reader
109 changeNumber = ChangeNumber.valueOf(reader
140 changeNumber.toByteString(builder);
148 builder.append(changeNumber.toString());
|
| H A D | AckMsg.java | 65 private ChangeNumber changeNumber; field in class:AckMsg
87 * @param changeNumber The ChangeNumber used to build the AckMsg.
89 public AckMsg(ChangeNumber changeNumber) argument
91 this.changeNumber = changeNumber;
97 * @param changeNumber The ChangeNumber used to build the AckMsg.
103 public AckMsg(ChangeNumber changeNumber, boolean hasTimeout, argument
106 this.changeNumber = changeNumber;
173 /* Read the changeNumber */
[all...] |
| /forgerock/opendj-b2.6/src/server/org/opends/server/replication/plugin/ |
| H A D | AttrHistoricalMultiple.java | 250 Iterator<Modification> modsIterator, ChangeNumber changeNumber,
257 if ((ChangeNumber.compare(changeNumber, getLastUpdateTime()) < 0) ||
265 if (changeNumber.older(getDeleteTime()))
274 if (!conflictDelete(changeNumber, m, modifiedEntry))
281 conflictAdd(changeNumber, m, modsIterator);
285 if (changeNumber.older(getDeleteTime()))
305 conflictDelete(changeNumber, m, modifiedEntry);
309 conflictAdd(changeNumber, m, modsIterator);
324 processLocalOrNonConflictModification(changeNumber, m);
338 * @param changeNumber Th
249 replayOperation( Iterator<Modification> modsIterator, ChangeNumber changeNumber, Entry modifiedEntry, Modification m) argument
342 processLocalOrNonConflictModification(ChangeNumber changeNumber, Modification mod) argument
400 conflictDelete(ChangeNumber changeNumber, Modification m, Entry modifiedEntry) argument
546 conflictAdd(ChangeNumber changeNumber, Modification m, Iterator<Modification> modsIterator) argument
[all...] |
| H A D | AttrHistoricalSingle.java | 95 public void processLocalOrNonConflictModification(ChangeNumber changeNumber, argument
109 this.deleteTime = changeNumber;
115 this.addTime = changeNumber;
125 this.deleteTime = changeNumber;
131 this.deleteTime = addTime = changeNumber;
148 ChangeNumber changeNumber, Entry modifiedEntry, Modification mod)
162 if (changeNumber.newer(addTime))
166 if (changeNumber.newer(deleteTime))
168 deleteTime = changeNumber;
195 else if (changeNumber
147 replayOperation(Iterator<Modification> modsIterator, ChangeNumber changeNumber, Entry modifiedEntry, Modification mod) argument
[all...] |
| 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);
|
| /forgerock/opendj2.6.2/src/server/org/opends/server/replication/plugin/ |
| H A D | AttrHistoricalMultiple.java | 250 Iterator<Modification> modsIterator, ChangeNumber changeNumber,
257 if ((ChangeNumber.compare(changeNumber, getLastUpdateTime()) < 0) ||
265 if (changeNumber.older(getDeleteTime()))
274 if (!conflictDelete(changeNumber, m, modifiedEntry))
281 conflictAdd(changeNumber, m, modsIterator);
285 if (changeNumber.older(getDeleteTime()))
305 conflictDelete(changeNumber, m, modifiedEntry);
309 conflictAdd(changeNumber, m, modsIterator);
324 processLocalOrNonConflictModification(changeNumber, m);
338 * @param changeNumber Th
249 replayOperation( Iterator<Modification> modsIterator, ChangeNumber changeNumber, Entry modifiedEntry, Modification m) argument
342 processLocalOrNonConflictModification(ChangeNumber changeNumber, Modification mod) argument
400 conflictDelete(ChangeNumber changeNumber, Modification m, Entry modifiedEntry) argument
546 conflictAdd(ChangeNumber changeNumber, Modification m, Iterator<Modification> modsIterator) argument
[all...] |
| H A D | AttrHistoricalSingle.java | 95 public void processLocalOrNonConflictModification(ChangeNumber changeNumber, argument
109 this.deleteTime = changeNumber;
115 this.addTime = changeNumber;
125 this.deleteTime = changeNumber;
131 this.deleteTime = addTime = changeNumber;
148 ChangeNumber changeNumber, Entry modifiedEntry, Modification mod)
162 if (changeNumber.newer(addTime))
166 if (changeNumber.newer(deleteTime))
168 deleteTime = changeNumber;
195 else if (changeNumber
147 replayOperation(Iterator<Modification> modsIterator, ChangeNumber changeNumber, Entry modifiedEntry, Modification mod) argument
[all...] |
| /forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/plugin/ |
| H A D | AttrHistoricalMultiple.java | 250 Iterator<Modification> modsIterator, ChangeNumber changeNumber,
257 if ((ChangeNumber.compare(changeNumber, getLastUpdateTime()) < 0) ||
265 if (changeNumber.older(getDeleteTime()))
274 if (!conflictDelete(changeNumber, m, modifiedEntry))
281 conflictAdd(changeNumber, m, modsIterator);
285 if (changeNumber.older(getDeleteTime()))
305 conflictDelete(changeNumber, m, modifiedEntry);
309 conflictAdd(changeNumber, m, modsIterator);
324 processLocalOrNonConflictModification(changeNumber, m);
338 * @param changeNumber Th
249 replayOperation( Iterator<Modification> modsIterator, ChangeNumber changeNumber, Entry modifiedEntry, Modification m) argument
342 processLocalOrNonConflictModification(ChangeNumber changeNumber, Modification mod) argument
400 conflictDelete(ChangeNumber changeNumber, Modification m, Entry modifiedEntry) argument
546 conflictAdd(ChangeNumber changeNumber, Modification m, Iterator<Modification> modsIterator) argument
[all...] |
| H A D | AttrHistoricalSingle.java | 95 public void processLocalOrNonConflictModification(ChangeNumber changeNumber, argument
109 this.deleteTime = changeNumber;
115 this.addTime = changeNumber;
125 this.deleteTime = changeNumber;
131 this.deleteTime = addTime = changeNumber;
148 ChangeNumber changeNumber, Entry modifiedEntry, Modification mod)
162 if (changeNumber.newer(addTime))
166 if (changeNumber.newer(deleteTime))
168 deleteTime = changeNumber;
195 else if (changeNumber
147 replayOperation(Iterator<Modification> modsIterator, ChangeNumber changeNumber, Entry modifiedEntry, Modification mod) argument
[all...] |
| /forgerock/opendj2/src/server/org/opends/server/replication/server/changelog/je/ |
| H A D | ReplicationDraftCNKey.java | 53 * @param changeNumber
56 public ReplicationDraftCNKey(long changeNumber) argument
61 setData(String.format("%016d", changeNumber).getBytes("UTF-8"));
|
| /forgerock/opendj2-hg/src/server/org/opends/server/replication/server/changelog/je/ |
| H A D | ReplicationDraftCNKey.java | 53 * @param changeNumber
56 public ReplicationDraftCNKey(long changeNumber) argument
61 setData(String.format("%016d", changeNumber).getBytes("UTF-8"));
|