com.hazelcast.map.impl.eviction

Class EvictionChecker

java.lang.Object

com.hazelcast.map.impl.eviction.EvictionChecker

public class EvictionChecker
extends Object

Checks whether a specific threshold is exceeded or not according to configured MaxSizeConfig.MaxSizePolicy to start eviction process.

See Also:

EvictorImpl.evictionChecker

Field Summary

Fields

Modifier and Type	Field and Description
protected ILogger	logger
protected MapServiceContext	mapServiceContext
protected MemoryInfoAccessor	memoryInfoAccessor
protected AtomicBoolean	misconfiguredPerNodeMaxSizeWarningLogged
protected static double	ONE_HUNDRED_PERCENT

Constructor Summary

Constructors

Constructor and Description
EvictionChecker(MemoryInfoAccessor givenMemoryInfoAccessor, MapServiceContext mapServiceContext)

Method Summary

Modifier and Type	Method and Description
boolean	checkEvictable(RecordStore recordStore)
protected boolean	checkFreeHeapPercentageEviction(MaxSizeConfig maxSizeConfig)
protected boolean	checkFreeHeapSizeEviction(MaxSizeConfig maxSizeConfig)
protected boolean	checkHeapPercentageEviction(String mapName, MaxSizeConfig maxSizeConfig)
protected boolean	checkHeapSizeEviction(String mapName, MaxSizeConfig maxSizeConfig)
protected boolean	checkPerNodeEviction(RecordStore recordStore)
protected boolean	checkPerPartitionEviction(String mapName, MaxSizeConfig maxSizeConfig, int partitionId)
protected List<Integer>	findPartitionIds()
protected long	getAvailableMemory()
protected long	getFreeMemory()
protected long	getMaxMemory()
protected long	getRecordStoreHeapCost(String mapName, PartitionContainer partitionContainer)
protected int	getRecordStoreSize(String mapName, PartitionContainer partitionContainer)
protected long	getTotalMemory()
protected long	getUsedHeapInBytes(String mapName)
protected boolean	isOwnerOrBackup(int partitionId)
double	translatePerNodeSizeToPartitionSize(RecordStore recordStore) Calculates and returns the expected maximum size of an evicted record-store when PER_NODE max-size-policy is used.

Methods inherited from class java.lang.Object

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

Field Detail

ONE_HUNDRED_PERCENT

protected static final double ONE_HUNDRED_PERCENT

See Also:

Constant Field Values

logger

protected final ILogger logger

mapServiceContext

protected final MapServiceContext mapServiceContext

memoryInfoAccessor

protected final MemoryInfoAccessor memoryInfoAccessor

misconfiguredPerNodeMaxSizeWarningLogged

protected final AtomicBoolean misconfiguredPerNodeMaxSizeWarningLogged

Constructor Detail

EvictionChecker

public EvictionChecker(MemoryInfoAccessor givenMemoryInfoAccessor,
                       MapServiceContext mapServiceContext)

Method Detail

checkEvictable

public boolean checkEvictable(RecordStore recordStore)

checkPerNodeEviction

protected boolean checkPerNodeEviction(RecordStore recordStore)

translatePerNodeSizeToPartitionSize

public double translatePerNodeSizeToPartitionSize(RecordStore recordStore)

Calculates and returns the expected maximum size of an evicted record-store when PER_NODE max-size-policy is used.

checkPerPartitionEviction

protected boolean checkPerPartitionEviction(String mapName,
                                            MaxSizeConfig maxSizeConfig,
                                            int partitionId)

checkHeapSizeEviction

protected boolean checkHeapSizeEviction(String mapName,
                                        MaxSizeConfig maxSizeConfig)

checkFreeHeapSizeEviction

protected boolean checkFreeHeapSizeEviction(MaxSizeConfig maxSizeConfig)

checkHeapPercentageEviction

protected boolean checkHeapPercentageEviction(String mapName,
                                              MaxSizeConfig maxSizeConfig)

checkFreeHeapPercentageEviction

protected boolean checkFreeHeapPercentageEviction(MaxSizeConfig maxSizeConfig)

getTotalMemory

protected long getTotalMemory()

getFreeMemory

protected long getFreeMemory()

getMaxMemory

protected long getMaxMemory()

getAvailableMemory

protected long getAvailableMemory()

getUsedHeapInBytes

protected long getUsedHeapInBytes(String mapName)

getRecordStoreSize

protected int getRecordStoreSize(String mapName,
                                 PartitionContainer partitionContainer)

getRecordStoreHeapCost

protected long getRecordStoreHeapCost(String mapName,
                                      PartitionContainer partitionContainer)

findPartitionIds

protected List<Integer> findPartitionIds()

isOwnerOrBackup

protected boolean isOwnerOrBackup(int partitionId)