/forgerock/opendj2-jel-hg/src/server/org/opends/server/backends/jeb/ |
H A D | EntryCachePreloader.java | 328 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 D | FileReplicaDBTest.java | 219 // 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 D | FileReplicaDBTest.java | 219 // 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 D | commontask.css | 34 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 D | scheduleView.less | 48 cursor: pointer;
|
H A D | selfserviceView.less | 82 cursor:default; 93 cursor:default; 102 cursor: default; 161 cursor:not-allowed;
|
H A D | testSync.less | 45 cursor: pointer;
|
/forgerock/openam/openam-console/src/main/webapp/console/css/ |
H A D | commontask.css | 34 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 D | ExportJob.java | 184 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 D | TracedStorage.java | 67 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 D | IndexQueryFactoryImpl.java | 242 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 D | FileChangeNumberIndexDBTest.java | 100 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 D | FileReplicaDBTest.java | 213 // 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 D | FileChangelogDB.java | 218 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 D | Log.java | 94 * 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 D | JEChangelogDB.java | 239 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 D | FileChangelogDB.java | 218 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 D | Log.java | 94 * 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 D | JEChangelogDB.java | 239 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 D | FileChangelogDB.java | 208 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 D | Log.java | 91 * 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 D | LogFile.java | 275 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 D | ExportJob.java | 196 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 D | ExportJob.java | 197 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 D | ExportJob.java | 197 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();
|