AIOSequentialFileFactory (HornetQ Parent 2.4.0.Beta2 API)

java.lang.Object
- org.hornetq.core.journal.impl.AIOSequentialFileFactory

All Implemented Interfaces:

SequentialFileFactory
```
public final class AIOSequentialFileFactory
extends Object
```
A AIOSequentialFileFactory

Author:

clebert.suconic@jboss.com

Field Summary

Fields
Modifier and Type	Field and Description
`protected int`	`bufferSize`
`protected long`	`bufferTimeout`
`protected static int`	`EXECUTOR_TIMEOUT`
`protected String`	`journalDir`
`protected TimedBuffer`	`timedBuffer`
`protected ExecutorService`	`writeExecutor` Asynchronous writes need to be done at another executor.

Constructor Summary

Constructors
Constructor and Description
`AIOSequentialFileFactory(String journalDir)`
`AIOSequentialFileFactory(String journalDir, int bufferSize, int bufferTimeout, boolean logRates)`
`AIOSequentialFileFactory(String journalDir, int bufferSize, int bufferTimeout, boolean logRates, IOCriticalErrorListener listener)`
`AIOSequentialFileFactory(String journalDir, IOCriticalErrorListener listener)`

Method Summary

Methods
Modifier and Type	Method and Description
`void`	`activateBuffer(SequentialFile file)`
`ByteBuffer`	`allocateDirectBuffer(int size)` used for cases where you need direct buffer outside of the journal context.
`int`	`calculateBlockSize(int position)`
`void`	`clearBuffer(ByteBuffer directByteBuffer)`
`void`	`createDirs()` Create the directory if it doesn't exist yet
`SequentialFile`	`createSequentialFile(String fileName, int maxIO)`
`void`	`deactivateBuffer()`
`protected void`	`finalize()`
`void`	`flush()`
`int`	`getAlignment()`
`String`	`getDirectory()`
`static boolean`	`isSupported()`
`boolean`	`isSupportsCallbacks()`
`List<String>`	`listFiles(String extension)` Lists files that end with the given extension.
`ByteBuffer`	`newBuffer(int size)` Note: You need to release the buffer if is used for reading operations.
`void`	`onIOError(Exception exception, String message, SequentialFile file)` The SequentialFile will call this method when a disk IO Error happens during the live phase.
`void`	`releaseBuffer(ByteBuffer buffer)`
`void`	`releaseDirectBuffer(ByteBuffer buffer)` used for cases where you need direct buffer outside of the journal context.
`void`	`start()`
`void`	`stop()`
`String`	`toString()`
`ByteBuffer`	`wrapBuffer(byte[] bytes)`

Methods inherited from class java.lang.Object
clone, equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

- Field Detail
  - EXECUTOR_TIMEOUT
```
protected static final int EXECUTOR_TIMEOUT
```
    See Also:
    Constant Field Values
  - journalDir
```
protected final String journalDir
```
  - timedBuffer
```
protected final TimedBuffer timedBuffer
```
  - bufferSize
```
protected final int bufferSize
```
  - bufferTimeout
```
protected final long bufferTimeout
```
  - writeExecutor
```
protected ExecutorService writeExecutor
```
    Asynchronous writes need to be done at another executor. This needs to be done at NIO, or else we would have the callers thread blocking for the return. At AIO this is necessary as context switches on writes would fire flushes at the kernel.
- Constructor Detail
  - AIOSequentialFileFactory
```
public AIOSequentialFileFactory(String journalDir)
```
  - AIOSequentialFileFactory
```
public AIOSequentialFileFactory(String journalDir,
                        IOCriticalErrorListener listener)
```
  - AIOSequentialFileFactory
```
public AIOSequentialFileFactory(String journalDir,
                        int bufferSize,
                        int bufferTimeout,
                        boolean logRates)
```
  - AIOSequentialFileFactory
```
public AIOSequentialFileFactory(String journalDir,
                        int bufferSize,
                        int bufferTimeout,
                        boolean logRates,
                        IOCriticalErrorListener listener)
```
- Method Detail
  - createSequentialFile
```
public SequentialFile createSequentialFile(String fileName,
                                  int maxIO)
```
  - isSupportsCallbacks
```
public boolean isSupportsCallbacks()
```
  - isSupported
```
public static boolean isSupported()
```
  - allocateDirectBuffer
```
public ByteBuffer allocateDirectBuffer(int size)
```
    Description copied from interface: SequentialFileFactory
    
    used for cases where you need direct buffer outside of the journal context. This is because the native layer has a method that can be reused in certain cases like paging
  - releaseDirectBuffer
```
public void releaseDirectBuffer(ByteBuffer buffer)
```
    Description copied from interface: SequentialFileFactory
    
    used for cases where you need direct buffer outside of the journal context. This is because the native layer has a method that can be reused in certain cases like paging
  - newBuffer
```
public ByteBuffer newBuffer(int size)
```
    Description copied from interface: SequentialFileFactory
    
    Note: You need to release the buffer if is used for reading operations. You don't need to do it if using writing operations (AIO Buffer Lister will take of writing operations)
    
    Returns:
    the allocated ByteBuffer
  - clearBuffer
```
public void clearBuffer(ByteBuffer directByteBuffer)
```
  - getAlignment
```
public int getAlignment()
```
  - wrapBuffer
```
public ByteBuffer wrapBuffer(byte[] bytes)
```
  - calculateBlockSize
```
public int calculateBlockSize(int position)
```
  - releaseBuffer
```
public void releaseBuffer(ByteBuffer buffer)
```
    Specified by:
    
    releaseBuffer in interface SequentialFileFactory
  - start
```
public void start()
```
    Specified by:
    
    start in interface SequentialFileFactory
  - stop
```
public void stop()
```
    Specified by:
    
    stop in interface SequentialFileFactory
  - finalize
```
protected void finalize()
```
    Overrides:
    
    finalize in class Object
  - toString
```
public String toString()
```
    Overrides:
    
    toString in class Object
  - getDirectory
```
public String getDirectory()
```
    Specified by:
    
    getDirectory in interface SequentialFileFactory
  - onIOError
```
public void onIOError(Exception exception,
             String message,
             SequentialFile file)
```
    Description copied from interface: SequentialFileFactory
    
    The SequentialFile will call this method when a disk IO Error happens during the live phase.
    
    Specified by:
    
    onIOError in interface SequentialFileFactory
  - activateBuffer
```
public void activateBuffer(SequentialFile file)
```
    Specified by:
    
    activateBuffer in interface SequentialFileFactory
  - flush
```
public void flush()
```
    Specified by:
    
    flush in interface SequentialFileFactory
  - deactivateBuffer
```
public void deactivateBuffer()
```
    Specified by:
    
    deactivateBuffer in interface SequentialFileFactory
  - createDirs
```
public void createDirs()
                throws Exception
```
    Create the directory if it doesn't exist yet
    
    Specified by:
    
    createDirs in interface SequentialFileFactory
    
    Throws:
    
    Exception
  - listFiles
```
public List<String> listFiles(String extension)
                       throws Exception
```
    Description copied from interface: SequentialFileFactory
    
    Lists files that end with the given extension.
    This method inserts a ".' before the extension.
    
    Specified by:
    
    listFiles in interface SequentialFileFactory
    
    Returns:
    
    Throws:
    
    Exception

Class AIOSequentialFileFactory

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

EXECUTOR_TIMEOUT

journalDir

timedBuffer

bufferSize

bufferTimeout

writeExecutor

Constructor Detail

AIOSequentialFileFactory

AIOSequentialFileFactory

AIOSequentialFileFactory

AIOSequentialFileFactory

Method Detail

createSequentialFile

isSupportsCallbacks

isSupported

allocateDirectBuffer

releaseDirectBuffer

newBuffer

clearBuffer

getAlignment

wrapBuffer

calculateBlockSize

releaseBuffer

start

stop

finalize

toString

getDirectory

onIOError

activateBuffer

flush

deactivateBuffer

createDirs

listFiles