/forgerock/openam-v13/openam-core-rest/src/main/java/org/forgerock/openam/core/rest/record/ |
H A D | DebugRecorder.java | 40 Record getCurrentRecord(); 48 Record stopRecording() throws RecordException;
|
H A D | Record.java | 28 public class Record { class 44 public Record(RecordProperties recordProperties, String folderPath) { method in class:Record 83 throw new IllegalStateException("Record '" + this + "' is already running.");
|
/forgerock/openam/openam-core-rest/src/main/java/org/forgerock/openam/core/rest/record/ |
H A D | DebugRecorder.java | 40 Record getCurrentRecord(); 48 Record stopRecording() throws RecordException;
|
/forgerock/opendj2/src/server/org/opends/server/replication/server/changelog/file/ |
H A D | Record.java | 36 class Record<K, V> class 49 private Record(final K key, final V value) method in class:Record 68 static <K, V> Record<K, V> from(final K key, final V value) { 69 return new Record<K, V>(key, value); 111 if (!(that instanceof Record)) 115 Record<?, ?> other = (Record<?, ?>) that; 127 return "Record [" + key + ":" + value + "]";
|
H A D | FileChangeNumberIndexDBCursor.java | 41 private final DBCursor<Record<Long, ChangeNumberIndexRecord>> cursor; 51 FileChangeNumberIndexDBCursor(final DBCursor<Record<Long, ChangeNumberIndexRecord>> cursor) 61 final Record<Long, ChangeNumberIndexRecord> record = cursor.getRecord();
|
H A D | RecordParser.java | 57 Record<K, V> decodeRecord(ByteString data) throws DecodingException; 68 ByteString encodeRecord(Record<K, V> record);
|
H A D | LogFile.java | 247 void append(final Record<K, V> record) throws ChangelogException argument 263 DBCursor<Record<K, V>> cursor = getCursor(); 270 Record<K, V> record = cursor.getRecord(); 337 LogFileCursor<K, V> getCursorInitialisedTo(Record<K,V> record, long position) throws ChangelogException 350 Record<K, V> getOldestRecord() throws ChangelogException 352 DBCursor<Record<K, V>> cursor = null; 371 Record<K, V> getNewestRecord() throws ChangelogException 374 DBCursor<Record<K, V>> cursor = null; 378 Record<K, V> record = null; 401 DBCursor<Record< [all...] |
H A D | BlockLogReader.java | 162 public Pair<Boolean, Record<K,V>> seekToRecord( 204 public Record<K,V> readRecord() throws ChangelogException 247 private Record<K,V> readRecord(final long blockStartPosition) throws ChangelogException 407 final Record<K, V> middleRecord = readRecord(middleBlockStartPos); 471 Pair<Boolean, Record<K,V>> positionToKeySequentially(final long blockStartPosition, final K key, 474 Record<K,V> record = readRecord(blockStartPosition); 475 Record<K,V> previousRecord = null; 503 private Pair<Boolean,Record<K,V>> getMatchingRecord(KeyMatchingStrategy matchStrategy, 505 Record<K, V> currentRecord, Record< 530 getRecordNoMatchForLessStrategy( final PositionStrategy positionStrategy, final Record<K, V> previousRecord, final long previousPosition) argument [all...] |
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/changelog/file/ |
H A D | Record.java | 36 class Record<K, V> class 49 private Record(final K key, final V value) method in class:Record 68 static <K, V> Record<K, V> from(final K key, final V value) { 69 return new Record<K, V>(key, value); 111 if (!(that instanceof Record)) 115 Record<?, ?> other = (Record<?, ?>) that; 127 return "Record [" + key + ":" + value + "]";
|
H A D | FileChangeNumberIndexDBCursor.java | 41 private final DBCursor<Record<Long, ChangeNumberIndexRecord>> cursor; 51 FileChangeNumberIndexDBCursor(final DBCursor<Record<Long, ChangeNumberIndexRecord>> cursor) 61 final Record<Long, ChangeNumberIndexRecord> record = cursor.getRecord();
|
H A D | RecordParser.java | 57 Record<K, V> decodeRecord(ByteString data) throws DecodingException; 68 ByteString encodeRecord(Record<K, V> record);
|
H A D | LogFile.java | 247 void append(final Record<K, V> record) throws ChangelogException argument 263 DBCursor<Record<K, V>> cursor = getCursor(); 270 Record<K, V> record = cursor.getRecord(); 337 LogFileCursor<K, V> getCursorInitialisedTo(Record<K,V> record, long position) throws ChangelogException 350 Record<K, V> getOldestRecord() throws ChangelogException 352 DBCursor<Record<K, V>> cursor = null; 371 Record<K, V> getNewestRecord() throws ChangelogException 374 DBCursor<Record<K, V>> cursor = null; 378 Record<K, V> record = null; 401 DBCursor<Record< [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/changelog/file/ |
H A D | Record.java | 38 class Record<K, V> class 63 private Record(final K key, final V value) method in class:Record 82 static <K, V> Record<K, V> from(final K key, final V value) { 83 return new Record<>(key, value); 125 if (!(that instanceof Record)) 129 Record<?, ?> other = (Record<?, ?>) that; 137 return "Record [" + key + ":" + value + "]";
|
H A D | FileChangeNumberIndexDBCursor.java | 41 private final DBCursor<Record<Long, ChangeNumberIndexRecord>> cursor; 51 FileChangeNumberIndexDBCursor(final DBCursor<Record<Long, ChangeNumberIndexRecord>> cursor) 61 final Record<Long, ChangeNumberIndexRecord> record = cursor.getRecord();
|
H A D | RecordParser.java | 57 Record<K, V> decodeRecord(ByteString data) throws DecodingException; 68 ByteString encodeRecord(Record<K, V> record);
|
H A D | LogFile.java | 90 private Record<K, V> newestRecord; 249 void append(final Record<K, V> record) throws ChangelogException argument 275 final DBCursor<Record<K, V>> cursor = getCursor()) 279 Record<K, V> record = cursor.getRecord(); 348 LogFileCursor<K, V> getCursorInitialisedTo(Record<K,V> record, long position) throws ChangelogException 361 Record<K, V> getOldestRecord() throws ChangelogException 363 try (final DBCursor<Record<K, V>> cursor = getCursor()) 376 Record<K, V> getNewestRecord() throws ChangelogException 410 try (final DBCursor<Record<K, V>> cursor = getCursor()) 534 private Record< [all...] |
H A D | BlockLogReader.java | 160 public Pair<Boolean, Record<K,V>> seekToRecord( 202 public Record<K,V> readRecord() throws ChangelogException 245 private Record<K,V> readRecord(final long blockStartPosition) throws ChangelogException 408 final Record<K, V> middleRecord = readRecord(middleBlockStartPos); 471 Pair<Boolean, Record<K,V>> positionToKey(final long blockStartPosition, final K key, 474 Record<K,V> record = readRecord(blockStartPosition); 475 Record<K,V> previousRecord = null; 498 private Pair<Boolean, Record<K, V>> getMatchingRecord(KeyMatchingStrategy matchStrategy, 499 PositionStrategy positionStrategy, int keysComparison, Record<K, V> currentRecord, Record< 520 getRecordNoMatchForLessStrategy( final PositionStrategy positionStrategy, final Record<K, V> previousRecord, final long previousPosition) argument [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/server/changelog/file/ |
H A D | LogTest.java | 46 import org.opends.server.replication.server.changelog.file.Record.Mapper; 76 log.append(Record.from(String.format("key%03d", i), "value" + i)); 100 DBCursor<Record<String, String>> cursor = log.getCursor()) 110 DBCursor<Record<String, String>> cursor = log.getCursor("key005")) 121 DBCursor<Record<String, String>> cursor = log.getCursor("key005000")) 133 DBCursor<Record<String, String>> cursor = log.getCursor(null)) 205 DBCursor<Record<String, String>> cursor = log.getCursor(key, matchingStrategy, positionStrategy)) 222 DBCursor<Record<String, String>> cursor = log.getCursor(null, null, null)) 244 Record<String, String> record = log.getOldestRecord(); 246 assertThat(record).isEqualTo(Record [all...] |
H A D | LogFileTest.java | 83 logFile.append(Record.from(String.format("key%02d", i), "value"+i)); 103 DBCursor<Record<String, String>> cursor = changelog.getCursor()) 206 Record<String, String> record = changelog.getOldestRecord(); 208 assertThat(record).isEqualTo(Record.from("key01", "value1")); 217 Record<String, String> record = changelog.getNewestRecord(); 219 assertThat(record).isEqualTo(Record.from("key10", "value10")); 254 logFile.append(Record.from(String.format("key%02d", 11), "value"+ 11)); 257 try (DBCursor<Record<String, String>> cursor = logFile.getCursor()) 282 Record<String, String> record = Record [all...] |
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/changelog/file/ |
H A D | LogTest.java | 70 log.append(Record.from(String.format("key%03d", i), "value" + i)); 91 DBCursor<Record<String, String>> cursor = null; 106 DBCursor<Record<String, String>> cursor = null; 121 DBCursor<Record<String, String>> cursor = null; 139 DBCursor<Record<String, String>> cursor = null; 216 DBCursor<Record<String, String>> cursor = null; 238 DBCursor<Record<String, String>> cursor = null; 269 Record<String, String> record = log.getOldestRecord(); 271 assertThat(record).isEqualTo(Record.from("key001", "value1")); 284 Record<Strin [all...] |
H A D | LogFileTest.java | 87 logFile.append(Record.from(String.format("key%02d", i), "value"+i)); 111 DBCursor<Record<String, String>> cursor = null; 224 Record<String, String> record = changelog.getOldestRecord(); 226 assertThat(record).isEqualTo(Record.from("key01", "value1")); 239 Record<String, String> record = changelog.getNewestRecord(); 241 assertThat(record).isEqualTo(Record.from("key10", "value10")); 274 DBCursor<Record<String, String>> cursor = null; 283 logFile.append(Record.from(String.format("key%02d", 11), "value"+ 11)); 328 Record<String, String> record = Record [all...] |
H A D | BlockLogReaderWriterTest.java | 111 public void testWriteThenRead(int blockSize, int expectedSizeOfFile, List<Record<Integer, Integer>> records) 122 Record<Integer, Integer> record = reader.readRecord(); 256 public void testSeekToRecord(int blockSize, List<Record<Integer, Integer>> records, int key, 257 KeyMatchingStrategy matchingStrategy, PositionStrategy positionStrategy, Record<Integer, Integer> expectedRecord, 266 Pair<Boolean, Record<Integer, Integer>> result = reader.seekToRecord(key, matchingStrategy, positionStrategy); 394 Pair<Boolean, Record<Integer, Integer>> result = 418 Pair<Boolean, Record<Integer, Integer>> result = 420 assertThat(result.getSecond()).isEqualTo(Record.from(val, val)); 437 private void writeRecords(int blockSize, List<Record<Integer, Integer>> records) throws ChangelogException 443 for (Record<Intege [all...] |
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/changelog/file/ |
H A D | LogTest.java | 70 log.append(Record.from(String.format("key%03d", i), "value" + i)); 91 DBCursor<Record<String, String>> cursor = null; 106 DBCursor<Record<String, String>> cursor = null; 121 DBCursor<Record<String, String>> cursor = null; 139 DBCursor<Record<String, String>> cursor = null; 216 DBCursor<Record<String, String>> cursor = null; 238 DBCursor<Record<String, String>> cursor = null; 269 Record<String, String> record = log.getOldestRecord(); 271 assertThat(record).isEqualTo(Record.from("key001", "value1")); 284 Record<Strin [all...] |
H A D | LogFileTest.java | 87 logFile.append(Record.from(String.format("key%02d", i), "value"+i)); 111 DBCursor<Record<String, String>> cursor = null; 224 Record<String, String> record = changelog.getOldestRecord(); 226 assertThat(record).isEqualTo(Record.from("key01", "value1")); 239 Record<String, String> record = changelog.getNewestRecord(); 241 assertThat(record).isEqualTo(Record.from("key10", "value10")); 274 DBCursor<Record<String, String>> cursor = null; 283 logFile.append(Record.from(String.format("key%02d", 11), "value"+ 11)); 328 Record<String, String> record = Record [all...] |
H A D | BlockLogReaderWriterTest.java | 111 public void testWriteThenRead(int blockSize, int expectedSizeOfFile, List<Record<Integer, Integer>> records) 122 Record<Integer, Integer> record = reader.readRecord(); 256 public void testSeekToRecord(int blockSize, List<Record<Integer, Integer>> records, int key, 257 KeyMatchingStrategy matchingStrategy, PositionStrategy positionStrategy, Record<Integer, Integer> expectedRecord, 266 Pair<Boolean, Record<Integer, Integer>> result = reader.seekToRecord(key, matchingStrategy, positionStrategy); 394 Pair<Boolean, Record<Integer, Integer>> result = 418 Pair<Boolean, Record<Integer, Integer>> result = 420 assertThat(result.getSecond()).isEqualTo(Record.from(val, val)); 437 private void writeRecords(int blockSize, List<Record<Integer, Integer>> records) throws ChangelogException 443 for (Record<Intege [all...] |