org.hornetq.core.journal.impl

Class NIOSequentialFileFactory

java.lang.Object

org.hornetq.core.journal.impl.AbstractSequentialFileFactory

org.hornetq.core.journal.impl.NIOSequentialFileFactory

All Implemented Interfaces:

SequentialFileFactory

public class NIOSequentialFileFactory
extends AbstractSequentialFileFactory
implements SequentialFileFactory

A NIOSequentialFileFactory

Author:

Tim Fox, Clebert Suconic

Field Summary

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

bufferSize, bufferTimeout, EXECUTOR_TIMEOUT, journalDir, timedBuffer, writeExecutor

Constructor Summary

Constructors

Constructor and Description
NIOSequentialFileFactory(String journalDir)
NIOSequentialFileFactory(String journalDir, boolean buffered)
NIOSequentialFileFactory(String journalDir, boolean buffered, int bufferSize, int bufferTimeout, boolean logRates)
NIOSequentialFileFactory(String journalDir, boolean buffered, int bufferSize, int bufferTimeout, boolean logRates, IOCriticalErrorListener listener)
NIOSequentialFileFactory(String journalDir, boolean buffered, IOCriticalErrorListener listener)
NIOSequentialFileFactory(String journalDir, IOCriticalErrorListener listener)

Method Summary

Methods

Modifier and Type	Method and Description
ByteBuffer	allocateDirectBuffer(int size) used for cases where you need direct buffer outside of the journal context.
int	calculateBlockSize(int bytes)
void	clearBuffer(ByteBuffer buffer)
SequentialFile	createSequentialFile(String fileName, int maxIO)
int	getAlignment()
boolean	isSupportsCallbacks()
ByteBuffer	newBuffer(int size) Note: You need to release the buffer if is used for reading operations.
void	releaseDirectBuffer(ByteBuffer buffer) used for cases where you need direct buffer outside of the journal context.
ByteBuffer	wrapBuffer(byte[] bytes)

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

activateBuffer, createDirs, deactivateBuffer, flush, getDirectory, listFiles, onIOError, releaseBuffer, start, 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

activateBuffer, createDirs, deactivateBuffer, flush, getDirectory, listFiles, onIOError, releaseBuffer, start, stop

Constructor Detail

NIOSequentialFileFactory

public NIOSequentialFileFactory(String journalDir)

NIOSequentialFileFactory

public NIOSequentialFileFactory(String journalDir,
                        IOCriticalErrorListener listener)

NIOSequentialFileFactory

public NIOSequentialFileFactory(String journalDir,
                        boolean buffered)

NIOSequentialFileFactory

public NIOSequentialFileFactory(String journalDir,
                        boolean buffered,
                        IOCriticalErrorListener listener)

NIOSequentialFileFactory

public NIOSequentialFileFactory(String journalDir,
                        boolean buffered,
                        int bufferSize,
                        int bufferTimeout,
                        boolean logRates)

NIOSequentialFileFactory

public NIOSequentialFileFactory(String journalDir,
                        boolean buffered,
                        int bufferSize,
                        int bufferTimeout,
                        boolean logRates,
                        IOCriticalErrorListener listener)

Method Detail

createSequentialFile

public SequentialFile createSequentialFile(String fileName,
                                  int maxIO)

Specified by:

createSequentialFile in interface SequentialFileFactory

isSupportsCallbacks

public boolean isSupportsCallbacks()

Specified by:

isSupportsCallbacks in interface SequentialFileFactory

allocateDirectBuffer

public ByteBuffer allocateDirectBuffer(int size)

Description copied from interface: SequentialFileFactory

used for cases where you need direct buffer outside of the journal context. This is because the native layer has a method that can be reused in certain cases like paging

Specified by:

allocateDirectBuffer in interface SequentialFileFactory

releaseDirectBuffer

public void releaseDirectBuffer(ByteBuffer buffer)

Description copied from interface: SequentialFileFactory

used for cases where you need direct buffer outside of the journal context. This is because the native layer has a method that can be reused in certain cases like paging

Specified by:

releaseDirectBuffer in interface SequentialFileFactory

newBuffer

public ByteBuffer newBuffer(int size)

Description copied from interface: SequentialFileFactory

Note: You need to release the buffer if is used for reading operations. You don't need to do it if using writing operations (AIO Buffer Lister will take of writing operations)

Specified by:

newBuffer in interface SequentialFileFactory

Returns:

clearBuffer

public void clearBuffer(ByteBuffer buffer)

Specified by:

clearBuffer in interface SequentialFileFactory

wrapBuffer

public ByteBuffer wrapBuffer(byte[] bytes)

Specified by:

wrapBuffer in interface SequentialFileFactory

getAlignment

public int getAlignment()

Specified by:

getAlignment in interface SequentialFileFactory

calculateBlockSize

public int calculateBlockSize(int bytes)

Specified by:

calculateBlockSize in interface SequentialFileFactory