Searched refs:RecordParser (Results 1 - 25 of 42) sorted by relevance

12

/forgerock/opendj2/src/server/org/opends/server/replication/server/changelog/file/
H A DBlockLogWriter.java57 private final RecordParser<K, V> parser;
75 final LogWriter writer, final RecordParser<K, V> parser)
99 final LogWriter writer, final RecordParser<K, V> parser, final int blockSize)
114 private BlockLogWriter(LogWriter writer, RecordParser<K, V> parser, int blockSize)
74 newWriter( final LogWriter writer, final RecordParser<K, V> parser) argument
98 newWriterForTests( final LogWriter writer, final RecordParser<K, V> parser, final int blockSize) argument
H A DRecordParser.java42 interface RecordParser<K, V> interface
H A DLogReaderPool.java51 private final RecordParser<K, V> parser;
61 LogReaderPool(File file, RecordParser<K, V> parser)
H A DLogFile.java101 private LogFile(final File logFilePath, final RecordParser<K, V> parser, boolean isWriteEnabled) argument
137 final RecordParser<K, V> parser) throws ChangelogException
159 final RecordParser<K, V> parser) throws ChangelogException
208 private void ensureLogFileIsValid(final RecordParser<K, V> parser) throws ChangelogException argument
136 newReadOnlyLogFile(final File logFilePath, final RecordParser<K, V> parser) argument
158 newAppendableLogFile(final File logFilePath, final RecordParser<K, V> parser) argument
H A DBlockLogReader.java81 private final RecordParser<K, V> parser;
103 final File file, final RandomAccessFile reader, final RecordParser<K, V> parser)
129 final File file, final RandomAccessFile reader, final RecordParser<K, V> parser, int blockSize)
135 final File file, final RandomAccessFile reader, final RecordParser<K, V> parser, final int blockSize)
102 newReader( final File file, final RandomAccessFile reader, final RecordParser<K, V> parser) argument
128 newReaderForTests( final File file, final RandomAccessFile reader, final RecordParser<K, V> parser, int blockSize) argument
134 BlockLogReader( final File file, final RandomAccessFile reader, final RecordParser<K, V> parser, final int blockSize) argument
H A DFileChangeNumberIndexDB.java59 static final RecordParser<Long, ChangeNumberIndexRecord> RECORD_PARSER = new ChangeNumberIndexDBParser();
324 private static class ChangeNumberIndexDBParser implements RecordParser<Long, ChangeNumberIndexRecord>
H A DFileReplicaDB.java70 static final RecordParser<CSN, UpdateMsg> RECORD_PARSER = new ReplicaDBParser();
362 private static class ReplicaDBParser implements RecordParser<CSN, UpdateMsg>
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/changelog/file/
H A DBlockLogWriter.java57 private final RecordParser<K, V> parser;
75 final LogWriter writer, final RecordParser<K, V> parser)
99 final LogWriter writer, final RecordParser<K, V> parser, final int blockSize)
114 private BlockLogWriter(LogWriter writer, RecordParser<K, V> parser, int blockSize)
74 newWriter( final LogWriter writer, final RecordParser<K, V> parser) argument
98 newWriterForTests( final LogWriter writer, final RecordParser<K, V> parser, final int blockSize) argument
H A DRecordParser.java42 interface RecordParser<K, V> interface
H A DLogReaderPool.java51 private final RecordParser<K, V> parser;
61 LogReaderPool(File file, RecordParser<K, V> parser)
H A DLogFile.java101 private LogFile(final File logFilePath, final RecordParser<K, V> parser, boolean isWriteEnabled) argument
137 final RecordParser<K, V> parser) throws ChangelogException
159 final RecordParser<K, V> parser) throws ChangelogException
208 private void ensureLogFileIsValid(final RecordParser<K, V> parser) throws ChangelogException argument
136 newReadOnlyLogFile(final File logFilePath, final RecordParser<K, V> parser) argument
158 newAppendableLogFile(final File logFilePath, final RecordParser<K, V> parser) argument
H A DBlockLogReader.java81 private final RecordParser<K, V> parser;
103 final File file, final RandomAccessFile reader, final RecordParser<K, V> parser)
129 final File file, final RandomAccessFile reader, final RecordParser<K, V> parser, int blockSize)
135 final File file, final RandomAccessFile reader, final RecordParser<K, V> parser, final int blockSize)
102 newReader( final File file, final RandomAccessFile reader, final RecordParser<K, V> parser) argument
128 newReaderForTests( final File file, final RandomAccessFile reader, final RecordParser<K, V> parser, int blockSize) argument
134 BlockLogReader( final File file, final RandomAccessFile reader, final RecordParser<K, V> parser, final int blockSize) argument
H A DFileChangeNumberIndexDB.java59 static final RecordParser<Long, ChangeNumberIndexRecord> RECORD_PARSER = new ChangeNumberIndexDBParser();
324 private static class ChangeNumberIndexDBParser implements RecordParser<Long, ChangeNumberIndexRecord>
H A DFileReplicaDB.java70 static final RecordParser<CSN, UpdateMsg> RECORD_PARSER = new ReplicaDBParser();
362 private static class ReplicaDBParser implements RecordParser<CSN, UpdateMsg>
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/changelog/file/
H A DBlockLogWriter.java56 private final RecordParser<K, V> parser;
74 final LogWriter writer, final RecordParser<K, V> parser)
98 final LogWriter writer, final RecordParser<K, V> parser, final int blockSize)
113 private BlockLogWriter(LogWriter writer, RecordParser<K, V> parser, int blockSize)
73 newWriter( final LogWriter writer, final RecordParser<K, V> parser) argument
97 newWriterForTests( final LogWriter writer, final RecordParser<K, V> parser, final int blockSize) argument
H A DRecordParser.java42 interface RecordParser<K, V> interface
H A DLogReaderPool.java51 private final RecordParser<K, V> parser;
61 LogReaderPool(File file, RecordParser<K, V> parser)
H A DLogFile.java105 private LogFile(final File logFilePath, final RecordParser<K, V> parser, boolean isWriteEnabled) argument
145 final RecordParser<K, V> parser) throws ChangelogException
167 final RecordParser<K, V> parser) throws ChangelogException
216 private void ensureLogFileIsValid(final RecordParser<K, V> parser) throws ChangelogException argument
144 newReadOnlyLogFile(final File logFilePath, final RecordParser<K, V> parser) argument
166 newAppendableLogFile(final File logFilePath, final RecordParser<K, V> parser) argument
H A DBlockLogReader.java79 private final RecordParser<K, V> parser;
101 final File file, final RandomAccessFile reader, final RecordParser<K, V> parser)
127 final File file, final RandomAccessFile reader, final RecordParser<K, V> parser, int blockSize)
133 final File file, final RandomAccessFile reader, final RecordParser<K, V> parser, final int blockSize)
100 newReader( final File file, final RandomAccessFile reader, final RecordParser<K, V> parser) argument
126 newReaderForTests( final File file, final RandomAccessFile reader, final RecordParser<K, V> parser, int blockSize) argument
132 BlockLogReader( final File file, final RandomAccessFile reader, final RecordParser<K, V> parser, final int blockSize) argument
H A DFileChangeNumberIndexDB.java92 static final RecordParser<Long, ChangeNumberIndexRecord> RECORD_PARSER = new ChangeNumberIndexDBParser();
404 private static class ChangeNumberIndexDBParser implements RecordParser<Long, ChangeNumberIndexRecord>
H A DFileReplicaDB.java70 static final RecordParser<CSN, UpdateMsg> RECORD_PARSER = new ReplicaDBParser();
361 private static class ReplicaDBParser implements RecordParser<CSN, UpdateMsg>
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/server/changelog/file/
H A DLogFileTest.java94 private LogFile<String, String> getLogFile(RecordParser<String, String> parser) throws ChangelogException
316 private static class StringRecordParser implements RecordParser<String, String>
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/changelog/file/
H A DLogFileTest.java102 private LogFile<String, String> getLogFile(RecordParser<String, String> parser) throws ChangelogException
368 private static class StringRecordParser implements RecordParser<String, String>
H A DBlockLogReaderWriterTest.java64 private static final RecordParser<Integer, Integer> RECORD_PARSER = new IntRecordParser();
517 private static class IntRecordParser implements RecordParser<Integer, Integer>
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/changelog/file/
H A DLogFileTest.java102 private LogFile<String, String> getLogFile(RecordParser<String, String> parser) throws ChangelogException
368 private static class StringRecordParser implements RecordParser<String, String>

Completed in 91 milliseconds

12