com.hazelcast.spi.hotrestart.impl.gc.record

Class RecordMapOffHeap

java.lang.Object

com.hazelcast.spi.hotrestart.impl.gc.record.RecordMapOffHeap

All Implemented Interfaces:

com.hazelcast.nio.Disposable, RecordMap

public final class RecordMapOffHeap
extends Object
implements RecordMap

Record map backed by off-heap storage.

Nested Class Summary

Nested classes/interfaces inherited from interface com.hazelcast.spi.hotrestart.impl.gc.record.RecordMap

RecordMap.Cursor

Method Summary

Modifier and Type	Method and Description
com.hazelcast.spi.hotrestart.impl.gc.record.RecordMapOffHeap.CursorOffHeap	cursor()
void	dispose()
RecordOffHeap	get(KeyHandle kh) Returns the record mapped by the supplied KeyHandle, if any; otherwise returns null.
static RecordMapOffHeap	newRecordMapOffHeap(com.hazelcast.internal.memory.MemoryManager memMgr, com.hazelcast.internal.memory.MemoryManager stableMemMgr)
static RecordMapOffHeap	newTombstoneMapOffHeap(com.hazelcast.internal.memory.MemoryManager memMgr)
Record	putIfAbsent(long prefix, KeyHandle kh, long seq, int size, boolean isTombstone, int additionalInt) If there is no current mapping for kh, establishes a mapping from kh to a record defined by (seq, size, isTombstone, additionalInt) and returns null.
int	size()
SortedBySeqRecordCursor	sortedBySeqCursor(int liveRecordCount, RecordMap[] recordMaps, MutatorCatchup mc) Creates a sorted-by-seq cursor over all live records in the provided record maps.
RecordMap	toStable() Special-purpose method supporting an off-heap memory optimization where during GC the growing chunk's record map is stored using an auxiliary memory allocator that allocates from a different pool than the main one, thus reducing the peak memory demand on the main allocator.

Methods inherited from class java.lang.Object

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

Method Detail

newRecordMapOffHeap

public static RecordMapOffHeap newRecordMapOffHeap(com.hazelcast.internal.memory.MemoryManager memMgr,
                                                   com.hazelcast.internal.memory.MemoryManager stableMemMgr)

newTombstoneMapOffHeap

public static RecordMapOffHeap newTombstoneMapOffHeap(com.hazelcast.internal.memory.MemoryManager memMgr)

putIfAbsent

public Record putIfAbsent(long prefix,
                          KeyHandle kh,
                          long seq,
                          int size,
                          boolean isTombstone,
                          int additionalInt)

Description copied from interface: RecordMap

If there is no current mapping for kh, establishes a mapping from kh to a record defined by (seq, size, isTombstone, additionalInt) and returns null. If a mapping already exists, returns the existing record without updating it.

Warning! The returned instance is valid only up to the next update operation on this map. The caller should generally not retain it.

Specified by:

putIfAbsent in interface RecordMap

additionalInt - for a value record, this is its garbage count; for tombstone, it is its position in the chunk file.

get

public RecordOffHeap get(KeyHandle kh)

Description copied from interface: RecordMap

Returns the record mapped by the supplied KeyHandle, if any; otherwise returns null. Warning! The returned instance is valid only up to the next operation on this map, including another get. The caller should generally not retain it.

Specified by:

get in interface RecordMap

size

public int size()

Specified by:

size in interface RecordMap

Returns:

the number of entries in this map.

sortedBySeqCursor

public SortedBySeqRecordCursor sortedBySeqCursor(int liveRecordCount,
                                                 RecordMap[] recordMaps,
                                                 MutatorCatchup mc)

Description copied from interface: RecordMap

Creates a sorted-by-seq cursor over all live records in the provided record maps. The record maps must be of the same type as this record map.

Specified by:

sortedBySeqCursor in interface RecordMap

cursor

public com.hazelcast.spi.hotrestart.impl.gc.record.RecordMapOffHeap.CursorOffHeap cursor()

Specified by:

cursor in interface RecordMap

toStable

public RecordMap toStable()

Description copied from interface: RecordMap

Special-purpose method supporting an off-heap memory optimization where during GC the growing chunk's record map is stored using an auxiliary memory allocator that allocates from a different pool than the main one, thus reducing the peak memory demand on the main allocator. This method moves the data back to the main allocator.

Specified by:

toStable in interface RecordMap

Returns:

a copy of this record map appropriate to be used inside a StableChunk.

dispose

public void dispose()

Specified by:

dispose in interface com.hazelcast.nio.Disposable