/forgerock/opendj2/src/server/org/opends/server/replication/server/changelog/je/ |
H A D | DomainDBCursor.java | 97 * @param startCSN 100 public void addReplicaDB(int serverId, CSN startCSN) argument 103 newReplicas.putIfAbsent(serverId, startCSN != null ? startCSN : NULL_CSN); 115 final CSN startCSN = !NULL_CSN.equals(csn) ? csn : null; 117 domainDB.getCursorFrom(baseDN, serverId, startCSN, matchingStrategy, positionStrategy);
|
H A D | JEReplicaDBCursor.java | 49 private final CSN startCSN; field in class:JEReplicaDBCursor 65 * @param startCSN 77 public JEReplicaDBCursor(ReplicationDB db, CSN startCSN, KeyMatchingStrategy matchingStrategy, argument 84 this.startCSN = startCSN; 85 this.lastNonNullCurrentCSN = startCSN; 119 if (lastNonNullCurrentCSN != startCSN)
|
H A D | ReplicationDB.java | 292 * @param startCSN 303 ReplServerDBCursor openReadCursor(CSN startCSN, KeyMatchingStrategy matchingStrategy, argument 306 return new ReplServerDBCursor(startCSN, matchingStrategy, positionStrategy); 507 * @param startCSN 515 * When the startCSN does not exist. 517 private ReplServerDBCursor(CSN startCSN, KeyMatchingStrategy matchingStrategy, PositionStrategy positionStrategy) argument 520 key = createReplicationKey(startCSN); 540 maybeEmptyCursor = generateCursor(startCSN, matchingStrategy, positionStrategy); 568 private CursorWithEmptyIndicator generateCursor(CSN startCSN, KeyMatchingStrategy matchingStrategy, argument 572 boolean isCsnFound = startCSN [all...] |
H A D | JEReplicaDB.java | 184 * @param startCSN 196 DBCursor<UpdateMsg> generateCursorFrom(final CSN startCSN, final KeyMatchingStrategy matchingStrategy, argument 199 return new JEReplicaDBCursor(db, startCSN, matchingStrategy, positionStrategy, this);
|
H A D | JEChangelogDB.java | 777 public DBCursor<UpdateMsg> getCursorFrom(final DN baseDN, final int serverId, final CSN startCSN, argument 783 final DBCursor<UpdateMsg> cursor = replicaDB.generateCursorFrom(startCSN, matchingStrategy, positionStrategy); 784 final CSN offlineCSN = getOfflineCSN(baseDN, serverId, startCSN);
|
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/changelog/je/ |
H A D | DomainDBCursor.java | 97 * @param startCSN 100 public void addReplicaDB(int serverId, CSN startCSN) argument 103 newReplicas.putIfAbsent(serverId, startCSN != null ? startCSN : NULL_CSN); 115 final CSN startCSN = !NULL_CSN.equals(csn) ? csn : null; 117 domainDB.getCursorFrom(baseDN, serverId, startCSN, matchingStrategy, positionStrategy);
|
H A D | JEReplicaDBCursor.java | 49 private final CSN startCSN; field in class:JEReplicaDBCursor 65 * @param startCSN 77 public JEReplicaDBCursor(ReplicationDB db, CSN startCSN, KeyMatchingStrategy matchingStrategy, argument 84 this.startCSN = startCSN; 85 this.lastNonNullCurrentCSN = startCSN; 119 if (lastNonNullCurrentCSN != startCSN)
|
H A D | ReplicationDB.java | 292 * @param startCSN 303 ReplServerDBCursor openReadCursor(CSN startCSN, KeyMatchingStrategy matchingStrategy, argument 306 return new ReplServerDBCursor(startCSN, matchingStrategy, positionStrategy); 507 * @param startCSN 515 * When the startCSN does not exist. 517 private ReplServerDBCursor(CSN startCSN, KeyMatchingStrategy matchingStrategy, PositionStrategy positionStrategy) argument 520 key = createReplicationKey(startCSN); 540 maybeEmptyCursor = generateCursor(startCSN, matchingStrategy, positionStrategy); 568 private CursorWithEmptyIndicator generateCursor(CSN startCSN, KeyMatchingStrategy matchingStrategy, argument 572 boolean isCsnFound = startCSN [all...] |
H A D | JEReplicaDB.java | 184 * @param startCSN 196 DBCursor<UpdateMsg> generateCursorFrom(final CSN startCSN, final KeyMatchingStrategy matchingStrategy, argument 199 return new JEReplicaDBCursor(db, startCSN, matchingStrategy, positionStrategy, this);
|
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/changelog/file/ |
H A D | DomainDBCursor.java | 85 * @param startCSN 88 public void addReplicaDB(int serverId, CSN startCSN) argument 91 newReplicas.putIfAbsent(serverId, startCSN != null ? startCSN : NULL_CSN); 103 final CSN startCSN = !NULL_CSN.equals(csn) ? csn : null; 104 final DBCursor<UpdateMsg> cursor = domainDB.getCursorFrom(baseDN, serverId, startCSN, options);
|
H A D | FileReplicaDBCursor.java | 80 * @param startCSN 89 final CSN startCSN, 92 this.lastNonNullCurrentCSN = startCSN; 87 FileReplicaDBCursor( final RepositionableCursor<CSN, UpdateMsg> cursor, final CSN startCSN, final PositionStrategy positionStrategy) argument
|
H A D | FileReplicaDB.java | 209 * @param startCSN 220 DBCursor<UpdateMsg> generateCursorFrom(final CSN startCSN, final KeyMatchingStrategy matchingStrategy, argument 223 RepositionableCursor<CSN, UpdateMsg> cursor = log.getCursor(startCSN, matchingStrategy, positionStrategy); 224 CSN actualStartCSN = (startCSN != null && startCSN.getServerId() == serverId) ? startCSN : null;
|
/forgerock/opendj2/src/server/org/opends/server/replication/server/changelog/file/ |
H A D | FileReplicaDBCursor.java | 80 * @param startCSN 89 final CSN startCSN, 92 this.lastNonNullCurrentCSN = startCSN; 87 FileReplicaDBCursor( final RepositionableCursor<CSN, UpdateMsg> cursor, final CSN startCSN, final PositionStrategy positionStrategy) argument
|
H A D | FileReplicaDB.java | 209 * @param startCSN 220 DBCursor<UpdateMsg> generateCursorFrom(final CSN startCSN, final KeyMatchingStrategy matchingStrategy, argument 223 RepositionableCursor<CSN, UpdateMsg> cursor = log.getCursor(startCSN, matchingStrategy, positionStrategy); 224 return new FileReplicaDBCursor(cursor, startCSN, positionStrategy);
|
H A D | FileChangelogDB.java | 734 public DBCursor<UpdateMsg> getCursorFrom(final DN baseDN, final int serverId, final CSN startCSN, argument 740 final DBCursor<UpdateMsg> cursor = replicaDB.generateCursorFrom(startCSN, matchingStrategy, positionStrategy); 741 final CSN offlineCSN = getOfflineCSN(baseDN, serverId, startCSN);
|
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/changelog/file/ |
H A D | FileReplicaDBCursor.java | 80 * @param startCSN 89 final CSN startCSN, 92 this.lastNonNullCurrentCSN = startCSN; 87 FileReplicaDBCursor( final RepositionableCursor<CSN, UpdateMsg> cursor, final CSN startCSN, final PositionStrategy positionStrategy) argument
|
H A D | FileReplicaDB.java | 209 * @param startCSN 220 DBCursor<UpdateMsg> generateCursorFrom(final CSN startCSN, final KeyMatchingStrategy matchingStrategy, argument 223 RepositionableCursor<CSN, UpdateMsg> cursor = log.getCursor(startCSN, matchingStrategy, positionStrategy); 224 return new FileReplicaDBCursor(cursor, startCSN, positionStrategy);
|
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/changelog/api/ |
H A D | ReplicationDomainDB.java | 176 * @param startCSN 184 DBCursor<UpdateMsg> getCursorFrom(DN baseDN, int serverId, CSN startCSN, CursorOptions options) argument
|
/forgerock/opendj2/src/server/org/opends/server/replication/server/changelog/api/ |
H A D | ReplicationDomainDB.java | 188 * @param startCSN 199 DBCursor<UpdateMsg> getCursorFrom(DN baseDN, int serverId, CSN startCSN, KeyMatchingStrategy matchingStrategy, argument
|
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/changelog/api/ |
H A D | ReplicationDomainDB.java | 188 * @param startCSN 199 DBCursor<UpdateMsg> getCursorFrom(DN baseDN, int serverId, CSN startCSN, KeyMatchingStrategy matchingStrategy, argument
|
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/changelog/file/ |
H A D | FileReplicaDBTest.java | 354 private void assertNextCSN(FileReplicaDB replicaDB, final CSN startCSN, argument 358 DBCursor<UpdateMsg> cursor = replicaDB.generateCursorFrom(startCSN, GREATER_THAN_OR_EQUAL_TO_KEY, positionStrategy); 372 private void assertNotFound(FileReplicaDB replicaDB, final CSN startCSN, argument 375 DBCursor<UpdateMsg> cursor = replicaDB.generateCursorFrom(startCSN, GREATER_THAN_OR_EQUAL_TO_KEY, positionStrategy);
|
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/changelog/file/ |
H A D | FileReplicaDBTest.java | 354 private void assertNextCSN(FileReplicaDB replicaDB, final CSN startCSN, argument 358 DBCursor<UpdateMsg> cursor = replicaDB.generateCursorFrom(startCSN, GREATER_THAN_OR_EQUAL_TO_KEY, positionStrategy); 372 private void assertNotFound(FileReplicaDB replicaDB, final CSN startCSN, argument 375 DBCursor<UpdateMsg> cursor = replicaDB.generateCursorFrom(startCSN, GREATER_THAN_OR_EQUAL_TO_KEY, positionStrategy);
|
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/server/changelog/file/ |
H A D | FileReplicaDBTest.java | 351 private void assertNextCSN(FileReplicaDB replicaDB, final CSN startCSN, argument 356 startCSN, GREATER_THAN_OR_EQUAL_TO_KEY, positionStrategy)) 365 private void assertNotFound(FileReplicaDB replicaDB, final CSN startCSN, argument 369 startCSN, GREATER_THAN_OR_EQUAL_TO_KEY, positionStrategy))
|
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/changelog/je/ |
H A D | JEReplicaDBTest.java | 366 private void assertNotFound(JEReplicaDB replicaDB, final CSN startCSN, argument 369 DBCursor<UpdateMsg> cursor = replicaDB.generateCursorFrom(startCSN, GREATER_THAN_OR_EQUAL_TO_KEY, positionStrategy);
|
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/changelog/je/ |
H A D | JEReplicaDBTest.java | 366 private void assertNotFound(JEReplicaDB replicaDB, final CSN startCSN, argument 369 DBCursor<UpdateMsg> cursor = replicaDB.generateCursorFrom(startCSN, GREATER_THAN_OR_EQUAL_TO_KEY, positionStrategy);
|