org.hornetq.core.journal.impl

Class JournalCompactor

java.lang.Object

org.hornetq.core.journal.impl.AbstractJournalUpdateTask

org.hornetq.core.journal.impl.JournalCompactor

All Implemented Interfaces:

JournalReaderCallback, JournalRecordProvider

public class JournalCompactor
extends AbstractJournalUpdateTask
implements JournalRecordProvider

A JournalCompactor

Author:

Clebert Suconic

Field Summary

Fields inherited from class org.hornetq.core.journal.impl.AbstractJournalUpdateTask

currentFile, FILE_COMPACT_CONTROL, fileFactory, filesRepository, journal, newDataFiles, nextOrderingID, sequentialFile

Constructor Summary

Constructors

Constructor and Description
JournalCompactor(SequentialFileFactory fileFactory, JournalImpl journal, JournalFilesRepository filesRepository, Set<Long> recordsSnapshot, long firstFileID)

Method Summary

Methods

Modifier and Type	Method and Description
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
JournalCompactor	getCompactor()
List<JournalFile>	getNewDataFiles()
Map<Long,JournalRecord>	getNewRecords()
Map<Long,JournalTransaction>	getNewTransactions()
Map<Long,JournalRecord>	getRecords()
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, List<String> dataFiles, List<String> newFiles, List<Pair<String,String>> renameFile)
void	replayPendingCommands() Replay pending counts that happened during compacting

Methods inherited from class org.hornetq.core.journal.impl.AbstractJournalUpdateTask

addToRecordsSnaptshot, flush, getWritingChannel, lookupRecord, openFile, writeControlFile, writeEncoder, writeEncoder

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

JournalCompactor

public JournalCompactor(SequentialFileFactory fileFactory,
                JournalImpl journal,
                JournalFilesRepository filesRepository,
                Set<Long> recordsSnapshot,
                long firstFileID)

Method Detail

readControlFile

public static SequentialFile readControlFile(SequentialFileFactory fileFactory,
                             List<String> dataFiles,
                             List<String> newFiles,
                             List<Pair<String,String>> renameFile)
                                      throws Exception

Throws:

Exception

getNewDataFiles

public List<JournalFile> getNewDataFiles()

getNewRecords

public Map<Long,JournalRecord> getNewRecords()

getNewTransactions

public Map<Long,JournalTransaction> getNewTransactions()

addPendingTransaction

public void addPendingTransaction(long transactionID,
                         long[] ids)

This methods informs the Compactor about the existence of a pending (non committed) transaction

addCommandCommit

public void addCommandCommit(JournalTransaction liveTransaction,
                    JournalFile currentFile)

addCommandRollback

public void addCommandRollback(JournalTransaction liveTransaction,
                      JournalFile currentFile)

addCommandDelete

public void addCommandDelete(long id,
                    JournalFile usedFile)

Parameters:

id -

usedFile -

addCommandUpdate

public void addCommandUpdate(long id,
                    JournalFile usedFile,
                    int size)

Parameters:

id -

usedFile -

replayPendingCommands

public void replayPendingCommands()

Replay pending counts that happened during compacting

onReadAddRecord

public void onReadAddRecord(RecordInfo info)
                     throws Exception

Specified by:

onReadAddRecord in interface JournalReaderCallback

Throws:

Exception

onReadAddRecordTX

public void onReadAddRecordTX(long transactionID,
                     RecordInfo info)
                       throws Exception

Specified by:

onReadAddRecordTX in interface JournalReaderCallback

Throws:

Exception

onReadCommitRecord

public void onReadCommitRecord(long transactionID,
                      int numberOfRecords)
                        throws Exception

Specified by:

onReadCommitRecord in interface JournalReaderCallback

Throws:

Exception

onReadDeleteRecord

public void onReadDeleteRecord(long recordID)
                        throws Exception

Specified by:

onReadDeleteRecord in interface JournalReaderCallback

Throws:

Exception

onReadDeleteRecordTX

public void onReadDeleteRecordTX(long transactionID,
                        RecordInfo info)
                          throws Exception

Specified by:

onReadDeleteRecordTX in interface JournalReaderCallback

Throws:

Exception

markAsDataFile

public void markAsDataFile(JournalFile file)

Specified by:

markAsDataFile in interface JournalReaderCallback

onReadPrepareRecord

public void onReadPrepareRecord(long transactionID,
                       byte[] extraData,
                       int numberOfRecords)
                         throws Exception

Specified by:

onReadPrepareRecord in interface JournalReaderCallback

Throws:

Exception

onReadRollbackRecord

public void onReadRollbackRecord(long transactionID)
                          throws Exception

Specified by:

onReadRollbackRecord in interface JournalReaderCallback

Throws:

Exception

onReadUpdateRecord

public void onReadUpdateRecord(RecordInfo info)
                        throws Exception

Specified by:

onReadUpdateRecord in interface JournalReaderCallback

Throws:

Exception

onReadUpdateRecordTX

public void onReadUpdateRecordTX(long transactionID,
                        RecordInfo info)
                          throws Exception

Specified by:

onReadUpdateRecordTX in interface JournalReaderCallback

Throws:

Exception

getCompactor

public JournalCompactor getCompactor()

Specified by:

getCompactor in interface JournalRecordProvider

getRecords

public Map<Long,JournalRecord> getRecords()

Specified by:

getRecords in interface JournalRecordProvider