org.hornetq.core.asyncio

Interface AsynchronousFile

All Known Implementing Classes:

AsynchronousFileImpl

public interface AsynchronousFile

Author:

clebert.suconic@jboss.com

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
void	fill(long position, int blocks, long size, byte fillChar)
int	getBlockSize()
String	getFileName()
void	open(String fileName, int maxIO) Note: If you are using a native Linux implementation, maxIO can't be higher than what's defined on /proc/sys/fs/aio-max-nr, or you would get an error
void	read(long position, long size, ByteBuffer directByteBuffer, AIOCallback aioCallback)
void	setBufferCallback(BufferCallback callback)
long	size() Warning: This function will perform a synchronous IO, probably translating to a fstat call
void	write(long position, long size, ByteBuffer directByteBuffer, AIOCallback aioCallback) Any error will be reported on the callback interface
void	writeInternal(long positionToWrite, long size, ByteBuffer bytes) Performs an internal direct write.

Method Detail

close

void close()
           throws Exception

Throws:

Exception

open

void open(String fileName,
        int maxIO)
          throws HornetQException

Note: If you are using a native Linux implementation, maxIO can't be higher than what's defined on /proc/sys/fs/aio-max-nr, or you would get an error

Parameters:

fileName -

maxIO - The number of max concurrent asynchronous IO operations. It has to be balanced between the size of your writes and the capacity of your disk.

Throws:

HornetQException

size

long size()
          throws HornetQException

Warning: This function will perform a synchronous IO, probably translating to a fstat call

Throws:

HornetQException

write

void write(long position,
         long size,
         ByteBuffer directByteBuffer,
         AIOCallback aioCallback)

Any error will be reported on the callback interface

writeInternal

void writeInternal(long positionToWrite,
                 long size,
                 ByteBuffer bytes)
                   throws HornetQException

Performs an internal direct write.

Throws:

HornetQException

read

void read(long position,
        long size,
        ByteBuffer directByteBuffer,
        AIOCallback aioCallback)
          throws HornetQException

Throws:

HornetQException

fill

void fill(long position,
        int blocks,
        long size,
        byte fillChar)
          throws HornetQException

Throws:

HornetQException

setBufferCallback

void setBufferCallback(BufferCallback callback)

getBlockSize

int getBlockSize()

getFileName

String getFileName()