Searched refs:cursor (Results 1 - 25 of 371) sorted by relevance

1234567891011>>

/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/changelog/file/
H A DECLMultiDomainDBCursor.java36 * 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 DFileChangeNumberIndexDBCursor.java33 * 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 DFileReplicaDBCursor.java38 * 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 DReplicaCursor.java47 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 DReplicaCursorTest.java58 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 DJEChangeNumberIndexDBTest.java73 * <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 DReplicaCursorTest.java58 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 DJEChangeNumberIndexDBTest.java73 * <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 DReplicaCursorTest.java59 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 DReplicationIterator.java43 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 DReplicationIterator.java43 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 DReplicationIterator.java43 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 DFileChangeNumberIndexDBCursor.java33 * 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 DFileReplicaDBCursor.java38 * 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 DFileChangeNumberIndexDBCursor.java33 * 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 DFileReplicaDBCursor.java38 * 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 DIdentityDatabase.java223 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 DECLMultiDomainDBCursor.java39 * 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 DJEReplicaDBCursor.java52 * 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 DReplicaCursor.java49 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 DECLMultiDomainDBCursor.java39 * 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 DJEReplicaDBCursor.java52 * 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 DReplicaCursor.java49 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 DLogTest.java91 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 DLogTest.java91 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...]

Completed in 143 milliseconds

1234567891011>>