Searched refs:Record (Results 1 - 25 of 70) sorted by relevance

123

/forgerock/openam-v13/openam-core-rest/src/main/java/org/forgerock/openam/core/rest/record/
H A DDebugRecorder.java40 Record getCurrentRecord();
48 Record stopRecording() throws RecordException;
H A DRecord.java28 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 DDebugRecorder.java40 Record getCurrentRecord();
48 Record stopRecording() throws RecordException;
/forgerock/opendj2/src/server/org/opends/server/replication/server/changelog/file/
H A DRecord.java36 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 DFileChangeNumberIndexDBCursor.java41 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 DRecordParser.java57 Record<K, V> decodeRecord(ByteString data) throws DecodingException;
68 ByteString encodeRecord(Record<K, V> record);
H A DLogFile.java247 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 DBlockLogReader.java162 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 DRecord.java36 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 DFileChangeNumberIndexDBCursor.java41 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 DRecordParser.java57 Record<K, V> decodeRecord(ByteString data) throws DecodingException;
68 ByteString encodeRecord(Record<K, V> record);
H A DLogFile.java247 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 DRecord.java38 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 DFileChangeNumberIndexDBCursor.java41 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 DRecordParser.java57 Record<K, V> decodeRecord(ByteString data) throws DecodingException;
68 ByteString encodeRecord(Record<K, V> record);
H A DLogFile.java90 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 DBlockLogReader.java160 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 DLogTest.java46 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 DLogFileTest.java83 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 DLogTest.java70 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 DLogFileTest.java87 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 DBlockLogReaderWriterTest.java111 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 DLogTest.java70 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 DLogFileTest.java87 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 DBlockLogReaderWriterTest.java111 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...]

Completed in 110 milliseconds

123