Searched refs:getCSN (Results 1 - 25 of 204) sorted by relevance

123456789

/forgerock/opendj2/src/server/org/opends/server/replication/plugin/
H A DFakeOperationComparator.java45 return op1.getCSN().compareTo(op2.getCSN());
H A DFakeOperation.java58 public CSN getCSN() method in class:FakeOperation
H A DRemotePendingChanges.java104 CSN csn = update.getCSN();
179 dependentChange.addDependency(pendingChange.getCSN());
203 final CSN csn = OperationContext.getCSN(op);
212 if (pendingChange.getCSN().isOlderThan(csn))
295 final CSN csn = OperationContext.getCSN(op);
304 if (pendingChange.getCSN().isOlderThan(csn))
349 final CSN csn = msg.getCSN();
360 if (pendingChange.getCSN().isOlderThan(csn))
437 final CSN csn = OperationContext.getCSN(op);
446 if (pendingChange.getCSN()
[all...]
H A DFakeAddOperation.java63 return new AddMsg(getCSN(), entry.getDN(),
H A DFakeDelOperation.java67 return new DeleteMsg(dn, getCSN(), entryUUID);
/forgerock/opendj2-hg/src/server/org/opends/server/replication/plugin/
H A DFakeOperationComparator.java45 return op1.getCSN().compareTo(op2.getCSN());
H A DFakeOperation.java58 public CSN getCSN() method in class:FakeOperation
H A DRemotePendingChanges.java104 CSN csn = update.getCSN();
179 dependentChange.addDependency(pendingChange.getCSN());
203 final CSN csn = OperationContext.getCSN(op);
212 if (pendingChange.getCSN().isOlderThan(csn))
295 final CSN csn = OperationContext.getCSN(op);
304 if (pendingChange.getCSN().isOlderThan(csn))
349 final CSN csn = msg.getCSN();
360 if (pendingChange.getCSN().isOlderThan(csn))
437 final CSN csn = OperationContext.getCSN(op);
446 if (pendingChange.getCSN()
[all...]
H A DFakeAddOperation.java63 return new AddMsg(getCSN(), entry.getDN(),
H A DFakeDelOperation.java67 return new DeleteMsg(dn, getCSN(), entryUUID);
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/plugin/
H A DFakeOperationComparator.java45 return op1.getCSN().compareTo(op2.getCSN());
H A DFakeOperation.java58 public CSN getCSN() method in class:FakeOperation
H A DRemotePendingChanges.java98 CSN csn = update.getCSN();
173 dependentChange.addDependency(pendingChange.getCSN());
197 final CSN csn = OperationContext.getCSN(op);
206 if (pendingChange.getCSN().isOlderThan(csn))
289 final CSN csn = OperationContext.getCSN(op);
298 if (pendingChange.getCSN().isOlderThan(csn))
343 final CSN csn = msg.getCSN();
354 if (pendingChange.getCSN().isOlderThan(csn))
431 final CSN csn = OperationContext.getCSN(op);
440 if (pendingChange.getCSN()
[all...]
H A DFakeAddOperation.java61 return new AddMsg(getCSN(), entry.getName(),
/forgerock/opendj2/src/server/org/opends/server/replication/protocol/
H A DOperationContext.java70 public CSN getCSN() method in class:OperationContext
93 public static CSN getCSN(Operation op) method in class:OperationContext
112 public static CSN getCSN(PluginOperation op) method in class:OperationContext
131 return this.csn.equals(ctx.getCSN())
/forgerock/opendj2-hg/src/server/org/opends/server/replication/protocol/
H A DOperationContext.java70 public CSN getCSN() method in class:OperationContext
93 public static CSN getCSN(Operation op) method in class:OperationContext
112 public static CSN getCSN(PluginOperation op) method in class:OperationContext
131 return this.csn.equals(ctx.getCSN())
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/protocol/
H A DOperationContext.java66 public CSN getCSN() method in class:OperationContext
89 public static CSN getCSN(Operation op) method in class:OperationContext
108 public static CSN getCSN(PluginOperation op) method in class:OperationContext
125 return this.csn.equals(ctx.getCSN())
/forgerock/opendj2/src/server/org/opends/server/replication/server/
H A DMsgQueue.java119 final UpdateMsg msgSameCSN = map.put(update.getCSN(), update);
132 msgSameCSN.getCSN().toString(),
159 map.remove(update.getCSN());
185 return map.containsKey(msg.getCSN());
213 // if (!map.containsKey(finalMsg.getCSN())) {
216 // map.headMap(finalMsg.getCSN(), true).clear();
219 final CSN finalCSN = finalMsg.getCSN();
225 while (!finalCSN.equals(msg.getCSN()));
H A DNotAssuredUpdateMsg.java203 public CSN getCSN() method in class:NotAssuredUpdateMsg
205 return realUpdateMsg.getCSN();
234 && realUpdateMsg.getCSN().equals(((UpdateMsg) obj).getCSN());
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/
H A DMsgQueue.java119 final UpdateMsg msgSameCSN = map.put(update.getCSN(), update);
132 msgSameCSN.getCSN().toString(),
159 map.remove(update.getCSN());
185 return map.containsKey(msg.getCSN());
213 // if (!map.containsKey(finalMsg.getCSN())) {
216 // map.headMap(finalMsg.getCSN(), true).clear();
219 final CSN finalCSN = finalMsg.getCSN();
225 while (!finalCSN.equals(msg.getCSN()));
H A DNotAssuredUpdateMsg.java203 public CSN getCSN() method in class:NotAssuredUpdateMsg
205 return realUpdateMsg.getCSN();
234 && realUpdateMsg.getCSN().equals(((UpdateMsg) obj).getCSN());
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/
H A DMsgQueue.java120 final UpdateMsg msgSameCSN = map.put(update.getCSN(), update);
131 logger.error(ERR_RSQUEUE_DIFFERENT_MSGS_WITH_SAME_CSN, msgSameCSN.getCSN(), msgSameCSN, update);
159 map.remove(update.getCSN());
184 return map.containsKey(msg.getCSN());
210 // if (!map.containsKey(finalMsg.getCSN())) {
213 // map.headMap(finalMsg.getCSN(), true).clear();
216 final CSN finalCSN = finalMsg.getCSN();
222 while (!finalCSN.equals(msg.getCSN()));
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/common/
H A DMultiDomainServerStateTest.java113 assertSame(csn3, state2.getCSN(dn1, csn3.getServerId()));
114 assertSame(csn2, state2.getCSN(dn2, csn2.getServerId()));
159 assertNull(state.getCSN(dn3, 42));
162 assertSame(csn1, state.getCSN(dn1, csn1.getServerId()));
163 assertSame(csn1, state.getCSN(dn2, csn1.getServerId()));
164 assertSame(csn2, state.getCSN(dn2, csn2.getServerId()));
167 assertSame(csn1, state.getCSN(dn1, csn1.getServerId()));
168 assertSame(csn1, state.getCSN(dn2, csn1.getServerId()));
169 assertSame(csn2, state.getCSN(dn2, csn2.getServerId()));
172 assertSame(csn1, state.getCSN(dn
[all...]
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/common/
H A DMultiDomainServerStateTest.java113 assertSame(csn3, state2.getCSN(dn1, csn3.getServerId()));
114 assertSame(csn2, state2.getCSN(dn2, csn2.getServerId()));
159 assertNull(state.getCSN(dn3, 42));
162 assertSame(csn1, state.getCSN(dn1, csn1.getServerId()));
163 assertSame(csn1, state.getCSN(dn2, csn1.getServerId()));
164 assertSame(csn2, state.getCSN(dn2, csn2.getServerId()));
167 assertSame(csn1, state.getCSN(dn1, csn1.getServerId()));
168 assertSame(csn1, state.getCSN(dn2, csn1.getServerId()));
169 assertSame(csn2, state.getCSN(dn2, csn2.getServerId()));
172 assertSame(csn1, state.getCSN(dn
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/common/
H A DMultiDomainServerStateTest.java136 assertSame(csn3, state2.getCSN(dn1, csn3.getServerId()));
137 assertSame(csn2, state2.getCSN(dn2, csn2.getServerId()));
182 assertNull(state.getCSN(dn3, 42));
185 assertSame(csn1, state.getCSN(dn1, csn1.getServerId()));
186 assertSame(csn1, state.getCSN(dn2, csn1.getServerId()));
187 assertSame(csn2, state.getCSN(dn2, csn2.getServerId()));
190 assertSame(csn1, state.getCSN(dn1, csn1.getServerId()));
191 assertSame(csn1, state.getCSN(dn2, csn1.getServerId()));
192 assertSame(csn2, state.getCSN(dn2, csn2.getServerId()));
195 assertSame(csn1, state.getCSN(dn
[all...]

Completed in 133 milliseconds

123456789