com.hazelcast.cache.hidensity.impl.nativememory

Class HotRestartHiDensityNativeMemoryCacheRecordStore

java.lang.Object

com.hazelcast.cache.impl.AbstractCacheRecordStore<HiDensityNativeMemoryCacheRecord,HiDensityNativeMemoryCacheRecordMap>

com.hazelcast.cache.hidensity.impl.nativememory.HiDensityNativeMemoryCacheRecordStore

com.hazelcast.cache.hidensity.impl.nativememory.HotRestartHiDensityNativeMemoryCacheRecordStore

All Implemented Interfaces:

HiDensityCacheRecordStore<HiDensityNativeMemoryCacheRecord>, com.hazelcast.cache.impl.ICacheRecordStore, com.hazelcast.internal.eviction.EvictionListener<com.hazelcast.nio.serialization.Data,HiDensityNativeMemoryCacheRecord>, HiDensityRecordStore<HiDensityNativeMemoryCacheRecord>, com.hazelcast.spi.hotrestart.RamStore

public class HotRestartHiDensityNativeMemoryCacheRecordStore
extends HiDensityNativeMemoryCacheRecordStore
implements com.hazelcast.spi.hotrestart.RamStore

NativeMemory cache record store with Hot Restart support.

Field Summary

Fields inherited from class com.hazelcast.cache.hidensity.impl.nativememory.HiDensityNativeMemoryCacheRecordStore

cacheInfo, cacheRecordProcessor, memoryManager, serializationService

Fields inherited from class com.hazelcast.cache.impl.AbstractCacheRecordStore

batchEvent, cacheConfig, cacheContext, cacheLoader, cacheRecordFactory, cacheService, cacheWriter, clearExpiredRecordsTask, DEFAULT_INITIAL_CAPACITY, defaultExpiryPolicy, disablePerEntryInvalidationEvents, eventJournalConfig, eventsBatchingEnabled, eventsEnabled, evictionChecker, evictionConfig, evictionPolicyEvaluator, evictionStrategy, expirationIterator, expiredKeys, hasEntryWithExpiration, name, nodeEngine, objectNamespace, partitionCount, partitionId, persistWanReplicatedData, primary, records, SOURCE_NOT_AVAILABLE, ss, statistics, valueComparator, wanReplicationEnabled

Fields inherited from interface com.hazelcast.cache.hidensity.HiDensityCacheRecordStore

SYSTEM_PROPERTY_NAME_TO_DISABLE_INVALID_MAX_SIZE_POLICY_EXCEPTION

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
HotRestartHiDensityNativeMemoryCacheRecordStore(int partitionId, String cacheNameWithPrefix, EnterpriseCacheService cacheService, com.hazelcast.spi.NodeEngine nodeEngine, boolean fsync, long keyPrefix)

Method Summary

Modifier and Type	Method and Description
void	accept(com.hazelcast.spi.hotrestart.KeyHandle kh, byte[] valueBytes)
void	close(boolean onShutdown)
boolean	copyEntry(com.hazelcast.spi.hotrestart.KeyHandle keyHandle, int expectedSize, com.hazelcast.spi.hotrestart.RecordDataSink sink)
protected com.hazelcast.internal.eviction.EvictionChecker	createCacheEvictionChecker(int size, com.hazelcast.config.EvictionConfig.MaxSizePolicy maxSizePolicy) Creates an instance for checking if the maximum cache size has been reached.
protected HiDensityNativeMemoryCacheRecordMap	createMapInternal(int capacity)
void	disposeDeferredBlocks() Used to release HD memory.
protected HiDensityNativeMemoryCacheRecord	doPutRecord(com.hazelcast.nio.serialization.Data key, HiDensityNativeMemoryCacheRecord record, String source, boolean updateJournal)
protected HiDensityNativeMemoryCacheRecord	doRemoveRecord(com.hazelcast.nio.serialization.Data key, String source)
protected void	onOwn(com.hazelcast.nio.serialization.Data key, Object value, long ttlMillis, HiDensityNativeMemoryCacheRecord record, NativeMemoryData oldValueData, boolean isNewPut, boolean disableDeferredDispose)
protected void	onUpdateRecord(com.hazelcast.nio.serialization.Data key, HiDensityNativeMemoryCacheRecord record, Object value, com.hazelcast.nio.serialization.Data oldDataValue)
void	removeNullEntries(com.hazelcast.spi.hotrestart.impl.SetOfKeyHandle keyHandles)
com.hazelcast.cache.impl.record.CacheRecord	removeRecord(com.hazelcast.nio.serialization.Data key)
void	reset()
com.hazelcast.spi.hotrestart.KeyHandleOffHeap	toKeyHandle(byte[] keyBytes)
protected void	updateRecordValue(HiDensityNativeMemoryCacheRecord record, Object recordValue)

Methods inherited from class com.hazelcast.cache.hidensity.impl.nativememory.HiDensityNativeMemoryCacheRecordStore

clear, createCacheEntryProcessorEntry, createRecord, createRecordCacheMap, dataToValue, destroy, evictExpiredEntries, evictIfExpired, forceEvict, forceRemoveRecord, getRecordProcessor, getRecordValue, getValueComparatorOf, initExpirationIterator, iterator, merge, merge, onCreateRecordError, onDeleteRecord, onDestroy, onOwnError, onProcessExpiredEntry, onPut, onPutIfAbsent, onRemoveError, onReplace, onUpdateExpiryPolicy, onUpdateExpiryPolicyError, onUpdateRecordError, putBackup, putIfAbsent, putRecord, putReplica, recordToData, recordToValue, replace, replace, toData, toHeapCacheRecord, toHeapData, valueToData

Methods inherited from class com.hazelcast.cache.impl.AbstractCacheRecordStore

accessRecord, accumulateOrSendExpiredKeysToBackup, closeListeners, compare, contains, createEvictionPolicyEvaluator, createEvictionStrategy, createRecord, createRecord, createRecord, createRecord, createRecordWithExpiry, createRecordWithExpiry, createRecordWithExpiry, createRecordWithExpiry, deleteAllCacheEntry, deleteCacheEntry, deleteCacheEntry, deleteRecord, deleteRecord, deleteRecord, destroyEventJournal, destroyInternals, evictIfRequired, extractExpiryPolicyOfRecord, fetchEntries, fetchKeys, get, getAll, getAndPut, getAndRemove, getAndRemove, getAndReplace, getCacheStats, getConfig, getExpiredKeysQueue, getExpiryPolicy, getExpiryPolicy, getName, getObjectNamespace, getPartitionId, getReadOnlyRecords, getRecord, init, instrument, invalidateEntry, invalidateEntry, invoke, isEventsEnabled, isEvictionEnabled, isExpirable, isInvalidationEnabled, isReadThrough, isStatisticsEnabled, isWanReplicationEnabled, isWriteThrough, loadAll, loadAllCacheEntry, markExpirable, onEvict, onGet, onGetError, onPutError, onPutIfAbsentError, onRecordAccess, onRemove, onReplaceError, processExpiredEntry, processExpiredEntry, processExpiredEntry, processExpiredEntry, processExpiredEntry, publishBatchedEvents, publishEvent, put, put, put, putIfAbsent, putIfAbsent, readThroughCache, readThroughRecord, remove, remove, remove, removeAll, replace, replace, sampleAndForceRemoveEntries, setExpiryPolicy, size, toEventData, toStorageValue, toValue, updateAccessDuration, updateExpiryPolicyOfRecord, updateGetAndPutStat, updateRecord, updateRecord, updateRecordWithExpiry, updateRecordWithExpiry, updateRecordWithExpiry, updateRecordWithExpiry, updateRecordWithExpiry, updateRecordWithExpiry, updateRecordWithExpiry, updateReplaceStat, writeThroughCache

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.hazelcast.cache.hidensity.HiDensityCacheRecordStore

toEventData

Methods inherited from interface com.hazelcast.cache.impl.ICacheRecordStore

contains, destroyInternals, evictIfRequired, fetchEntries, fetchKeys, get, getAll, getAndPut, getAndRemove, getAndReplace, getCacheStats, getConfig, getExpiredKeysQueue, getExpiryPolicy, getName, getObjectNamespace, getPartitionId, getReadOnlyRecords, getRecord, init, invoke, isExpirable, isWanReplicationEnabled, loadAll, put, putIfAbsent, remove, remove, remove, removeAll, replace, replace, sampleAndForceRemoveEntries, setExpiryPolicy, size

Constructor Detail

HotRestartHiDensityNativeMemoryCacheRecordStore

public HotRestartHiDensityNativeMemoryCacheRecordStore(int partitionId,
                                                       String cacheNameWithPrefix,
                                                       EnterpriseCacheService cacheService,
                                                       com.hazelcast.spi.NodeEngine nodeEngine,
                                                       boolean fsync,
                                                       long keyPrefix)

Method Detail

createMapInternal

protected HiDensityNativeMemoryCacheRecordMap createMapInternal(int capacity)

Overrides:

createMapInternal in class HiDensityNativeMemoryCacheRecordStore

createCacheEvictionChecker

protected com.hazelcast.internal.eviction.EvictionChecker createCacheEvictionChecker(int size,
                                                                                     com.hazelcast.config.EvictionConfig.MaxSizePolicy maxSizePolicy)

Description copied from class: HiDensityNativeMemoryCacheRecordStore

Creates an instance for checking if the maximum cache size has been reached. Supports the following policies :

• EvictionConfig.MaxSizePolicy.USED_NATIVE_MEMORY_SIZE
• EvictionConfig.MaxSizePolicy.USED_NATIVE_MEMORY_PERCENTAGE
• EvictionConfig.MaxSizePolicy.FREE_NATIVE_MEMORY_SIZE
• EvictionConfig.MaxSizePolicy.FREE_NATIVE_MEMORY_PERCENTAGE

If the maxSizePolicy parameter is null or the policy is not supported, returns null if the HiDensityCacheRecordStore.SYSTEM_PROPERTY_NAME_TO_DISABLE_INVALID_MAX_SIZE_POLICY_EXCEPTION system property is true, else throws an IllegalArgumentException.

Overrides:

createCacheEvictionChecker in class HiDensityNativeMemoryCacheRecordStore

Parameters:

size - the maximum size

maxSizePolicy - the way in which the size is interpreted based on the supported policies

Returns:

the instance which will check if the maximum size has been reached or null if the maxSizePolicy is null or not supported and the HiDensityCacheRecordStore.SYSTEM_PROPERTY_NAME_TO_DISABLE_INVALID_MAX_SIZE_POLICY_EXCEPTION system property is true

doPutRecord

protected HiDensityNativeMemoryCacheRecord doPutRecord(com.hazelcast.nio.serialization.Data key,
                                                       HiDensityNativeMemoryCacheRecord record,
                                                       String source,
                                                       boolean updateJournal)

Overrides:

doPutRecord in class com.hazelcast.cache.impl.AbstractCacheRecordStore<HiDensityNativeMemoryCacheRecord,HiDensityNativeMemoryCacheRecordMap>

updateRecordValue

protected void updateRecordValue(HiDensityNativeMemoryCacheRecord record,
                                 Object recordValue)

Overrides:

updateRecordValue in class com.hazelcast.cache.impl.AbstractCacheRecordStore<HiDensityNativeMemoryCacheRecord,HiDensityNativeMemoryCacheRecordMap>

onUpdateRecord

protected void onUpdateRecord(com.hazelcast.nio.serialization.Data key,
                              HiDensityNativeMemoryCacheRecord record,
                              Object value,
                              com.hazelcast.nio.serialization.Data oldDataValue)

Overrides:

onUpdateRecord in class HiDensityNativeMemoryCacheRecordStore

removeRecord

public com.hazelcast.cache.impl.record.CacheRecord removeRecord(com.hazelcast.nio.serialization.Data key)

Specified by:

removeRecord in interface com.hazelcast.cache.impl.ICacheRecordStore

Overrides:

removeRecord in class HiDensityNativeMemoryCacheRecordStore

doRemoveRecord

protected HiDensityNativeMemoryCacheRecord doRemoveRecord(com.hazelcast.nio.serialization.Data key,
                                                          String source)

Overrides:

doRemoveRecord in class com.hazelcast.cache.impl.AbstractCacheRecordStore<HiDensityNativeMemoryCacheRecord,HiDensityNativeMemoryCacheRecordMap>

onOwn

protected void onOwn(com.hazelcast.nio.serialization.Data key,
                     Object value,
                     long ttlMillis,
                     HiDensityNativeMemoryCacheRecord record,
                     NativeMemoryData oldValueData,
                     boolean isNewPut,
                     boolean disableDeferredDispose)

Overrides:

onOwn in class HiDensityNativeMemoryCacheRecordStore

disposeDeferredBlocks

public void disposeDeferredBlocks()

Description copied from interface: HiDensityCacheRecordStore

Used to release HD memory.

Specified by:

disposeDeferredBlocks in interface HiDensityCacheRecordStore<HiDensityNativeMemoryCacheRecord>

Specified by:

disposeDeferredBlocks in interface com.hazelcast.cache.impl.ICacheRecordStore

Overrides:

disposeDeferredBlocks in class HiDensityNativeMemoryCacheRecordStore

copyEntry

public boolean copyEntry(com.hazelcast.spi.hotrestart.KeyHandle keyHandle,
                         int expectedSize,
                         com.hazelcast.spi.hotrestart.RecordDataSink sink)

Specified by:

copyEntry in interface com.hazelcast.spi.hotrestart.RamStore

toKeyHandle

public com.hazelcast.spi.hotrestart.KeyHandleOffHeap toKeyHandle(byte[] keyBytes)

Specified by:

toKeyHandle in interface com.hazelcast.spi.hotrestart.RamStore

accept

public void accept(com.hazelcast.spi.hotrestart.KeyHandle kh,
                   byte[] valueBytes)

Specified by:

accept in interface com.hazelcast.spi.hotrestart.RamStore

removeNullEntries

public void removeNullEntries(com.hazelcast.spi.hotrestart.impl.SetOfKeyHandle keyHandles)

Specified by:

removeNullEntries in interface com.hazelcast.spi.hotrestart.RamStore

reset

public void reset()

Specified by:

reset in interface com.hazelcast.cache.impl.ICacheRecordStore

Overrides:

reset in class com.hazelcast.cache.impl.AbstractCacheRecordStore<HiDensityNativeMemoryCacheRecord,HiDensityNativeMemoryCacheRecordMap>

close

public void close(boolean onShutdown)

Specified by:

close in interface com.hazelcast.cache.impl.ICacheRecordStore

Overrides:

close in class HiDensityNativeMemoryCacheRecordStore