public abstract class AbstractJournalUpdateTask extends Object implements JournalReaderCallback
Modifier and Type | Field and Description |
---|---|
protected JournalFile |
currentFile |
protected static String |
FILE_COMPACT_CONTROL |
protected SequentialFileFactory |
fileFactory |
protected JournalFilesRepository |
filesRepository |
protected JournalImpl |
journal |
protected List<JournalFile> |
newDataFiles |
protected long |
nextOrderingID |
protected SequentialFile |
sequentialFile |
Modifier | Constructor and Description |
---|---|
protected |
AbstractJournalUpdateTask(SequentialFileFactory fileFactory,
JournalImpl journal,
JournalFilesRepository filesRepository,
Set<Long> recordsSnapshot,
long nextOrderingID) |
Modifier and Type | Method and Description |
---|---|
protected void |
addToRecordsSnaptshot(long id) |
void |
flush()
Write pending output into file
|
protected HornetQBuffer |
getWritingChannel() |
boolean |
lookupRecord(long id) |
protected void |
openFile() |
static SequentialFile |
writeControlFile(SequentialFileFactory fileFactory,
List<JournalFile> files,
List<JournalFile> newFiles,
List<Pair<String,String>> renames) |
protected void |
writeEncoder(JournalInternalRecord record) |
protected void |
writeEncoder(JournalInternalRecord record,
int txcounter) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
markAsDataFile, onReadAddRecord, onReadAddRecordTX, onReadCommitRecord, onReadDeleteRecord, onReadDeleteRecordTX, onReadPrepareRecord, onReadRollbackRecord, onReadUpdateRecord, onReadUpdateRecordTX
protected static final String FILE_COMPACT_CONTROL
protected final JournalImpl journal
protected final SequentialFileFactory fileFactory
protected JournalFile currentFile
protected SequentialFile sequentialFile
protected final JournalFilesRepository filesRepository
protected long nextOrderingID
protected final List<JournalFile> newDataFiles
protected AbstractJournalUpdateTask(SequentialFileFactory fileFactory, JournalImpl journal, JournalFilesRepository filesRepository, Set<Long> recordsSnapshot, long nextOrderingID)
public static SequentialFile writeControlFile(SequentialFileFactory fileFactory, List<JournalFile> files, List<JournalFile> newFiles, List<Pair<String,String>> renames) throws Exception
Exception
public boolean lookupRecord(long id)
protected void addToRecordsSnaptshot(long id)
protected HornetQBuffer getWritingChannel()
protected void writeEncoder(JournalInternalRecord record) throws Exception
Exception
protected void writeEncoder(JournalInternalRecord record, int txcounter) throws Exception
Exception
Copyright © 2018 JBoss by Red Hat. All rights reserved.