org.hornetq.core.journal.impl

Class AIOSequentialFileFactory

java.lang.Object

org.hornetq.core.journal.impl.AbstractSequentialFileFactory

org.hornetq.core.journal.impl.AIOSequentialFileFactory

All Implemented Interfaces:

SequentialFileFactory

public class AIOSequentialFileFactory
extends AbstractSequentialFileFactory

A AIOSequentialFileFactory

Author:

clebert.suconic@jboss.com

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
AIOSequentialFileFactory(String journalDir)
AIOSequentialFileFactory(String journalDir, int bufferSize, int bufferTimeout, boolean logRates)
AIOSequentialFileFactory(String journalDir, int bufferSize, int bufferTimeout, boolean logRates, IOCriticalErrorListener listener)
AIOSequentialFileFactory(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 position)
void	clearBuffer(ByteBuffer directByteBuffer)
SequentialFile	createSequentialFile(String fileName, int maxIO)
protected void	finalize()
int	getAlignment()
static boolean	isSupported()
boolean	isSupportsCallbacks()
ByteBuffer	newBuffer(int size) Note: You need to release the buffer if is used for reading operations.
void	releaseBuffer(ByteBuffer buffer)
void	releaseDirectBuffer(ByteBuffer buffer) used for cases where you need direct buffer outside of the journal context.
void	start()
void	stop()
ByteBuffer	wrapBuffer(byte[] bytes)

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

activateBuffer, createDirs, deactivateBuffer, flush, getDirectory, listFiles, onIOError

Methods inherited from class java.lang.Object

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

Constructor Detail

AIOSequentialFileFactory

public AIOSequentialFileFactory(String journalDir)

AIOSequentialFileFactory

public AIOSequentialFileFactory(String journalDir,
                        IOCriticalErrorListener listener)

AIOSequentialFileFactory

public AIOSequentialFileFactory(String journalDir,
                        int bufferSize,
                        int bufferTimeout,
                        boolean logRates)

AIOSequentialFileFactory

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

Method Detail

createSequentialFile

public SequentialFile createSequentialFile(String fileName,
                                  int maxIO)

isSupportsCallbacks

public boolean isSupportsCallbacks()

isSupported

public static boolean isSupported()

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

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

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)

Returns:

clearBuffer

public void clearBuffer(ByteBuffer directByteBuffer)

getAlignment

public int getAlignment()

wrapBuffer

public ByteBuffer wrapBuffer(byte[] bytes)

calculateBlockSize

public int calculateBlockSize(int position)

releaseBuffer

public void releaseBuffer(ByteBuffer buffer)

Specified by:

releaseBuffer in interface SequentialFileFactory

Overrides:

releaseBuffer in class AbstractSequentialFileFactory

start

public void start()

Specified by:

start in interface SequentialFileFactory

Overrides:

start in class AbstractSequentialFileFactory

stop

public void stop()

Specified by:

stop in interface SequentialFileFactory

Overrides:

stop in class AbstractSequentialFileFactory

finalize

protected void finalize()

Overrides:

finalize in class Object