Searched refs:pendingChanges (Results 1 - 18 of 18) sorted by relevance

/forgerock/opendj-b2.6/src/server/org/opends/server/replication/plugin/
H A DPendingChanges.java56 private SortedMap<ChangeNumber, PendingChange> pendingChanges = field in class:PendingChanges
94 return pendingChanges.remove(changeNumber).getMsg();
104 return pendingChanges.size();
129 PendingChange curChange = pendingChanges.get(changeNumber);
147 PendingChange curChange = pendingChanges.get(changeNumber);
181 pendingChanges.put(changeNumber, change);
203 if (pendingChanges.isEmpty())
206 ChangeNumber firstChangeNumber = pendingChanges.firstKey();
207 PendingChange firstChange = pendingChanges.get(firstChangeNumber);
225 pendingChanges
[all...]
H A DRemotePendingChanges.java67 private SortedMap<ChangeNumber, PendingChange> pendingChanges = field in class:RemotePendingChanges
101 return pendingChanges.size();
114 pendingChanges.put(changeNumber, new PendingChange(changeNumber, null,
126 PendingChange curChange = pendingChanges.get(changeNumber);
133 ChangeNumber firstChangeNumber = pendingChanges.firstKey();
134 PendingChange firstChange = pendingChanges.get(firstChangeNumber);
139 pendingChanges.remove(firstChangeNumber);
141 if (pendingChanges.isEmpty())
147 firstChangeNumber = pendingChanges.firstKey();
148 firstChange = pendingChanges
[all...]
H A DLDAPReplicationDomain.java194 private final PendingChanges pendingChanges; field in class:LDAPReplicationDomain
579 pendingChanges =
2260 pendingChanges.remove(curChangeNumber);
2297 pendingChanges.commitAndPushCommittedChanges(curChangeNumber, msg);
2347 pendingChanges.remove(curChangeNumber);
2348 pendingChanges.pushCommittedChanges();
2498 if (pendingChanges != null)
2499 return pendingChanges.size();
2801 return pendingChanges.putLocalOperation(operation);
4651 pendingChanges
[all...]
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/plugin/
H A DPendingChanges.java56 private SortedMap<ChangeNumber, PendingChange> pendingChanges = field in class:PendingChanges
94 return pendingChanges.remove(changeNumber).getMsg();
104 return pendingChanges.size();
129 PendingChange curChange = pendingChanges.get(changeNumber);
147 PendingChange curChange = pendingChanges.get(changeNumber);
181 pendingChanges.put(changeNumber, change);
203 if (pendingChanges.isEmpty())
206 ChangeNumber firstChangeNumber = pendingChanges.firstKey();
207 PendingChange firstChange = pendingChanges.get(firstChangeNumber);
225 pendingChanges
[all...]
H A DRemotePendingChanges.java67 private final SortedMap<ChangeNumber, PendingChange> pendingChanges = field in class:RemotePendingChanges
101 return pendingChanges.size();
116 return pendingChanges.put(changeNumber,
128 PendingChange curChange = pendingChanges.get(changeNumber);
135 ChangeNumber firstChangeNumber = pendingChanges.firstKey();
136 PendingChange firstChange = pendingChanges.get(firstChangeNumber);
141 pendingChanges.remove(firstChangeNumber);
143 if (pendingChanges.isEmpty())
149 firstChangeNumber = pendingChanges.firstKey();
150 firstChange = pendingChanges
[all...]
H A DLDAPReplicationDomain.java195 private final PendingChanges pendingChanges; field in class:LDAPReplicationDomain
599 pendingChanges =
2281 pendingChanges.remove(curChangeNumber);
2312 pendingChanges.commitAndPushCommittedChanges(curChangeNumber, msg);
2362 pendingChanges.remove(curChangeNumber);
2363 pendingChanges.pushCommittedChanges();
2513 if (pendingChanges != null)
2514 return pendingChanges.size();
2822 return pendingChanges.putLocalOperation(operation);
4688 pendingChanges
[all...]
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/plugin/
H A DPendingChanges.java56 private SortedMap<ChangeNumber, PendingChange> pendingChanges = field in class:PendingChanges
94 return pendingChanges.remove(changeNumber).getMsg();
104 return pendingChanges.size();
129 PendingChange curChange = pendingChanges.get(changeNumber);
147 PendingChange curChange = pendingChanges.get(changeNumber);
181 pendingChanges.put(changeNumber, change);
203 if (pendingChanges.isEmpty())
206 ChangeNumber firstChangeNumber = pendingChanges.firstKey();
207 PendingChange firstChange = pendingChanges.get(firstChangeNumber);
225 pendingChanges
[all...]
H A DRemotePendingChanges.java67 private SortedMap<ChangeNumber, PendingChange> pendingChanges = field in class:RemotePendingChanges
101 return pendingChanges.size();
114 pendingChanges.put(changeNumber, new PendingChange(changeNumber, null,
126 PendingChange curChange = pendingChanges.get(changeNumber);
133 ChangeNumber firstChangeNumber = pendingChanges.firstKey();
134 PendingChange firstChange = pendingChanges.get(firstChangeNumber);
139 pendingChanges.remove(firstChangeNumber);
141 if (pendingChanges.isEmpty())
147 firstChangeNumber = pendingChanges.firstKey();
148 firstChange = pendingChanges
[all...]
H A DLDAPReplicationDomain.java194 private final PendingChanges pendingChanges; field in class:LDAPReplicationDomain
579 pendingChanges =
2260 pendingChanges.remove(curChangeNumber);
2297 pendingChanges.commitAndPushCommittedChanges(curChangeNumber, msg);
2347 pendingChanges.remove(curChangeNumber);
2348 pendingChanges.pushCommittedChanges();
2498 if (pendingChanges != null)
2499 return pendingChanges.size();
2801 return pendingChanges.putLocalOperation(operation);
4651 pendingChanges
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/plugin/
H A DPendingChanges.java54 private final TreeMap<CSN, PendingChange> pendingChanges = new TreeMap<>(); field in class:PendingChanges
87 pendingChanges.remove(csn);
97 return pendingChanges.size();
108 final PendingChange curChange = pendingChanges.get(csn);
129 pendingChanges.put(csn, new PendingChange(csn, operation, null));
144 pendingChanges.put(offlineCSN, pendingChange);
154 Entry<CSN, PendingChange> firstEntry = pendingChanges.firstEntry();
187 pendingChanges.remove(firstEntry.getKey());
190 firstEntry = pendingChanges.firstEntry();
213 * changes from the pendingChanges becaus
[all...]
H A DRemotePendingChanges.java54 private final SortedMap<CSN, PendingChange> pendingChanges = new TreeMap<>(); field in class:RemotePendingChanges
84 return pendingChanges.size();
99 return pendingChanges.put(csn,
111 PendingChange curChange = pendingChanges.get(csn);
118 CSN firstCSN = pendingChanges.firstKey();
119 PendingChange firstChange = pendingChanges.get(firstCSN);
127 pendingChanges.remove(firstCSN);
129 if (pendingChanges.isEmpty())
135 firstCSN = pendingChanges.firstKey();
136 firstChange = pendingChanges
[all...]
H A DLDAPReplicationDomain.java259 private final PendingChanges pendingChanges; field in class:LDAPReplicationDomain
527 pendingChanges = new PendingChanges(getGenerator(), this);
1980 pendingChanges.putReplicaOfflineMsg();
2028 pendingChanges.remove(curCSN);
2042 pendingChanges.commitAndPushCommittedChanges(curCSN, msg);
2083 pendingChanges.remove(curCSN);
2084 pendingChanges.pushCommittedChanges();
2498 return pendingChanges.putLocalOperation(operation);
3995 pendingChanges.setRecovering(true);
4127 } while (pendingChanges
[all...]
/forgerock/opendj2/src/server/org/opends/server/replication/plugin/
H A DRemotePendingChanges.java56 private final SortedMap<CSN, PendingChange> pendingChanges = field in class:RemotePendingChanges
90 return pendingChanges.size();
105 return pendingChanges.put(csn,
117 PendingChange curChange = pendingChanges.get(csn);
124 CSN firstCSN = pendingChanges.firstKey();
125 PendingChange firstChange = pendingChanges.get(firstCSN);
133 pendingChanges.remove(firstCSN);
135 if (pendingChanges.isEmpty())
141 firstCSN = pendingChanges.firstKey();
142 firstChange = pendingChanges
[all...]
H A DPendingChanges.java56 private final TreeMap<CSN, PendingChange> pendingChanges = field in class:PendingChanges
92 pendingChanges.remove(csn);
102 return pendingChanges.size();
113 final PendingChange curChange = pendingChanges.get(csn);
135 pendingChanges.put(csn, new PendingChange(csn, operation, null));
150 pendingChanges.put(offlineCSN, pendingChange);
160 Entry<CSN, PendingChange> firstEntry = pendingChanges.firstEntry();
193 pendingChanges.remove(firstEntry.getKey());
196 firstEntry = pendingChanges.firstEntry();
219 * changes from the pendingChanges becaus
[all...]
H A DLDAPReplicationDomain.java212 private final PendingChanges pendingChanges; field in class:LDAPReplicationDomain
510 pendingChanges = new PendingChanges(getGenerator(), this);
2007 pendingChanges.putReplicaOfflineMsg();
2056 pendingChanges.remove(curCSN);
2070 pendingChanges.commitAndPushCommittedChanges(curCSN, msg);
2111 pendingChanges.remove(curCSN);
2112 pendingChanges.pushCommittedChanges();
2530 return pendingChanges.putLocalOperation(operation);
4112 pendingChanges.setRecovering(true);
4241 } while (pendingChanges
[all...]
/forgerock/opendj2-hg/src/server/org/opends/server/replication/plugin/
H A DRemotePendingChanges.java56 private final SortedMap<CSN, PendingChange> pendingChanges = field in class:RemotePendingChanges
90 return pendingChanges.size();
105 return pendingChanges.put(csn,
117 PendingChange curChange = pendingChanges.get(csn);
124 CSN firstCSN = pendingChanges.firstKey();
125 PendingChange firstChange = pendingChanges.get(firstCSN);
133 pendingChanges.remove(firstCSN);
135 if (pendingChanges.isEmpty())
141 firstCSN = pendingChanges.firstKey();
142 firstChange = pendingChanges
[all...]
H A DPendingChanges.java56 private final TreeMap<CSN, PendingChange> pendingChanges = field in class:PendingChanges
92 pendingChanges.remove(csn);
102 return pendingChanges.size();
113 final PendingChange curChange = pendingChanges.get(csn);
135 pendingChanges.put(csn, new PendingChange(csn, operation, null));
150 pendingChanges.put(offlineCSN, pendingChange);
160 Entry<CSN, PendingChange> firstEntry = pendingChanges.firstEntry();
193 pendingChanges.remove(firstEntry.getKey());
196 firstEntry = pendingChanges.firstEntry();
219 * changes from the pendingChanges becaus
[all...]
H A DLDAPReplicationDomain.java212 private final PendingChanges pendingChanges; field in class:LDAPReplicationDomain
510 pendingChanges = new PendingChanges(getGenerator(), this);
2007 pendingChanges.putReplicaOfflineMsg();
2056 pendingChanges.remove(curCSN);
2070 pendingChanges.commitAndPushCommittedChanges(curCSN, msg);
2111 pendingChanges.remove(curCSN);
2112 pendingChanges.pushCommittedChanges();
2530 return pendingChanges.putLocalOperation(operation);
4112 pendingChanges.setRecovering(true);
4241 } while (pendingChanges
[all...]

Completed in 6481 milliseconds