/forgerock/opendj2/src/server/org/opends/server/replication/server/changelog/file/ |
H A D | BlockLogWriter.java | 57 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 D | RecordParser.java | 42 interface RecordParser<K, V> interface
|
H A D | LogReaderPool.java | 51 private final RecordParser<K, V> parser; 61 LogReaderPool(File file, RecordParser<K, V> parser)
|
H A D | LogFile.java | 101 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 D | BlockLogReader.java | 81 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 D | FileChangeNumberIndexDB.java | 59 static final RecordParser<Long, ChangeNumberIndexRecord> RECORD_PARSER = new ChangeNumberIndexDBParser(); 324 private static class ChangeNumberIndexDBParser implements RecordParser<Long, ChangeNumberIndexRecord>
|
H A D | FileReplicaDB.java | 70 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 D | BlockLogWriter.java | 57 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 D | RecordParser.java | 42 interface RecordParser<K, V> interface
|
H A D | LogReaderPool.java | 51 private final RecordParser<K, V> parser; 61 LogReaderPool(File file, RecordParser<K, V> parser)
|
H A D | LogFile.java | 101 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 D | BlockLogReader.java | 81 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 D | FileChangeNumberIndexDB.java | 59 static final RecordParser<Long, ChangeNumberIndexRecord> RECORD_PARSER = new ChangeNumberIndexDBParser(); 324 private static class ChangeNumberIndexDBParser implements RecordParser<Long, ChangeNumberIndexRecord>
|
H A D | FileReplicaDB.java | 70 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 D | BlockLogWriter.java | 56 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 D | RecordParser.java | 42 interface RecordParser<K, V> interface
|
H A D | LogReaderPool.java | 51 private final RecordParser<K, V> parser; 61 LogReaderPool(File file, RecordParser<K, V> parser)
|
H A D | LogFile.java | 105 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 D | BlockLogReader.java | 79 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 D | FileChangeNumberIndexDB.java | 92 static final RecordParser<Long, ChangeNumberIndexRecord> RECORD_PARSER = new ChangeNumberIndexDBParser(); 404 private static class ChangeNumberIndexDBParser implements RecordParser<Long, ChangeNumberIndexRecord>
|
H A D | FileReplicaDB.java | 70 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 D | LogFileTest.java | 94 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 D | LogFileTest.java | 102 private LogFile<String, String> getLogFile(RecordParser<String, String> parser) throws ChangelogException 368 private static class StringRecordParser implements RecordParser<String, String>
|
H A D | BlockLogReaderWriterTest.java | 64 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 D | LogFileTest.java | 102 private LogFile<String, String> getLogFile(RecordParser<String, String> parser) throws ChangelogException 368 private static class StringRecordParser implements RecordParser<String, String>
|