Lines Matching refs:LogFile
60 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<K, V> logFile)
824 for (LogFile<K, V> logFile : logFiles.values())
870 for (LogFile<K, V> logFile : logFiles.values())
931 for (LogFile<K, V> logFile : logFiles.values())
972 private LogFile<K, V> getHeadLogFile()
977 private LogFile<K, V> getOldestLogFile()
995 final LogFile<K, V> headLogFile = getHeadLogFile();
1033 private Pair<K, K> getKeyBounds(final LogFile<K, V> logFile) throws ChangelogException
1059 private String generateReadOnlyFileName(final LogFile<K,V> logFile) throws ChangelogException
1082 final LogFile<K, V> logFile = findLogFileFor(previousKey, KeyMatchingStrategy.EQUAL_TO_KEY);
1111 final LogFile<K, V> headLogFile = getHeadLogFile();
1125 final LogFile<K, V> head = LogFile.newAppendableLogFile(new File(logPath, HEAD_LOG_FILE_NAME), recordParser);
1133 final LogFile<K, V> logFile = LogFile.newReadOnlyLogFile(logFilePath, recordParser);
1153 private LogFile<K, V> getNextLogFile(final LogFile<K, V> currentLogFile) throws ChangelogException
1171 private boolean isHeadLogFile(final LogFile<K, V> logFile)
1177 private LogFile<K, V> findLogFileFor(final K key, KeyMatchingStrategy keyMatchingStrategy) throws ChangelogException
1184 final LogFile<K, V> candidate = logFiles.ceilingEntry(key).getValue();
1239 abstract boolean isAccessingLogFile(LogFile<K, V> logFile);
1251 private LogFile<K, V> currentLogFile;
1286 final LogFile<K, V> logFile = log.getNextLogFile(currentLogFile);
1318 final LogFile<K, V> logFile = log.findLogFileFor(key, matchStrategy);
1362 boolean isAccessingLogFile(LogFile<K, V> logFile)
1368 private void switchToLogFile(final LogFile<K, V> logFile) throws ChangelogException
1486 boolean isAccessingLogFile(LogFile<K, V> logFile)
1610 boolean isAccessingLogFile(LogFile<K, V> logFile)
1632 private final LogFile<K, V> logFile;
1654 private CursorState(final LogFile<K, V> logFile, final long filePosition, final Record<K, V> record)