org.hornetq.core.journal

Interface SequentialFileFactory

All Known Implementing Classes:

AbstractSequentialFileFactory, AIOSequentialFileFactory, NIOSequentialFileFactory

public interface SequentialFileFactory

A SequentialFileFactory

Author:

Tim Fox, Clebert Suconic

Method Summary

Methods

Modifier and Type	Method and Description
void	activateBuffer(SequentialFile file)
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)
void	createDirs() Create the directory if it doesn't exist yet
SequentialFile	createSequentialFile(String fileName, int maxIO)
void	deactivateBuffer()
void	flush()
int	getAlignment()
String	getDirectory()
boolean	isSupportsCallbacks()
List<String>	listFiles(String extension)
ByteBuffer	newBuffer(int size) Note: You need to release the buffer if is used for reading operations.
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	releaseDirectBuffer(ByteBuffer buffer) used for cases where you need direct buffer outside of the journal context.
void	start()
void	stop()
ByteBuffer	wrapBuffer(byte[] bytes)

Method Detail

createSequentialFile

SequentialFile createSequentialFile(String fileName,
                                  int maxIO)

listFiles

List<String> listFiles(String extension)
                       throws Exception

Throws:

Exception

isSupportsCallbacks

boolean isSupportsCallbacks()

onIOError

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

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

allocateDirectBuffer

ByteBuffer allocateDirectBuffer(int size)

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

void releaseDirectBuffer(ByteBuffer buffer)

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

ByteBuffer newBuffer(int size)

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)

Parameters:

size -

Returns:

releaseBuffer

void releaseBuffer(ByteBuffer buffer)

activateBuffer

void activateBuffer(SequentialFile file)

deactivateBuffer

void deactivateBuffer()

wrapBuffer

ByteBuffer wrapBuffer(byte[] bytes)

getAlignment

int getAlignment()

calculateBlockSize

int calculateBlockSize(int bytes)

getDirectory

String getDirectory()

clearBuffer

void clearBuffer(ByteBuffer buffer)

start

void start()

stop

void stop()

createDirs

void createDirs()
                throws Exception

Create the directory if it doesn't exist yet

Throws:

Exception

flush

void flush()