AIOSequentialFileFactory (Red Hat JBoss Enterprise Application Platform 7.4.0.GA public API)

java.lang.Object
- org.apache.activemq.artemis.core.io.AbstractSequentialFileFactory
- - org.apache.activemq.artemis.core.io.aio.AIOSequentialFileFactory

All Implemented Interfaces:: SequentialFileFactory

public final class AIOSequentialFileFactory
extends AbstractSequentialFileFactory

Nested Class Summary

Nested Classes
Modifier and Type Class and Description

class AIOSequentialFileFactory.AIOSequentialCallback
The same callback is used for Runnable executor.

Nested Classes
Modifier and Type	Class and Description
`class`	`AIOSequentialFileFactory.AIOSequentialCallback` The same callback is used for Runnable executor.

Field Summary
- Fields inherited from class org.apache.activemq.artemis.core.io.AbstractSequentialFileFactory
  alignment, bufferSize, bufferTimeout, critialErrorListener, criticalAnalyzer, dataSync, EXECUTOR_TIMEOUT, journalDir, maxIO, timedBuffer, writeExecutor

Constructor Summary

Constructors
Constructor and Description
`AIOSequentialFileFactory(File journalDir, int maxIO)`
`AIOSequentialFileFactory(File journalDir, int bufferSize, int bufferTimeout, int maxIO, boolean logRates)`
`AIOSequentialFileFactory(File journalDir, int bufferSize, int bufferTimeout, int maxIO, boolean logRates, IOCriticalErrorListener listener, CriticalAnalyzer analyzer)`
`AIOSequentialFileFactory(File journalDir, IOCriticalErrorListener listener, int maxIO)`

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`afterClose()`
`ByteBuffer`	`allocateDirectBuffer(int size)` used for cases where you need direct buffer outside of the journal context.
`void`	`beforeClose()`
`int`	`calculateBlockSize(int position)`
`void`	`clearBuffer(ByteBuffer directByteBuffer)`
`SequentialFile`	`createSequentialFile(String fileName)`
`void`	`disableBufferReuse()`
`void`	`enableBufferReuse()`
`int`	`getAlignment()`
`AIOSequentialFileFactory.AIOSequentialCallback`	`getCallback()`
`static boolean`	`isSupported()`
`static boolean`	`isSupported(File journalPath)`
`boolean`	`isSupportsCallbacks()`
`ByteBuffer`	`newBuffer(int size)` Note: You need to release the buffer if is used for reading operations.
`ByteBuffer`	`newBuffer(int size, boolean zeroed)` Note: You need to release the buffer if is used for reading operations.
`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 org.apache.activemq.artemis.core.io.AbstractSequentialFileFactory
activateBuffer, createDirs, deactivateBuffer, flush, getBufferSize, getCriticalAnalyzer, getDirectory, getMaxIO, isDatasync, listFiles, onIOError, setAlignment, setDatasync

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

- Constructor Detail
  - AIOSequentialFileFactory
```
public AIOSequentialFileFactory(File journalDir,
                                int maxIO)
```
  - AIOSequentialFileFactory
```
public AIOSequentialFileFactory(File journalDir,
                                IOCriticalErrorListener listener,
                                int maxIO)
```
  - AIOSequentialFileFactory
```
public AIOSequentialFileFactory(File journalDir,
                                int bufferSize,
                                int bufferTimeout,
                                int maxIO,
                                boolean logRates)
```
  - AIOSequentialFileFactory
```
public AIOSequentialFileFactory(File journalDir,
                                int bufferSize,
                                int bufferTimeout,
                                int maxIO,
                                boolean logRates,
                                IOCriticalErrorListener listener,
                                CriticalAnalyzer analyzer)
```
- Method Detail
  - beforeClose
```
public void beforeClose()
```
  - afterClose
```
public void afterClose()
```
  - getCallback
```
public AIOSequentialFileFactory.AIOSequentialCallback getCallback()
```
  - enableBufferReuse
```
public void enableBufferReuse()
```
  - disableBufferReuse
```
public void disableBufferReuse()
```
  - createSequentialFile
```
public SequentialFile createSequentialFile(String fileName)
```
  - isSupportsCallbacks
```
public boolean isSupportsCallbacks()
```
  - isSupported
```
public static boolean isSupported()
```
  - isSupported
```
public static boolean isSupported(File journalPath)
```
  - 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
  - newBuffer
```
public ByteBuffer newBuffer(int size,
                            boolean zeroed)
```
    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)
    
    zeroed - if true the returned ByteBuffer must be zeroed, otherwise it tries to save zeroing it.
    
    Returns:
    
    the allocated ByteBuffer
  - clearBuffer
```
public void clearBuffer(ByteBuffer directByteBuffer)
```
  - getAlignment
```
public int getAlignment()
```
    Specified by:
    
    getAlignment in interface SequentialFileFactory
    
    Overrides:
    
    getAlignment in class AbstractSequentialFileFactory
  - wrapBuffer
```
public ByteBuffer wrapBuffer(byte[] bytes)
```
  - calculateBlockSize
```
public int calculateBlockSize(int position)
```
  - releaseBuffer
```
public void releaseBuffer(ByteBuffer buffer)
```
    Specified by:
    
    releaseBuffer in interface SequentialFileFactory
    
    Overrides:
    
    releaseBuffer in class AbstractSequentialFileFactory
  - start
```
public void start()
```
    Specified by:
    
    start in interface SequentialFileFactory
    
    Overrides:
    
    start in class AbstractSequentialFileFactory
  - stop
```
public void stop()
```
    Specified by:
    
    stop in interface SequentialFileFactory
    
    Overrides:
    
    stop in class AbstractSequentialFileFactory
  - toString
```
public String toString()
```
    Overrides:
    
    toString in class Object

Class AIOSequentialFileFactory

Nested Class Summary

Field Summary

Fields inherited from class org.apache.activemq.artemis.core.io.AbstractSequentialFileFactory

Constructor Summary

Method Summary

Methods inherited from class org.apache.activemq.artemis.core.io.AbstractSequentialFileFactory

Methods inherited from class java.lang.Object

Constructor Detail

AIOSequentialFileFactory

AIOSequentialFileFactory

AIOSequentialFileFactory

AIOSequentialFileFactory

Method Detail

beforeClose

afterClose

getCallback

enableBufferReuse

disableBufferReuse

createSequentialFile

isSupportsCallbacks

isSupported

isSupported

allocateDirectBuffer

releaseDirectBuffer

newBuffer

newBuffer

clearBuffer

getAlignment

wrapBuffer

calculateBlockSize

releaseBuffer

start

stop

toString