com.hazelcast.spi.hotrestart.memory

Class HotRestartThreadLocalPoolingMemoryManager

java.lang.Object

com.hazelcast.memory.ThreadLocalPoolingMemoryManager

com.hazelcast.spi.hotrestart.memory.HotRestartThreadLocalPoolingMemoryManager

All Implemented Interfaces:

com.hazelcast.internal.memory.MemoryAllocator, com.hazelcast.memory.HazelcastMemoryManager, com.hazelcast.nio.Disposable

public class HotRestartThreadLocalPoolingMemoryManager
extends com.hazelcast.memory.ThreadLocalPoolingMemoryManager

Specialization of ThreadLocalPoolingMemoryManager which contributes mutex locking needed to safely perform pointer validation inside RamStore.copyEntry( com.hazelcast.spi.hotrestart.KeyHandle, int, com.hazelcast.spi.hotrestart.RecordDataSink) calls.

Field Summary

Fields

Modifier and Type	Field and Description
protected static int	EXTERNAL_BLOCK_HEADER_SIZE
protected com.hazelcast.internal.memory.MemoryAllocator	pageAllocator

Fields inherited from interface com.hazelcast.memory.HazelcastMemoryManager

SIZE_INVALID

Fields inherited from interface com.hazelcast.internal.memory.MemoryAllocator

NULL_ADDRESS

Constructor Summary

Constructors

Constructor and Description
HotRestartThreadLocalPoolingMemoryManager(int minBlockSize, int pageSize, com.hazelcast.internal.memory.impl.LibMalloc malloc, com.hazelcast.memory.PooledNativeMemoryStats stats)

Method Summary

Modifier and Type	Method and Description
protected long	acquireInternal(com.hazelcast.memory.AddressQueue arg0)
long	allocate(long arg0)
protected long	allocateExternalBlock(long size)
void	compact()
protected void	compact(com.hazelcast.memory.AddressQueue arg0)
void	dispose()
String	dump()
void	free(long arg0, long arg1)
protected void	freeExternalBlock(long address, long size)
protected void	freePage(long arg0)
protected com.hazelcast.memory.AddressQueue	getAddressQueue(long arg0)
long	getAllocatedSize(long arg0)
double	getFragmentationRatio(int arg0)
com.hazelcast.memory.MemoryStats	getMemoryStats()
com.hazelcast.internal.memory.MemoryAllocator	getSystemAllocator()
long	getUsableSize(long arg0)
long	newSequence()
protected void	onMallocPage(long pageAddress)
protected long	toHeaderAddress(long arg0, int arg1)
long	validateAndGetAllocatedSize(long address)
long	validateAndGetUsableSize(long arg0)

Methods inherited from class com.hazelcast.memory.ThreadLocalPoolingMemoryManager

createAddressQueue, getOffsetWithinPage, getQueueMergeThreshold, getSizeInternal, headerSize, initialize, isAvailable, isDisposed, isValidAndAvailable, markAvailable, markInvalid, markUnavailable, newCounter, onOome, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.hazelcast.memory.HazelcastMemoryManager

allocate, compact, free, getAllocatedSize, getMemoryStats, getSystemAllocator, getUsableSize, newSequence, validateAndGetUsableSize

Field Detail

EXTERNAL_BLOCK_HEADER_SIZE

protected static final int EXTERNAL_BLOCK_HEADER_SIZE

See Also:

Constant Field Values

pageAllocator

protected final com.hazelcast.internal.memory.MemoryAllocator pageAllocator

Constructor Detail

HotRestartThreadLocalPoolingMemoryManager

public HotRestartThreadLocalPoolingMemoryManager(int minBlockSize,
                                                 int pageSize,
                                                 com.hazelcast.internal.memory.impl.LibMalloc malloc,
                                                 com.hazelcast.memory.PooledNativeMemoryStats stats)

Method Detail

validateAndGetAllocatedSize

public long validateAndGetAllocatedSize(long address)

Specified by:

validateAndGetAllocatedSize in interface com.hazelcast.memory.HazelcastMemoryManager

Overrides:

validateAndGetAllocatedSize in class com.hazelcast.memory.ThreadLocalPoolingMemoryManager

allocateExternalBlock

protected long allocateExternalBlock(long size)

Overrides:

allocateExternalBlock in class com.hazelcast.memory.ThreadLocalPoolingMemoryManager

freeExternalBlock

protected void freeExternalBlock(long address,
                                 long size)

Overrides:

freeExternalBlock in class com.hazelcast.memory.ThreadLocalPoolingMemoryManager

onMallocPage

protected void onMallocPage(long pageAddress)

Overrides:

onMallocPage in class com.hazelcast.memory.ThreadLocalPoolingMemoryManager

dispose

public void dispose()

Specified by:

dispose in interface com.hazelcast.nio.Disposable

Overrides:

dispose in class com.hazelcast.memory.ThreadLocalPoolingMemoryManager

allocate

public final long allocate(long arg0)

Specified by:

allocate in interface com.hazelcast.internal.memory.MemoryAllocator

Specified by:

allocate in interface com.hazelcast.memory.HazelcastMemoryManager

free

public final void free(long arg0,
                       long arg1)

Specified by:

free in interface com.hazelcast.internal.memory.MemoryAllocator

Specified by:

free in interface com.hazelcast.memory.HazelcastMemoryManager

getMemoryStats

public final com.hazelcast.memory.MemoryStats getMemoryStats()

Specified by:

getMemoryStats in interface com.hazelcast.memory.HazelcastMemoryManager

getSystemAllocator

public final com.hazelcast.internal.memory.MemoryAllocator getSystemAllocator()

Specified by:

getSystemAllocator in interface com.hazelcast.memory.HazelcastMemoryManager

compact

public final void compact()

Specified by:

compact in interface com.hazelcast.memory.HazelcastMemoryManager

getAllocatedSize

public final long getAllocatedSize(long arg0)

Specified by:

getAllocatedSize in interface com.hazelcast.memory.HazelcastMemoryManager

getUsableSize

public final long getUsableSize(long arg0)

Specified by:

getUsableSize in interface com.hazelcast.memory.HazelcastMemoryManager

validateAndGetUsableSize

public final long validateAndGetUsableSize(long arg0)

Specified by:

validateAndGetUsableSize in interface com.hazelcast.memory.HazelcastMemoryManager

newSequence

public final long newSequence()

Specified by:

newSequence in interface com.hazelcast.memory.HazelcastMemoryManager

getAddressQueue

protected final com.hazelcast.memory.AddressQueue getAddressQueue(long arg0)

acquireInternal

protected final long acquireInternal(com.hazelcast.memory.AddressQueue arg0)

toHeaderAddress

protected final long toHeaderAddress(long arg0,
                                     int arg1)

compact

protected final void compact(com.hazelcast.memory.AddressQueue arg0)

freePage

protected final void freePage(long arg0)

getFragmentationRatio

public final double getFragmentationRatio(int arg0)

dump

public final String dump()