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 static class	AbstractSequentialFile.DelegateCallback
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

Methods

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()
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 Exception

Specified by:

delete in interface SequentialFile

Throws:

Exception

copyTo

public void copyTo(SequentialFile newFileName)
            throws Exception

Specified by:

copyTo in interface SequentialFile

Throws:

Exception

position

public void position(long pos)
              throws Exception

Specified by:

position in interface SequentialFile

Throws:

Exception

position

public long position()
              throws Exception

Specified by:

position in interface SequentialFile

Throws:

Exception

renameTo

public final void renameTo(String newFileName)
                    throws Exception

Specified by:

renameTo in interface SequentialFile

Throws:

Exception

close

public void close()
           throws Exception

Specified by:

close in interface SequentialFile

Throws:

Exception

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 Exception

Specified by:

write in interface SequentialFile

Throws:

Exception

write

public void write(HornetQBuffer bytes,
         boolean sync)
           throws Exception

Specified by:

write in interface SequentialFile

Throws:

Exception

write

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

Specified by:

write in interface SequentialFile

Throws:

Exception

write

public void write(EncodingSupport bytes,
         boolean sync)
           throws Exception

Specified by:

write in interface SequentialFile

Throws:

Exception

getFile

protected File getFile()

newBuffer

protected ByteBuffer newBuffer(int size,
                   int limit)