org.hornetq.core.journal.impl

Class JournalFileImpl

java.lang.Object

org.hornetq.core.journal.impl.JournalFileImpl

All Implemented Interfaces:

JournalFile

public class JournalFileImpl
extends Object
implements JournalFile

A JournalFileImpl

Author:

Tim Fox, Clebert Suconic

Constructor Summary

Constructors

Constructor and Description
JournalFileImpl(SequentialFile file, long fileID, int version)

Method Summary

Methods

Modifier and Type	Method and Description
void	addSize(int bytes)
void	clearCounts() Used during compacting (clearing counters)
String	debug() Receive debug information about the journal
void	decPosCount()
void	decSize(int bytes)
void	extendOffset(int delta)
SequentialFile	getFile()
long	getFileID()
int	getJournalVersion()
int	getLiveSize()
int	getNegCount(JournalFile file)
long	getOffset()
int	getPosCount()
int	getRecordID() This is a field to identify that records on this file actually belong to the current file.
int	getTotalNegativeToOthers() The total number of deletes this file has
void	incNegCount(JournalFile file)
void	incPosCount()
boolean	isCanReclaim()
boolean	resetNegCount(JournalFile file)
void	setCanReclaim(boolean canReclaim)
void	setOffset(long offset)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

JournalFileImpl

public JournalFileImpl(SequentialFile file,
               long fileID,
               int version)

Method Detail

clearCounts

public void clearCounts()

Description copied from interface: JournalFile

Used during compacting (clearing counters)

Specified by:

clearCounts in interface JournalFile

getPosCount

public int getPosCount()

Specified by:

getPosCount in interface JournalFile

isCanReclaim

public boolean isCanReclaim()

Specified by:

isCanReclaim in interface JournalFile

setCanReclaim

public void setCanReclaim(boolean canReclaim)

Specified by:

setCanReclaim in interface JournalFile

incNegCount

public void incNegCount(JournalFile file)

Specified by:

incNegCount in interface JournalFile

getNegCount

public int getNegCount(JournalFile file)

Specified by:

getNegCount in interface JournalFile

getJournalVersion

public int getJournalVersion()

Specified by:

getJournalVersion in interface JournalFile

resetNegCount

public boolean resetNegCount(JournalFile file)

Specified by:

resetNegCount in interface JournalFile

incPosCount

public void incPosCount()

Specified by:

incPosCount in interface JournalFile

decPosCount

public void decPosCount()

Specified by:

decPosCount in interface JournalFile

extendOffset

public void extendOffset(int delta)

getOffset

public long getOffset()

Specified by:

getOffset in interface JournalFile

getFileID

public long getFileID()

Specified by:

getFileID in interface JournalFile

getRecordID

public int getRecordID()

Description copied from interface: JournalFile

This is a field to identify that records on this file actually belong to the current file. The possible implementation for this is fileID & Integer.MAX_VALUE

Specified by:

getRecordID in interface JournalFile

setOffset

public void setOffset(long offset)

getFile

public SequentialFile getFile()

Specified by:

getFile in interface JournalFile

toString

public String toString()

Overrides:

toString in class Object

debug

public String debug()

Receive debug information about the journal

addSize

public void addSize(int bytes)

Specified by:

addSize in interface JournalFile

decSize

public void decSize(int bytes)

Specified by:

decSize in interface JournalFile

getLiveSize

public int getLiveSize()

Specified by:

getLiveSize in interface JournalFile

getTotalNegativeToOthers

public int getTotalNegativeToOthers()

Description copied from interface: JournalFile

The total number of deletes this file has

Specified by:

getTotalNegativeToOthers in interface JournalFile