Searched defs:LogFile (Results 1 - 6 of 6) sorted by relevance

/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/main/java/org/opends/server/replication/server/changelog/file/
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...]
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...]

Completed in 39 milliseconds