public final class FileWrapperJournal extends Object
JournalFile
.
Its main purpose is to store the data as a Journal would, but without verifying records.Journal.JournalState
Modifier and Type | Field and Description |
---|---|
protected JournalFile |
currentFile |
protected int |
fileSize |
Constructor and Description |
---|
FileWrapperJournal(Journal journal) |
Modifier and Type | Method and Description |
---|---|
void |
appendAddRecord(long id,
byte recordType,
byte[] record,
boolean sync) |
void |
appendAddRecord(long id,
byte recordType,
EncodingSupport record,
boolean sync) |
void |
appendAddRecord(long id,
byte recordType,
EncodingSupport record,
boolean sync,
IOCompletion callback) |
void |
appendAddRecordTransactional(long txID,
long id,
byte recordType,
byte[] record) |
void |
appendAddRecordTransactional(long txID,
long id,
byte recordType,
EncodingSupport record) |
void |
appendCommitRecord(long txID,
boolean sync) |
void |
appendCommitRecord(long txID,
boolean sync,
IOCompletion callback) |
void |
appendCommitRecord(long txID,
boolean sync,
IOCompletion callback,
boolean lineUpContext) |
void |
appendDeleteRecord(long id,
boolean sync) |
void |
appendDeleteRecord(long id,
boolean sync,
IOCompletion callback) |
void |
appendDeleteRecordTransactional(long txID,
long id) |
void |
appendDeleteRecordTransactional(long txID,
long id,
byte[] record) |
void |
appendDeleteRecordTransactional(long txID,
long id,
EncodingSupport record) |
void |
appendPrepareRecord(long txID,
byte[] transactionData,
boolean sync) |
void |
appendPrepareRecord(long txID,
EncodingSupport transactionData,
boolean sync)
If the system crashed after a prepare was called, it should store information that is required to bring the transaction
back to a state it could be committed.
|
void |
appendPrepareRecord(long txID,
EncodingSupport transactionData,
boolean sync,
IOCompletion callback) |
void |
appendRollbackRecord(long txID,
boolean sync) |
void |
appendRollbackRecord(long txID,
boolean sync,
IOCompletion callback) |
void |
appendUpdateRecord(long id,
byte recordType,
byte[] record,
boolean sync) |
void |
appendUpdateRecord(long id,
byte recordType,
EncodingSupport record,
boolean sync) |
void |
appendUpdateRecord(long id,
byte recordType,
EncodingSupport record,
boolean sync,
IOCompletion callback) |
void |
appendUpdateRecordTransactional(long txID,
long id,
byte recordType,
byte[] record) |
void |
appendUpdateRecordTransactional(long txID,
long id,
byte recordType,
EncodingSupport record) |
Map<Long,JournalFile> |
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.
|
void |
forceMoveNextFile()
Force the usage of a new
JournalFile . |
int |
getAlignment() |
JournalFile[] |
getDataFiles()
Returns the
JournalFile s in use. |
SequentialFileFactory |
getFileFactory() |
int |
getFileSize() |
int |
getNumberOfRecords() |
protected SyncIOCompletion |
getSyncCallback(boolean sync) |
int |
getUserVersion() |
boolean |
isStarted() |
void |
lineUpContext(IOCompletion callback) |
JournalLoadInformation |
load(List<RecordInfo> committedRecords,
List<PreparedTransactionInfo> preparedTransactions,
TransactionFailureCallback transactionFailure) |
JournalLoadInformation |
load(LoaderCallback reloadManager) |
JournalLoadInformation |
loadInternalOnly()
Load internal data structures and not expose any data.
|
JournalLoadInformation |
loadSyncOnly(Journal.JournalState state)
Load internal data structures, and remain waiting for synchronization to complete.
|
void |
perfBlast(int pages) |
void |
replicationSyncFinished()
Restarts file reclaim and compacting on the journal.
|
void |
replicationSyncPreserveOldFiles()
Stops any operation that may delete or modify old (stale) data.
|
void |
runDirectJournalBlast() |
void |
scheduleCompactAndBlock(int timeout)
This method will start compact using the compactorExecutor and block up to timeout seconds
|
void |
start() |
void |
stop() |
void |
synchronizationLock()
Write lock the Journal and write lock the compacting process.
|
void |
synchronizationUnlock()
Unlock the Journal and the compacting process.
|
String |
toString() |
protected volatile JournalFile currentFile
protected final int fileSize
public boolean isStarted()
public void appendAddRecord(long id, byte recordType, EncodingSupport record, boolean sync, IOCompletion callback) throws Exception
appendAddRecord
in interface Journal
Exception
public void appendDeleteRecord(long id, boolean sync, IOCompletion callback) throws Exception
appendDeleteRecord
in interface Journal
Exception
public void appendDeleteRecordTransactional(long txID, long id, EncodingSupport record) throws Exception
appendDeleteRecordTransactional
in interface Journal
Exception
public void appendAddRecordTransactional(long txID, long id, byte recordType, EncodingSupport record) throws Exception
appendAddRecordTransactional
in interface Journal
Exception
public void appendUpdateRecord(long id, byte recordType, EncodingSupport record, boolean sync, IOCompletion callback) throws Exception
appendUpdateRecord
in interface Journal
Exception
public void appendUpdateRecordTransactional(long txID, long id, byte recordType, EncodingSupport record) throws Exception
appendUpdateRecordTransactional
in interface Journal
Exception
public void appendCommitRecord(long txID, boolean sync, IOCompletion callback, boolean lineUpContext) throws Exception
appendCommitRecord
in interface Journal
lineUpContext
- if appendCommitRecord should call a storeLineUp. This is because the
caller may have already taken into accountException
public void appendPrepareRecord(long txID, EncodingSupport transactionData, boolean sync, IOCompletion callback) throws Exception
appendPrepareRecord
in interface Journal
Exception
public void appendRollbackRecord(long txID, boolean sync, IOCompletion callback) throws Exception
appendRollbackRecord
in interface Journal
Exception
public JournalLoadInformation load(LoaderCallback reloadManager) throws Exception
Exception
public JournalLoadInformation loadInternalOnly() throws Exception
Journal
Exception
public void lineUpContext(IOCompletion callback)
public JournalLoadInformation load(List<RecordInfo> committedRecords, List<PreparedTransactionInfo> preparedTransactions, TransactionFailureCallback transactionFailure) throws Exception
Exception
public int getNumberOfRecords()
public int getUserVersion()
public void perfBlast(int pages)
public JournalLoadInformation loadSyncOnly(Journal.JournalState state) throws Exception
Journal
state
- the current state of the journal, this parameter ensures consistency.Exception
public Map<Long,JournalFile> createFilesForBackupSync(long[] fileIds) throws Exception
Journal
During the synchronization between a live server and backup, we reserve in the backup the journal file IDs used in the live server. This call also makes sure the files are created empty without any kind of headers added.
fileIds
- IDs to reserve for synchronizationException
public void synchronizationLock()
Journal
public void synchronizationUnlock()
Journal
Journal.synchronizationLock()
public void forceMoveNextFile()
Journal
JournalFile
.public JournalFile[] getDataFiles()
Journal
JournalFile
s in use.JournalFile
s in usepublic SequentialFileFactory getFileFactory()
public void scheduleCompactAndBlock(int timeout) throws Exception
Journal
timeout
- the timeout in seconds or block forever if <= 0
Exception
public void replicationSyncPreserveOldFiles()
Journal
Meant to be used during synchronization of data between a live server and its replicating (remote) backup. Old files must not be compacted or deleted during synchronization.
public void replicationSyncFinished()
Journal
Meant to be used to revert the effect of Journal.replicationSyncPreserveOldFiles()
. it should
only be called once the synchronization of the backup and live servers is completed.
public void appendAddRecord(long id, byte recordType, byte[] record, boolean sync) throws Exception
appendAddRecord
in interface Journal
Exception
public void appendAddRecord(long id, byte recordType, EncodingSupport record, boolean sync) throws Exception
appendAddRecord
in interface Journal
Exception
public void appendCommitRecord(long txID, boolean sync) throws Exception
appendCommitRecord
in interface Journal
Exception
public void appendCommitRecord(long txID, boolean sync, IOCompletion callback) throws Exception
appendCommitRecord
in interface Journal
Exception
public void appendUpdateRecord(long id, byte recordType, byte[] record, boolean sync) throws Exception
appendUpdateRecord
in interface Journal
Exception
public void appendUpdateRecordTransactional(long txID, long id, byte recordType, byte[] record) throws Exception
appendUpdateRecordTransactional
in interface Journal
Exception
public void appendAddRecordTransactional(long txID, long id, byte recordType, byte[] record) throws Exception
appendAddRecordTransactional
in interface Journal
Exception
public void appendDeleteRecordTransactional(long txID, long id) throws Exception
appendDeleteRecordTransactional
in interface Journal
Exception
public void appendPrepareRecord(long txID, byte[] transactionData, boolean sync) throws Exception
appendPrepareRecord
in interface Journal
Exception
public void appendPrepareRecord(long txID, EncodingSupport transactionData, boolean sync) throws Exception
Journal
If the system crashed after a prepare was called, it should store information that is required to bring the transaction back to a state it could be committed.
transactionData allows you to store any other supporting user-data related to the transaction
appendPrepareRecord
in interface Journal
transactionData
- - extra user data for the prepareException
public void appendDeleteRecordTransactional(long txID, long id, byte[] record) throws Exception
appendDeleteRecordTransactional
in interface Journal
Exception
public void appendUpdateRecord(long id, byte recordType, EncodingSupport record, boolean sync) throws Exception
appendUpdateRecord
in interface Journal
Exception
public void appendRollbackRecord(long txID, boolean sync) throws Exception
appendRollbackRecord
in interface Journal
Exception
public void appendDeleteRecord(long id, boolean sync) throws Exception
appendDeleteRecord
in interface Journal
Exception
protected SyncIOCompletion getSyncCallback(boolean sync)
public int getFileSize()
getFileSize
in interface Journal
Copyright © 2016 JBoss by Red Hat. All rights reserved.