Searched defs:positionStrategy (Results 1 - 25 of 43) sorted by relevance

12

/forgerock/opendj2/src/server/org/opends/server/replication/server/changelog/file/
H A DFileReplicaDBCursor.java73 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 DBlockLogReader.java151 * @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 DFileReplicaDB.java214 * @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 DDomainDBCursor.java55 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 DMultiDomainDBCursor.java52 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 DJEReplicaDBCursor.java46 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 DJEReplicaDB.java189 * @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 DFileReplicaDBCursor.java73 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 DDomainDBCursor.java55 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 DMultiDomainDBCursor.java52 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 DJEReplicaDBCursor.java46 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 DFileReplicaDBCursor.java73 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 DReplicationDomainDB.java110 * @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 DReplicationDomainDB.java110 * @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 DDBCursor.java125 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 DBlockLogReaderWriterTest.java257 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 DFileReplicaDBTest.java355 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 DLogFileTest.java194 public void testCursorPositionTo(String key, KeyMatchingStrategy matchingStrategy, PositionStrategy positionStrategy, argument
201 boolean success = cursor.positionTo(key, matchingStrategy, positionStrategy);
H A DLogTest.java213 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 DJEReplicaDBTest.java190 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 DBlockLogReaderWriterTest.java257 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 DFileReplicaDBTest.java355 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 DLogFileTest.java194 public void testCursorPositionTo(String key, KeyMatchingStrategy matchingStrategy, PositionStrategy positionStrategy, argument
201 boolean success = cursor.positionTo(key, matchingStrategy, positionStrategy);
H A DLogTest.java213 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 DJEReplicaDBTest.java190 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

Completed in 146 milliseconds

12