|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.jboss.messaging.core.asyncio.impl.AsynchronousFileImpl
public class AsynchronousFileImpl
AsynchronousFile implementation
Constructor Summary | |
---|---|
AsynchronousFileImpl()
|
Method Summary | |
---|---|
void |
close()
|
void |
destroyBuffer(java.nio.ByteBuffer buffer)
|
void |
fill(long position,
int blocks,
long size,
byte fillChar)
|
int |
getBlockSize()
|
static int |
getTotalMaxIO()
For test purposes |
static boolean |
isLoaded()
|
java.nio.ByteBuffer |
newBuffer(long size)
|
void |
open(java.lang.String fileName,
int maxIO,
long timeout)
Note: If you are using a native Linux implementation, maxIO can't be higher than what's defined on /proc/sys/fs/aio-max-nr, or you would get an error |
void |
read(long position,
long size,
java.nio.ByteBuffer directByteBuffer,
AIOCallback aioPackage)
|
long |
size()
Warning: This function will perform a synchronous IO, probably translating to a fstat call |
void |
write(long position,
long size,
java.nio.ByteBuffer directByteBuffer,
AIOCallback aioPackage)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public AsynchronousFileImpl()
Method Detail |
---|
public static int getTotalMaxIO()
public static boolean isLoaded()
public void open(java.lang.String fileName, int maxIO, long timeout)
AsynchronousFile
open
in interface AsynchronousFile
maxIO
- The number of max concurrent asynchrnous IO operations. It has to be balanced between the size of your writes and the capacity of your disk.public void close() throws java.lang.Exception
close
in interface AsynchronousFile
java.lang.Exception
public void write(long position, long size, java.nio.ByteBuffer directByteBuffer, AIOCallback aioPackage)
write
in interface AsynchronousFile
public void read(long position, long size, java.nio.ByteBuffer directByteBuffer, AIOCallback aioPackage)
read
in interface AsynchronousFile
public long size()
AsynchronousFile
size
in interface AsynchronousFile
public void fill(long position, int blocks, long size, byte fillChar)
fill
in interface AsynchronousFile
public int getBlockSize()
getBlockSize
in interface AsynchronousFile
public void destroyBuffer(java.nio.ByteBuffer buffer)
destroyBuffer
in interface AsynchronousFile
public java.nio.ByteBuffer newBuffer(long size)
newBuffer
in interface AsynchronousFile
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |