org.jboss.messaging.core.journal.impl
Class AIOSequentialFileFactory
java.lang.Object
org.jboss.messaging.core.journal.impl.AbstractSequentialFactory
org.jboss.messaging.core.journal.impl.AIOSequentialFileFactory
- All Implemented Interfaces:
- SequentialFileFactory
public class AIOSequentialFileFactory
- extends AbstractSequentialFactory
A AIOSequentialFileFactory
- Author:
- clebert.suconic@jboss.com
Methods inherited from class java.lang.Object |
clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
AIOSequentialFileFactory
public AIOSequentialFileFactory(java.lang.String journalDir)
AIOSequentialFileFactory
public AIOSequentialFileFactory(java.lang.String journalDir,
int bufferSize,
long bufferTimeout,
boolean flushOnSync,
boolean logRates)
activate
public void activate(SequentialFile file)
- Description copied from interface:
SequentialFileFactory
- The factory may need to do some initialization before the file is activated.
this was added as a hook for AIO to initialize the Observer on TimedBuffer.
It could be eventually done the same on NIO if we implement TimedBuffer on NIO
- Specified by:
activate
in interface SequentialFileFactory
- Overrides:
activate
in class AbstractSequentialFactory
testFlush
public void testFlush()
- Specified by:
testFlush
in interface SequentialFileFactory
- Overrides:
testFlush
in class AbstractSequentialFactory
deactivate
public void deactivate(SequentialFile file)
- Specified by:
deactivate
in interface SequentialFileFactory
- Overrides:
deactivate
in class AbstractSequentialFactory
createSequentialFile
public SequentialFile createSequentialFile(java.lang.String fileName,
int maxIO)
isSupportsCallbacks
public boolean isSupportsCallbacks()
isSupported
public static boolean isSupported()
newBuffer
public java.nio.ByteBuffer newBuffer(int size)
clearBuffer
public void clearBuffer(java.nio.ByteBuffer directByteBuffer)
getAlignment
public int getAlignment()
wrapBuffer
public java.nio.ByteBuffer wrapBuffer(byte[] bytes)
calculateBlockSize
public int calculateBlockSize(int position)
releaseBuffer
public void releaseBuffer(java.nio.ByteBuffer buffer)
- Specified by:
releaseBuffer
in interface SequentialFileFactory
- Overrides:
releaseBuffer
in class AbstractSequentialFactory
start
public void start()
- Specified by:
start
in interface SequentialFileFactory
- Overrides:
start
in class AbstractSequentialFactory
stop
public void stop()
- Specified by:
stop
in interface SequentialFileFactory
- Overrides:
stop
in class AbstractSequentialFactory
finalize
protected void finalize()
- Overrides:
finalize
in class java.lang.Object
Copyright © 2006 JBoss Inc. All Rights Reserved.