Searched defs:RecordParser (Results 1 - 18 of 18) sorted by relevance

/forgerock/opendj2/src/server/org/opends/server/replication/server/changelog/file/
H A DRecordParser.java42 interface RecordParser<K, V> interface
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 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 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 DLog.java141 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 DReplicationEnvironment.java658 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 DRecordParser.java42 interface RecordParser<K, V> interface
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 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 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 DLog.java141 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 DReplicationEnvironment.java658 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 DRecordParser.java42 interface RecordParser<K, V> interface
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 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 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 DReplicationEnvironment.java751 private <K extends Comparable<K>, V> Log<K, V> openLog(final File serverIdPath, final RecordParser<K, V> parser, argument
H A DLog.java140 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

Completed in 77 milliseconds