public class Native extends Object
Constructor and Description |
---|
Native() |
Modifier and Type | Method and Description |
---|---|
static void |
closeFile(int handle) |
static void |
closeInternal(ByteBuffer handler) |
static void |
destroyBuffer(ByteBuffer buffer) |
static void |
fill(ByteBuffer handle,
long position,
int blocks,
long size,
byte fillChar) |
static boolean |
flock(int handle) |
static int |
getNativeVersion()
A native method that does nothing, and just validate if the ELF dependencies are loaded and on the correct platform as this binary format
|
static ByteBuffer |
init(Class controllerClass,
String fileName,
int maxIO,
Object logger) |
static void |
internalPollEvents(ByteBuffer handler)
Poll asynchronous events from internal queues
|
static void |
newInit(Class someClass) |
static ByteBuffer |
newNativeBuffer(long size) |
static int |
openFile(String fileName) |
static void |
read(Object thisObject,
ByteBuffer handle,
long position,
long size,
ByteBuffer buffer,
Object aioPackageCallback)
This is using org.hornetq.core.asyncio.AIOCallback
|
static void |
resetBuffer(ByteBuffer directByteBuffer,
int size) |
static long |
size0(ByteBuffer handle) |
static void |
stopPoller(ByteBuffer handler) |
static void |
write(Object thisObject,
ByteBuffer handle,
long sequence,
long position,
long size,
ByteBuffer buffer,
Object aioPackageCallback) |
static void |
writeInternal(ByteBuffer handle,
long positionToWrite,
long size,
ByteBuffer bytes)
a direct write to the file without the use of libaio's submit.
|
public static int openFile(String fileName)
public static void closeFile(int handle)
public static boolean flock(int handle)
public static void resetBuffer(ByteBuffer directByteBuffer, int size)
public static void destroyBuffer(ByteBuffer buffer)
public static ByteBuffer newNativeBuffer(long size)
public static void newInit(Class someClass)
public static ByteBuffer init(Class controllerClass, String fileName, int maxIO, Object logger) throws HornetQException
HornetQException
public static long size0(ByteBuffer handle)
public static void write(Object thisObject, ByteBuffer handle, long sequence, long position, long size, ByteBuffer buffer, Object aioPackageCallback) throws HornetQException
HornetQException
public static void writeInternal(ByteBuffer handle, long positionToWrite, long size, ByteBuffer bytes) throws HornetQException
HornetQException
public static void read(Object thisObject, ByteBuffer handle, long position, long size, ByteBuffer buffer, Object aioPackageCallback) throws HornetQException
HornetQException
public static void fill(ByteBuffer handle, long position, int blocks, long size, byte fillChar) throws HornetQException
HornetQException
public static void closeInternal(ByteBuffer handler)
public static void stopPoller(ByteBuffer handler)
public static int getNativeVersion()
public static void internalPollEvents(ByteBuffer handler)
Copyright © 2016 JBoss, a division of Red Hat. All rights reserved.