Searched refs:cursor (Results 51 - 75 of 371) sorted by relevance

1234567891011>>

/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/
H A DDraftCNDbHandler.java178 * Get a read cursor on the database from a provided key.
179 * The cursor MUST be released after use.
181 * @return the new cursor.
196 * Release a provided read cursor.
197 * @param cursor The provided read cursor.
199 public void releaseReadCursor(DraftCNDBCursor cursor) argument
203 cursor.close();
341 DraftCNDBCursor cursor = db.openDeleteCursor();
347 if (!cursor
[all...]
/forgerock/opendj2/src/server/org/opends/server/replication/server/changelog/je/
H A DJEChangeNumberIndexDB.java221 final DraftCNDBCursor cursor = db.openDeleteCursor();
224 while (!mustShutdown(shutdown) && cursor.next())
226 final ChangeNumberIndexRecord record = cursor.currentRecord();
230 cursor.delete();
245 cursor.abort();
250 cursor.abort();
255 cursor.close();
276 final DraftCNDBCursor cursor = db.openDeleteCursor();
279 while (!mustShutdown(shutdown) && cursor.next())
281 final ChangeNumberIndexRecord record = cursor
[all...]
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/changelog/je/
H A DJEChangeNumberIndexDB.java221 final DraftCNDBCursor cursor = db.openDeleteCursor();
224 while (!mustShutdown(shutdown) && cursor.next())
226 final ChangeNumberIndexRecord record = cursor.currentRecord();
230 cursor.delete();
245 cursor.abort();
250 cursor.abort();
255 cursor.close();
276 final DraftCNDBCursor cursor = db.openDeleteCursor();
279 while (!mustShutdown(shutdown) && cursor.next())
281 final ChangeNumberIndexRecord record = cursor
[all...]
/forgerock/openam-v13/openam-server-only/src/main/webapp/assets/lib/yui/datatable/assets/
H A Ddatatable-core.css27 cursor:w-resize;
28 cursor:col-resize;
H A Ddatatable.css28 cursor:w-resize;
29 cursor:col-resize;
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/server/changelog/file/
H A DLogFileTest.java103 DBCursor<Record<String, String>> cursor = changelog.getCursor())
105 assertThatCursorCanBeFullyRead(cursor, 1, 10);
114 // expected start index of cursor (use -1 if cursor should be exhausted), expected end index of cursor
135 // key00 is a special case : position is not found but cursor is positioned on beginning
145 // key00 is a special case : position is not found but cursor is positioned on beginning
176 * Test cursor positioning for a given key, matching strategy and position strategy.
185 LogFileCursor<String, String> cursor = changelog.getCursor())
187 boolean success = cursor
294 assertThatCursorCanBeFullyRead(DBCursor<Record<String, String>> cursor, int fromIndex, int endIndex) argument
306 assertThatCursorIsExhausted(DBCursor<Record<String, String>> cursor) argument
[all...]
/forgerock/openam/openam-server-only/src/main/webapp/assets/lib/yui/datatable/assets/
H A Ddatatable-core.css27 cursor:w-resize;
28 cursor:col-resize;
H A Ddatatable.css28 cursor:w-resize;
29 cursor:col-resize;
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/changelog/file/
H A DLogFileTest.java111 DBCursor<Record<String, String>> cursor = null;
113 cursor = changelog.getCursor();
115 assertThatCursorCanBeFullyRead(cursor, 1, 10);
118 StaticUtils.close(cursor, changelog);
127 // expected start index of cursor (use -1 if cursor should be exhausted), expected end index of cursor
148 // key00 is a special case : position is not found but cursor is positioned on beginning
158 // key00 is a special case : position is not found but cursor is positioned on beginning
189 * Test cursor positionin
346 assertThatCursorCanBeFullyRead(DBCursor<Record<String, String>> cursor, int fromIndex, int endIndex) argument
358 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 DLogFileTest.java111 DBCursor<Record<String, String>> cursor = null;
113 cursor = changelog.getCursor();
115 assertThatCursorCanBeFullyRead(cursor, 1, 10);
118 StaticUtils.close(cursor, changelog);
127 // expected start index of cursor (use -1 if cursor should be exhausted), expected end index of cursor
148 // key00 is a special case : position is not found but cursor is positioned on beginning
158 // key00 is a special case : position is not found but cursor is positioned on beginning
189 * Test cursor positionin
346 assertThatCursorCanBeFullyRead(DBCursor<Record<String, String>> cursor, int fromIndex, int endIndex) argument
358 assertThatCursorIsExhausted(DBCursor<Record<String, String>> cursor) argument
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/backends/pluggable/
H A DShardedCounter.java120 try (final SequentialCursor<ByteString, Long> cursor = new ShardCursor(openCursor0(txn), key))
122 while (cursor.next())
124 counterValue += cursor.getValue();
133 try (final SequentialCursor<ByteString, Long> cursor = new ShardCursor(openCursor0(txn), key))
136 while (cursor.next())
138 counterValue += cursor.getValue();
139 cursor.delete();
187 /** Restricts a cursor to the shards of a specific key. */
226 UniqueKeysCursor(Cursor<K, ?> cursor) argument
228 this.delegate = cursor;
291 throwIfUndefined(SequentialCursor<?, ?> cursor) argument
[all...]
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/changelog/je/
H A DJEReplicaDBTest.java121 // in order to test cursor generation from a key not present in the log (before, in the middle, after)
184 * Test the cursor with all acceptable strategies combination.
192 DBCursor<UpdateMsg> cursor = null;
211 cursor = replicaDB.generateCursorFrom(startCsn, matchingStrategy, positionStrategy);
214 assertThatCursorCanBeFullyReadFromStart(cursor, csns, startIndex, endIndex);
218 assertThatCursorIsExhausted(cursor);
223 close(cursor);
264 // Test cursor from existing CSN
334 private void advanceCursorUpTo(DBCursor<UpdateMsg> cursor, CSN[] csns, int startIndex, int endIndex) argument
339 assertThat(cursor
344 assertThatCursorIsExhausted(DBCursor<UpdateMsg> cursor) argument
352 assertThatCursorCanBeFullyRead(DBCursor<UpdateMsg> cursor, CSN[] csns, int startIndex, int endIndex) argument
359 assertThatCursorCanBeFullyReadFromStart(DBCursor<UpdateMsg> cursor, CSN[] csns, int startIndex, int endIndex) argument
[all...]
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/changelog/je/
H A DJEReplicaDBTest.java121 // in order to test cursor generation from a key not present in the log (before, in the middle, after)
184 * Test the cursor with all acceptable strategies combination.
192 DBCursor<UpdateMsg> cursor = null;
211 cursor = replicaDB.generateCursorFrom(startCsn, matchingStrategy, positionStrategy);
214 assertThatCursorCanBeFullyReadFromStart(cursor, csns, startIndex, endIndex);
218 assertThatCursorIsExhausted(cursor);
223 close(cursor);
264 // Test cursor from existing CSN
334 private void advanceCursorUpTo(DBCursor<UpdateMsg> cursor, CSN[] csns, int startIndex, int endIndex) argument
339 assertThat(cursor
344 assertThatCursorIsExhausted(DBCursor<UpdateMsg> cursor) argument
352 assertThatCursorCanBeFullyRead(DBCursor<UpdateMsg> cursor, CSN[] csns, int startIndex, int endIndex) argument
359 assertThatCursorCanBeFullyReadFromStart(DBCursor<UpdateMsg> cursor, CSN[] csns, int startIndex, int endIndex) argument
[all...]
/forgerock/opendj2/src/server/org/opends/server/backends/jeb/
H A DDN2URI.java208 Cursor cursor = openCursor(txn, cursorConfig);
211 status = cursor.getSearchBoth(key, data, null);
214 status = cursor.delete();
219 cursor.close();
243 Cursor cursor = openCursor(txn, null);
247 OperationStatus status = cursor.getFirst(key, data, null);
248 cursor.close();
544 Cursor cursor = openCursor(txn, cursorConfig);
557 cursor.getSearchKey(key, data, LockMode.DEFAULT);
562 new LinkedHashSet<String>(cursor
[all...]
H A DEntryCachePreloader.java327 Cursor cursor = null;
344 if (cursor == null) {
351 cursor = id2entry.openCursor(null, new CursorConfig());
356 // BUG cursor might be null ? If not why testing below ?
357 status = cursor.getNext(key, data, LockMode.DEFAULT);
359 // Reset cursor and continue.
360 if (cursor != null) {
362 cursor.close();
369 cursor = null;
386 // Always close cursor
[all...]
/forgerock/opendj-b2.6/src/server/org/opends/server/backends/jeb/
H A DDN2URI.java209 Cursor cursor = openCursor(txn, cursorConfig);
212 status = cursor.getSearchBoth(key, data, null);
215 status = cursor.delete();
220 cursor.close();
244 Cursor cursor = openCursor(txn, null);
248 OperationStatus status = cursor.getFirst(key, data, null);
249 cursor.close();
545 Cursor cursor = openCursor(txn, cursorConfig);
558 cursor.getSearchKey(key, data, LockMode.DEFAULT);
563 new LinkedHashSet<String>(cursor
[all...]
H A DEntryCachePreloader.java328 Cursor cursor = null;
345 if (cursor == null) {
352 cursor = id2entry.openCursor(null, new CursorConfig());
357 // BUG cursor might be null ? If not why testing below ?
358 status = cursor.getNext(key, data, LockMode.DEFAULT);
360 // Reset cursor and continue.
361 if (cursor != null) {
363 cursor.close();
370 cursor = null;
387 // Always close cursor
[all...]
/forgerock/opendj2.6.2/src/server/org/opends/server/backends/jeb/
H A DDN2URI.java209 Cursor cursor = openCursor(txn, cursorConfig);
212 status = cursor.getSearchBoth(key, data, null);
215 status = cursor.delete();
220 cursor.close();
244 Cursor cursor = openCursor(txn, null);
248 OperationStatus status = cursor.getFirst(key, data, null);
249 cursor.close();
545 Cursor cursor = openCursor(txn, cursorConfig);
558 cursor.getSearchKey(key, data, LockMode.DEFAULT);
563 new LinkedHashSet<String>(cursor
[all...]
H A DEntryCachePreloader.java328 Cursor cursor = null;
345 if (cursor == null) {
352 cursor = id2entry.openCursor(null, new CursorConfig());
357 // BUG cursor might be null ? If not why testing below ?
358 status = cursor.getNext(key, data, LockMode.DEFAULT);
360 // Reset cursor and continue.
361 if (cursor != null) {
363 cursor.close();
370 cursor = null;
387 // Always close cursor
[all...]
/forgerock/opendj2-hg/src/server/org/opends/server/backends/jeb/
H A DDN2URI.java208 Cursor cursor = openCursor(txn, cursorConfig);
211 status = cursor.getSearchBoth(key, data, null);
214 status = cursor.delete();
219 cursor.close();
243 Cursor cursor = openCursor(txn, null);
247 OperationStatus status = cursor.getFirst(key, data, null);
248 cursor.close();
544 Cursor cursor = openCursor(txn, cursorConfig);
557 cursor.getSearchKey(key, data, LockMode.DEFAULT);
562 new LinkedHashSet<String>(cursor
[all...]
H A DEntryCachePreloader.java327 Cursor cursor = null;
344 if (cursor == null) {
351 cursor = id2entry.openCursor(null, new CursorConfig());
356 // BUG cursor might be null ? If not why testing below ?
357 status = cursor.getNext(key, data, LockMode.DEFAULT);
359 // Reset cursor and continue.
360 if (cursor != null) {
362 cursor.close();
369 cursor = null;
386 // Always close cursor
[all...]
/forgerock/opendj2-jel-hg/src/server/org/opends/server/backends/jeb/
H A DDN2URI.java209 Cursor cursor = openCursor(txn, cursorConfig);
212 status = cursor.getSearchBoth(key, data, null);
215 status = cursor.delete();
220 cursor.close();
244 Cursor cursor = openCursor(txn, null);
248 OperationStatus status = cursor.getFirst(key, data, null);
249 cursor.close();
545 Cursor cursor = openCursor(txn, cursorConfig);
558 cursor.getSearchKey(key, data, LockMode.DEFAULT);
563 new LinkedHashSet<String>(cursor
[all...]
/forgerock/opendj2/src/server/org/opends/server/replication/server/
H A DMessageHandler.java406 DBCursor<UpdateMsg> cursor = null;
409 cursor = replicationServerDomain.getCursorFrom(serverState);
410 while (cursor.next() && isLateQueueBelowThreshold())
412 final UpdateMsg record = cursor.getRecord();
425 close(cursor);
474 DBCursor<UpdateMsg> cursor = null;
477 cursor = replicationServerDomain.getCursorFrom(serverState);
478 while (cursor.next())
480 final UpdateMsg record = cursor.getRecord();
494 close(cursor);
[all...]
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/
H A DMessageHandler.java406 DBCursor<UpdateMsg> cursor = null;
409 cursor = replicationServerDomain.getCursorFrom(serverState);
410 while (cursor.next() && isLateQueueBelowThreshold())
412 final UpdateMsg record = cursor.getRecord();
425 close(cursor);
474 DBCursor<UpdateMsg> cursor = null;
477 cursor = replicationServerDomain.getCursorFrom(serverState);
478 while (cursor.next())
480 final UpdateMsg record = cursor.getRecord();
494 close(cursor);
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/backends/pluggable/
H A DDN2IDTest.java156 try (final Cursor<ByteString, ByteString> cursor = txn.openCursor(dn2ID.getName()))
158 cursor.next();
159 final ByteString rootDN = cursor.getKey();
160 cursor.next();
161 final ByteString parentDN = cursor.getKey();
162 cursor.next();
165 final ByteString childDN = cursor.getKey();
168 cursor.next();
169 final ByteString otherChildDN = cursor.getKey();
173 final ByteString lastChildDN = cursor
274 getAllIDs(SequentialCursor<K, V> cursor) argument
[all...]

Completed in 64 milliseconds

1234567891011>>