Searched refs:LogFile (Results 1 - 9 of 9) sorted by relevance

/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/changelog/file/
H A DLog.java60 import org.opends.server.replication.server.changelog.file.LogFile.LogFileCursor;
156 private final TreeMap<K, LogFile<K, V>> logFiles = new TreeMap<>();
454 LogFile<K, V> headLogFile = getHeadLogFile();
475 LogFile<K, V> headLogFile = getHeadLogFile();
492 private boolean mustRotate(LogFile<K, V> headLogFile)
710 for (final LogFile<K, V> logFile : logFiles.values())
741 final SortedMap<K, LogFile<K, V>> logFilesToPurge = logFiles.headMap(purgeKey);
749 final Iterator<LogFile<K, V>> entriesToPurge = logFilesToPurge.values().iterator();
752 final LogFile<K, V> logFile = entriesToPurge.next();
785 private void abortCursorsOpenOnLogFile(LogFile<
1033 getKeyBounds(final LogFile<K, V> logFile) argument
1059 generateReadOnlyFileName(final LogFile<K,V> logFile) argument
1153 getNextLogFile(final LogFile<K, V> currentLogFile) argument
1171 isHeadLogFile(final LogFile<K, V> logFile) argument
1368 switchToLogFile(final LogFile<K, V> logFile) argument
1654 CursorState(final LogFile<K, V> logFile, final long filePosition, final Record<K, V> record) argument
[all...]
H A DLogFile.java65 final class LogFile<K extends Comparable<K>, V> implements Closeable class in inherits:Closeable
105 private LogFile(final File logFilePath, final RecordParser<K, V> parser, boolean isWriteEnabled) method in class:LogFile
144 static <K extends Comparable<K>, V> LogFile<K, V> newReadOnlyLogFile(final File logFilePath,
147 return new LogFile<>(logFilePath, parser, false);
166 static <K extends Comparable<K>, V> LogFile<K, V> newAppendableLogFile(final File logFilePath,
169 return new LogFile<>(logFilePath, parser, true);
510 if (!(that instanceof LogFile))
514 final LogFile<?, ?> other = (LogFile<?, ?>) that;
521 return "LogFile [logfil
550 LogFileCursor(final LogFile<K, V> logFile) argument
[all...]
/forgerock/opendj2/src/server/org/opends/server/replication/server/changelog/file/
H A DLogFile.java69 final class LogFile<K extends Comparable<K>, V> implements Closeable class in inherits:Closeable
101 private LogFile(final File logFilePath, final RecordParser<K, V> parser, boolean isWriteEnabled) method in class:LogFile
136 static <K extends Comparable<K>, V> LogFile<K, V> newReadOnlyLogFile(final File logFilePath,
139 return new LogFile<K, V>(logFilePath, parser, false);
158 static <K extends Comparable<K>, V> LogFile<K, V> newAppendableLogFile(final File logFilePath,
161 return new LogFile<K, V>(logFilePath, parser, true);
498 if (!(that instanceof LogFile))
502 final LogFile<?, ?> other = (LogFile<?, ?>) that;
510 private final LogFile<
532 LogFileCursor(final LogFile<K, V> logFile) argument
[all...]
H A DLog.java60 import org.opends.server.replication.server.changelog.file.LogFile.LogFileCursor;
157 private final TreeMap<K, LogFile<K, V>> logFiles = new TreeMap<K, LogFile<K, V>>();
379 LogFile<K, V> headLogFile = getHeadLogFile();
571 for (final LogFile<K, V> logFile : logFiles.values())
597 final SortedMap<K, LogFile<K, V>> logFilesToPurge = logFiles.headMap(purgeKey);
603 final Iterator<Entry<K, LogFile<K, V>>> entriesToPurge = logFilesToPurge.entrySet().iterator();
606 final LogFile<K, V> logFile = entriesToPurge.next().getValue();
659 for (LogFile<K, V> logFile : logFiles.values())
702 for (LogFile<
795 getKeyBounds(final LogFile<K, V> logFile) argument
821 generateReadOnlyFileName(final LogFile<K,V> logFile) argument
910 getNextLogFile(final LogFile<K, V> currentLogFile) argument
920 isHeadLogFile(final LogFile<K, V> logFile) argument
1104 switchToLogFile(final LogFile<K, V> logFile) argument
1181 CursorState(final LogFile<K, V> logFile, final long filePosition, final Record<K, V> record) argument
[all...]
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/changelog/file/
H A DLogFile.java69 final class LogFile<K extends Comparable<K>, V> implements Closeable class in inherits:Closeable
101 private LogFile(final File logFilePath, final RecordParser<K, V> parser, boolean isWriteEnabled) method in class:LogFile
136 static <K extends Comparable<K>, V> LogFile<K, V> newReadOnlyLogFile(final File logFilePath,
139 return new LogFile<K, V>(logFilePath, parser, false);
158 static <K extends Comparable<K>, V> LogFile<K, V> newAppendableLogFile(final File logFilePath,
161 return new LogFile<K, V>(logFilePath, parser, true);
498 if (!(that instanceof LogFile))
502 final LogFile<?, ?> other = (LogFile<?, ?>) that;
510 private final LogFile<
532 LogFileCursor(final LogFile<K, V> logFile) argument
[all...]
H A DLog.java60 import org.opends.server.replication.server.changelog.file.LogFile.LogFileCursor;
157 private final TreeMap<K, LogFile<K, V>> logFiles = new TreeMap<K, LogFile<K, V>>();
379 LogFile<K, V> headLogFile = getHeadLogFile();
571 for (final LogFile<K, V> logFile : logFiles.values())
597 final SortedMap<K, LogFile<K, V>> logFilesToPurge = logFiles.headMap(purgeKey);
603 final Iterator<Entry<K, LogFile<K, V>>> entriesToPurge = logFilesToPurge.entrySet().iterator();
606 final LogFile<K, V> logFile = entriesToPurge.next().getValue();
659 for (LogFile<K, V> logFile : logFiles.values())
702 for (LogFile<
795 getKeyBounds(final LogFile<K, V> logFile) argument
821 generateReadOnlyFileName(final LogFile<K,V> logFile) argument
910 getNextLogFile(final LogFile<K, V> currentLogFile) argument
920 isHeadLogFile(final LogFile<K, V> logFile) argument
1104 switchToLogFile(final LogFile<K, V> logFile) argument
1181 CursorState(final LogFile<K, V> logFile, final long filePosition, final Record<K, V> record) argument
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/server/changelog/file/
H A DLogFileTest.java41 import org.opends.server.replication.server.changelog.file.LogFile.LogFileCursor;
79 try (LogFile<String, String> logFile = getLogFile(RECORD_PARSER))
94 private LogFile<String, String> getLogFile(RecordParser<String, String> parser) throws ChangelogException
96 return LogFile.newAppendableLogFile(TEST_LOG_FILE, parser);
102 try (LogFile<String, String> changelog = getLogFile(RECORD_PARSER);
184 try (LogFile<String, String> changelog = getLogFile(RECORD_PARSER);
204 try (LogFile<String, String> changelog = getLogFile(RECORD_PARSER))
215 try (LogFile<String, String> changelog = getLogFile(RECORD_PARSER))
251 try (LogFile<String, String> logFile = getLogFile(RECORD_PARSER))
278 try (LogFile<Strin
[all...]
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/changelog/file/
H A DLogFileTest.java38 import org.opends.server.replication.server.changelog.file.LogFile.LogFileCursor;
80 LogFile<String, String> logFile = null;
102 private LogFile<String, String> getLogFile(RecordParser<String, String> parser) throws ChangelogException
104 return LogFile.newAppendableLogFile(TEST_LOG_FILE, parser);
110 LogFile<String, String> changelog = getLogFile(RECORD_PARSER);
197 LogFile<String, String> changelog = getLogFile(RECORD_PARSER);
221 LogFile<String, String> changelog = getLogFile(RECORD_PARSER);
236 LogFile<String, String> changelog = getLogFile(RECORD_PARSER);
273 LogFile<String, String> logFile = null;
319 LogFile<Strin
[all...]
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/changelog/file/
H A DLogFileTest.java38 import org.opends.server.replication.server.changelog.file.LogFile.LogFileCursor;
80 LogFile<String, String> logFile = null;
102 private LogFile<String, String> getLogFile(RecordParser<String, String> parser) throws ChangelogException
104 return LogFile.newAppendableLogFile(TEST_LOG_FILE, parser);
110 LogFile<String, String> changelog = getLogFile(RECORD_PARSER);
197 LogFile<String, String> changelog = getLogFile(RECORD_PARSER);
221 LogFile<String, String> changelog = getLogFile(RECORD_PARSER);
236 LogFile<String, String> changelog = getLogFile(RECORD_PARSER);
273 LogFile<String, String> logFile = null;
319 LogFile<Strin
[all...]

Completed in 46 milliseconds