com.hazelcast.internal.nearcache.impl.nativememory

Class NativeMemoryNearCacheRecordStore<K,V>

java.lang.Object

com.hazelcast.internal.nearcache.impl.store.AbstractNearCacheRecordStore<K,V,com.hazelcast.nio.serialization.Data,NativeMemoryNearCacheRecord,NativeMemoryNearCacheRecordMap>

com.hazelcast.internal.nearcache.impl.nativememory.NativeMemoryNearCacheRecordStore<K,V>

Type Parameters:

K - the type of the key stored in Near Cache

V - the type of the value stored in Near Cache

All Implemented Interfaces:

com.hazelcast.internal.eviction.EvictionListener<com.hazelcast.nio.serialization.Data,NativeMemoryNearCacheRecord>, HiDensityRecordStore<NativeMemoryNearCacheRecord>, HiDensityNearCacheRecordStore<K,V,NativeMemoryNearCacheRecord>, com.hazelcast.internal.nearcache.NearCacheRecordStore<K,V>, com.hazelcast.spi.InitializingObject

public class NativeMemoryNearCacheRecordStore<K,V>
extends com.hazelcast.internal.nearcache.impl.store.AbstractNearCacheRecordStore<K,V,com.hazelcast.nio.serialization.Data,NativeMemoryNearCacheRecord,NativeMemoryNearCacheRecordMap>
implements HiDensityNearCacheRecordStore<K,V,NativeMemoryNearCacheRecord>

NearCacheRecordStore implementation for Near Caches with InMemoryFormat.NATIVE in-memory-format.

Nested Class Summary

Nested classes/interfaces inherited from class com.hazelcast.internal.nearcache.impl.store.AbstractNearCacheRecordStore

com.hazelcast.internal.nearcache.impl.store.AbstractNearCacheRecordStore.ReserveForUpdateFunction

Field Summary

Fields inherited from class com.hazelcast.internal.nearcache.impl.store.AbstractNearCacheRecordStore

classLoader, evictionChecker, evictionDisabled, evictionPolicyEvaluator, evictionStrategy, inMemoryFormat, maxIdleMillis, MILLI_SECONDS_IN_A_SECOND, nearCacheConfig, nearCacheStats, records, REFERENCE_SIZE, RESERVATION_ID, reservationId, serializationService, staleReadDetector, timeToLiveMillis

Fields inherited from interface com.hazelcast.internal.hidensity.HiDensityRecordStore

DEFAULT_FORCED_EVICTION_PERCENTAGE, FORCE_EVICTION_TRY_COUNT, HUNDRED_PERCENT, NULL_PTR

Fields inherited from interface com.hazelcast.internal.eviction.EvictionListener

NO_LISTENER

Constructor Summary

Constructors

Constructor and Description
NativeMemoryNearCacheRecordStore(com.hazelcast.config.NearCacheConfig nearCacheConfig, EnterpriseSerializationService ss, ClassLoader classLoader)
NativeMemoryNearCacheRecordStore(com.hazelcast.config.NearCacheConfig nearCacheConfig, com.hazelcast.monitor.impl.NearCacheStatsImpl nearCacheStats, HiDensityStorageInfo storageInfo, EnterpriseSerializationService ss, ClassLoader classLoader)

Method Summary

Modifier and Type	Method and Description
protected boolean	containsRecordKey(K key)
protected com.hazelcast.internal.eviction.EvictionChecker	createNearCacheEvictionChecker(com.hazelcast.config.EvictionConfig evictionConfig, com.hazelcast.config.NearCacheConfig nearCacheConfig)
protected NativeMemoryNearCacheRecordMap	createNearCacheRecordMap(com.hazelcast.config.NearCacheConfig nearCacheConfig)
protected NativeMemoryNearCacheRecord	createRecord(V value)
void	destroy()
void	doExpiration()
int	forceEvict() Forcefully evict records.
protected long	getKeyStorageMemoryCost(K key)
com.hazelcast.memory.HazelcastMemoryManager	getMemoryManager() Gets underlying MemoryManager implementation.
protected NativeMemoryNearCacheRecord	getOrCreateToReserve(K key, com.hazelcast.nio.serialization.Data keyData)
NativeMemoryNearCacheRecord	getRecord(K key)
protected long	getRecordStorageMemoryCost(NativeMemoryNearCacheRecord record)
void	invalidate(K key)
void	loadKeys(com.hazelcast.internal.adapter.DataStructureAdapter<Object,?> adapter)
void	onEvict(com.hazelcast.nio.serialization.Data key, NativeMemoryNearCacheRecord record, boolean wasExpired)
protected void	onPut(K key, V value, NativeMemoryNearCacheRecord record, NativeMemoryNearCacheRecord oldRecord)
protected void	onPutError(K key, V value, NativeMemoryNearCacheRecord record, NativeMemoryNearCacheRecord oldRecord, Throwable error)
protected void	onRemove(K key, NativeMemoryNearCacheRecord record, boolean removed)
protected void	onRemoveError(K key, NativeMemoryNearCacheRecord record, boolean removed, Throwable error)
protected NativeMemoryNearCacheRecord	putRecord(K key, NativeMemoryNearCacheRecord record)
protected V	recordToValue(NativeMemoryNearCacheRecord record)
void	storeKeys()
protected V	updateAndGetReserved(K key, V value, long reservationId, boolean deserialize)
protected void	updateRecordValue(NativeMemoryNearCacheRecord record, V value)

Methods inherited from class com.hazelcast.internal.nearcache.impl.store.AbstractNearCacheRecordStore

canUpdateStats, checkAvailable, clear, doEviction, get, getNearCacheStats, getStaleReadDetector, getTotalStorageMemoryCost, initialize, isRecordExpired, onExpire, onGet, onGetError, onRecordCreate, put, setStaleReadDetector, size, toData, toValue, tryPublishReserved, tryReserveForUpdate, updateReservedRecordInternal

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.hazelcast.internal.nearcache.NearCacheRecordStore

clear, doEviction, get, getNearCacheStats, put, setStaleReadDetector, size, tryPublishReserved, tryReserveForUpdate

Methods inherited from interface com.hazelcast.spi.InitializingObject

initialize

Constructor Detail

NativeMemoryNearCacheRecordStore

public NativeMemoryNearCacheRecordStore(com.hazelcast.config.NearCacheConfig nearCacheConfig,
                                        EnterpriseSerializationService ss,
                                        ClassLoader classLoader)

NativeMemoryNearCacheRecordStore

public NativeMemoryNearCacheRecordStore(com.hazelcast.config.NearCacheConfig nearCacheConfig,
                                        com.hazelcast.monitor.impl.NearCacheStatsImpl nearCacheStats,
                                        HiDensityStorageInfo storageInfo,
                                        EnterpriseSerializationService ss,
                                        ClassLoader classLoader)

Method Detail

createNearCacheRecordMap

protected NativeMemoryNearCacheRecordMap createNearCacheRecordMap(com.hazelcast.config.NearCacheConfig nearCacheConfig)

Specified by:

createNearCacheRecordMap in class com.hazelcast.internal.nearcache.impl.store.AbstractNearCacheRecordStore<K,V,com.hazelcast.nio.serialization.Data,NativeMemoryNearCacheRecord,NativeMemoryNearCacheRecordMap>

createNearCacheEvictionChecker

protected com.hazelcast.internal.eviction.EvictionChecker createNearCacheEvictionChecker(com.hazelcast.config.EvictionConfig evictionConfig,
                                                                                         com.hazelcast.config.NearCacheConfig nearCacheConfig)

Specified by:

createNearCacheEvictionChecker in class com.hazelcast.internal.nearcache.impl.store.AbstractNearCacheRecordStore<K,V,com.hazelcast.nio.serialization.Data,NativeMemoryNearCacheRecord,NativeMemoryNearCacheRecordMap>

invalidate

public void invalidate(K key)

Specified by:

invalidate in interface com.hazelcast.internal.nearcache.NearCacheRecordStore<K,V>

getKeyStorageMemoryCost

protected long getKeyStorageMemoryCost(K key)

Specified by:

getKeyStorageMemoryCost in class com.hazelcast.internal.nearcache.impl.store.AbstractNearCacheRecordStore<K,V,com.hazelcast.nio.serialization.Data,NativeMemoryNearCacheRecord,NativeMemoryNearCacheRecordMap>

getRecordStorageMemoryCost

protected long getRecordStorageMemoryCost(NativeMemoryNearCacheRecord record)

Specified by:

getRecordStorageMemoryCost in class com.hazelcast.internal.nearcache.impl.store.AbstractNearCacheRecordStore<K,V,com.hazelcast.nio.serialization.Data,NativeMemoryNearCacheRecord,NativeMemoryNearCacheRecordMap>

createRecord

protected NativeMemoryNearCacheRecord createRecord(V value)

Specified by:

createRecord in class com.hazelcast.internal.nearcache.impl.store.AbstractNearCacheRecordStore<K,V,com.hazelcast.nio.serialization.Data,NativeMemoryNearCacheRecord,NativeMemoryNearCacheRecordMap>

updateRecordValue

protected void updateRecordValue(NativeMemoryNearCacheRecord record,
                                 V value)

Specified by:

updateRecordValue in class com.hazelcast.internal.nearcache.impl.store.AbstractNearCacheRecordStore<K,V,com.hazelcast.nio.serialization.Data,NativeMemoryNearCacheRecord,NativeMemoryNearCacheRecordMap>

recordToValue

protected V recordToValue(NativeMemoryNearCacheRecord record)

Overrides:

recordToValue in class com.hazelcast.internal.nearcache.impl.store.AbstractNearCacheRecordStore<K,V,com.hazelcast.nio.serialization.Data,NativeMemoryNearCacheRecord,NativeMemoryNearCacheRecordMap>

getRecord

public NativeMemoryNearCacheRecord getRecord(K key)

Specified by:

getRecord in interface com.hazelcast.internal.nearcache.NearCacheRecordStore<K,V>

Specified by:

getRecord in class com.hazelcast.internal.nearcache.impl.store.AbstractNearCacheRecordStore<K,V,com.hazelcast.nio.serialization.Data,NativeMemoryNearCacheRecord,NativeMemoryNearCacheRecordMap>

getOrCreateToReserve

protected NativeMemoryNearCacheRecord getOrCreateToReserve(K key,
                                                           com.hazelcast.nio.serialization.Data keyData)

Specified by:

getOrCreateToReserve in class com.hazelcast.internal.nearcache.impl.store.AbstractNearCacheRecordStore<K,V,com.hazelcast.nio.serialization.Data,NativeMemoryNearCacheRecord,NativeMemoryNearCacheRecordMap>

updateAndGetReserved

protected V updateAndGetReserved(K key,
                                 V value,
                                 long reservationId,
                                 boolean deserialize)

Specified by:

updateAndGetReserved in class com.hazelcast.internal.nearcache.impl.store.AbstractNearCacheRecordStore<K,V,com.hazelcast.nio.serialization.Data,NativeMemoryNearCacheRecord,NativeMemoryNearCacheRecordMap>

putRecord

protected NativeMemoryNearCacheRecord putRecord(K key,
                                                NativeMemoryNearCacheRecord record)

Specified by:

putRecord in class com.hazelcast.internal.nearcache.impl.store.AbstractNearCacheRecordStore<K,V,com.hazelcast.nio.serialization.Data,NativeMemoryNearCacheRecord,NativeMemoryNearCacheRecordMap>

containsRecordKey

protected boolean containsRecordKey(K key)

Specified by:

containsRecordKey in class com.hazelcast.internal.nearcache.impl.store.AbstractNearCacheRecordStore<K,V,com.hazelcast.nio.serialization.Data,NativeMemoryNearCacheRecord,NativeMemoryNearCacheRecordMap>

onPut

protected void onPut(K key,
                     V value,
                     NativeMemoryNearCacheRecord record,
                     NativeMemoryNearCacheRecord oldRecord)

Overrides:

onPut in class com.hazelcast.internal.nearcache.impl.store.AbstractNearCacheRecordStore<K,V,com.hazelcast.nio.serialization.Data,NativeMemoryNearCacheRecord,NativeMemoryNearCacheRecordMap>

onPutError

protected void onPutError(K key,
                          V value,
                          NativeMemoryNearCacheRecord record,
                          NativeMemoryNearCacheRecord oldRecord,
                          Throwable error)

Overrides:

onPutError in class com.hazelcast.internal.nearcache.impl.store.AbstractNearCacheRecordStore<K,V,com.hazelcast.nio.serialization.Data,NativeMemoryNearCacheRecord,NativeMemoryNearCacheRecordMap>

onRemove

protected void onRemove(K key,
                        NativeMemoryNearCacheRecord record,
                        boolean removed)

Overrides:

onRemove in class com.hazelcast.internal.nearcache.impl.store.AbstractNearCacheRecordStore<K,V,com.hazelcast.nio.serialization.Data,NativeMemoryNearCacheRecord,NativeMemoryNearCacheRecordMap>

onRemoveError

protected void onRemoveError(K key,
                             NativeMemoryNearCacheRecord record,
                             boolean removed,
                             Throwable error)

Overrides:

onRemoveError in class com.hazelcast.internal.nearcache.impl.store.AbstractNearCacheRecordStore<K,V,com.hazelcast.nio.serialization.Data,NativeMemoryNearCacheRecord,NativeMemoryNearCacheRecordMap>

forceEvict

public int forceEvict()

Description copied from interface: HiDensityRecordStore

Forcefully evict records.

Specified by:

forceEvict in interface HiDensityRecordStore<NativeMemoryNearCacheRecord>

Returns:

evicted entry count.

doExpiration

public void doExpiration()

Specified by:

doExpiration in interface com.hazelcast.internal.nearcache.NearCacheRecordStore<K,V>

loadKeys

public void loadKeys(com.hazelcast.internal.adapter.DataStructureAdapter<Object,?> adapter)

Specified by:

loadKeys in interface com.hazelcast.internal.nearcache.NearCacheRecordStore<K,V>

storeKeys

public void storeKeys()

Specified by:

storeKeys in interface com.hazelcast.internal.nearcache.NearCacheRecordStore<K,V>

onEvict

public void onEvict(com.hazelcast.nio.serialization.Data key,
                    NativeMemoryNearCacheRecord record,
                    boolean wasExpired)

Specified by:

onEvict in interface com.hazelcast.internal.eviction.EvictionListener<com.hazelcast.nio.serialization.Data,NativeMemoryNearCacheRecord>

Overrides:

onEvict in class com.hazelcast.internal.nearcache.impl.store.AbstractNearCacheRecordStore<K,V,com.hazelcast.nio.serialization.Data,NativeMemoryNearCacheRecord,NativeMemoryNearCacheRecordMap>

getMemoryManager

public com.hazelcast.memory.HazelcastMemoryManager getMemoryManager()

Description copied from interface: HiDensityNearCacheRecordStore

Gets underlying MemoryManager implementation.

Specified by:

getMemoryManager in interface HiDensityNearCacheRecordStore<K,V,NativeMemoryNearCacheRecord>

Returns:

the underlying MemoryManager implementation.

destroy

public void destroy()

Specified by:

destroy in interface com.hazelcast.internal.nearcache.NearCacheRecordStore<K,V>

Overrides:

destroy in class com.hazelcast.internal.nearcache.impl.store.AbstractNearCacheRecordStore<K,V,com.hazelcast.nio.serialization.Data,NativeMemoryNearCacheRecord,NativeMemoryNearCacheRecordMap>