/forgerock/opendj2/src/server/org/opends/server/replication/server/changelog/file/ |
H A D | FileReplicaDBCursor.java | 73 private PositionStrategy positionStrategy; field in class:FileReplicaDBCursor 83 * @param positionStrategy 90 final PositionStrategy positionStrategy) { 93 this.positionStrategy = positionStrategy; 111 if (nextCSNCompare > 0 || (nextCSNCompare == 0 && positionStrategy == ON_MATCHING_KEY)) 115 positionStrategy = AFTER_MATCHING_KEY; 126 final boolean found = cursor.positionTo(lastNonNullCurrentCSN, GREATER_THAN_OR_EQUAL_TO_KEY, positionStrategy); 87 FileReplicaDBCursor( final RepositionableCursor<CSN, UpdateMsg> cursor, final CSN startCSN, final PositionStrategy positionStrategy) argument
|
H A D | BlockLogReader.java | 151 * @param positionStrategy 165 final PositionStrategy positionStrategy) 172 return positionToKeySequentially(markerPosition, key, matchStrategy, positionStrategy); 463 * @param positionStrategy 472 final KeyMatchingStrategy matchStrategy, final PositionStrategy positionStrategy) throws ChangelogException 488 return getMatchingRecord(matchStrategy, positionStrategy, keysComparison, matchingKeyIsLowerThanAnyRecord, 498 return getRecordNoMatchForLessStrategy(positionStrategy, previousRecord, previousPosition); 504 PositionStrategy positionStrategy, int keysComparison, boolean matchKeyIsLowerThanAnyRecord, 510 if (positionStrategy == AFTER_MATCHING_KEY) 522 else if (positionStrategy 162 seekToRecord( final K key, final KeyMatchingStrategy matchStrategy, final PositionStrategy positionStrategy) argument 471 positionToKeySequentially(final long blockStartPosition, final K key, final KeyMatchingStrategy matchStrategy, final PositionStrategy positionStrategy) argument 503 getMatchingRecord(KeyMatchingStrategy matchStrategy, PositionStrategy positionStrategy, int keysComparison, boolean matchKeyIsLowerThanAnyRecord, Record<K, V> currentRecord, Record<K, V> previousRecord, long previousPosition) argument 530 getRecordNoMatchForLessStrategy( final PositionStrategy positionStrategy, final Record<K, V> previousRecord, final long previousPosition) argument [all...] |
H A D | FileReplicaDB.java | 214 * @param positionStrategy 221 final PositionStrategy positionStrategy) throws ChangelogException 223 RepositionableCursor<CSN, UpdateMsg> cursor = log.getCursor(startCSN, matchingStrategy, positionStrategy); 224 return new FileReplicaDBCursor(cursor, startCSN, positionStrategy); 220 generateCursorFrom(final CSN startCSN, final KeyMatchingStrategy matchingStrategy, final PositionStrategy positionStrategy) argument
|
/forgerock/opendj2/src/server/org/opends/server/replication/server/changelog/je/ |
H A D | DomainDBCursor.java | 55 private final PositionStrategy positionStrategy; field in class:DomainDBCursor 68 * @param positionStrategy 73 final PositionStrategy positionStrategy) 78 this.positionStrategy = positionStrategy; 117 domainDB.getCursorFrom(baseDN, serverId, startCSN, matchingStrategy, positionStrategy); 72 DomainDBCursor(final DN baseDN, final ReplicationDomainDB domainDB, final KeyMatchingStrategy matchingStrategy, final PositionStrategy positionStrategy) argument
|
H A D | MultiDomainDBCursor.java | 52 private final PositionStrategy positionStrategy; field in class:MultiDomainDBCursor 61 * @param positionStrategy 65 final PositionStrategy positionStrategy) 69 this.positionStrategy = positionStrategy; 97 domainDB.getCursorFrom(baseDN, serverState, matchingStrategy, positionStrategy); 64 MultiDomainDBCursor(final ReplicationDomainDB domainDB, final KeyMatchingStrategy matchingStrategy, final PositionStrategy positionStrategy) argument
|
H A D | JEReplicaDBCursor.java | 46 private PositionStrategy positionStrategy; field in class:JEReplicaDBCursor 70 * @param positionStrategy 78 PositionStrategy positionStrategy, JEReplicaDB replicaDB) throws ChangelogException 82 this.positionStrategy = positionStrategy; 123 positionStrategy = AFTER_MATCHING_KEY; 125 cursor = db.openReadCursor(lastNonNullCurrentCSN, matchingStrategy, positionStrategy); 130 if (positionStrategy == ON_MATCHING_KEY && previousCursor != null 131 || positionStrategy == AFTER_MATCHING_KEY) 187 + " positionStrategy 77 JEReplicaDBCursor(ReplicationDB db, CSN startCSN, KeyMatchingStrategy matchingStrategy, PositionStrategy positionStrategy, JEReplicaDB replicaDB) argument [all...] |
H A D | JEReplicaDB.java | 189 * @param positionStrategy 197 final PositionStrategy positionStrategy) throws ChangelogException 199 return new JEReplicaDBCursor(db, startCSN, matchingStrategy, positionStrategy, this); 196 generateCursorFrom(final CSN startCSN, final KeyMatchingStrategy matchingStrategy, final PositionStrategy positionStrategy) argument
|
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/changelog/file/ |
H A D | FileReplicaDBCursor.java | 73 private PositionStrategy positionStrategy; field in class:FileReplicaDBCursor 83 * @param positionStrategy 90 final PositionStrategy positionStrategy) { 93 this.positionStrategy = positionStrategy; 111 if (nextCSNCompare > 0 || (nextCSNCompare == 0 && positionStrategy == ON_MATCHING_KEY)) 115 positionStrategy = AFTER_MATCHING_KEY; 126 final boolean found = cursor.positionTo(lastNonNullCurrentCSN, GREATER_THAN_OR_EQUAL_TO_KEY, positionStrategy); 87 FileReplicaDBCursor( final RepositionableCursor<CSN, UpdateMsg> cursor, final CSN startCSN, final PositionStrategy positionStrategy) argument
|
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/changelog/je/ |
H A D | DomainDBCursor.java | 55 private final PositionStrategy positionStrategy; field in class:DomainDBCursor 68 * @param positionStrategy 73 final PositionStrategy positionStrategy) 78 this.positionStrategy = positionStrategy; 117 domainDB.getCursorFrom(baseDN, serverId, startCSN, matchingStrategy, positionStrategy); 72 DomainDBCursor(final DN baseDN, final ReplicationDomainDB domainDB, final KeyMatchingStrategy matchingStrategy, final PositionStrategy positionStrategy) argument
|
H A D | MultiDomainDBCursor.java | 52 private final PositionStrategy positionStrategy; field in class:MultiDomainDBCursor 61 * @param positionStrategy 65 final PositionStrategy positionStrategy) 69 this.positionStrategy = positionStrategy; 97 domainDB.getCursorFrom(baseDN, serverState, matchingStrategy, positionStrategy); 64 MultiDomainDBCursor(final ReplicationDomainDB domainDB, final KeyMatchingStrategy matchingStrategy, final PositionStrategy positionStrategy) argument
|
H A D | JEReplicaDBCursor.java | 46 private PositionStrategy positionStrategy; field in class:JEReplicaDBCursor 70 * @param positionStrategy 78 PositionStrategy positionStrategy, JEReplicaDB replicaDB) throws ChangelogException 82 this.positionStrategy = positionStrategy; 123 positionStrategy = AFTER_MATCHING_KEY; 125 cursor = db.openReadCursor(lastNonNullCurrentCSN, matchingStrategy, positionStrategy); 130 if (positionStrategy == ON_MATCHING_KEY && previousCursor != null 131 || positionStrategy == AFTER_MATCHING_KEY) 187 + " positionStrategy 77 JEReplicaDBCursor(ReplicationDB db, CSN startCSN, KeyMatchingStrategy matchingStrategy, PositionStrategy positionStrategy, JEReplicaDB replicaDB) argument [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/changelog/file/ |
H A D | FileReplicaDBCursor.java | 73 private PositionStrategy positionStrategy; field in class:FileReplicaDBCursor 83 * @param positionStrategy 90 final PositionStrategy positionStrategy) { 93 this.positionStrategy = positionStrategy; 111 if (nextCSNCompare > 0 || (nextCSNCompare == 0 && positionStrategy == ON_MATCHING_KEY)) 115 positionStrategy = AFTER_MATCHING_KEY; 126 final boolean found = cursor.positionTo(lastNonNullCurrentCSN, GREATER_THAN_OR_EQUAL_TO_KEY, positionStrategy); 87 FileReplicaDBCursor( final RepositionableCursor<CSN, UpdateMsg> cursor, final CSN startCSN, final PositionStrategy positionStrategy) argument
|
/forgerock/opendj2/src/server/org/opends/server/replication/server/changelog/api/ |
H A D | ReplicationDomainDB.java | 110 * @param positionStrategy 118 PositionStrategy positionStrategy) throws ChangelogException; 135 * @param positionStrategy 145 PositionStrategy positionStrategy, Set<DN> excludedDomainDns) throws ChangelogException; 165 * @param positionStrategy 173 PositionStrategy positionStrategy) throws ChangelogException; 193 * @param positionStrategy 200 PositionStrategy positionStrategy) throws ChangelogException; 117 getCursorFrom(MultiDomainServerState startState, KeyMatchingStrategy matchingStrategy, PositionStrategy positionStrategy) argument 144 getCursorFrom(MultiDomainServerState startState, KeyMatchingStrategy matchingStrategy, PositionStrategy positionStrategy, Set<DN> excludedDomainDns) argument 172 getCursorFrom(DN baseDN, ServerState startState, KeyMatchingStrategy matchingStrategy, PositionStrategy positionStrategy) argument 199 getCursorFrom(DN baseDN, int serverId, CSN startCSN, KeyMatchingStrategy matchingStrategy, PositionStrategy positionStrategy) argument
|
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/changelog/api/ |
H A D | ReplicationDomainDB.java | 110 * @param positionStrategy 118 PositionStrategy positionStrategy) throws ChangelogException; 135 * @param positionStrategy 145 PositionStrategy positionStrategy, Set<DN> excludedDomainDns) throws ChangelogException; 165 * @param positionStrategy 173 PositionStrategy positionStrategy) throws ChangelogException; 193 * @param positionStrategy 200 PositionStrategy positionStrategy) throws ChangelogException; 117 getCursorFrom(MultiDomainServerState startState, KeyMatchingStrategy matchingStrategy, PositionStrategy positionStrategy) argument 144 getCursorFrom(MultiDomainServerState startState, KeyMatchingStrategy matchingStrategy, PositionStrategy positionStrategy, Set<DN> excludedDomainDns) argument 172 getCursorFrom(DN baseDN, ServerState startState, KeyMatchingStrategy matchingStrategy, PositionStrategy positionStrategy) argument 199 getCursorFrom(DN baseDN, int serverId, CSN startCSN, KeyMatchingStrategy matchingStrategy, PositionStrategy positionStrategy) argument
|
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/changelog/api/ |
H A D | DBCursor.java | 125 private final PositionStrategy positionStrategy; field in class:DBCursor.CursorOptions 133 * @param positionStrategy 136 public CursorOptions(KeyMatchingStrategy keyMatchingStrategy, PositionStrategy positionStrategy) argument 138 this(keyMatchingStrategy, positionStrategy, null); 146 * @param positionStrategy 152 public CursorOptions(KeyMatchingStrategy keyMatchingStrategy, PositionStrategy positionStrategy, CSN defaultCSN) argument 155 this.positionStrategy = positionStrategy; 176 return positionStrategy; 198 && positionStrategy [all...] |
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/changelog/file/ |
H A D | BlockLogReaderWriterTest.java | 257 KeyMatchingStrategy matchingStrategy, PositionStrategy positionStrategy, Record<Integer, Integer> expectedRecord, 266 Pair<Boolean, Record<Integer, Integer>> result = reader.seekToRecord(key, matchingStrategy, positionStrategy); 256 testSeekToRecord(int blockSize, List<Record<Integer, Integer>> records, int key, KeyMatchingStrategy matchingStrategy, PositionStrategy positionStrategy, Record<Integer, Integer> expectedRecord, boolean shouldBeFound) argument
|
H A D | FileReplicaDBTest.java | 355 final PositionStrategy positionStrategy, final CSN expectedCSN) 358 DBCursor<UpdateMsg> cursor = replicaDB.generateCursorFrom(startCSN, GREATER_THAN_OR_EQUAL_TO_KEY, positionStrategy); 373 final PositionStrategy positionStrategy) throws ChangelogException 375 DBCursor<UpdateMsg> cursor = replicaDB.generateCursorFrom(startCSN, GREATER_THAN_OR_EQUAL_TO_KEY, positionStrategy); 580 final PositionStrategy positionStrategy, CSN... csns) throws ChangelogException 582 DBCursor<UpdateMsg> cursor = replicaDB.generateCursorFrom(csns[0], GREATER_THAN_OR_EQUAL_TO_KEY, positionStrategy); 587 for (int i = positionStrategy == ON_MATCHING_KEY ? 0 : 1; i < csns.length; i++) 354 assertNextCSN(FileReplicaDB replicaDB, final CSN startCSN, final PositionStrategy positionStrategy, final CSN expectedCSN) argument 372 assertNotFound(FileReplicaDB replicaDB, final CSN startCSN, final PositionStrategy positionStrategy) argument 579 assertFoundInOrder(FileReplicaDB replicaDB, final PositionStrategy positionStrategy, CSN... csns) argument
|
H A D | LogFileTest.java | 194 public void testCursorPositionTo(String key, KeyMatchingStrategy matchingStrategy, PositionStrategy positionStrategy, argument 201 boolean success = cursor.positionTo(key, matchingStrategy, positionStrategy);
|
H A D | LogTest.java | 213 PositionStrategy positionStrategy, int cursorShouldStartAt, int cursorShouldEndAt) throws Exception 218 cursor = log.getCursor(key, matchingStrategy, positionStrategy); 212 testCursorWithStrategies(String key, KeyMatchingStrategy matchingStrategy, PositionStrategy positionStrategy, int cursorShouldStartAt, int cursorShouldEndAt) argument
|
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/changelog/je/ |
H A D | JEReplicaDBTest.java | 190 PositionStrategy positionStrategy, int startIndex, int endIndex) throws Exception 211 cursor = replicaDB.generateCursorFrom(startCsn, matchingStrategy, positionStrategy); 367 final PositionStrategy positionStrategy) throws ChangelogException 369 DBCursor<UpdateMsg> cursor = replicaDB.generateCursorFrom(startCSN, GREATER_THAN_OR_EQUAL_TO_KEY, positionStrategy); 547 final PositionStrategy positionStrategy, CSN... csns) throws ChangelogException 549 DBCursor<UpdateMsg> cursor = replicaDB.generateCursorFrom(csns[0], GREATER_THAN_OR_EQUAL_TO_KEY, positionStrategy); 554 for (int i = positionStrategy == ON_MATCHING_KEY ? 0 : 1; i < csns.length; i++) 189 testGenerateCursor(CSN[] csns, CSN startCsn, KeyMatchingStrategy matchingStrategy, PositionStrategy positionStrategy, int startIndex, int endIndex) argument 366 assertNotFound(JEReplicaDB replicaDB, final CSN startCSN, final PositionStrategy positionStrategy) argument 546 assertFoundInOrder(JEReplicaDB replicaDB, final PositionStrategy positionStrategy, CSN... csns) argument
|
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/changelog/file/ |
H A D | BlockLogReaderWriterTest.java | 257 KeyMatchingStrategy matchingStrategy, PositionStrategy positionStrategy, Record<Integer, Integer> expectedRecord, 266 Pair<Boolean, Record<Integer, Integer>> result = reader.seekToRecord(key, matchingStrategy, positionStrategy); 256 testSeekToRecord(int blockSize, List<Record<Integer, Integer>> records, int key, KeyMatchingStrategy matchingStrategy, PositionStrategy positionStrategy, Record<Integer, Integer> expectedRecord, boolean shouldBeFound) argument
|
H A D | FileReplicaDBTest.java | 355 final PositionStrategy positionStrategy, final CSN expectedCSN) 358 DBCursor<UpdateMsg> cursor = replicaDB.generateCursorFrom(startCSN, GREATER_THAN_OR_EQUAL_TO_KEY, positionStrategy); 373 final PositionStrategy positionStrategy) throws ChangelogException 375 DBCursor<UpdateMsg> cursor = replicaDB.generateCursorFrom(startCSN, GREATER_THAN_OR_EQUAL_TO_KEY, positionStrategy); 580 final PositionStrategy positionStrategy, CSN... csns) throws ChangelogException 582 DBCursor<UpdateMsg> cursor = replicaDB.generateCursorFrom(csns[0], GREATER_THAN_OR_EQUAL_TO_KEY, positionStrategy); 587 for (int i = positionStrategy == ON_MATCHING_KEY ? 0 : 1; i < csns.length; i++) 354 assertNextCSN(FileReplicaDB replicaDB, final CSN startCSN, final PositionStrategy positionStrategy, final CSN expectedCSN) argument 372 assertNotFound(FileReplicaDB replicaDB, final CSN startCSN, final PositionStrategy positionStrategy) argument 579 assertFoundInOrder(FileReplicaDB replicaDB, final PositionStrategy positionStrategy, CSN... csns) argument
|
H A D | LogFileTest.java | 194 public void testCursorPositionTo(String key, KeyMatchingStrategy matchingStrategy, PositionStrategy positionStrategy, argument 201 boolean success = cursor.positionTo(key, matchingStrategy, positionStrategy);
|
H A D | LogTest.java | 213 PositionStrategy positionStrategy, int cursorShouldStartAt, int cursorShouldEndAt) throws Exception 218 cursor = log.getCursor(key, matchingStrategy, positionStrategy); 212 testCursorWithStrategies(String key, KeyMatchingStrategy matchingStrategy, PositionStrategy positionStrategy, int cursorShouldStartAt, int cursorShouldEndAt) argument
|
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/changelog/je/ |
H A D | JEReplicaDBTest.java | 190 PositionStrategy positionStrategy, int startIndex, int endIndex) throws Exception 211 cursor = replicaDB.generateCursorFrom(startCsn, matchingStrategy, positionStrategy); 367 final PositionStrategy positionStrategy) throws ChangelogException 369 DBCursor<UpdateMsg> cursor = replicaDB.generateCursorFrom(startCSN, GREATER_THAN_OR_EQUAL_TO_KEY, positionStrategy); 547 final PositionStrategy positionStrategy, CSN... csns) throws ChangelogException 549 DBCursor<UpdateMsg> cursor = replicaDB.generateCursorFrom(csns[0], GREATER_THAN_OR_EQUAL_TO_KEY, positionStrategy); 554 for (int i = positionStrategy == ON_MATCHING_KEY ? 0 : 1; i < csns.length; i++) 189 testGenerateCursor(CSN[] csns, CSN startCsn, KeyMatchingStrategy matchingStrategy, PositionStrategy positionStrategy, int startIndex, int endIndex) argument 366 assertNotFound(JEReplicaDB replicaDB, final CSN startCSN, final PositionStrategy positionStrategy) argument 546 assertFoundInOrder(JEReplicaDB replicaDB, final PositionStrategy positionStrategy, CSN... csns) argument
|