Package | Description |
---|---|
org.hornetq.core.journal | |
org.hornetq.core.journal.impl |
Modifier and Type | Method and Description |
---|---|
JournalFile |
TestableJournal.getCurrentFile() |
JournalFile[] |
TestableJournal.getDataFiles() |
Modifier and Type | Class and Description |
---|---|
class |
JournalFileImpl
A JournalFileImpl
|
Modifier and Type | Field and Description |
---|---|
protected JournalFile |
AbstractJournalUpdateTask.currentFile |
Modifier and Type | Field and Description |
---|---|
protected List<JournalFile> |
AbstractJournalUpdateTask.newDataFiles |
Modifier and Type | Method and Description |
---|---|
JournalFile |
JournalImpl.getCurrentFile() |
JournalFile[] |
JournalImpl.getDataFiles() |
JournalFile[] |
JournalFilesRepository.getDataFilesArray() |
JournalFile |
JournalFilesRepository.getFreeFile() |
JournalFile |
JournalFilesRepository.openFile()
This method will instantly return the opened file, and schedule opening and reclaiming.
|
JournalFile |
JournalFilesRepository.pollLastDataFile() |
JournalFile |
JournalFilesRepository.takeFile(boolean keepOpened,
boolean multiAIO,
boolean initFile,
boolean tmpCompactExtension)
This will get a File from freeFile without initializing it
|
Modifier and Type | Method and Description |
---|---|
Collection<JournalFile> |
JournalFilesRepository.getDataFiles() |
Collection<JournalFile> |
JournalFilesRepository.getFreeFiles() |
List<JournalFile> |
JournalCompactor.getNewDataFiles() |
List<JournalFile> |
JournalImpl.orderFiles()
this method is used internally only however tools may use it to maintenance.
|
Modifier and Type | Method and Description |
---|---|
void |
JournalCompactor.addCommandCommit(JournalTransaction liveTransaction,
JournalFile currentFile) |
void |
JournalCompactor.addCommandDelete(long id,
JournalFile usedFile) |
void |
JournalCompactor.addCommandRollback(JournalTransaction liveTransaction,
JournalFile currentFile) |
void |
JournalCompactor.addCommandUpdate(long id,
JournalFile usedFile,
int size) |
void |
JournalFilesRepository.addDataFileOnBottom(JournalFile file) |
void |
JournalFilesRepository.addDataFileOnTop(JournalFile file) |
void |
JournalFilesRepository.addFreeFile(JournalFile file,
boolean renameTmp) |
void |
JournalFilesRepository.addFreeFile(JournalFile file,
boolean renameTmp,
boolean checkDelete) |
void |
JournalTransaction.addNegative(JournalFile file,
long id) |
void |
JournalTransaction.addPositive(JournalFile file,
long id,
int size) |
void |
JournalFilesRepository.closeFile(JournalFile file) |
void |
JournalTransaction.commit(JournalFile file)
The caller of this method needs to guarantee appendLock.lock at the journal.
|
static void |
ExportJournal.exportJournalFile(PrintStream out,
SequentialFileFactory fileFactory,
JournalFile file) |
void |
JournalTransaction.fillNumberOfRecords(JournalFile currentFile,
JournalInternalRecord data) |
TransactionCallback |
JournalTransaction.getCallback(JournalFile file) |
int |
JournalTransaction.getCounter(JournalFile file) |
int |
JournalFileImpl.getNegCount(JournalFile file) |
int |
JournalFile.getNegCount(JournalFile file) |
void |
JournalTransaction.incCounter(JournalFile file) |
void |
JournalFileImpl.incNegCount(JournalFile file) |
void |
JournalFile.incNegCount(JournalFile file) |
void |
JournalReaderCallbackAbstract.markAsDataFile(JournalFile file) |
void |
JournalReaderCallback.markAsDataFile(JournalFile file) |
void |
JournalCompactor.markAsDataFile(JournalFile file) |
void |
JournalFilesRepository.openFile(JournalFile file,
boolean multiAIO) |
void |
JournalTransaction.prepare(JournalFile file)
The caller of this method needs to guarantee appendLock.lock before calling this method if being used outside of the lock context.
|
static int |
JournalImpl.readJournalFile(SequentialFileFactory fileFactory,
JournalFile file,
JournalReaderCallback reader)
this method is used internally only however tools may use it to maintenance.
|
void |
JournalFilesRepository.removeDataFile(JournalFile file) |
boolean |
JournalFileImpl.resetNegCount(JournalFile file) |
boolean |
JournalFile.resetNegCount(JournalFile file) |
void |
JournalTransaction.rollback(JournalFile file)
The caller of this method needs to guarantee appendLock.lock before calling this method if being used outside of the lock context.
|
void |
Reclaimer.scan(JournalFile[] files) |
Modifier and Type | Method and Description |
---|---|
void |
JournalFilesRepository.calculateNextfileID(List<JournalFile> files) |
protected SequentialFile |
JournalImpl.createControlFile(List<JournalFile> files,
List<JournalFile> newFiles,
Pair<String,String> cleanupRename) |
protected SequentialFile |
JournalImpl.createControlFile(List<JournalFile> files,
List<JournalFile> newFiles,
Pair<String,String> cleanupRename) |
protected void |
JournalImpl.renameFiles(List<JournalFile> oldFiles,
List<JournalFile> newFiles)
being protected as testcases can override this method
|
protected void |
JournalImpl.renameFiles(List<JournalFile> oldFiles,
List<JournalFile> newFiles)
being protected as testcases can override this method
|
static SequentialFile |
AbstractJournalUpdateTask.writeControlFile(SequentialFileFactory fileFactory,
List<JournalFile> files,
List<JournalFile> newFiles,
List<Pair<String,String>> renames) |
static SequentialFile |
AbstractJournalUpdateTask.writeControlFile(SequentialFileFactory fileFactory,
List<JournalFile> files,
List<JournalFile> newFiles,
List<Pair<String,String>> renames) |
Constructor and Description |
---|
JournalRecord(JournalFile addFile,
int size) |
Copyright © 2012 JBoss by Red Hat. All Rights Reserved.