/forgerock/opendj2/src/server/org/opends/server/replication/server/changelog/file/ |
H A D | RecordParser.java | 42 interface RecordParser<K, V> interface
|
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 | 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 | 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 | Log.java | 141 private final RecordParser<K, V> recordParser; 213 final RecordParser<K, V> parser, final long sizeLimitPerFileInBytes) throws ChangelogException 269 private Log(final File logPath, final RecordParser<K, V> parser, final long sizeLimitPerFile) argument 212 openLog(final File logPath, final RecordParser<K, V> parser, final long sizeLimitPerFileInBytes) argument
|
H A D | ReplicationEnvironment.java | 658 private <K extends Comparable<K>, V> Log<K, V> openLog(final File serverIdPath, final RecordParser<K, V> parser) argument
|
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/changelog/file/ |
H A D | RecordParser.java | 42 interface RecordParser<K, V> interface
|
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 | 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 | 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 | Log.java | 141 private final RecordParser<K, V> recordParser; 213 final RecordParser<K, V> parser, final long sizeLimitPerFileInBytes) throws ChangelogException 269 private Log(final File logPath, final RecordParser<K, V> parser, final long sizeLimitPerFile) argument 212 openLog(final File logPath, final RecordParser<K, V> parser, final long sizeLimitPerFileInBytes) argument
|
H A D | ReplicationEnvironment.java | 658 private <K extends Comparable<K>, V> Log<K, V> openLog(final File serverIdPath, final RecordParser<K, V> parser) argument
|
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/changelog/file/ |
H A D | RecordParser.java | 42 interface RecordParser<K, V> interface
|
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 | 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 | 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 | ReplicationEnvironment.java | 751 private <K extends Comparable<K>, V> Log<K, V> openLog(final File serverIdPath, final RecordParser<K, V> parser, argument
|
H A D | Log.java | 140 private final RecordParser<K, V> recordParser; 227 final File logPath, final RecordParser<K, V> parser, final LogRotationParameters rotationParameters) 342 private Log(final ReplicationEnvironment replicationEnv, final File logPath, final RecordParser<K, V> parser, argument 226 openLog(final ReplicationEnvironment replicationEnv, final File logPath, final RecordParser<K, V> parser, final LogRotationParameters rotationParameters) argument
|