org.apache.ignite.internal.portable

Class PortableThreadLocalMemoryAllocator

java.lang.Object

org.apache.ignite.internal.portable.PortableThreadLocalMemoryAllocator

All Implemented Interfaces:

PortableMemoryAllocator

public class PortableThreadLocalMemoryAllocator
extends Object
implements PortableMemoryAllocator

Thread-local memory allocator.

Field Summary

Fields

Modifier and Type	Field and Description
protected static long	BYTE_ARR_OFF Array offset: byte.
static PortableThreadLocalMemoryAllocator	THREAD_LOCAL_ALLOC Memory allocator instance.
protected static sun.misc.Unsafe	UNSAFE Unsafe instance.

Fields inherited from interface org.apache.ignite.internal.portable.streams.PortableMemoryAllocator

DFLT_ALLOC

Method Summary

Methods

Modifier and Type	Method and Description
byte[]	allocate(int size) Allocate memory.
long	allocateDirect(int size) Allocate memory.
boolean	isThreadLocalArrayAcquired() Checks whether a thread-local array is acquired or not.
byte[]	reallocate(byte[] data, int size) Reallocates memory.
long	reallocateDirect(long addr, int size) Reallocate memory.
void	release(byte[] data, int maxMsgSize) Release memory.
void	releaseDirect(long addr) Release memory.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

THREAD_LOCAL_ALLOC

public static final PortableThreadLocalMemoryAllocator THREAD_LOCAL_ALLOC

Memory allocator instance.

UNSAFE

protected static final sun.misc.Unsafe UNSAFE

Unsafe instance.

BYTE_ARR_OFF

protected static final long BYTE_ARR_OFF

Array offset: byte.

Method Detail

allocate

public byte[] allocate(int size)

Allocate memory.

Specified by:

allocate in interface PortableMemoryAllocator

Parameters:

size - Size.

Returns:

Data.

reallocate

public byte[] reallocate(byte[] data,
                int size)

Reallocates memory.

Specified by:

reallocate in interface PortableMemoryAllocator

Parameters:

data - Current data chunk.

size - New size required.

Returns:

Data.

release

public void release(byte[] data,
           int maxMsgSize)

Release memory.

Specified by:

release in interface PortableMemoryAllocator

Parameters:

data - Data.

maxMsgSize - Max message size sent during the time the allocator is used.

allocateDirect

public long allocateDirect(int size)

Allocate memory.

Specified by:

allocateDirect in interface PortableMemoryAllocator

Parameters:

size - Size.

Returns:

Address.

reallocateDirect

public long reallocateDirect(long addr,
                    int size)

Reallocate memory.

Specified by:

reallocateDirect in interface PortableMemoryAllocator

Parameters:

addr - Address.

size - Size.

Returns:

Address.

releaseDirect

public void releaseDirect(long addr)

Release memory.

Specified by:

releaseDirect in interface PortableMemoryAllocator

Parameters:

addr - Address.

isThreadLocalArrayAcquired

public boolean isThreadLocalArrayAcquired()

Checks whether a thread-local array is acquired or not. The function is used by Unit tests.

Returns:

true if acquired false otherwise.