/forgerock/opendj2/src/server/org/opends/server/replication/plugin/ |
H A D | FakeOperationComparator.java | 45 return op1.getCSN().compareTo(op2.getCSN());
|
H A D | FakeOperation.java | 58 public CSN getCSN() method in class:FakeOperation
|
H A D | RemotePendingChanges.java | 104 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 D | FakeAddOperation.java | 63 return new AddMsg(getCSN(), entry.getDN(),
|
H A D | FakeDelOperation.java | 67 return new DeleteMsg(dn, getCSN(), entryUUID);
|
/forgerock/opendj2-hg/src/server/org/opends/server/replication/plugin/ |
H A D | FakeOperationComparator.java | 45 return op1.getCSN().compareTo(op2.getCSN());
|
H A D | FakeOperation.java | 58 public CSN getCSN() method in class:FakeOperation
|
H A D | RemotePendingChanges.java | 104 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 D | FakeAddOperation.java | 63 return new AddMsg(getCSN(), entry.getDN(),
|
H A D | FakeDelOperation.java | 67 return new DeleteMsg(dn, getCSN(), entryUUID);
|
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/plugin/ |
H A D | FakeOperationComparator.java | 45 return op1.getCSN().compareTo(op2.getCSN());
|
H A D | FakeOperation.java | 58 public CSN getCSN() method in class:FakeOperation
|
H A D | RemotePendingChanges.java | 98 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 D | FakeAddOperation.java | 61 return new AddMsg(getCSN(), entry.getName(),
|
/forgerock/opendj2/src/server/org/opends/server/replication/protocol/ |
H A D | OperationContext.java | 70 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 D | OperationContext.java | 70 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 D | OperationContext.java | 66 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 D | MsgQueue.java | 119 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 D | NotAssuredUpdateMsg.java | 203 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 D | MsgQueue.java | 119 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 D | NotAssuredUpdateMsg.java | 203 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 D | MsgQueue.java | 120 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 D | MultiDomainServerStateTest.java | 113 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 D | MultiDomainServerStateTest.java | 113 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 D | MultiDomainServerStateTest.java | 136 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...] |