org.hornetq.core.journal.impl

Class AIOSequentialFile

java.lang.Object

org.hornetq.core.journal.impl.AbstractSequentialFile

org.hornetq.core.journal.impl.AIOSequentialFile

All Implemented Interfaces:

IOExceptionListener, SequentialFile

public class AIOSequentialFile
extends AbstractSequentialFile
implements IOExceptionListener

A AIOSequentialFile

Author:

Clebert Suconic

Nested Class Summary

Nested classes/interfaces inherited from class org.hornetq.core.journal.impl.AbstractSequentialFile

AbstractSequentialFile.LocalBufferObserver

Field Summary

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

factory, fileSize, position, timedBuffer, timedBufferObserver, writerExecutor

Constructor Summary

Constructors

Constructor and Description
AIOSequentialFile(SequentialFileFactory factory, int bufferSize, long bufferTimeoutMilliseconds, String directory, String fileName, int maxIO, BufferCallback bufferCallback, Executor writerExecutor, Executor pollerExecutor)

Method Summary

Modifier and Type	Method and Description
int	calculateBlockStart(int position)
SequentialFile	cloneFile()
void	close()
void	fill(int position, int size, byte fillCharacter)
int	getAlignment()
boolean	isOpen()
protected ByteBuffer	newBuffer(int size, int limit)
void	onIOException(Exception code, String message)
void	open()
void	open(int maxIO, boolean useExecutor) The maximum number of simultaneous writes accepted
int	read(ByteBuffer bytes)
int	read(ByteBuffer bytes, IOAsyncTask callback)
void	setBufferCallback(BufferCallback callback)
long	size()
void	sync()
String	toString()
void	waitForClose()
void	writeDirect(ByteBuffer bytes, boolean sync) Write directly to the file without using any buffer
void	writeDirect(ByteBuffer bytes, boolean sync, IOAsyncTask callback) Write directly to the file without using any buffer
void	writeInternal(ByteBuffer bytes) Write directly to the file.

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

copyTo, delete, exists, fits, getFile, getFileName, getJavaFile, position, position, renameTo, setTimedBuffer, write, write, write, write

Methods inherited from class java.lang.Object

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

Constructor Detail

AIOSequentialFile

public AIOSequentialFile(SequentialFileFactory factory,
                         int bufferSize,
                         long bufferTimeoutMilliseconds,
                         String directory,
                         String fileName,
                         int maxIO,
                         BufferCallback bufferCallback,
                         Executor writerExecutor,
                         Executor pollerExecutor)

Method Detail

isOpen

public boolean isOpen()

Specified by:

isOpen in interface SequentialFile

getAlignment

public int getAlignment()

Specified by:

getAlignment in interface SequentialFile

calculateBlockStart

public int calculateBlockStart(int position)

Specified by:

calculateBlockStart in interface SequentialFile

cloneFile

public SequentialFile cloneFile()

Specified by:

cloneFile in interface SequentialFile

close

public void close()
           throws IOException,
                  InterruptedException,
                  HornetQException

Specified by:

close in interface SequentialFile

Overrides:

close in class AbstractSequentialFile

Throws:

IOException - we declare throwing IOException because sub-classes need to do it

InterruptedException

HornetQException

waitForClose

public void waitForClose()
                  throws Exception

Specified by:

waitForClose in interface SequentialFile

Throws:

Exception

fill

public void fill(int position,
                 int size,
                 byte fillCharacter)
          throws Exception

Specified by:

fill in interface SequentialFile

Throws:

Exception

open

public void open()
          throws Exception

Specified by:

open in interface SequentialFile

Throws:

Exception

open

public void open(int maxIO,
                 boolean useExecutor)
          throws HornetQException

Description copied from interface: SequentialFile

The maximum number of simultaneous writes accepted

Specified by:

open in interface SequentialFile

Throws:

HornetQException

setBufferCallback

public void setBufferCallback(BufferCallback callback)

read

public int read(ByteBuffer bytes,
                IOAsyncTask callback)
         throws HornetQException

Specified by:

read in interface SequentialFile

Parameters:

bytes - the ByteBuffer must be compatible with the SequentialFile implementation (AIO or NIO). To be safe, use a buffer from the corresponding SequentialFileFactory.newBuffer(int).

Throws:

HornetQException

read

public int read(ByteBuffer bytes)
         throws Exception

Specified by:

read in interface SequentialFile

Parameters:

bytes - the ByteBuffer must be compatible with the SequentialFile implementation (AIO or NIO). To be safe, use a buffer from the corresponding SequentialFileFactory.newBuffer(int).

Throws:

Exception

sync

public void sync()

Specified by:

sync in interface SequentialFile

size

public long size()
          throws Exception

Specified by:

size in interface SequentialFile

Throws:

Exception

toString

public String toString()

Overrides:

toString in class Object

onIOException

public void onIOException(Exception code,
                          String message)

Specified by:

onIOException in interface IOExceptionListener

writeDirect

public void writeDirect(ByteBuffer bytes,
                        boolean sync)
                 throws Exception

Description copied from interface: SequentialFile

Write directly to the file without using any buffer

Specified by:

writeDirect in interface SequentialFile

Parameters:

bytes - the ByteBuffer must be compatible with the SequentialFile implementation (AIO or NIO). To be safe, use a buffer from the corresponding SequentialFileFactory.newBuffer(int).

Throws:

Exception

writeDirect

public void writeDirect(ByteBuffer bytes,
                        boolean sync,
                        IOAsyncTask callback)

Description copied from interface: SequentialFile

Write directly to the file without using any buffer

Specified by:

writeDirect in interface SequentialFile

Parameters:

sync - Not used on AIO

bytes - the ByteBuffer must be compatible with the SequentialFile implementation (AIO or NIO). To be safe, use a buffer from the corresponding SequentialFileFactory.newBuffer(int).

writeInternal

public void writeInternal(ByteBuffer bytes)
                   throws HornetQException

Description copied from interface: SequentialFile

Write directly to the file. This is used by compacting and other places where we write a big buffer in a single shot. writeInternal should always block until the entire write is sync on disk.

Specified by:

writeInternal in interface SequentialFile

Parameters:

bytes - the ByteBuffer must be compatible with the SequentialFile implementation (AIO or NIO). To be safe, use a buffer from the corresponding SequentialFileFactory.newBuffer(int).

Throws:

HornetQException

newBuffer

protected ByteBuffer newBuffer(int size,
                               int limit)

Overrides:

newBuffer in class AbstractSequentialFile