Searched defs:cursor (Results 1 - 25 of 102) sorted by relevance

12345

/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/opendj-v3/opendj-server-legacy/src/main/java/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 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 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/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/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 DCompositeDBCursor.java45 * The type of data associated with each cursor
56 * The state of this cursor. One of {@link #UNINITIALIZED}, {@link #READY} or
69 * The cursors are sorted based on the current change of each cursor to
99 // If previous state was ready, then we must advance the first cursor
102 // to remove the first cursor, then add it again after moving it forward.
132 * Removes the cursor matching the provided data.
135 * the data for which the cursor must be found and removed
158 * Adds a cursor to this composite cursor. It first calls
161 * @param cursor
168 addCursor(final DBCursor<UpdateMsg> cursor, final T data) argument
[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.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-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 DCompositeDBCursor.java45 * The type of data associated with each cursor
56 * The state of this cursor. One of {@link #UNINITIALIZED}, {@link #READY} or
69 * The cursors are sorted based on the current change of each cursor to
99 // If previous state was ready, then we must advance the first cursor
102 // to remove the first cursor, then add it again after moving it forward.
132 * Removes the cursor matching the provided data.
135 * the data for which the cursor must be found and removed
158 * Adds a cursor to this composite cursor. It first calls
161 * @param cursor
168 addCursor(final DBCursor<UpdateMsg> cursor, final T data) argument
[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/je/
H A DECLMultiDomainDBCursorTest.java165 private void addDomainCursorToCursor(DN baseDN, SequentialDBCursor cursor) throws ChangelogException argument
168 when(domainDB.getCursorFrom(baseDN, state, GREATER_THAN_OR_EQUAL_TO_KEY, ON_MATCHING_KEY)).thenReturn(cursor);
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/src/server/org/opends/server/replication/server/changelog/api/
H A DReplicationDomainDB.java43 * In particular, the {@code getCursorFom()} methods allow to obtain a cursor at any level:
49 * The cursor starting point is specified by providing a key, a {@link KeyMatchingStrategy} and
100 * When the cursor is not used anymore, client code MUST call the
102 * cursor.
105 * Starting point for each domain cursor. If any {@link ServerState}
125 * When the cursor is not used anymore, client code MUST call the
127 * cursor.
130 * Starting point for each domain cursor. If any {@link ServerState}
138 * Every domain appearing in this set is excluded from the cursor
153 * When the cursor i
208 unregisterCursor(DBCursor<?> cursor) argument
[all...]
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/changelog/je/
H A DECLMultiDomainDBCursorTest.java165 private void addDomainCursorToCursor(DN baseDN, SequentialDBCursor cursor) throws ChangelogException argument
168 when(domainDB.getCursorFrom(baseDN, state, GREATER_THAN_OR_EQUAL_TO_KEY, ON_MATCHING_KEY)).thenReturn(cursor);
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/src/server/org/opends/server/replication/server/changelog/api/
H A DReplicationDomainDB.java43 * In particular, the {@code getCursorFom()} methods allow to obtain a cursor at any level:
49 * The cursor starting point is specified by providing a key, a {@link KeyMatchingStrategy} and
100 * When the cursor is not used anymore, client code MUST call the
102 * cursor.
105 * Starting point for each domain cursor. If any {@link ServerState}
125 * When the cursor is not used anymore, client code MUST call the
127 * cursor.
130 * Starting point for each domain cursor. If any {@link ServerState}
138 * Every domain appearing in this set is excluded from the cursor
153 * When the cursor i
208 unregisterCursor(DBCursor<?> cursor) argument
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/changelog/api/
H A DReplicationDomainDB.java42 * In particular, the {@code getCursorFom()} methods allow to obtain a cursor at any level:
48 * The cursor starting point is specified by providing a key, a {@link KeyMatchingStrategy} and
99 * When the cursor is not used anymore, client code MUST call the
101 * cursor.
104 * Starting point for each domain cursor. If any {@link ServerState}
107 * @param options The cursor options
120 * When the cursor is not used anymore, client code MUST call the
122 * cursor.
125 * Starting point for each domain cursor. If any {@link ServerState}
128 * @param options The cursor option
193 unregisterCursor(DBCursor<?> cursor) argument
[all...]

Completed in 2535 milliseconds

12345