org.hornetq.core.journal.impl

Class AbstractSequentialFileFactory

java.lang.Object

org.hornetq.core.journal.impl.AbstractSequentialFileFactory

All Implemented Interfaces:

SequentialFileFactory

Direct Known Subclasses:

AIOSequentialFileFactory, NIOSequentialFileFactory

public abstract class AbstractSequentialFileFactory
extends Object
implements SequentialFileFactory

An abstract SequentialFileFactory containing basic functionality for both AIO and NIO SequentialFactories

Author:

Tim Fox, Clebert Suconic

Field Summary

Fields

Modifier and Type	Field and Description
protected int	bufferSize
protected long	bufferTimeout
protected static int	EXECUTOR_TIMEOUT
protected String	journalDir
protected TimedBuffer	timedBuffer
protected ExecutorService	writeExecutor Asynchronous writes need to be done at another executor.

Constructor Summary

Constructors

Constructor and Description
AbstractSequentialFileFactory(String journalDir, boolean buffered, int bufferSize, int bufferTimeout, boolean logRates, IOCriticalErrorListener criticalErrorListener)

Method Summary

Methods

Modifier and Type	Method and Description
void	activateBuffer(SequentialFile file)
void	createDirs() Create the directory if it doesn't exist yet
void	deactivateBuffer()
void	flush()
String	getDirectory()
List<String>	listFiles(String extension)
void	onIOError(int errorCode, String message, SequentialFile file) The SequentialFile will call this method when a disk IO Error happens during the live phase.
void	releaseBuffer(ByteBuffer buffer)
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.hornetq.core.journal.SequentialFileFactory

allocateDirectBuffer, calculateBlockSize, clearBuffer, createSequentialFile, getAlignment, isSupportsCallbacks, newBuffer, releaseDirectBuffer, wrapBuffer

Field Detail

EXECUTOR_TIMEOUT

protected static final int EXECUTOR_TIMEOUT

See Also:

Constant Field Values

journalDir

protected final String journalDir

timedBuffer

protected final TimedBuffer timedBuffer

bufferSize

protected final int bufferSize

bufferTimeout

protected final long bufferTimeout

writeExecutor

protected ExecutorService writeExecutor

Asynchronous writes need to be done at another executor. This needs to be done at NIO, or else we would have the callers thread blocking for the return. At AIO this is necessary as context switches on writes would fire flushes at the kernel.

Constructor Detail

AbstractSequentialFileFactory

public AbstractSequentialFileFactory(String journalDir,
                             boolean buffered,
                             int bufferSize,
                             int bufferTimeout,
                             boolean logRates,
                             IOCriticalErrorListener criticalErrorListener)

Method Detail

stop

public void stop()

Specified by:

stop in interface SequentialFileFactory

getDirectory

public String getDirectory()

Specified by:

getDirectory in interface SequentialFileFactory

start

public void start()

Specified by:

start in interface SequentialFileFactory

onIOError

public void onIOError(int errorCode,
             String message,
             SequentialFile file)

Description copied from interface: SequentialFileFactory

The SequentialFile will call this method when a disk IO Error happens during the live phase.

Specified by:

onIOError in interface SequentialFileFactory

activateBuffer

public void activateBuffer(SequentialFile file)

Specified by:

activateBuffer in interface SequentialFileFactory

flush

public void flush()

Specified by:

flush in interface SequentialFileFactory

deactivateBuffer

public void deactivateBuffer()

Specified by:

deactivateBuffer in interface SequentialFileFactory

releaseBuffer

public void releaseBuffer(ByteBuffer buffer)

Specified by:

releaseBuffer in interface SequentialFileFactory

createDirs

public void createDirs()
                throws Exception

Create the directory if it doesn't exist yet

Specified by:

createDirs in interface SequentialFileFactory

Throws:

Exception

listFiles

public List<String> listFiles(String extension)
                       throws Exception

Specified by:

listFiles in interface SequentialFileFactory

Throws:

Exception