/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/ |
H A D | DraftCNDbHandler.java | 178 * 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 D | JEChangeNumberIndexDB.java | 221 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 D | JEChangeNumberIndexDB.java | 221 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 D | datatable-core.css | 27 cursor:w-resize; 28 cursor:col-resize;
|
H A D | datatable.css | 28 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 D | LogFileTest.java | 103 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 D | datatable-core.css | 27 cursor:w-resize; 28 cursor:col-resize;
|
H A D | datatable.css | 28 cursor:w-resize; 29 cursor:col-resize;
|
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/changelog/file/ |
H A D | LogFileTest.java | 111 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 D | LogFileTest.java | 111 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 D | ShardedCounter.java | 120 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 D | JEReplicaDBTest.java | 121 // 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 D | JEReplicaDBTest.java | 121 // 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 D | DN2URI.java | 208 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 D | EntryCachePreloader.java | 327 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 D | DN2URI.java | 209 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 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.6.2/src/server/org/opends/server/backends/jeb/ |
H A D | DN2URI.java | 209 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 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-hg/src/server/org/opends/server/backends/jeb/ |
H A D | DN2URI.java | 208 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 D | EntryCachePreloader.java | 327 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 D | DN2URI.java | 209 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 D | MessageHandler.java | 406 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 D | MessageHandler.java | 406 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 D | DN2IDTest.java | 156 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...] |