Modifier and Type | Method and Description |
---|---|
static void |
EncodeJournal.exportJournalFile(PrintStream out,
SequentialFileFactory fileFactory,
JournalFile file) |
Modifier and Type | Method and Description |
---|---|
JournalFile |
TestableJournal.getCurrentFile() |
JournalFile[] |
TestableJournal.getDataFiles() |
JournalFile[] |
Journal.getDataFiles()
Returns the
JournalFile s in use. |
Modifier and Type | Method and Description |
---|---|
Map<Long,JournalFile> |
Journal.createFilesForBackupSync(long[] fileIds)
Reserves journal file IDs, creates the necessary files for synchronization, and places
references to these (reserved for sync) files in the map.
|
Modifier and Type | Class and Description |
---|---|
class |
JournalFileImpl |
Modifier and Type | Field and Description |
---|---|
protected JournalFile |
FileWrapperJournal.currentFile |
protected JournalFile |
AbstractJournalUpdateTask.currentFile |
Modifier and Type | Field and Description |
---|---|
protected List<JournalFile> |
AbstractJournalUpdateTask.newDataFiles |
Modifier and Type | Method and Description |
---|---|
JournalFile |
JournalFilesRepository.createRemoteBackupSyncFile(long fileID)
Creates files for journal synchronization of a replicated backup.
|
JournalFile |
JournalImpl.getCurrentFile() |
JournalFile[] |
JournalImpl.getDataFiles() |
JournalFile[] |
FileWrapperJournal.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() |
protected JournalFile |
JournalImpl.setUpCurrentFile(int lastDataPos) |
protected JournalFile |
JournalImpl.switchFileIfNecessary(int size) |
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 |
---|---|
Map<Long,JournalFile> |
JournalImpl.createFilesForBackupSync(long[] fileIds)
Returns Map with a
JournalFile for all existing files. |
Map<Long,JournalFile> |
FileWrapperJournal.createFilesForBackupSync(long[] fileIds) |
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.
|
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) |
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) |
Constructor and Description |
---|
ReplicationStartSyncMessage(JournalFile[] datafiles,
JournalStorageManager.JournalContent contentType,
String nodeID,
boolean allowsAutoFailBack) |
Modifier and Type | Method and Description |
---|---|
JournalFile[] |
ReplicatedJournal.getDataFiles() |
Modifier and Type | Method and Description |
---|---|
Map<Long,JournalFile> |
ReplicatedJournal.createFilesForBackupSync(long[] fileIds) |
Modifier and Type | Method and Description |
---|---|
void |
ReplicationManager.sendStartSyncMessage(JournalFile[] datafiles,
JournalStorageManager.JournalContent contentType,
String nodeID,
boolean allowsAutoFailBack)
Reserve the following fileIDs in the backup server.
|
void |
ReplicationManager.syncJournalFile(JournalFile jf,
JournalStorageManager.JournalContent content)
Sends the whole content of the file to be duplicated.
|
Constructor and Description |
---|
JournalSyncFile(JournalFile jFile) |
Modifier and Type | Method and Description |
---|---|
void |
ActiveMQServerLogger.journalSynch(JournalFile jf,
Long size,
SequentialFile file) |
Modifier and Type | Method and Description |
---|---|
void |
ActiveMQJournalLogger.compactReadError(JournalFile file) |
void |
ActiveMQJournalLogger.couldNotRemoveFile(JournalFile file) |
void |
ActiveMQJournalLogger.deletingFile(JournalFile file) |
void |
ActiveMQJournalLogger.errorReinitializingFile(Throwable e,
JournalFile file) |
void |
ActiveMQJournalLogger.failedToAddFile(JournalFile nextOpenedFile) |
Copyright © 2016 JBoss by Red Hat. All rights reserved.