Package one.nio.mem

Class SharedMemoryMap<K,V>

java.lang.Object

one.nio.mem.OffheapMap<K,V>

one.nio.mem.SharedMemoryMap<K,V>

All Implemented Interfaces:

OffheapMapMXBean, SharedMemoryMapMXBean

Direct Known Subclasses:

SharedMemoryFixedMap, SharedMemoryLongMap, SharedMemoryStringMap

public abstract class SharedMemoryMap<K,V>
extends OffheapMap<K,V>
implements SharedMemoryMapMXBean

Nested Class Summary

Nested classes/interfaces inherited from class one.nio.mem.OffheapMap

OffheapMap.BasicCleanup, OffheapMap.Record<K,V>, OffheapMap.SamplingCleanup, OffheapMap.Visitor<K,V>, OffheapMap.WritableRecord<K,V>, OffheapMap.WritableVisitor<K,V>

Field Summary

Fields

Modifier and Type	Field	Description
protected MallocMT	allocator
protected static long	BASE_OFFSET
protected static long	CAPACITY_OFFSET
protected java.lang.String	className
protected static long	CUSTOM_DATA_OFFSET
protected static long	CUSTOM_SIZE_OFFSET
protected static long	MAP_OFFSET
protected static int	MAX_CUSTOM_DATA_SIZE
protected MappedFile	mmap
protected java.lang.String	name
protected Serializer<V>	serializer
protected static long	SIGNATURE_CLEAR
protected static long	SIGNATURE_DIRTY
protected static long	SIGNATURE_LEGACY
protected static long	SIGNATURE_OFFSET
protected static long	TIMESTAMP_OFFSET
protected static long	UID_OFFSET

Fields inherited from class one.nio.mem.OffheapMap

byteArrayOffset, capacity, cleanupInterval, cleanupThread, cleanupThreshold, CONCURRENCY_LEVEL, count, expirations, HASH_OFFSET, HEADER_SIZE, locks, lockWaitTime, log, mapBase, maxSamples, MB, minTimeToLive, NEXT_OFFSET, TIME_OFFSET, timeToLive, unsafe

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	SharedMemoryMap(int capacity, java.lang.String fileName, long fileSize)
protected	SharedMemoryMap(int capacity, java.lang.String fileName, long fileSize, long expirationTime)

Method Summary

Modifier and Type	Method	Description
protected long	allocateEntry(K key, long hashCode, int size)
protected void	closeInternal()
protected void	convert(Serializer<V> oldSerializer, Serializer<V> newSerializer)
protected void	createAllocator(long startAddress, long totalMemory)
protected void	destroyEntry(long entry)
int	entriesToClean()
private Serializer<V>	findSerializer(long uid)
protected byte[]	getCustomData()
long	getFreeMemory()
protected long	getHeader(long offset)
long	getTotalMemory()
long	getUsedMemory()
protected int	headerSize(long entry)
private void	init(long expirationTime)
protected void	loadSchema()
protected boolean	needCleanup(long expirationTime)
protected void	relocate(long delta)
protected void	setCustomData(byte[] data)
protected void	setHeader(long offset, long value)
void	setSerializer(java.lang.Class<V> valueType)
void	setSerializer(Serializer<V> serializer)
protected void	setValueAt(long entry, V value)
protected int	sizeOf(long entry)
protected int	sizeOf(V value)
protected void	storeSchema()
protected V	valueAt(long entry)

Methods inherited from class one.nio.mem.OffheapMap

bucketFor, clear, close, equalsAt, get, getCapacity, getCleanupInterval, getCleanupThreshold, getCount, getExpirations, getLockWaitTime, getMaxSamples, getMinTimeToLive, getTimeToLive, hashCode, isExpired, iterate, iterate, iterate, iterate, iterate, iterate, keyAt, lockFor, lockRecordForRead, lockRecordForRead, lockRecordForWrite, lockRecordForWrite, put, putIfAbsent, remove, removeExpired, reuseEntry, setCleanupInterval, setCleanupThreshold, setLockWaitTime, setMaxSamples, setMinTimeToLive, setTimeAt, setTimeAt, setTimeToLive, shouldCleanup, timeAt, touch

Methods inherited from class java.lang.Object

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

Methods inherited from interface one.nio.mem.OffheapMapMXBean

getCapacity, getCleanupInterval, getCleanupThreshold, getCount, getExpirations, getLockWaitTime, getMaxSamples, getMinTimeToLive, getTimeToLive, setCleanupInterval, setCleanupThreshold, setLockWaitTime, setMaxSamples, setMinTimeToLive, setTimeToLive

Field Detail

SIGNATURE_CLEAR

protected static final long SIGNATURE_CLEAR

See Also:

Constant Field Values

SIGNATURE_LEGACY

protected static final long SIGNATURE_LEGACY

See Also:

Constant Field Values

SIGNATURE_DIRTY

protected static final long SIGNATURE_DIRTY

See Also:

Constant Field Values

SIGNATURE_OFFSET

protected static final long SIGNATURE_OFFSET

See Also:

Constant Field Values

TIMESTAMP_OFFSET

protected static final long TIMESTAMP_OFFSET

See Also:

Constant Field Values

CAPACITY_OFFSET

protected static final long CAPACITY_OFFSET

See Also:

Constant Field Values

BASE_OFFSET

protected static final long BASE_OFFSET

See Also:

Constant Field Values

UID_OFFSET

protected static final long UID_OFFSET

See Also:

Constant Field Values

CUSTOM_SIZE_OFFSET

protected static final long CUSTOM_SIZE_OFFSET

See Also:

Constant Field Values

CUSTOM_DATA_OFFSET

protected static final long CUSTOM_DATA_OFFSET

See Also:

Constant Field Values

MAP_OFFSET

protected static final long MAP_OFFSET

See Also:

Constant Field Values

MAX_CUSTOM_DATA_SIZE

protected static final int MAX_CUSTOM_DATA_SIZE

See Also:

Constant Field Values

className

protected final java.lang.String className

mmap

protected final MappedFile mmap

name

protected final java.lang.String name

allocator

protected MallocMT allocator

serializer

protected Serializer<V> serializer

Constructor Detail

SharedMemoryMap

protected SharedMemoryMap(int capacity,
                          java.lang.String fileName,
                          long fileSize)
                   throws java.io.IOException

Throws:

java.io.IOException

SharedMemoryMap

protected SharedMemoryMap(int capacity,
                          java.lang.String fileName,
                          long fileSize,
                          long expirationTime)
                   throws java.io.IOException

Throws:

java.io.IOException

Method Detail

closeInternal

protected void closeInternal()

Overrides:

closeInternal in class OffheapMap<K,V>

init

private void init(long expirationTime)

needCleanup

protected boolean needCleanup(long expirationTime)

relocate

protected void relocate(long delta)

getHeader

protected long getHeader(long offset)

setHeader

protected void setHeader(long offset,
                         long value)

getCustomData

protected byte[] getCustomData()

setCustomData

protected void setCustomData(byte[] data)

allocateEntry

protected long allocateEntry(K key,
                             long hashCode,
                             int size)

Specified by:

allocateEntry in class OffheapMap<K,V>

destroyEntry

protected void destroyEntry(long entry)

Specified by:

destroyEntry in class OffheapMap<K,V>

sizeOf

protected int sizeOf(long entry)

Specified by:

sizeOf in class OffheapMap<K,V>

valueAt

protected V valueAt(long entry)

Specified by:

valueAt in class OffheapMap<K,V>

setValueAt

protected void setValueAt(long entry,
                          V value)

Specified by:

setValueAt in class OffheapMap<K,V>

sizeOf

protected int sizeOf(V value)

Specified by:

sizeOf in class OffheapMap<K,V>

headerSize

protected int headerSize(long entry)

getTotalMemory

public long getTotalMemory()

Specified by:

getTotalMemory in interface SharedMemoryMapMXBean

getFreeMemory

public long getFreeMemory()

Specified by:

getFreeMemory in interface SharedMemoryMapMXBean

getUsedMemory

public long getUsedMemory()

Specified by:

getUsedMemory in interface SharedMemoryMapMXBean

entriesToClean

public int entriesToClean()

Overrides:

entriesToClean in class OffheapMap<K,V>

createAllocator

protected void createAllocator(long startAddress,
                               long totalMemory)

setSerializer

public void setSerializer(java.lang.Class<V> valueType)
                   throws java.io.IOException

Throws:

java.io.IOException

setSerializer

public void setSerializer(Serializer<V> serializer)
                   throws java.io.IOException

Throws:

java.io.IOException

loadSchema

protected void loadSchema()
                   throws java.io.IOException

Throws:

java.io.IOException

storeSchema

protected void storeSchema()

convert

protected void convert(Serializer<V> oldSerializer,
                       Serializer<V> newSerializer)

findSerializer

private Serializer<V> findSerializer(long uid)
                              throws SerializerNotFoundException

Throws:

SerializerNotFoundException