com.hazelcast.cache.hidensity.impl.nativememory

Class HiDensityNativeMemoryCacheRecordStore

java.lang.Object

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

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

All Implemented Interfaces:

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

Direct Known Subclasses:

HotRestartHiDensityNativeMemoryCacheRecordStore

public class HiDensityNativeMemoryCacheRecordStore
extends com.hazelcast.cache.impl.AbstractCacheRecordStore<HiDensityNativeMemoryCacheRecord,HiDensityNativeMemoryCacheRecordMap>
implements HiDensityCacheRecordStore<HiDensityNativeMemoryCacheRecord>

Field Summary

Fields

Modifier and Type	Field and Description
protected HiDensityStorageInfo	cacheInfo
protected HiDensityRecordProcessor<HiDensityNativeMemoryCacheRecord>	cacheRecordProcessor
protected com.hazelcast.memory.HazelcastMemoryManager	memoryManager
protected EnterpriseSerializationService	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
HiDensityNativeMemoryCacheRecordStore(int partitionId, String cacheNameWithPrefix, EnterpriseCacheService cacheService, com.hazelcast.spi.NodeEngine nodeEngine)

Method Summary

Modifier and Type	Method and Description
void	clear()
void	close(boolean onShutdown)
protected com.hazelcast.cache.impl.CacheEntryProcessorEntry	createCacheEntryProcessorEntry(com.hazelcast.nio.serialization.Data key, HiDensityNativeMemoryCacheRecord record, long now, int completionId)
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)
protected HiDensityNativeMemoryCacheRecord	createRecord(Object value, long creationTime, long expiryTime)
protected HiDensityNativeMemoryCacheRecordMap	createRecordCacheMap()
protected Object	dataToValue(com.hazelcast.nio.serialization.Data data)
void	destroy()
void	disposeDeferredBlocks() Used to release HD memory.
void	evictExpiredEntries(int expirationPercentage)
protected boolean	evictIfExpired(com.hazelcast.nio.serialization.Data key, HiDensityNativeMemoryCacheRecord record, long now)
int	forceEvict() Forcefully evict records.
protected void	forceRemoveRecord(com.hazelcast.nio.serialization.Data key)
HiDensityRecordProcessor<HiDensityNativeMemoryCacheRecord>	getRecordProcessor() Gets the HiDensityRecordProcessor which is used by this HiDensityCacheRecordStore.
Object	getRecordValue(HiDensityNativeMemoryCacheRecord record) Gets the value of specified record.
protected com.hazelcast.internal.util.comparators.ValueComparator	getValueComparatorOf(com.hazelcast.config.InMemoryFormat inMemoryFormat)
protected void	initExpirationIterator()
com.hazelcast.elastic.SlottableIterator<Map.Entry<com.hazelcast.nio.serialization.Data,HiDensityNativeMemoryCacheRecord>>	iterator(int slot) Returns a slottable iterator for this HiDensityCacheRecordStore to iterate over records.
com.hazelcast.cache.impl.record.CacheRecord	merge(com.hazelcast.cache.CacheEntryView<com.hazelcast.nio.serialization.Data,com.hazelcast.nio.serialization.Data> cacheEntryView, com.hazelcast.cache.CacheMergePolicy mergePolicy, String caller, String origin, int completionId, com.hazelcast.wan.impl.CallerProvenance callerProvenance)
com.hazelcast.cache.impl.record.CacheRecord	merge(com.hazelcast.spi.merge.SplitBrainMergeTypes.CacheMergeTypes mergingEntry, com.hazelcast.spi.merge.SplitBrainMergePolicy<com.hazelcast.nio.serialization.Data,com.hazelcast.spi.merge.SplitBrainMergeTypes.CacheMergeTypes> mergePolicy, com.hazelcast.wan.impl.CallerProvenance callerProvenance)
protected void	onCreateRecordError(com.hazelcast.nio.serialization.Data key, Object value, long expiryTime, long now, boolean disableWriteThrough, int completionId, String origin, HiDensityNativeMemoryCacheRecord record, Throwable error)
protected void	onDeleteRecord(com.hazelcast.nio.serialization.Data key, HiDensityNativeMemoryCacheRecord record, boolean deleted)
protected void	onDestroy()
protected void	onOwn(com.hazelcast.nio.serialization.Data key, Object value, long ttlMillis, HiDensityNativeMemoryCacheRecord record, NativeMemoryData oldValueData, boolean isNewPut, boolean disableDeferredDispose)
protected void	onOwnError(com.hazelcast.nio.serialization.Data key, Object value, long ttlMillis, HiDensityNativeMemoryCacheRecord record, NativeMemoryData oldValueData, boolean isNewPut, boolean disableDeferredDispose, Throwable error)
protected void	onProcessExpiredEntry(com.hazelcast.nio.serialization.Data key, HiDensityNativeMemoryCacheRecord record, long expiryTime, long now, String source, String origin)
protected void	onPut(com.hazelcast.nio.serialization.Data key, Object value, javax.cache.expiry.ExpiryPolicy expiryPolicy, String caller, boolean getValue, boolean disableWriteThrough, HiDensityNativeMemoryCacheRecord record, Object oldValue, boolean isExpired, boolean isNewPut, boolean isSaveSucceed)
protected void	onPutIfAbsent(com.hazelcast.nio.serialization.Data key, Object value, javax.cache.expiry.ExpiryPolicy expiryPolicy, String caller, boolean disableWriteThrough, HiDensityNativeMemoryCacheRecord record, boolean isExpired, boolean isSaveSucceed)
protected void	onRemoveError(com.hazelcast.nio.serialization.Data key, Object value, String caller, boolean getValue, HiDensityNativeMemoryCacheRecord record, boolean removed, Throwable error)
protected void	onReplace(com.hazelcast.nio.serialization.Data key, Object oldValue, Object newValue, javax.cache.expiry.ExpiryPolicy expiryPolicy, String caller, boolean getValue, HiDensityNativeMemoryCacheRecord record, boolean isExpired, boolean replaced)
protected void	onUpdateExpiryPolicy(com.hazelcast.nio.serialization.Data key, HiDensityNativeMemoryCacheRecord record, com.hazelcast.nio.serialization.Data oldDataExpiryPolicy)
protected void	onUpdateExpiryPolicyError(com.hazelcast.nio.serialization.Data key, HiDensityNativeMemoryCacheRecord record, com.hazelcast.nio.serialization.Data oldDataExpiryPolicy)
protected void	onUpdateRecord(com.hazelcast.nio.serialization.Data key, HiDensityNativeMemoryCacheRecord record, Object value, com.hazelcast.nio.serialization.Data oldDataValue)
protected void	onUpdateRecordError(com.hazelcast.nio.serialization.Data key, HiDensityNativeMemoryCacheRecord record, Object value, com.hazelcast.nio.serialization.Data newDataValue, com.hazelcast.nio.serialization.Data oldDataValue, Throwable error)
com.hazelcast.cache.impl.record.CacheRecord	putBackup(com.hazelcast.nio.serialization.Data key, Object value, long creationTime, javax.cache.expiry.ExpiryPolicy expiryPolicy) Puts and saves (replaces if exist) the backup value with the specified key to this HiDensityCacheRecordStore.
boolean	putIfAbsent(com.hazelcast.nio.serialization.Data key, Object value, String caller, int completionId) Puts the value with the specified key to this HiDensityCacheRecordStore if there is no value with the same key.
void	putRecord(com.hazelcast.nio.serialization.Data key, com.hazelcast.cache.impl.record.CacheRecord record, boolean updateJournal)
com.hazelcast.cache.impl.record.CacheRecord	putReplica(com.hazelcast.nio.serialization.Data key, Object value, long creationTime, long ttlMillis) Puts and saves (replaces if exist) the replicated value with the specified key to this HiDensityCacheRecordStore.
protected com.hazelcast.nio.serialization.Data	recordToData(HiDensityNativeMemoryCacheRecord record)
protected Object	recordToValue(HiDensityNativeMemoryCacheRecord record)
com.hazelcast.cache.impl.record.CacheRecord	removeRecord(com.hazelcast.nio.serialization.Data key)
boolean	replace(com.hazelcast.nio.serialization.Data key, Object oldValue, Object newValue, String caller, int completionId) Replaces the already stored value with the new value mapped by the specified key to this HiDensityCacheRecordStore if there is a value with the specified key and equals to specified value.
boolean	replace(com.hazelcast.nio.serialization.Data key, Object value, String caller, int completionId) Replaces the already stored value with the new value mapped by the specified key to this HiDensityCacheRecordStore if there is a value with the specified key.
protected com.hazelcast.nio.serialization.Data	toData(Object obj)
com.hazelcast.cache.impl.record.CacheRecord	toHeapCacheRecord(HiDensityNativeMemoryCacheRecord record) Converts given HiDensityCacheRecord to heap based CacheRecord.
protected com.hazelcast.nio.serialization.Data	toHeapData(Object obj)
protected com.hazelcast.nio.serialization.Data	valueToData(Object value)

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, doPutRecord, doRemoveRecord, 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, reset, sampleAndForceRemoveEntries, setExpiryPolicy, size, toEventData, toStorageValue, toValue, updateAccessDuration, updateExpiryPolicyOfRecord, updateGetAndPutStat, updateRecord, updateRecord, updateRecordValue, 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, reset, sampleAndForceRemoveEntries, setExpiryPolicy, size

Field Detail

cacheInfo

protected HiDensityStorageInfo cacheInfo

memoryManager

protected com.hazelcast.memory.HazelcastMemoryManager memoryManager

serializationService

protected EnterpriseSerializationService serializationService

cacheRecordProcessor

protected HiDensityRecordProcessor<HiDensityNativeMemoryCacheRecord> cacheRecordProcessor

Constructor Detail

HiDensityNativeMemoryCacheRecordStore

public HiDensityNativeMemoryCacheRecordStore(int partitionId,
                                             String cacheNameWithPrefix,
                                             EnterpriseCacheService cacheService,
                                             com.hazelcast.spi.NodeEngine nodeEngine)

Method Detail

getValueComparatorOf

protected com.hazelcast.internal.util.comparators.ValueComparator getValueComparatorOf(com.hazelcast.config.InMemoryFormat inMemoryFormat)

Overrides:

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

createCacheEvictionChecker

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. 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 com.hazelcast.cache.impl.AbstractCacheRecordStore<HiDensityNativeMemoryCacheRecord,HiDensityNativeMemoryCacheRecordMap>

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

Throws:

IllegalArgumentException - if the maxSizePolicy is null or not supported and the HiDensityCacheRecordStore.SYSTEM_PROPERTY_NAME_TO_DISABLE_INVALID_MAX_SIZE_POLICY_EXCEPTION system property is false

forceRemoveRecord

protected void forceRemoveRecord(com.hazelcast.nio.serialization.Data key)

Overrides:

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

createRecordCacheMap

protected HiDensityNativeMemoryCacheRecordMap createRecordCacheMap()

Specified by:

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

createMapInternal

protected HiDensityNativeMemoryCacheRecordMap createMapInternal(int capacity)

createCacheEntryProcessorEntry

protected com.hazelcast.cache.impl.CacheEntryProcessorEntry createCacheEntryProcessorEntry(com.hazelcast.nio.serialization.Data key,
                                                                                           HiDensityNativeMemoryCacheRecord record,
                                                                                           long now,
                                                                                           int completionId)

Specified by:

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

valueToData

protected com.hazelcast.nio.serialization.Data valueToData(Object value)

Specified by:

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

dataToValue

protected Object dataToValue(com.hazelcast.nio.serialization.Data data)

Specified by:

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

recordToValue

protected Object recordToValue(HiDensityNativeMemoryCacheRecord record)

Specified by:

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

recordToData

protected com.hazelcast.nio.serialization.Data recordToData(HiDensityNativeMemoryCacheRecord record)

Specified by:

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

toData

protected com.hazelcast.nio.serialization.Data toData(Object obj)

Overrides:

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

toHeapData

protected com.hazelcast.nio.serialization.Data toHeapData(Object obj)

Specified by:

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

merge

public com.hazelcast.cache.impl.record.CacheRecord merge(com.hazelcast.spi.merge.SplitBrainMergeTypes.CacheMergeTypes mergingEntry,
                                                         com.hazelcast.spi.merge.SplitBrainMergePolicy<com.hazelcast.nio.serialization.Data,com.hazelcast.spi.merge.SplitBrainMergeTypes.CacheMergeTypes> mergePolicy,
                                                         com.hazelcast.wan.impl.CallerProvenance callerProvenance)

Specified by:

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

Overrides:

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

merge

public com.hazelcast.cache.impl.record.CacheRecord merge(com.hazelcast.cache.CacheEntryView<com.hazelcast.nio.serialization.Data,com.hazelcast.nio.serialization.Data> cacheEntryView,
                                                         com.hazelcast.cache.CacheMergePolicy mergePolicy,
                                                         String caller,
                                                         String origin,
                                                         int completionId,
                                                         com.hazelcast.wan.impl.CallerProvenance callerProvenance)

Specified by:

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

Overrides:

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

toHeapCacheRecord

public final com.hazelcast.cache.impl.record.CacheRecord toHeapCacheRecord(HiDensityNativeMemoryCacheRecord record)

Description copied from interface: HiDensityCacheRecordStore

Converts given HiDensityCacheRecord to heap based CacheRecord.

Specified by:

toHeapCacheRecord in interface HiDensityCacheRecordStore<HiDensityNativeMemoryCacheRecord>

Parameters:

record - the HiDensityCacheRecord to be converted to heap based CacheRecord

Returns:

the heap based CacheRecord converted from the given HiDensityCacheRecord

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

getRecordValue

public Object getRecordValue(HiDensityNativeMemoryCacheRecord record)

Description copied from interface: HiDensityCacheRecordStore

Gets the value of specified record.

Specified by:

getRecordValue in interface HiDensityCacheRecordStore<HiDensityNativeMemoryCacheRecord>

Parameters:

record - the record whose value is extracted

Returns:

value of the record

iterator

public com.hazelcast.elastic.SlottableIterator<Map.Entry<com.hazelcast.nio.serialization.Data,HiDensityNativeMemoryCacheRecord>> iterator(int slot)

Description copied from interface: HiDensityCacheRecordStore

Returns a slottable iterator for this HiDensityCacheRecordStore to iterate over records.

Specified by:

iterator in interface HiDensityCacheRecordStore<HiDensityNativeMemoryCacheRecord>

Parameters:

slot - the slot number (or index) to start the iterator

Returns:

the slottable iterator for specified slot

getRecordProcessor

public HiDensityRecordProcessor<HiDensityNativeMemoryCacheRecord> getRecordProcessor()

Description copied from interface: HiDensityCacheRecordStore

Gets the HiDensityRecordProcessor which is used by this HiDensityCacheRecordStore.

Specified by:

getRecordProcessor in interface HiDensityCacheRecordStore<HiDensityNativeMemoryCacheRecord>

Returns:

the used Hi-Density cache record processor

createRecord

protected HiDensityNativeMemoryCacheRecord createRecord(Object value,
                                                        long creationTime,
                                                        long expiryTime)

Specified by:

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

initExpirationIterator

protected void initExpirationIterator()

Overrides:

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

onCreateRecordError

protected void onCreateRecordError(com.hazelcast.nio.serialization.Data key,
                                   Object value,
                                   long expiryTime,
                                   long now,
                                   boolean disableWriteThrough,
                                   int completionId,
                                   String origin,
                                   HiDensityNativeMemoryCacheRecord record,
                                   Throwable error)

Overrides:

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

evictIfExpired

protected boolean evictIfExpired(com.hazelcast.nio.serialization.Data key,
                                 HiDensityNativeMemoryCacheRecord record,
                                 long now)

Overrides:

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

evictExpiredEntries

public void evictExpiredEntries(int expirationPercentage)

Specified by:

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

Overrides:

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

onProcessExpiredEntry

protected void onProcessExpiredEntry(com.hazelcast.nio.serialization.Data key,
                                     HiDensityNativeMemoryCacheRecord record,
                                     long expiryTime,
                                     long now,
                                     String source,
                                     String origin)

Overrides:

onProcessExpiredEntry 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 com.hazelcast.cache.impl.AbstractCacheRecordStore<HiDensityNativeMemoryCacheRecord,HiDensityNativeMemoryCacheRecordMap>

onUpdateRecordError

protected void onUpdateRecordError(com.hazelcast.nio.serialization.Data key,
                                   HiDensityNativeMemoryCacheRecord record,
                                   Object value,
                                   com.hazelcast.nio.serialization.Data newDataValue,
                                   com.hazelcast.nio.serialization.Data oldDataValue,
                                   Throwable error)

Overrides:

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

onDeleteRecord

protected void onDeleteRecord(com.hazelcast.nio.serialization.Data key,
                              HiDensityNativeMemoryCacheRecord record,
                              boolean deleted)

Overrides:

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

onUpdateExpiryPolicy

protected void onUpdateExpiryPolicy(com.hazelcast.nio.serialization.Data key,
                                    HiDensityNativeMemoryCacheRecord record,
                                    com.hazelcast.nio.serialization.Data oldDataExpiryPolicy)

Overrides:

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

onUpdateExpiryPolicyError

protected void onUpdateExpiryPolicyError(com.hazelcast.nio.serialization.Data key,
                                         HiDensityNativeMemoryCacheRecord record,
                                         com.hazelcast.nio.serialization.Data oldDataExpiryPolicy)

Overrides:

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

putRecord

public void putRecord(com.hazelcast.nio.serialization.Data key,
                      com.hazelcast.cache.impl.record.CacheRecord record,
                      boolean updateJournal)

Specified by:

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

Overrides:

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

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 com.hazelcast.cache.impl.AbstractCacheRecordStore<HiDensityNativeMemoryCacheRecord,HiDensityNativeMemoryCacheRecordMap>

onPut

protected void onPut(com.hazelcast.nio.serialization.Data key,
                     Object value,
                     javax.cache.expiry.ExpiryPolicy expiryPolicy,
                     String caller,
                     boolean getValue,
                     boolean disableWriteThrough,
                     HiDensityNativeMemoryCacheRecord record,
                     Object oldValue,
                     boolean isExpired,
                     boolean isNewPut,
                     boolean isSaveSucceed)

Overrides:

onPut 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)

onOwnError

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

putBackup

public com.hazelcast.cache.impl.record.CacheRecord putBackup(com.hazelcast.nio.serialization.Data key,
                                                             Object value,
                                                             long creationTime,
                                                             javax.cache.expiry.ExpiryPolicy expiryPolicy)

Description copied from interface: HiDensityCacheRecordStore

Puts and saves (replaces if exist) the backup value with the specified key to this HiDensityCacheRecordStore.

Specified by:

putBackup in interface HiDensityCacheRecordStore<HiDensityNativeMemoryCacheRecord>

Parameters:

key - the key of the value to be owned

value - the value to be owned

expiryPolicy - expiry policy of the owned value

Returns:

the updated (or added) record

putReplica

public com.hazelcast.cache.impl.record.CacheRecord putReplica(com.hazelcast.nio.serialization.Data key,
                                                              Object value,
                                                              long creationTime,
                                                              long ttlMillis)

Description copied from interface: HiDensityCacheRecordStore

Puts and saves (replaces if exist) the replicated value with the specified key to this HiDensityCacheRecordStore.

Specified by:

putReplica in interface HiDensityCacheRecordStore<HiDensityNativeMemoryCacheRecord>

Parameters:

key - the key of the value to be owned

value - the value to be owned

ttlMillis - the TTL value in milliseconds for the owned value

Returns:

the updated (or added) record

onPutIfAbsent

protected void onPutIfAbsent(com.hazelcast.nio.serialization.Data key,
                             Object value,
                             javax.cache.expiry.ExpiryPolicy expiryPolicy,
                             String caller,
                             boolean disableWriteThrough,
                             HiDensityNativeMemoryCacheRecord record,
                             boolean isExpired,
                             boolean isSaveSucceed)

Overrides:

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

putIfAbsent

public boolean putIfAbsent(com.hazelcast.nio.serialization.Data key,
                           Object value,
                           String caller,
                           int completionId)

Description copied from interface: HiDensityCacheRecordStore

Puts the value with the specified key to this HiDensityCacheRecordStore if there is no value with the same key.

Specified by:

putIfAbsent in interface HiDensityCacheRecordStore<HiDensityNativeMemoryCacheRecord>

Parameters:

key - the key of the value to be put

value - the value to be put

caller - the ID which represents the caller

Returns:

true if the value has been put to the record store, otherwise false

onReplace

protected void onReplace(com.hazelcast.nio.serialization.Data key,
                         Object oldValue,
                         Object newValue,
                         javax.cache.expiry.ExpiryPolicy expiryPolicy,
                         String caller,
                         boolean getValue,
                         HiDensityNativeMemoryCacheRecord record,
                         boolean isExpired,
                         boolean replaced)

Overrides:

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

replace

public boolean replace(com.hazelcast.nio.serialization.Data key,
                       Object value,
                       String caller,
                       int completionId)

Description copied from interface: HiDensityCacheRecordStore

Replaces the already stored value with the new value mapped by the specified key to this HiDensityCacheRecordStore if there is a value with the specified key.

Specified by:

replace in interface HiDensityCacheRecordStore<HiDensityNativeMemoryCacheRecord>

Parameters:

key - the key of the value to be put

value - the value to be put

caller - the ID which represents the caller

Returns:

true if the value has been replaced with the specified value, otherwise false

replace

public boolean replace(com.hazelcast.nio.serialization.Data key,
                       Object oldValue,
                       Object newValue,
                       String caller,
                       int completionId)

Description copied from interface: HiDensityCacheRecordStore

Replaces the already stored value with the new value mapped by the specified key to this HiDensityCacheRecordStore if there is a value with the specified key and equals to specified value.

Specified by:

replace in interface HiDensityCacheRecordStore<HiDensityNativeMemoryCacheRecord>

Parameters:

key - the key of the value to be put

oldValue - the expected value of the record for the specified key

newValue - the new value to be put

caller - the ID which represents the caller

Returns:

true if the value has been replaced with the specified value, otherwise false

onRemoveError

protected void onRemoveError(com.hazelcast.nio.serialization.Data key,
                             Object value,
                             String caller,
                             boolean getValue,
                             HiDensityNativeMemoryCacheRecord record,
                             boolean removed,
                             Throwable error)

Overrides:

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

forceEvict

public int forceEvict()

Description copied from interface: HiDensityRecordStore

Forcefully evict records.

Specified by:

forceEvict in interface HiDensityRecordStore<HiDensityNativeMemoryCacheRecord>

Returns:

evicted entry count.

clear

public void clear()

Specified by:

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

Overrides:

clear 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 com.hazelcast.cache.impl.AbstractCacheRecordStore<HiDensityNativeMemoryCacheRecord,HiDensityNativeMemoryCacheRecordMap>

onDestroy

protected void onDestroy()

Overrides:

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

destroy

public void destroy()

Specified by:

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

Overrides:

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