org.apache.ignite.internal.processors.cache

Class IgniteCacheOffheapManagerImpl

java.lang.Object

org.apache.ignite.internal.processors.cache.GridCacheManagerAdapter

org.apache.ignite.internal.processors.cache.IgniteCacheOffheapManagerImpl

All Implemented Interfaces:

GridCacheManager, IgniteCacheOffheapManager

public class IgniteCacheOffheapManagerImpl
extends GridCacheManagerAdapter
implements IgniteCacheOffheapManager

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	IgniteCacheOffheapManagerImpl.CacheDataRowStore
protected class	IgniteCacheOffheapManagerImpl.CacheDataStoreImpl
protected static class	IgniteCacheOffheapManagerImpl.CacheDataTree
static class	IgniteCacheOffheapManagerImpl.DataInnerIO
static class	IgniteCacheOffheapManagerImpl.DataLeafIO
protected static class	IgniteCacheOffheapManagerImpl.PendingEntriesTree
static class	IgniteCacheOffheapManagerImpl.PendingEntryInnerIO
static class	IgniteCacheOffheapManagerImpl.PendingEntryLeafIO

Nested classes/interfaces inherited from interface org.apache.ignite.internal.processors.cache.IgniteCacheOffheapManager

IgniteCacheOffheapManager.CacheDataStore, IgniteCacheOffheapManager.OffheapInvokeClosure

Field Summary

Fields

Modifier and Type	Field and Description
protected ConcurrentMap<Integer,IgniteCacheOffheapManager.CacheDataStore>	partDataStores
protected IgniteCacheOffheapManagerImpl.PendingEntriesTree	pendingEntries
protected IgniteCacheOffheapManager.CacheDataStore	rmvdStore

Fields inherited from class org.apache.ignite.internal.processors.cache.GridCacheManagerAdapter

cctx, log, starting

Constructor Summary

Constructors

Constructor and Description
IgniteCacheOffheapManagerImpl()

Method Summary

Methods

Modifier and Type	Method and Description
Iterable<IgniteCacheOffheapManager.CacheDataStore>	cacheDataStores()
void	clear(boolean readers) Clears offheap entries.
boolean	containsKey(GridCacheMapEntry entry) TODO: GG-10884, used on only from initialValue.
IgniteCacheOffheapManager.CacheDataStore	createCacheDataStore(int p)
protected IgniteCacheOffheapManager.CacheDataStore	createCacheDataStore0(int p)
IgniteCacheOffheapManager.CacheDataStore	dataStore(GridDhtLocalPartition part)
void	destroyCacheDataStore(int p, IgniteCacheOffheapManager.CacheDataStore store)
protected void	destroyCacheDataStructures(boolean destroy)
void	dropRootPageForIndex(String idxName)
long	entriesCount()
long	entriesCount(boolean primary, boolean backup, AffinityTopologyVersion topVer)
long	entriesCount(int part)
<K,V> GridCloseableIterator<javax.cache.Cache.Entry<K,V>>	entriesIterator(boolean primary, boolean backup, AffinityTopologyVersion topVer, boolean keepBinary)
boolean	expire(IgniteInClosure2X<GridCacheEntryEx,GridCacheVersion> c, int amount)
long	expiredSize() Gets the number of entries pending expire.
GridAtomicLong	globalRemoveId()
protected void	initDataStructures()
void	invoke(KeyCacheObject key, GridDhtLocalPartition part, IgniteCacheOffheapManager.OffheapInvokeClosure c)
GridIterator<CacheDataRow>	iterator(boolean primary, boolean backups, AffinityTopologyVersion topVer)
GridIterator<CacheDataRow>	iterator(int part)
GridCloseableIterator<KeyCacheObject>	keysIterator(int part)
long	lastUpdatedPartitionCounter(int part) Partition counter provider.
long	offHeapAllocatedSize()
protected void	onKernalStop0(boolean cancel)
void	onPartitionCounterUpdated(int part, long cntr) Partition counter update callback.
void	onPartitionInitialCounterUpdated(int part, long cntr) Initial counter will be updated on state restore only
int	onUndeploy(ClassLoader ldr)
CacheDataRow	read(GridCacheMapEntry entry)
IgniteRebalanceIterator	rebalanceIterator(int part, AffinityTopologyVersion topVer, Long partCntr)
void	remove(KeyCacheObject key, int partId, GridDhtLocalPartition part)
ReuseList	reuseListForIndex(String idxName)
RootPage	rootPageForIndex(String idxName)
protected void	start0()
protected void	stop0(boolean cancel, boolean destroy)
protected String	treeName(int p)
void	update(KeyCacheObject key, CacheObject val, GridCacheVersion ver, long expireTime, int partId, GridDhtLocalPartition part, CacheDataRow oldRow)

Methods inherited from class org.apache.ignite.internal.processors.cache.GridCacheManagerAdapter

context, kernalStartInfo, kernalStopInfo, log, onDisconnected, onKernalStart, onKernalStart0, onKernalStop, printMemoryStats, start, startInfo, stop, stopInfo, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.ignite.internal.processors.cache.GridCacheManager

onDisconnected, onKernalStart, onKernalStop, printMemoryStats, start, stop

Field Detail

partDataStores

protected final ConcurrentMap<Integer,IgniteCacheOffheapManager.CacheDataStore> partDataStores

rmvdStore

protected final IgniteCacheOffheapManager.CacheDataStore rmvdStore

pendingEntries

protected IgniteCacheOffheapManagerImpl.PendingEntriesTree pendingEntries

Constructor Detail

IgniteCacheOffheapManagerImpl

public IgniteCacheOffheapManagerImpl()

Method Detail

globalRemoveId

public GridAtomicLong globalRemoveId()

Specified by:

globalRemoveId in interface IgniteCacheOffheapManager

Returns:

Global remove ID counter.

start0

protected void start0()
               throws IgniteCheckedException

Overrides:

start0 in class GridCacheManagerAdapter

Throws:

IgniteCheckedException - If failed.

initDataStructures

protected void initDataStructures()
                           throws IgniteCheckedException

Throws:

IgniteCheckedException - If failed.

stop0

protected void stop0(boolean cancel,
         boolean destroy)

Overrides:

stop0 in class GridCacheManagerAdapter

Parameters:

cancel - Cancel flag.

destroy - Cache destroy flag.

onKernalStop0

protected void onKernalStop0(boolean cancel)

Overrides:

onKernalStop0 in class GridCacheManagerAdapter

Parameters:

cancel - Cancel flag.

destroyCacheDataStructures

protected void destroyCacheDataStructures(boolean destroy)

dataStore

public IgniteCacheOffheapManager.CacheDataStore dataStore(GridDhtLocalPartition part)

Specified by:

dataStore in interface IgniteCacheOffheapManager

Parameters:

part - Partition.

Returns:

Data store for given entry.

entriesCount

public long entriesCount()

Specified by:

entriesCount in interface IgniteCacheOffheapManager

Returns:

Number of entries.

entriesCount

public long entriesCount(boolean primary,
                boolean backup,
                AffinityTopologyVersion topVer)
                  throws IgniteCheckedException

Specified by:

entriesCount in interface IgniteCacheOffheapManager

Parameters:

primary - Primary entries flag.

backup - Backup entries flag.

topVer - Topology version.

Returns:

Entries count.

Throws:

IgniteCheckedException - If failed.

entriesCount

public long entriesCount(int part)

Specified by:

entriesCount in interface IgniteCacheOffheapManager

Parameters:

part - Partition.

Returns:

Number of entries in given partition.

invoke

public void invoke(KeyCacheObject key,
          GridDhtLocalPartition part,
          IgniteCacheOffheapManager.OffheapInvokeClosure c)
            throws IgniteCheckedException

Specified by:

invoke in interface IgniteCacheOffheapManager

Parameters:

key - Key.

part - Partition.

c - Tree update closure.

Throws:

IgniteCheckedException - If failed.

update

public void update(KeyCacheObject key,
          CacheObject val,
          GridCacheVersion ver,
          long expireTime,
          int partId,
          GridDhtLocalPartition part,
          @Nullable
          CacheDataRow oldRow)
            throws IgniteCheckedException

Specified by:

update in interface IgniteCacheOffheapManager

Parameters:

key - Key.

val - Value.

ver - Version.

expireTime - Expire time.

partId - Partition number.

part - Partition.

oldRow - Old row if available.

Throws:

IgniteCheckedException - If failed.

remove

public void remove(KeyCacheObject key,
          int partId,
          GridDhtLocalPartition part)
            throws IgniteCheckedException

Specified by:

remove in interface IgniteCacheOffheapManager

Parameters:

key - Key.

partId - Partition number.

part - Partition.

Throws:

IgniteCheckedException - If failed.

read

@Nullable
public CacheDataRow read(GridCacheMapEntry entry)
                  throws IgniteCheckedException

Specified by:

read in interface IgniteCacheOffheapManager

Parameters:

entry - Cache entry.

Returns:

Cached row, if available, null otherwise.

Throws:

IgniteCheckedException - If failed.

containsKey

public boolean containsKey(GridCacheMapEntry entry)

TODO: GG-10884, used on only from initialValue.

Specified by:

containsKey in interface IgniteCacheOffheapManager

onPartitionCounterUpdated

public void onPartitionCounterUpdated(int part,
                             long cntr)

Partition counter update callback. May be overridden by plugin-provided subclasses.

Specified by:

onPartitionCounterUpdated in interface IgniteCacheOffheapManager

Parameters:

part - Partition.

cntr - Partition counter.

onPartitionInitialCounterUpdated

public void onPartitionInitialCounterUpdated(int part,
                                    long cntr)

Initial counter will be updated on state restore only

Specified by:

onPartitionInitialCounterUpdated in interface IgniteCacheOffheapManager

Parameters:

part - Partition

cntr - New initial counter

lastUpdatedPartitionCounter

public long lastUpdatedPartitionCounter(int part)

Partition counter provider. May be overridden by plugin-provided subclasses.

Specified by:

lastUpdatedPartitionCounter in interface IgniteCacheOffheapManager

Parameters:

part - Partition ID.

Returns:

Last updated counter.

clear

public void clear(boolean readers)

Clears offheap entries.

Specified by:

clear in interface IgniteCacheOffheapManager

Parameters:

readers - True to clear readers.

onUndeploy

public int onUndeploy(ClassLoader ldr)

Specified by:

onUndeploy in interface IgniteCacheOffheapManager

Parameters:

ldr - Class loader.

Returns:

Number of undeployed entries.

offHeapAllocatedSize

public long offHeapAllocatedSize()

Specified by:

offHeapAllocatedSize in interface IgniteCacheOffheapManager

Returns:

Offheap allocated size.

entriesIterator

public <K,V> GridCloseableIterator<javax.cache.Cache.Entry<K,V>> entriesIterator(boolean primary,
                                                                        boolean backup,
                                                                        AffinityTopologyVersion topVer,
                                                                        boolean keepBinary)
                                                                    throws IgniteCheckedException

Specified by:

entriesIterator in interface IgniteCacheOffheapManager

Parameters:

primary - True if need return primary entries.

backup - True if need return backup entries.

topVer - Topology version to use.

keepBinary - Keep binary flag.

Returns:

Entries iterator.

Throws:

IgniteCheckedException - If failed.

keysIterator

public GridCloseableIterator<KeyCacheObject> keysIterator(int part)
                                                   throws IgniteCheckedException

Specified by:

keysIterator in interface IgniteCacheOffheapManager

Parameters:

part - Partition.

Returns:

Iterator.

Throws:

IgniteCheckedException - If failed.

iterator

public GridIterator<CacheDataRow> iterator(boolean primary,
                                  boolean backups,
                                  AffinityTopologyVersion topVer)
                                    throws IgniteCheckedException

Specified by:

iterator in interface IgniteCacheOffheapManager

Parameters:

primary - Primary entries flag.

backups - Backup entries flag.

topVer - Topology version.

Returns:

Rows iterator.

Throws:

IgniteCheckedException - If failed.

iterator

public GridIterator<CacheDataRow> iterator(int part)
                                    throws IgniteCheckedException

Specified by:

iterator in interface IgniteCacheOffheapManager

Parameters:

part - Partition.

Returns:

Partition data iterator.

Throws:

IgniteCheckedException - If failed.

rootPageForIndex

public RootPage rootPageForIndex(String idxName)
                          throws IgniteCheckedException

Specified by:

rootPageForIndex in interface IgniteCacheOffheapManager

Parameters:

idxName - Index name.

Returns:

Root page for index tree.

Throws:

IgniteCheckedException - If failed.

dropRootPageForIndex

public void dropRootPageForIndex(String idxName)
                          throws IgniteCheckedException

Specified by:

dropRootPageForIndex in interface IgniteCacheOffheapManager

Parameters:

idxName - Index name.

Throws:

IgniteCheckedException - If failed.

reuseListForIndex

public ReuseList reuseListForIndex(String idxName)

Specified by:

reuseListForIndex in interface IgniteCacheOffheapManager

Returns:

Reuse list for index tree.

rebalanceIterator

public IgniteRebalanceIterator rebalanceIterator(int part,
                                        AffinityTopologyVersion topVer,
                                        Long partCntr)
                                          throws IgniteCheckedException

Specified by:

rebalanceIterator in interface IgniteCacheOffheapManager

Parameters:

part - Partition.

partCntr - Partition counter to get historical data if available.

Returns:

Partition data iterator.

Throws:

IgniteCheckedException - If failed.

createCacheDataStore

public final IgniteCacheOffheapManager.CacheDataStore createCacheDataStore(int p)
                                                                    throws IgniteCheckedException

Specified by:

createCacheDataStore in interface IgniteCacheOffheapManager

Parameters:

p - Partition.

Returns:

Data store.

Throws:

IgniteCheckedException - If failed.

createCacheDataStore0

protected IgniteCacheOffheapManager.CacheDataStore createCacheDataStore0(int p)
                                                                  throws IgniteCheckedException

Parameters:

p - Partition.

Returns:

Cache data store.

Throws:

IgniteCheckedException - If failed.

cacheDataStores

public Iterable<IgniteCacheOffheapManager.CacheDataStore> cacheDataStores()

Specified by:

cacheDataStores in interface IgniteCacheOffheapManager

Returns:

Iterable over all existing cache data stores.

destroyCacheDataStore

public void destroyCacheDataStore(int p,
                         IgniteCacheOffheapManager.CacheDataStore store)
                           throws IgniteCheckedException

Specified by:

destroyCacheDataStore in interface IgniteCacheOffheapManager

Parameters:

p - Partition ID.

store - Data store.

Throws:

IgniteCheckedException

treeName

protected final String treeName(int p)

Parameters:

p - Partition.

Returns:

Tree name for given partition.

expire

public boolean expire(IgniteInClosure2X<GridCacheEntryEx,GridCacheVersion> c,
             int amount)
               throws IgniteCheckedException

Specified by:

expire in interface IgniteCacheOffheapManager

Parameters:

c - Closure.

Throws:

IgniteCheckedException - If failed.

expiredSize

public long expiredSize()
                 throws IgniteCheckedException

Gets the number of entries pending expire.

Specified by:

expiredSize in interface IgniteCacheOffheapManager

Returns:

Number of pending entries.

Throws:

IgniteCheckedException - If failed to get number of pending entries.