org.hornetq.core.journal.impl

Class AbstractSequentialFile

java.lang.Object

org.hornetq.core.journal.impl.AbstractSequentialFile

All Implemented Interfaces:

SequentialFile

Direct Known Subclasses:

AIOSequentialFile, NIOSequentialFile

public abstract class AbstractSequentialFile
extends Object
implements SequentialFile

A AbstractSequentialFile

Author:

Clebert Suconic

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	AbstractSequentialFile.LocalBufferObserver

Field Summary

Fields

Modifier and Type	Field and Description
protected SequentialFileFactory	factory
protected long	fileSize
protected AtomicLong	position
protected TimedBuffer	timedBuffer
protected TimedBufferObserver	timedBufferObserver Instead of having AIOSequentialFile implementing the Observer, I have done it on an inner class.
protected Executor	writerExecutor Used for asynchronous writes

Constructor Summary

Constructors

Constructor and Description
AbstractSequentialFile(String directory, File file, SequentialFileFactory factory, Executor writerExecutor)

Method Summary

Modifier and Type	Method and Description
void	close()
void	copyTo(SequentialFile newFileName)
void	delete()
boolean	exists()
boolean	fits(int size)
protected File	getFile()
String	getFileName()
File	getJavaFile() Returns a native File of the file underlying this sequential file.
protected ByteBuffer	newBuffer(int size, int limit)
long	position()
void	position(long pos)
void	renameTo(String newFileName)
void	setTimedBuffer(TimedBuffer buffer)
void	write(EncodingSupport bytes, boolean sync)
void	write(EncodingSupport bytes, boolean sync, IOAsyncTask callback)
void	write(HornetQBuffer bytes, boolean sync)
void	write(HornetQBuffer bytes, boolean sync, IOAsyncTask callback)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.hornetq.core.journal.SequentialFile

calculateBlockStart, cloneFile, fill, getAlignment, isOpen, open, open, read, read, size, sync, waitForClose, writeDirect, writeDirect, writeInternal

Field Detail

factory

protected final SequentialFileFactory factory

fileSize

protected long fileSize

position

protected final AtomicLong position

timedBuffer

protected TimedBuffer timedBuffer

timedBufferObserver

protected final TimedBufferObserver timedBufferObserver

Instead of having AIOSequentialFile implementing the Observer, I have done it on an inner class. This is the class returned to the factory when the file is being activated.

writerExecutor

protected final Executor writerExecutor

Used for asynchronous writes

Constructor Detail

AbstractSequentialFile

public AbstractSequentialFile(String directory,
                              File file,
                              SequentialFileFactory factory,
                              Executor writerExecutor)

Parameters:

file -

directory -

Method Detail

exists

public final boolean exists()

Specified by:

exists in interface SequentialFile

getFileName

public final String getFileName()

Specified by:

getFileName in interface SequentialFile

delete

public final void delete()
                  throws IOException,
                         InterruptedException,
                         HornetQException

Specified by:

delete in interface SequentialFile

Throws:

IOException

InterruptedException

HornetQException

copyTo

public void copyTo(SequentialFile newFileName)
            throws Exception

Specified by:

copyTo in interface SequentialFile

Throws:

Exception

position

public void position(long pos)
              throws IOException

Specified by:

position in interface SequentialFile

Throws:

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

position

public long position()

Specified by:

position in interface SequentialFile

renameTo

public final void renameTo(String newFileName)
                    throws IOException,
                           InterruptedException,
                           HornetQException

Specified by:

renameTo in interface SequentialFile

Throws:

IOException

InterruptedException

HornetQException

close

public void close()
           throws IOException,
                  InterruptedException,
                  HornetQException

Specified by:

close in interface SequentialFile

Throws:

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

HornetQException

InterruptedException

fits

public final boolean fits(int size)

Specified by:

fits in interface SequentialFile

setTimedBuffer

public void setTimedBuffer(TimedBuffer buffer)

Specified by:

setTimedBuffer in interface SequentialFile

write

public void write(HornetQBuffer bytes,
                  boolean sync,
                  IOAsyncTask callback)
           throws IOException

Specified by:

write in interface SequentialFile

Throws:

IOException

write

public void write(HornetQBuffer bytes,
                  boolean sync)
           throws IOException,
                  InterruptedException,
                  HornetQException

Specified by:

write in interface SequentialFile

Throws:

IOException

InterruptedException

HornetQException

write

public void write(EncodingSupport bytes,
                  boolean sync,
                  IOAsyncTask callback)

Specified by:

write in interface SequentialFile

write

public void write(EncodingSupport bytes,
                  boolean sync)
           throws InterruptedException,
                  HornetQException

Specified by:

write in interface SequentialFile

Throws:

InterruptedException

HornetQException

getFile

protected File getFile()

newBuffer

protected ByteBuffer newBuffer(int size,
                               int limit)

getJavaFile

public File getJavaFile()

Description copied from interface: SequentialFile

Returns a native File of the file underlying this sequential file.

Specified by:

getJavaFile in interface SequentialFile