/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/changelog/file/ |
H A D | ECLMultiDomainDBCursor.java | 36 * Multi domain DB cursor that only returns updates for the domains which have 42 private final MultiDomainDBCursor cursor; field in class:ECLMultiDomainDBCursor 46 * Builds an instance of this class filtering updates from the provided cursor. 50 * @param cursor 51 * the cursor whose updates will be filtered 53 public ECLMultiDomainDBCursor(ECLEnabledDomainPredicate predicate, MultiDomainDBCursor cursor) argument 56 this.cursor = cursor; 63 return cursor.getRecord(); 67 * Returns the data associated to the cursor tha [all...] |
H A D | FileChangeNumberIndexDBCursor.java | 33 * A cursor on ChangeNumberIndexDB. 40 /** The underlying cursor. */ 41 private final DBCursor<Record<Long, ChangeNumberIndexRecord>> cursor; field in class:FileChangeNumberIndexDBCursor 44 * Creates the cursor from provided cursor. 46 * @param cursor 47 * The underlying cursor to read log. 51 FileChangeNumberIndexDBCursor(final DBCursor<Record<Long, ChangeNumberIndexRecord>> cursor) argument 54 this.cursor = cursor; [all...] |
H A D | FileReplicaDBCursor.java | 38 * A cursor on ReplicaDB, which can re-initialize itself after exhaustion. 40 * The cursor provides a java.sql.ResultSet like API : 42 * FileReplicaDBCursor cursor = ...; 44 * while (cursor.next()) { 45 * Record record = cursor.getRecord(); 46 * // ... can call cursor.getRecord() again: it will return the same result 50 * close(cursor); 55 * The cursor automatically re-initializes itself if it is exhausted: if a 64 /** The underlying cursor. */ 65 private final RepositionableCursor<CSN, UpdateMsg> cursor; field in class:FileReplicaDBCursor 87 FileReplicaDBCursor( final RepositionableCursor<CSN, UpdateMsg> cursor, final CSN startCSN, final PositionStrategy positionStrategy) argument [all...] |
H A D | ReplicaCursor.java | 47 private final DBCursor<UpdateMsg> cursor; field in class:ReplicaCursor 55 * Creates a ReplicaCursor object with a cursor to decorate 58 * @param cursor 59 * the non-null underlying cursor that needs to be exhausted before 69 public ReplicaCursor(DBCursor<UpdateMsg> cursor, CSN offlineCSN, ReplicaId replicaId, ReplicationDomainDB domainDB) argument 71 this.cursor = cursor; 78 * Sets the offline CSN to be returned by this cursor. 81 * The offline CSN to be returned by this cursor. 98 * Returns the replica identifier that this cursor i [all...] |
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/changelog/je/ |
H A D | ReplicaCursorTest.java | 58 final ReplicaCursor cursor = newReplicaCursor(delegateCursor, null); 59 assertThat(cursor.getRecord()).isNull(); 60 assertThat(cursor.next()).isFalse(); 61 assertThat(cursor.getRecord()).isNull(); 70 final ReplicaCursor cursor = newReplicaCursor(delegateCursor, null); 71 assertThat(cursor.getRecord()).isNull(); 72 assertThat(cursor.next()).isTrue(); 73 assertThat(cursor.getRecord()).isSameAs(updateMsg); 74 assertThat(cursor.next()).isFalse(); 75 assertThat(cursor [all...] |
H A D | JEChangeNumberIndexDBTest.java | 73 * <li>read them with a cursor</li> 107 DBCursor<ChangeNumberIndexRecord> cursor = cnIndexDB.getCursorFrom(oldestCN); 110 assertTrue(cursor.next()); 111 assertEqualTo(cursor.getRecord(), csns[0], baseDN1); 112 assertTrue(cursor.next()); 113 assertEqualTo(cursor.getRecord(), csns[1], baseDN2); 114 assertTrue(cursor.next()); 115 assertEqualTo(cursor.getRecord(), csns[2], baseDN3); 116 assertFalse(cursor.next()); 120 StaticUtils.close(cursor); 253 assertCursorReadsInOrder(DBCursor<ChangeNumberIndexRecord> cursor, long... cns) argument [all...] |
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/changelog/je/ |
H A D | ReplicaCursorTest.java | 58 final ReplicaCursor cursor = newReplicaCursor(delegateCursor, null); 59 assertThat(cursor.getRecord()).isNull(); 60 assertThat(cursor.next()).isFalse(); 61 assertThat(cursor.getRecord()).isNull(); 70 final ReplicaCursor cursor = newReplicaCursor(delegateCursor, null); 71 assertThat(cursor.getRecord()).isNull(); 72 assertThat(cursor.next()).isTrue(); 73 assertThat(cursor.getRecord()).isSameAs(updateMsg); 74 assertThat(cursor.next()).isFalse(); 75 assertThat(cursor [all...] |
H A D | JEChangeNumberIndexDBTest.java | 73 * <li>read them with a cursor</li> 107 DBCursor<ChangeNumberIndexRecord> cursor = cnIndexDB.getCursorFrom(oldestCN); 110 assertTrue(cursor.next()); 111 assertEqualTo(cursor.getRecord(), csns[0], baseDN1); 112 assertTrue(cursor.next()); 113 assertEqualTo(cursor.getRecord(), csns[1], baseDN2); 114 assertTrue(cursor.next()); 115 assertEqualTo(cursor.getRecord(), csns[2], baseDN3); 116 assertFalse(cursor.next()); 120 StaticUtils.close(cursor); 253 assertCursorReadsInOrder(DBCursor<ChangeNumberIndexRecord> cursor, long... cns) argument [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/server/changelog/file/ |
H A D | ReplicaCursorTest.java | 59 final ReplicaCursor cursor = newReplicaCursor(delegateCursor, null); 60 assertThat(cursor.getRecord()).isNull(); 61 assertThat(cursor.next()).isFalse(); 62 assertThat(cursor.getRecord()).isNull(); 71 final ReplicaCursor cursor = newReplicaCursor(delegateCursor, null); 72 assertThat(cursor.getRecord()).isNull(); 73 assertThat(cursor.next()).isTrue(); 74 assertThat(cursor.getRecord()).isSameAs(updateMsg); 75 assertThat(cursor.next()).isFalse(); 76 assertThat(cursor [all...] |
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/ |
H A D | ReplicationIterator.java | 43 private ReplServerDBCursor cursor = null; field in class:ReplicationIterator 71 cursor = db.openReadCursor(changeNumber); 76 cursor = null; 79 if (cursor == null) 85 cursor = db.openReadCursor(changeNumber); 86 if (cursor == null) 111 currentChange = cursor.next(); // can return null 122 if (cursor != null) 124 cursor.close(); 125 cursor [all...] |
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/ |
H A D | ReplicationIterator.java | 43 private ReplServerDBCursor cursor = null; field in class:ReplicationIterator 71 cursor = db.openReadCursor(changeNumber); 76 cursor = null; 79 if (cursor == null) 85 cursor = db.openReadCursor(changeNumber); 86 if (cursor == null) 111 currentChange = cursor.next(); // can return null 122 if (cursor != null) 124 cursor.close(); 125 cursor [all...] |
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/ |
H A D | ReplicationIterator.java | 43 private ReplServerDBCursor cursor = null; field in class:ReplicationIterator 71 cursor = db.openReadCursor(changeNumber); 76 cursor = null; 79 if (cursor == null) 85 cursor = db.openReadCursor(changeNumber); 86 if (cursor == null) 111 currentChange = cursor.next(); // can return null 122 if (cursor != null) 124 cursor.close(); 125 cursor [all...] |
/forgerock/opendj2/src/server/org/opends/server/replication/server/changelog/file/ |
H A D | FileChangeNumberIndexDBCursor.java | 33 * A cursor on ChangeNumberIndexDB. 40 /** The underlying cursor. */ 41 private final DBCursor<Record<Long, ChangeNumberIndexRecord>> cursor; field in class:FileChangeNumberIndexDBCursor 44 * Creates the cursor from provided cursor. 46 * @param cursor 47 * The underlying cursor to read log. 51 FileChangeNumberIndexDBCursor(final DBCursor<Record<Long, ChangeNumberIndexRecord>> cursor) argument 54 this.cursor = cursor; [all...] |
H A D | FileReplicaDBCursor.java | 38 * A cursor on ReplicaDB, which can re-initialize itself after exhaustion. 40 * The cursor provides a java.sql.ResultSet like API : 42 * FileReplicaDBCursor cursor = ...; 44 * while (cursor.next()) { 45 * Record record = cursor.getRecord(); 46 * // ... can call cursor.getRecord() again: it will return the same result 50 * close(cursor); 55 * The cursor automatically re-initializes itself if it is exhausted: if a 64 /** The underlying cursor. */ 65 private final RepositionableCursor<CSN, UpdateMsg> cursor; field in class:FileReplicaDBCursor 87 FileReplicaDBCursor( final RepositionableCursor<CSN, UpdateMsg> cursor, final CSN startCSN, final PositionStrategy positionStrategy) argument [all...] |
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/changelog/file/ |
H A D | FileChangeNumberIndexDBCursor.java | 33 * A cursor on ChangeNumberIndexDB. 40 /** The underlying cursor. */ 41 private final DBCursor<Record<Long, ChangeNumberIndexRecord>> cursor; field in class:FileChangeNumberIndexDBCursor 44 * Creates the cursor from provided cursor. 46 * @param cursor 47 * The underlying cursor to read log. 51 FileChangeNumberIndexDBCursor(final DBCursor<Record<Long, ChangeNumberIndexRecord>> cursor) argument 54 this.cursor = cursor; [all...] |
H A D | FileReplicaDBCursor.java | 38 * A cursor on ReplicaDB, which can re-initialize itself after exhaustion. 40 * The cursor provides a java.sql.ResultSet like API : 42 * FileReplicaDBCursor cursor = ...; 44 * while (cursor.next()) { 45 * Record record = cursor.getRecord(); 46 * // ... can call cursor.getRecord() again: it will return the same result 50 * close(cursor); 55 * The cursor automatically re-initializes itself if it is exhausted: if a 64 /** The underlying cursor. */ 65 private final RepositionableCursor<CSN, UpdateMsg> cursor; field in class:FileReplicaDBCursor 87 FileReplicaDBCursor( final RepositionableCursor<CSN, UpdateMsg> cursor, final CSN startCSN, final PositionStrategy positionStrategy) argument [all...] |
/forgerock/authenticator-android-v2/app/src/main/java/com/forgerock/authenticator/storage/ |
H A D | IdentityDatabase.java | 223 Cursor cursor = database.rawQuery("SELECT rowid, * FROM " + IDENTITY_TABLE_NAME + " ORDER BY " 226 cursor.moveToFirst(); 227 while (!cursor.isAfterLast()) { 228 Identity.IdentityBuilder newIdentityBuilder = cursorToIdentityBuilder(cursor); 230 cursor.moveToNext(); 235 private Identity.IdentityBuilder cursorToIdentityBuilder(Cursor cursor) { argument 236 int rowid = cursor.getInt(cursor.getColumnIndex("rowid")); 237 String issuer = cursor.getString(cursor 275 cursorToMechanismBuilder(Cursor cursor) argument 312 cursorToNotificationBuilder(Cursor cursor) argument [all...] |
/forgerock/opendj2/src/server/org/opends/server/replication/server/changelog/je/ |
H A D | ECLMultiDomainDBCursor.java | 39 * Multi domain DB cursor that only returns updates for the domains which have 46 private final MultiDomainDBCursor cursor; field in class:ECLMultiDomainDBCursor 49 * Builds an instance of this class filtering updates from the provided cursor. 53 * @param cursor 54 * the cursor whose updates will be filtered 56 public ECLMultiDomainDBCursor(ECLEnabledDomainPredicate predicate, MultiDomainDBCursor cursor) argument 59 this.cursor = cursor; 66 return cursor.getRecord(); 70 * Returns the data associated to the cursor tha [all...] |
H A D | JEReplicaDBCursor.java | 52 * The underlying replica DB cursor. 57 private ReplServerDBCursor cursor; field in class:JEReplicaDBCursor 60 * Creates a new {@link JEReplicaDBCursor}. All created cursor must be 64 * The db where the cursor must be created. 66 * The CSN after which the cursor must start.If null, start from the 92 if (!isClosed() && cursor != null) 94 return cursor.getRecord(); 108 final ReplServerDBCursor previousCursor = cursor; 114 // Previously exhausted cursor must be able to reinitialize themselves. 116 // if following code is called while the cursor i [all...] |
H A D | ReplicaCursor.java | 49 private final DBCursor<UpdateMsg> cursor; field in class:ReplicaCursor 58 * Creates a ReplicaCursor object with a cursor to decorate 61 * @param cursor 62 * the non-null underlying cursor that needs to be exhausted before 72 public ReplicaCursor(DBCursor<UpdateMsg> cursor, CSN offlineCSN, argument 75 this.cursor = cursor; 82 * Sets the offline CSN to be returned by this cursor. 85 * The offline CSN to be returned by this cursor. 102 * Returns the replica identifier that this cursor i [all...] |
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/changelog/je/ |
H A D | ECLMultiDomainDBCursor.java | 39 * Multi domain DB cursor that only returns updates for the domains which have 46 private final MultiDomainDBCursor cursor; field in class:ECLMultiDomainDBCursor 49 * Builds an instance of this class filtering updates from the provided cursor. 53 * @param cursor 54 * the cursor whose updates will be filtered 56 public ECLMultiDomainDBCursor(ECLEnabledDomainPredicate predicate, MultiDomainDBCursor cursor) argument 59 this.cursor = cursor; 66 return cursor.getRecord(); 70 * Returns the data associated to the cursor tha [all...] |
H A D | JEReplicaDBCursor.java | 52 * The underlying replica DB cursor. 57 private ReplServerDBCursor cursor; field in class:JEReplicaDBCursor 60 * Creates a new {@link JEReplicaDBCursor}. All created cursor must be 64 * The db where the cursor must be created. 66 * The CSN after which the cursor must start.If null, start from the 92 if (!isClosed() && cursor != null) 94 return cursor.getRecord(); 108 final ReplServerDBCursor previousCursor = cursor; 114 // Previously exhausted cursor must be able to reinitialize themselves. 116 // if following code is called while the cursor i [all...] |
H A D | ReplicaCursor.java | 49 private final DBCursor<UpdateMsg> cursor; field in class:ReplicaCursor 58 * Creates a ReplicaCursor object with a cursor to decorate 61 * @param cursor 62 * the non-null underlying cursor that needs to be exhausted before 72 public ReplicaCursor(DBCursor<UpdateMsg> cursor, CSN offlineCSN, argument 75 this.cursor = cursor; 82 * Sets the offline CSN to be returned by this cursor. 85 * The offline CSN to be returned by this cursor. 102 * Returns the replica identifier that this cursor i [all...] |
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/changelog/file/ |
H A D | LogTest.java | 91 DBCursor<Record<String, String>> cursor = null; 93 cursor = log.getCursor(); 95 assertThatCursorCanBeFullyReadFromStart(cursor, 1, 10); 98 StaticUtils.close(cursor, log); 106 DBCursor<Record<String, String>> cursor = null; 108 cursor = log.getCursor("key005"); 110 assertThatCursorCanBeFullyReadFromStart(cursor, 5, 10); 113 StaticUtils.close(cursor, log); 121 DBCursor<Record<String, String>> cursor = null; 124 cursor 536 advanceCursorUpTo(DBCursor<Record<String, String>> cursor, int fromIndex, int endIndex) argument 550 assertThatCursorCanBeFullyRead(DBCursor<Record<String, String>> cursor, int fromIndex, int endIndex) argument 560 assertThatCursorCanBeFullyReadFromStart(DBCursor<Record<String, String>> cursor, int fromIndex, int endIndex) argument 567 assertThatCursorIsExhausted(DBCursor<Record<String, String>> cursor) argument [all...] |
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/changelog/file/ |
H A D | LogTest.java | 91 DBCursor<Record<String, String>> cursor = null; 93 cursor = log.getCursor(); 95 assertThatCursorCanBeFullyReadFromStart(cursor, 1, 10); 98 StaticUtils.close(cursor, log); 106 DBCursor<Record<String, String>> cursor = null; 108 cursor = log.getCursor("key005"); 110 assertThatCursorCanBeFullyReadFromStart(cursor, 5, 10); 113 StaticUtils.close(cursor, log); 121 DBCursor<Record<String, String>> cursor = null; 124 cursor 536 advanceCursorUpTo(DBCursor<Record<String, String>> cursor, int fromIndex, int endIndex) argument 550 assertThatCursorCanBeFullyRead(DBCursor<Record<String, String>> cursor, int fromIndex, int endIndex) argument 560 assertThatCursorCanBeFullyReadFromStart(DBCursor<Record<String, String>> cursor, int fromIndex, int endIndex) argument 567 assertThatCursorIsExhausted(DBCursor<Record<String, String>> cursor) argument [all...] |