|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.jboss.messaging.core.journal.impl.JournalCompactor
public class JournalCompactor
A JournalCompactor
Constructor Summary | |
---|---|
JournalCompactor(SequentialFileFactory fileFactory,
JournalImpl journal,
java.util.Set<java.lang.Long> recordsSnapshot,
int firstFileID)
|
Method Summary | |
---|---|
void |
addCommandCommit(JournalTransaction liveTransaction,
JournalFile currentFile)
|
void |
addCommandDelete(long id,
JournalFile usedFile)
|
void |
addCommandRollback(JournalTransaction liveTransaction,
JournalFile currentFile)
|
void |
addCommandUpdate(long id,
JournalFile usedFile,
int size)
|
void |
addPendingTransaction(long transactionID,
long[] ids)
This methods informs the Compactor about the existence of a pending (non committed) transaction |
void |
flush()
Write pending output into file |
java.util.List<JournalFile> |
getNewDataFiles()
|
java.util.Map<java.lang.Long,JournalImpl.JournalRecord> |
getNewRecords()
|
java.util.Map<java.lang.Long,JournalTransaction> |
getNewTransactions()
|
boolean |
lookupRecord(long id)
|
void |
markAsDataFile(JournalFile file)
|
void |
onReadAddRecord(RecordInfo info)
|
void |
onReadAddRecordTX(long transactionID,
RecordInfo info)
|
void |
onReadCommitRecord(long transactionID,
int numberOfRecords)
|
void |
onReadDeleteRecord(long recordID)
|
void |
onReadDeleteRecordTX(long transactionID,
RecordInfo info)
|
void |
onReadPrepareRecord(long transactionID,
byte[] extraData,
int numberOfRecords)
|
void |
onReadRollbackRecord(long transactionID)
|
void |
onReadUpdateRecord(RecordInfo info)
|
void |
onReadUpdateRecordTX(long transactionID,
RecordInfo info)
|
static SequentialFile |
readControlFile(SequentialFileFactory fileFactory,
java.util.List<java.lang.String> dataFiles,
java.util.List<java.lang.String> newFiles)
|
void |
replayPendingCommands()
Replay pending counts that happened during compacting |
static SequentialFile |
writeControlFile(SequentialFileFactory fileFactory,
java.util.List<JournalFile> files,
java.util.List<JournalFile> newFiles)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public JournalCompactor(SequentialFileFactory fileFactory, JournalImpl journal, java.util.Set<java.lang.Long> recordsSnapshot, int firstFileID)
Method Detail |
---|
public static SequentialFile writeControlFile(SequentialFileFactory fileFactory, java.util.List<JournalFile> files, java.util.List<JournalFile> newFiles) throws java.lang.Exception
tmpRenameFile
- files
- newFiles
-
java.lang.Exception
public static SequentialFile readControlFile(SequentialFileFactory fileFactory, java.util.List<java.lang.String> dataFiles, java.util.List<java.lang.String> newFiles) throws java.lang.Exception
java.lang.Exception
public java.util.List<JournalFile> getNewDataFiles()
public java.util.Map<java.lang.Long,JournalImpl.JournalRecord> getNewRecords()
public java.util.Map<java.lang.Long,JournalTransaction> getNewTransactions()
public void addPendingTransaction(long transactionID, long[] ids)
public void addCommandCommit(JournalTransaction liveTransaction, JournalFile currentFile)
id
- journalTransaction
- public void addCommandRollback(JournalTransaction liveTransaction, JournalFile currentFile)
public void addCommandDelete(long id, JournalFile usedFile)
id
- usedFile
- public void addCommandUpdate(long id, JournalFile usedFile, int size)
id
- usedFile
- public boolean lookupRecord(long id)
public void flush() throws java.lang.Exception
java.lang.Exception
public void replayPendingCommands()
public void onReadAddRecord(RecordInfo info) throws java.lang.Exception
onReadAddRecord
in interface JournalReaderCallback
java.lang.Exception
public void onReadAddRecordTX(long transactionID, RecordInfo info) throws java.lang.Exception
onReadAddRecordTX
in interface JournalReaderCallback
java.lang.Exception
public void onReadCommitRecord(long transactionID, int numberOfRecords) throws java.lang.Exception
onReadCommitRecord
in interface JournalReaderCallback
java.lang.Exception
public void onReadDeleteRecord(long recordID) throws java.lang.Exception
onReadDeleteRecord
in interface JournalReaderCallback
java.lang.Exception
public void onReadDeleteRecordTX(long transactionID, RecordInfo info) throws java.lang.Exception
onReadDeleteRecordTX
in interface JournalReaderCallback
java.lang.Exception
public void markAsDataFile(JournalFile file)
markAsDataFile
in interface JournalReaderCallback
public void onReadPrepareRecord(long transactionID, byte[] extraData, int numberOfRecords) throws java.lang.Exception
onReadPrepareRecord
in interface JournalReaderCallback
java.lang.Exception
public void onReadRollbackRecord(long transactionID) throws java.lang.Exception
onReadRollbackRecord
in interface JournalReaderCallback
java.lang.Exception
public void onReadUpdateRecord(RecordInfo info) throws java.lang.Exception
onReadUpdateRecord
in interface JournalReaderCallback
java.lang.Exception
public void onReadUpdateRecordTX(long transactionID, RecordInfo info) throws java.lang.Exception
onReadUpdateRecordTX
in interface JournalReaderCallback
java.lang.Exception
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |