Searched refs:startCSN (Results 1 - 25 of 31) sorted by relevance

12

/forgerock/opendj2/src/server/org/opends/server/replication/server/changelog/je/
H A DDomainDBCursor.java97 * @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 DJEReplicaDBCursor.java49 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 DReplicationDB.java292 * @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 DJEReplicaDB.java184 * @param startCSN
196 DBCursor<UpdateMsg> generateCursorFrom(final CSN startCSN, final KeyMatchingStrategy matchingStrategy, argument
199 return new JEReplicaDBCursor(db, startCSN, matchingStrategy, positionStrategy, this);
H A DJEChangelogDB.java777 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 DDomainDBCursor.java97 * @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 DJEReplicaDBCursor.java49 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 DReplicationDB.java292 * @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 DJEReplicaDB.java184 * @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 DDomainDBCursor.java85 * @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 DFileReplicaDBCursor.java80 * @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 DFileReplicaDB.java209 * @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 DFileReplicaDBCursor.java80 * @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 DFileReplicaDB.java209 * @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 DFileChangelogDB.java734 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 DFileReplicaDBCursor.java80 * @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 DFileReplicaDB.java209 * @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 DReplicationDomainDB.java176 * @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 DReplicationDomainDB.java188 * @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 DReplicationDomainDB.java188 * @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 DFileReplicaDBTest.java354 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 DFileReplicaDBTest.java354 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 DFileReplicaDBTest.java351 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 DJEReplicaDBTest.java366 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 DJEReplicaDBTest.java366 private void assertNotFound(JEReplicaDB replicaDB, final CSN startCSN, argument
369 DBCursor<UpdateMsg> cursor = replicaDB.generateCursorFrom(startCSN, GREATER_THAN_OR_EQUAL_TO_KEY, positionStrategy);

Completed in 71 milliseconds

12