org.apache.ignite.internal.processors.cache.persistence

Class GridCacheOffheapManager

java.lang.Object

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

org.apache.ignite.internal.processors.cache.persistence.GridCacheOffheapManager

All Implemented Interfaces:

IgniteCacheOffheapManager, DbCheckpointListener

public class GridCacheOffheapManager
extends IgniteCacheOffheapManagerImpl
implements DbCheckpointListener

Used when persistence enabled.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	GridCacheOffheapManager.GridCacheDataStore

Nested classes/interfaces inherited from class org.apache.ignite.internal.processors.cache.IgniteCacheOffheapManagerImpl

IgniteCacheOffheapManagerImpl.CacheDataStoreImpl

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

DbCheckpointListener.Context

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
static GridCursor<CacheDataRow>	EMPTY_CURSOR

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

busyLock, ctx, grp, log, partDataStores, partStoreLock, PRELOAD_SIZE_UNDER_CHECKPOINT_LOCK

Constructor Summary

Constructors

Constructor and Description
GridCacheOffheapManager()

Method Summary

Modifier and Type	Method and Description
void	beforeCheckpointBegin(DbCheckpointListener.Context ctx) Do some actions before checkpoint write lock.
protected IgniteCacheOffheapManager.CacheDataStore	createCacheDataStore0(int p)
protected void	destroyCacheDataStore0(IgniteCacheOffheapManager.CacheDataStore store)
void	destroyPartitionStore(int grpId, int partId) Invalidates page memory for given partition.
void	dropRootPageForIndex(int cacheId, String idxName, int segment)
boolean	expire(GridCacheContext cctx, IgniteInClosure2X<GridCacheEntryEx,GridCacheVersion> c, int amount)
long	expiredSize() Gets the number of entries pending expire.
void	findAndCleanupLostIndexesForStoppedCache(int cacheId)
IndexStorage	getIndexStorage() Get internal IndexStorage.
protected @Nullable IgniteHistoricalIterator	historicalIterator(CachePartitionPartialCountersMap partCntrs, Set<Integer> missing)
protected void	initDataStructures()
protected void	initPendingTree(GridCacheContext cctx)
long	lastUpdatedPartitionCounter(int part) Partition counter provider.
void	onCheckpointBegin(DbCheckpointListener.Context ctx)
void	onMarkCheckpointBegin(DbCheckpointListener.Context ctx)
void	onPartitionCounterUpdated(int part, long cntr) Partition counter update callback.
void	onPartitionInitialCounterUpdated(int part, long start, long delta) Initial counter will be updated on state restore only
void	preloadPartition(int part) Preload a partition.
long	restorePartitionStates(Map<GroupPartitionId,Integer> partitionRecoveryStates) Pre-create partitions that resides in page memory or WAL and restores their state.
ReuseList	reuseListForIndex(String idxName)
RootPage	rootPageForIndex(int cacheId, String idxName, int segment)
void	stop()

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

cacheDataStores, cacheEntriesCount, cacheEntriesCount, cacheEntriesCount, cacheEntriesIterator, cacheIterator, cacheKeysIterator, cachePartitionIterator, clearCache, containsKey, createCacheDataStore, dataStore, dataStore, destroyCacheDataStore, globalRemoveId, invoke, mvccAllVersions, mvccAllVersionsCursor, mvccApplyHistoryIfAbsent, mvccApplyUpdate, mvccInitialValue, mvccLock, mvccRead, mvccRemove, mvccRemoveAll, mvccUpdate, mvccUpdateRowWithPreloadInfo, offHeapAllocatedSize, onCacheStarted, onKernalStop, onUndeploy, partitionIterator, read, read, rebalanceIterator, remove, reservedIterator, start, stopCache, storeEntries, totalPartitionEntriesCount, treeName, update

Methods inherited from class java.lang.Object

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

Field Detail

EMPTY_CURSOR

public static final GridCursor<CacheDataRow> EMPTY_CURSOR

Constructor Detail

GridCacheOffheapManager

public GridCacheOffheapManager()

Method Detail

initPendingTree

protected void initPendingTree(GridCacheContext cctx)
                        throws IgniteCheckedException

Overrides:

initPendingTree in class IgniteCacheOffheapManagerImpl

Parameters:

cctx - Cache context.

Throws:

IgniteCheckedException - If failed.

initDataStructures

protected void initDataStructures()
                           throws IgniteCheckedException

Overrides:

initDataStructures in class IgniteCacheOffheapManagerImpl

Throws:

IgniteCheckedException - If failed.

getIndexStorage

public IndexStorage getIndexStorage()

Get internal IndexStorage. See UpgradePendingTreeToPerPartitionTask for details.

createCacheDataStore0

protected IgniteCacheOffheapManager.CacheDataStore createCacheDataStore0(int p)
                                                                  throws IgniteCheckedException

Overrides:

createCacheDataStore0 in class IgniteCacheOffheapManagerImpl

Parameters:

p - Partition.

Returns:

Cache data store.

Throws:

IgniteCheckedException - If failed.

onCheckpointBegin

public void onCheckpointBegin(DbCheckpointListener.Context ctx)
                       throws IgniteCheckedException

Specified by:

onCheckpointBegin in interface DbCheckpointListener

Throws:

IgniteCheckedException - If failed.

onMarkCheckpointBegin

public void onMarkCheckpointBegin(DbCheckpointListener.Context ctx)
                           throws IgniteCheckedException

Specified by:

onMarkCheckpointBegin in interface DbCheckpointListener

Throws:

IgniteCheckedException - If failed.

beforeCheckpointBegin

public void beforeCheckpointBegin(DbCheckpointListener.Context ctx)
                           throws IgniteCheckedException

Do some actions before checkpoint write lock.

Specified by:

beforeCheckpointBegin in interface DbCheckpointListener

Throws:

IgniteCheckedException - If failed.

restorePartitionStates

public long restorePartitionStates(Map<GroupPartitionId,Integer> partitionRecoveryStates)
                            throws IgniteCheckedException

Pre-create partitions that resides in page memory or WAL and restores their state.

Specified by:

restorePartitionStates in interface IgniteCacheOffheapManager

Overrides:

restorePartitionStates in class IgniteCacheOffheapManagerImpl

Parameters:

partitionRecoveryStates - Partition recovery states.

Returns:

Number of processed partitions.

Throws:

IgniteCheckedException - If failed.

destroyCacheDataStore0

protected void destroyCacheDataStore0(IgniteCacheOffheapManager.CacheDataStore store)
                               throws IgniteCheckedException

Overrides:

destroyCacheDataStore0 in class IgniteCacheOffheapManagerImpl

Parameters:

store - Cache data store.

Throws:

IgniteCheckedException - If failed.

destroyPartitionStore

public void destroyPartitionStore(int grpId,
                                  int partId)
                           throws IgniteCheckedException

Invalidates page memory for given partition. Destroys partition store. NOTE: This method can be invoked only within checkpoint lock or checkpointer thread.

Parameters:

grpId - Group ID.

partId - Partition ID.

Throws:

IgniteCheckedException - If destroy has failed.

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

Overrides:

onPartitionCounterUpdated in class IgniteCacheOffheapManagerImpl

Parameters:

part - Partition.

cntr - Partition counter.

onPartitionInitialCounterUpdated

public void onPartitionInitialCounterUpdated(int part,
                                             long start,
                                             long delta)

Initial counter will be updated on state restore only

Specified by:

onPartitionInitialCounterUpdated in interface IgniteCacheOffheapManager

Overrides:

onPartitionInitialCounterUpdated in class IgniteCacheOffheapManagerImpl

Parameters:

part - Partition

start - Start.

delta - Delta.

lastUpdatedPartitionCounter

public long lastUpdatedPartitionCounter(int part)

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

Specified by:

lastUpdatedPartitionCounter in interface IgniteCacheOffheapManager

Overrides:

lastUpdatedPartitionCounter in class IgniteCacheOffheapManagerImpl

Parameters:

part - Partition ID.

Returns:

Last updated counter.

rootPageForIndex

public RootPage rootPageForIndex(int cacheId,
                                 String idxName,
                                 int segment)
                          throws IgniteCheckedException

Specified by:

rootPageForIndex in interface IgniteCacheOffheapManager

Overrides:

rootPageForIndex in class IgniteCacheOffheapManagerImpl

Parameters:

cacheId - Cache ID.

idxName - Index name.

segment - Segment.

Returns:

Root page for index tree.

Throws:

IgniteCheckedException - If failed.

dropRootPageForIndex

public void dropRootPageForIndex(int cacheId,
                                 String idxName,
                                 int segment)
                          throws IgniteCheckedException

Specified by:

dropRootPageForIndex in interface IgniteCacheOffheapManager

Overrides:

dropRootPageForIndex in class IgniteCacheOffheapManagerImpl

Parameters:

cacheId - Cache ID.

idxName - Index name.

Throws:

IgniteCheckedException - If failed.

reuseListForIndex

public ReuseList reuseListForIndex(String idxName)

Specified by:

reuseListForIndex in interface IgniteCacheOffheapManager

Overrides:

reuseListForIndex in class IgniteCacheOffheapManagerImpl

Parameters:

idxName - Index name.

Returns:

Reuse list for index tree.

stop

public void stop()

Specified by:

stop in interface IgniteCacheOffheapManager

Overrides:

stop in class IgniteCacheOffheapManagerImpl

historicalIterator

@Nullable
protected @Nullable IgniteHistoricalIterator historicalIterator(CachePartitionPartialCountersMap partCntrs,
                                                                          Set<Integer> missing)
                                                                   throws IgniteCheckedException

Overrides:

historicalIterator in class IgniteCacheOffheapManagerImpl

Parameters:

partCntrs - Partition counters map.

missing - Set of partitions need to populate if partition is missing or failed to reserve.

Returns:

Historical iterator.

Throws:

IgniteCheckedException - If failed.

expire

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

Specified by:

expire in interface IgniteCacheOffheapManager

Overrides:

expire in class IgniteCacheOffheapManagerImpl

Parameters:

cctx - Cache context.

c - Closure.

amount - Limit of processed entries by single call, -1 for no limit.

Returns:

True if unprocessed expired entries remains.

Throws:

IgniteCheckedException - If failed.

expiredSize

public long expiredSize()
                 throws IgniteCheckedException

Gets the number of entries pending expire.

Specified by:

expiredSize in interface IgniteCacheOffheapManager

Overrides:

expiredSize in class IgniteCacheOffheapManagerImpl

Returns:

Number of pending entries.

Throws:

IgniteCheckedException - If failed to get number of pending entries.

preloadPartition

public void preloadPartition(int part)
                      throws IgniteCheckedException

Preload a partition. Must be called under partition reservation for DHT caches.

Specified by:

preloadPartition in interface IgniteCacheOffheapManager

Overrides:

preloadPartition in class IgniteCacheOffheapManagerImpl

Parameters:

part - Partition.

Throws:

IgniteCheckedException - If failed.

findAndCleanupLostIndexesForStoppedCache

public void findAndCleanupLostIndexesForStoppedCache(int cacheId)
                                              throws IgniteCheckedException

Parameters:

cacheId - Which was stopped, but its data still presented.

Throws:

IgniteCheckedException - If failed.