Searched refs:cursor (Results 76 - 100 of 371) sorted by relevance

1234567891011>>

/forgerock/opendj2-jel-hg/src/server/org/opends/server/backends/jeb/
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/tests/unit-tests-testng/src/server/org/opends/server/replication/server/changelog/file/
H A DFileReplicaDBTest.java219 // the index to use in CSN array for the start key of the cursor
230 DBCursor<UpdateMsg> cursor = null;
240 cursor = replicaDB.generateCursorFrom(csns[csnIndexForStartKey],
242 assertFalse(cursor.next());
255 assertTrue(cursor.next());
256 assertEquals(cursor.getRecord().getCSN(), csns[i], "index i=" + i);
259 assertFalse(cursor.next());
263 close(cursor);
358 DBCursor<UpdateMsg> cursor = replicaDB.generateCursorFrom(startCSN, GREATER_THAN_OR_EQUAL_TO_KEY, positionStrategy);
362 softly.assertThat(cursor
[all...]
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/changelog/file/
H A DFileReplicaDBTest.java219 // the index to use in CSN array for the start key of the cursor
230 DBCursor<UpdateMsg> cursor = null;
240 cursor = replicaDB.generateCursorFrom(csns[csnIndexForStartKey],
242 assertFalse(cursor.next());
255 assertTrue(cursor.next());
256 assertEquals(cursor.getRecord().getCSN(), csns[i], "index i=" + i);
259 assertFalse(cursor.next());
263 close(cursor);
358 DBCursor<UpdateMsg> cursor = replicaDB.generateCursorFrom(startCSN, GREATER_THAN_OR_EQUAL_TO_KEY, positionStrategy);
362 softly.assertThat(cursor
[all...]
/forgerock/openam-v13/openam-console/src/main/webapp/console/css/
H A Dcommontask.css34 span.TskPgeTskLftBtm, span.TskPgeTskLftTp, span.TskPgeTskRghtBtm, span.TskPgeTskRghtTp, span.TskPgeTskRghtBrdr {cursor:hand;}
/forgerock/openidm-v4/openidm-ui/openidm-ui-admin/src/main/resources/css/config/
H A DscheduleView.less48 cursor: pointer;
H A DselfserviceView.less82 cursor:default;
93 cursor:default;
102 cursor: default;
161 cursor:not-allowed;
H A DtestSync.less45 cursor: pointer;
/forgerock/openam/openam-console/src/main/webapp/console/css/
H A Dcommontask.css34 span.TskPgeTskLftBtm, span.TskPgeTskLftTp, span.TskPgeTskRghtBtm, span.TskPgeTskRghtTp, span.TskPgeTskRghtBrdr {cursor:hand;}
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/backends/pluggable/
H A DExportJob.java184 Cursor<ByteString, ByteString> cursor = txn.openCursor(entryContainer.getID2Entry().getName());
187 while (cursor.next())
194 ByteString key = cursor.getKey();
218 ByteString value = cursor.getValue();
250 cursor.close();
H A DTracedStorage.java67 private final Cursor<ByteString, ByteString> cursor; field in class:TracedStorage.TracedCursor
69 private TracedCursor(final Cursor<ByteString, ByteString> cursor) argument
71 this.cursor = cursor;
88 boolean found = cursor.positionToKey(key);
97 boolean found = cursor.positionToKeyOrNext(key);
106 boolean found = cursor.positionToLastKey();
115 boolean found = cursor.positionToIndex(index);
124 boolean found = cursor.next();
133 cursor
[all...]
H A DIndexQueryFactoryImpl.java242 Cursor<ByteString, EntryIDSet> cursor = index.openCursor(txn);
249 // Initialize the cursor to the lower bound.
250 success = cursor.positionToKeyOrNext(lower);
253 if (success && !lowerIncluded && cursor.getKey().equals(lower))
256 success = cursor.next();
261 success = cursor.next();
276 int cmp = cursor.getKey().compareTo(upper);
283 EntryIDSet set = cursor.getValue();
294 return newUndefinedSetWithKey(cursor.getKey());
297 success = cursor
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/server/changelog/file/
H A DFileChangeNumberIndexDBTest.java100 try (DBCursor<ChangeNumberIndexRecord> cursor = cnIndexDB.getCursorFrom(cn1))
102 assertCursorReadsInOrder(cursor, cn1, cn2, cn3);
104 try (DBCursor<ChangeNumberIndexRecord> cursor = cnIndexDB.getCursorFrom(cn2))
106 assertCursorReadsInOrder(cursor, cn2, cn3);
108 try (DBCursor<ChangeNumberIndexRecord> cursor = cnIndexDB.getCursorFrom(cn3))
110 assertCursorReadsInOrder(cursor, cn3);
262 private void assertCursorReadsInOrder(DBCursor<ChangeNumberIndexRecord> cursor, long... cns) argument
267 assertTrue(cursor.next());
268 assertEquals(cursor.getRecord().getChangeNumber(), cn);
270 assertFalse(cursor
[all...]
H A DFileReplicaDBTest.java213 // the index to use in CSN array for the start key of the cursor
233 try (DBCursor<UpdateMsg> cursor = replicaDB.generateCursorFrom(
236 assertFalse(cursor.next());
250 assertTrue(cursor.next(), indexNbMsg);
251 assertEquals(cursor.getRecord().getCSN(), csns[i], indexNbMsg);
254 assertFalse(cursor.next());
355 try (DBCursor<UpdateMsg> cursor = replicaDB.generateCursorFrom(
359 softly.assertThat(cursor.next()).isTrue();
360 softly.assertThat(cursor.getRecord().getCSN()).isEqualTo(expectedCSN);
368 try (DBCursor<UpdateMsg> cursor
[all...]
/forgerock/opendj2/src/server/org/opends/server/replication/server/changelog/file/
H A DFileChangelogDB.java218 for (DomainDBCursor cursor : cursors)
220 cursor.addReplicaDB(serverId, null);
251 for (MultiDomainDBCursor cursor : registeredMultiDomainCursors)
253 cursor.addDomain(baseDN, null);
684 final MultiDomainDBCursor cursor = new MultiDomainDBCursor(this, matchingStrategy, positionStrategy);
685 registeredMultiDomainCursors.add(cursor);
690 cursor.addDomain(baseDN, startState.getServerState(baseDN));
693 return cursor;
701 final DomainDBCursor cursor = newDomainDBCursor(baseDN, matchingStrategy, positionStrategy);
704 // get the last already sent CSN from that server to get a cursor
752 putCursor(ConcurrentSkipListMap<K, CopyOnWriteArrayList<V>> map, final K key, final V cursor) argument
769 unregisterCursor(final DBCursor<?> cursor) argument
[all...]
H A DLog.java94 * DBCursor<K, V> cursor = log.getCursor(someKey);
95 * // use cursor, then close cursor
188 * The shared lock used for reads and cursor operations on this log.
429 * Returns a cursor that allows to retrieve the records from this log,
432 * @return a cursor on the log records, which is never {@code null}
434 * If the cursor can't be created.
438 LogCursor<K, V> cursor = null;
446 cursor = new LogCursor<K, V>(this);
447 cursor
895 registerCursor(final LogCursor<K, V> cursor) argument
900 unregisterCursor(final LogCursor<K, V> cursor) argument
[all...]
/forgerock/opendj2/src/server/org/opends/server/replication/server/changelog/je/
H A DJEChangelogDB.java239 for (DomainDBCursor cursor : cursors)
241 cursor.addReplicaDB(serverId, null);
272 for (MultiDomainDBCursor cursor : registeredMultiDomainCursors)
274 cursor.addDomain(baseDN, null);
727 final MultiDomainDBCursor cursor = new MultiDomainDBCursor(this, matchingStrategy, positionStrategy);
728 registeredMultiDomainCursors.add(cursor);
733 cursor.addDomain(baseDN, startState.getServerState(baseDN));
736 return cursor;
744 final DomainDBCursor cursor = newDomainDBCursor(baseDN, matchingStrategy, positionStrategy);
747 // get the last already sent CSN from that server to get a cursor
795 putCursor(ConcurrentSkipListMap<K, CopyOnWriteArrayList<V>> map, final K key, final V cursor) argument
812 unregisterCursor(final DBCursor<?> cursor) argument
[all...]
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/changelog/file/
H A DFileChangelogDB.java218 for (DomainDBCursor cursor : cursors)
220 cursor.addReplicaDB(serverId, null);
251 for (MultiDomainDBCursor cursor : registeredMultiDomainCursors)
253 cursor.addDomain(baseDN, null);
684 final MultiDomainDBCursor cursor = new MultiDomainDBCursor(this, matchingStrategy, positionStrategy);
685 registeredMultiDomainCursors.add(cursor);
690 cursor.addDomain(baseDN, startState.getServerState(baseDN));
693 return cursor;
701 final DomainDBCursor cursor = newDomainDBCursor(baseDN, matchingStrategy, positionStrategy);
704 // get the last already sent CSN from that server to get a cursor
752 putCursor(ConcurrentSkipListMap<K, CopyOnWriteArrayList<V>> map, final K key, final V cursor) argument
769 unregisterCursor(final DBCursor<?> cursor) argument
[all...]
H A DLog.java94 * DBCursor<K, V> cursor = log.getCursor(someKey);
95 * // use cursor, then close cursor
188 * The shared lock used for reads and cursor operations on this log.
429 * Returns a cursor that allows to retrieve the records from this log,
432 * @return a cursor on the log records, which is never {@code null}
434 * If the cursor can't be created.
438 LogCursor<K, V> cursor = null;
446 cursor = new LogCursor<K, V>(this);
447 cursor
895 registerCursor(final LogCursor<K, V> cursor) argument
900 unregisterCursor(final LogCursor<K, V> cursor) argument
[all...]
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/changelog/je/
H A DJEChangelogDB.java239 for (DomainDBCursor cursor : cursors)
241 cursor.addReplicaDB(serverId, null);
272 for (MultiDomainDBCursor cursor : registeredMultiDomainCursors)
274 cursor.addDomain(baseDN, null);
727 final MultiDomainDBCursor cursor = new MultiDomainDBCursor(this, matchingStrategy, positionStrategy);
728 registeredMultiDomainCursors.add(cursor);
733 cursor.addDomain(baseDN, startState.getServerState(baseDN));
736 return cursor;
744 final DomainDBCursor cursor = newDomainDBCursor(baseDN, matchingStrategy, positionStrategy);
747 // get the last already sent CSN from that server to get a cursor
795 putCursor(ConcurrentSkipListMap<K, CopyOnWriteArrayList<V>> map, final K key, final V cursor) argument
812 unregisterCursor(final DBCursor<?> cursor) argument
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/changelog/file/
H A DFileChangelogDB.java208 for (DomainDBCursor cursor : cursors)
210 cursor.addReplicaDB(serverId, null);
241 for (MultiDomainDBCursor cursor : registeredMultiDomainCursors)
243 cursor.addDomain(baseDN, null);
699 final MultiDomainDBCursor cursor = new MultiDomainDBCursor(this, options);
700 registeredMultiDomainCursors.add(cursor);
705 cursor.addDomain(baseDN, startState.getServerState(baseDN));
708 return cursor;
715 final DomainDBCursor cursor = newDomainDBCursor(baseDN, options);
718 // get the last already sent CSN from that server to get a cursor
766 putCursor(ConcurrentSkipListMap<K, CopyOnWriteArrayList<V>> map, final K key, final V cursor) argument
782 unregisterCursor(final DBCursor<?> cursor) argument
[all...]
H A DLog.java91 * DBCursor<K, V> cursor = log.getCursor(someKey);
92 * // use cursor, then close cursor
248 * Returns an empty cursor.
252 * @return an empty cursor
550 * Returns a cursor that allows to retrieve the records from this log,
553 * @return a cursor on the log records, which is never {@code null}
555 * If the cursor can't be created.
559 AbortableLogCursor<K, V> cursor = null;
567 cursor
1138 registerCursor(final AbortableLogCursor<K, V> cursor) argument
1143 unregisterCursor(final LogCursor<K, V> cursor) argument
[all...]
H A DLogFile.java275 final DBCursor<Record<K, V>> cursor = getCursor())
277 while (cursor.getRecord() != null)
279 Record<K, V> record = cursor.getRecord();
284 cursor.next();
325 * Returns a cursor that allows to retrieve the records from this log,
328 * @return a cursor on the log records, which is never {@code null}
330 * If the cursor can't be created.
338 * Returns a cursor initialized to the provided record and position in file.
341 * The initial record this cursor points on
343 * The file position this cursor point
[all...]
/forgerock/opendj2/src/server/org/opends/server/backends/jeb/
H A DExportJob.java196 Cursor cursor = id2entry.openCursor(null, new CursorConfig());
203 for (status = cursor.getFirst(key, data, LockMode.DEFAULT);
205 status = cursor.getNext(key, data, LockMode.DEFAULT))
268 cursor.close();
/forgerock/opendj-b2.6/src/server/org/opends/server/backends/jeb/
H A DExportJob.java197 Cursor cursor = id2entry.openCursor(null, new CursorConfig());
204 for (status = cursor.getFirst(key, data, LockMode.DEFAULT);
206 status = cursor.getNext(key, data, LockMode.DEFAULT))
269 cursor.close();
/forgerock/opendj2.6.2/src/server/org/opends/server/backends/jeb/
H A DExportJob.java197 Cursor cursor = id2entry.openCursor(null, new CursorConfig());
204 for (status = cursor.getFirst(key, data, LockMode.DEFAULT);
206 status = cursor.getNext(key, data, LockMode.DEFAULT))
269 cursor.close();

Completed in 55 milliseconds

1234567891011>>