com.hazelcast.map.impl.eviction

Class EvictionCheckerImpl

java.lang.Object

com.hazelcast.map.impl.eviction.EvictionCheckerImpl

All Implemented Interfaces:

EvictionChecker

public class EvictionCheckerImpl
extends Object
implements EvictionChecker

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 MapServiceContext	mapServiceContext
protected MemoryInfoAccessor	memoryInfoAccessor
protected static int	ONE_HUNDRED_PERCENT
protected static int	ONE_KILOBYTE
protected static int	ONE_MEGABYTE

Constructor Summary

Constructors

Constructor and Description
EvictionCheckerImpl(MapServiceContext mapServiceContext)

Method Summary

Methods

Modifier and Type	Method and Description
double	calculatePerNodeMaxRecordStoreSize(RecordStore recordStore) Calculates and returns the expected maximum size of an evicted record-store when PER_NODE max-size-policy is used.
boolean	checkEvictionPossible(RecordStore recordStore) Check whether the supplied record-store needs eviction.
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	getUsedHeapSize(String mapName)
protected boolean	isOwnerOrBackup(int partitionId)
void	setMemoryInfoAccessor(MemoryInfoAccessor memoryInfoAccessor)

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 int ONE_HUNDRED_PERCENT

See Also:

Constant Field Values

ONE_KILOBYTE

protected static final int ONE_KILOBYTE

See Also:

Constant Field Values

ONE_MEGABYTE

protected static final int ONE_MEGABYTE

See Also:

Constant Field Values

mapServiceContext

protected final MapServiceContext mapServiceContext

memoryInfoAccessor

protected MemoryInfoAccessor memoryInfoAccessor

Constructor Detail

EvictionCheckerImpl

public EvictionCheckerImpl(MapServiceContext mapServiceContext)

Method Detail

checkEvictionPossible

public boolean checkEvictionPossible(RecordStore recordStore)

Description copied from interface: EvictionChecker

Check whether the supplied record-store needs eviction.

Specified by:

checkEvictionPossible in interface EvictionChecker

Parameters:

recordStore - the recordStore

Returns:

true if eviction is required, false otherwise.

checkPerNodeEviction

protected boolean checkPerNodeEviction(RecordStore recordStore)

calculatePerNodeMaxRecordStoreSize

public double calculatePerNodeMaxRecordStoreSize(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()

getUsedHeapSize

protected long getUsedHeapSize(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)

setMemoryInfoAccessor

public void setMemoryInfoAccessor(MemoryInfoAccessor memoryInfoAccessor)