org.hornetq.core.journal.impl

Class NIOSequentialFile

java.lang.Object

org.hornetq.core.journal.impl.AbstractSequentialFile

org.hornetq.core.journal.impl.NIOSequentialFile

All Implemented Interfaces:

SequentialFile

public final class NIOSequentialFile
extends AbstractSequentialFile

A NIOSequentialFile

Author:

Tim Fox, 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
NIOSequentialFile(SequentialFileFactory factory, File file, int maxIO, Executor writerExecutor)
NIOSequentialFile(SequentialFileFactory factory, String directory, String fileName, int maxIO, Executor writerExecutor)

Method Summary

Methods

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	open() this.maxIO represents the default maxIO.
void	open(int maxIO, boolean useExecutor) The maximum number of simultaneous writes accepted
void	position(long pos)
int	read(ByteBuffer bytes)
int	read(ByteBuffer bytes, IOAsyncTask 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, 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

NIOSequentialFile

public NIOSequentialFile(SequentialFileFactory factory,
                 String directory,
                 String fileName,
                 int maxIO,
                 Executor writerExecutor)

NIOSequentialFile

public NIOSequentialFile(SequentialFileFactory factory,
                 File file,
                 int maxIO,
                 Executor writerExecutor)

Method Detail

getAlignment

public int getAlignment()

calculateBlockStart

public int calculateBlockStart(int position)

isOpen

public boolean isOpen()

open

public void open()
          throws IOException

this.maxIO represents the default maxIO. Some operations while initializing files on the journal may require a different maxIO

Throws:

IOException

open

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

Description copied from interface: SequentialFile

The maximum number of simultaneous writes accepted

Throws:

IOException

fill

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

Throws:

IOException

waitForClose

public void waitForClose()
                  throws InterruptedException

Throws:

InterruptedException

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

read

public int read(ByteBuffer bytes)
         throws Exception

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

read

public int read(ByteBuffer bytes,
       IOAsyncTask callback)
         throws IOException,
                HornetQIllegalStateException

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:

IOException

HornetQIllegalStateException

sync

public void sync()
          throws IOException

Throws:

IOException

size

public long size()
          throws IOException

Throws:

IOException

position

public void position(long pos)
              throws IOException

Specified by:

position in interface SequentialFile

Overrides:

position in class AbstractSequentialFile

Throws:

IOException - only declare exception due to signature. Sub-class needs it.

toString

public String toString()

Overrides:

toString in class Object

cloneFile

public SequentialFile cloneFile()

writeDirect

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

Description copied from interface: SequentialFile

Write directly to the file without using any buffer

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).

writeDirect

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

Description copied from interface: SequentialFile

Write directly to the file without using any buffer

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

writeInternal

public void writeInternal(ByteBuffer bytes)
                   throws Exception

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.

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

newBuffer

protected ByteBuffer newBuffer(int size,
                   int limit)

Overrides:

newBuffer in class AbstractSequentialFile