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

Class IgniteCacheDatabaseSharedManager

java.lang.Object

org.apache.ignite.internal.processors.cache.GridCacheSharedManagerAdapter

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

All Implemented Interfaces:

GridCacheSharedManager, CheckpointLockStateChecker, IgniteChangeGlobalStateSupport

Direct Known Subclasses:

GridCacheDatabaseSharedManager

public class IgniteCacheDatabaseSharedManager
extends GridCacheSharedManagerAdapter
implements IgniteChangeGlobalStateSupport, CheckpointLockStateChecker

Field Summary

Fields

Modifier and Type	Field	Description
static String	DATA_REGION_PAGE_LIST_VIEW	System view name for page lists.
static String	DATA_REGION_PAGE_LIST_VIEW_DESC	System view description for page lists.
protected Map<String,DataRegion>	dataRegionMap
protected boolean	dataRegionsInitialized
protected DataRegion	dfltDataRegion
protected DataStorageMetricsImpl	dsMetrics	Data storege metrics.
protected Map<String,CacheFreeList>	freeListMap
static Set<String>	INTERNAL_DATA_REGION_NAMES	DataRegionConfiguration names reserved for various internal needs.
static String	PAGE_TS_HISTOGRAM_VIEW	System view name for pages timestamp histogram.
static String	PAGE_TS_HISTOGRAM_VIEW_DESC	System view description for pages timestamp histogram.
protected boolean	reuseMemory	True to reuse memory on deactive.
static String	SYSTEM_DATA_REGION_NAME	DataRegionConfiguration name reserved for internal caches.

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

cctx, diagnosticLog, log

Constructor Summary

Constructors

Constructor	Description
IgniteCacheDatabaseSharedManager(GridKernalContext ctx)

Method Summary

Modifier and Type	Method	Description
DataRegion	addDataRegion(DataStorageConfiguration dataStorageCfg, DataRegionConfiguration dataRegionCfg, boolean trackable)
protected DataRegion	addDataRegion(DataStorageConfiguration dataStorageCfg, DataRegionConfiguration dataRegionCfg, boolean trackable, PageReadWriteManager pmPageMgr)
void	beforeExchange(GridDhtPartitionsExchangeFuture discoEvt)
protected @Nullable File	buildAllocPath(DataRegionConfiguration plc)	Builds allocation path for memory mapped file to be used with PageMemory.
protected File	buildPath(String path, String consId)
protected void	checkPageSize(DataStorageConfiguration memCfg)
boolean	checkpointLockIsHeldByThread()
void	checkpointReadLock()	No-op for non-persistent storage.
long	checkpointReadLockTimeout()
void	checkpointReadLockTimeout(long val)	No-op for non-persistent storage.
void	checkpointReadUnlock()	No-op for non-persistent storage.
protected void	checkRegionEvictionProperties(DataRegionConfiguration regCfg, DataStorageConfiguration dbCfg)
void	cleanupCheckpointDirectory()	Clean checkpoint directory CheckpointMarkersStorage.cpDir.
void	cleanupRestoredCaches()	Method will perform cleanup cache page memory and each cache partition store.
void	cleanupTempCheckpointDirectory()	No-op for non-persistent storage.
protected PageEvictionTracker	createPageEvictionTracker(DataRegionConfiguration plc, PageMemory pageMem)
protected PageMemory	createPageMemory(DirectMemoryProvider memProvider, DataStorageConfiguration dsCfg, DataRegionConfiguration regCfg, DataRegionMetricsImpl regMetrics, boolean trackable, PageReadWriteManager pageMgr)	Creates PageMemory with given size and memory provider.
@Nullable DataRegion	dataRegion(@Nullable String memPlcName)	Getting data region by name.
protected DataRegionMetricsProvider	dataRegionMetricsProvider(DataRegionConfiguration dataRegCfg)	Provide that can be used to compute some metrics for provided data region.
Collection<DataRegion>	dataRegions()	Getting registered data regions.
DataStorageMetricsImpl	dataStorageMetricsImpl()
void	dumpStatistics(IgniteLogger log)
void	ensureFreeSpace(DataRegion memPlc)	See GridCacheMapEntry#ensureFreeSpace()
void	ensureFreeSpaceForInsert(DataRegion region, int dataRowSize)	Checks that the given region has enough space for putting a new entry.
@Nullable CheckpointProgress	forceCheckpoint(String reason)	Schedule a new checkpoint.
<R> @Nullable CheckpointProgress	forceNewCheckpoint(String reason, IgniteInClosure<? super IgniteInternalFuture<R>> lsnr)	Schedule a new checkpoint.
Collection<GridCacheContext>	forceRebuildIndexes(Collection<GridCacheContext> contexts)	Initiate an asynchronous forced index rebuild for caches.
FreeList	freeList(String memPlcName)
protected IgniteOutClosure<Long>	freeSpaceProvider(DataRegionConfiguration dataRegCfg)	Deprecated. use dataRegionMetricsProvider(DataRegionConfiguration) instead.
protected List<DatabaseLifecycleListener>	getDatabaseListeners(GridKernalContext kctx)
protected void	initAndStartRegions(DataStorageConfiguration cfg)
protected void	initDataRegions(DataStorageConfiguration memCfg)
protected void	initDataRegions0(DataStorageConfiguration memCfg)
protected void	initPageMemoryDataStructures(DataStorageConfiguration dbCfg)
void	lastCheckpointInapplicableForWalRebalance(int grpId)	Marks last checkpoint as inapplicable for WAL rebalance for given group grpId.
@Nullable WALPointer	lastCheckpointMarkWalPointer()
WALPointer	latestWalPointerReservedForPreloading()	Returns the latest WAL pointer that reserved for preloading or null.
Collection<DataRegionMetrics>	memoryMetrics()
@Nullable DataRegionMetrics	memoryMetrics(String dataRegionName)
MetaStorage	metaStorage()
void	notifyMetaStorageSubscribersOnReadyForRead()	Notifies MetastorageLifecycleListener that MetaStorage is ready for read.
void	onActivate(GridKernalContext kctx)	Called when cluster performing activation.
void	onCacheGroupsStopped(Collection<IgniteBiTuple<CacheGroupContext,Boolean>> stoppedGrps)
void	onDeActivate(GridKernalContext kctx)	Called when cluster performing deactivation.
void	onStateRestored(AffinityTopologyVersion topVer)	Called when all partitions have been fully restored and pre-created on node start.
void	onWalTruncated(WALPointer highBound)	Wal truncate callback.
int	pageSize()
void	prepareCachesStop()	Needed action before any cache will stop
void	rebuildIndexesIfNeeded(GridDhtPartitionsExchangeFuture fut)
void	releaseHistoryForExchange()	Release reserved update history.
void	releaseHistoryForPreloading()	Release reserved update history.
Map<Integer,Map<Integer,Long>>	reserveHistoryForExchange()	Reserve update history for exchange.
boolean	reserveHistoryForPreloading(Map<T2<Integer,Integer>,Long> reservationMap)	Reserve update history for preloading.
ReuseList	reuseList(String memPlcName)
protected void	setPageSize(int pageSize)	Method for fake (standalone) context initialization.
protected void	start0()
void	startMemoryRestore(GridKernalContext kctx, TimeBag startTimer)	Perform memory restore before GridDiscoveryManager start.
protected void	stop0(boolean cancel)
boolean	supportsMemoryReuse(DataRegionConfiguration plcCfg)
String	systemDateRegionName()
void	waitForCheckpoint(String reason)	Waits until current state is checkpointed.
<R> void	waitForCheckpoint(String reason, IgniteInClosure<? super IgniteInternalFuture<R>> lsnr)	Waits until current state is checkpointed and execution listeners after finish.
@Nullable IgniteInternalFuture	wakeupForCheckpoint(String reason)
boolean	walEnabled(int grpId, boolean local)
void	walEnabled(int grpId, boolean enabled, boolean local)	Marks cache group as with disabled WAL.

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

context, isStopping, kernalStartInfo, kernalStopInfo, onDisconnected, onKernalStart, onKernalStart0, onKernalStop, onKernalStop0, onReconnected, printMemoryStats, start, startInfo, stop, stopInfo, toString

Methods inherited from class java.lang.Object

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

Field Detail

SYSTEM_DATA_REGION_NAME

public static final String SYSTEM_DATA_REGION_NAME

DataRegionConfiguration name reserved for internal caches.

See Also:

Constant Field Values

INTERNAL_DATA_REGION_NAMES

public static Set<String> INTERNAL_DATA_REGION_NAMES

DataRegionConfiguration names reserved for various internal needs.

DATA_REGION_PAGE_LIST_VIEW

public static final String DATA_REGION_PAGE_LIST_VIEW

System view name for page lists.

See Also:

Constant Field Values

DATA_REGION_PAGE_LIST_VIEW_DESC

public static final String DATA_REGION_PAGE_LIST_VIEW_DESC

System view description for page lists.

See Also:

Constant Field Values

PAGE_TS_HISTOGRAM_VIEW

public static final String PAGE_TS_HISTOGRAM_VIEW

System view name for pages timestamp histogram.

See Also:

Constant Field Values

PAGE_TS_HISTOGRAM_VIEW_DESC

public static final String PAGE_TS_HISTOGRAM_VIEW_DESC

System view description for pages timestamp histogram.

See Also:

Constant Field Values

reuseMemory

protected final boolean reuseMemory

True to reuse memory on deactive.

dataRegionMap

protected final Map<String,DataRegion> dataRegionMap

dataRegionsInitialized

protected volatile boolean dataRegionsInitialized

dfltDataRegion

protected DataRegion dfltDataRegion

freeListMap

protected Map<String,CacheFreeList> freeListMap

dsMetrics

protected final DataStorageMetricsImpl dsMetrics

Data storege metrics.

Constructor Detail

IgniteCacheDatabaseSharedManager

public IgniteCacheDatabaseSharedManager(GridKernalContext ctx)

Parameters:

ctx - Kernal context.

Method Detail

start0

protected void start0()
               throws IgniteCheckedException

Overrides:

start0 in class GridCacheSharedManagerAdapter

Throws:

IgniteCheckedException - If failed.

initPageMemoryDataStructures

protected void initPageMemoryDataStructures(DataStorageConfiguration dbCfg)
                                     throws IgniteCheckedException

Parameters:

dbCfg - Database config.

Throws:

IgniteCheckedException - If failed.

pageSize

public int pageSize()

Returns:

Size of page used for PageMemory regions.

initDataRegions

protected void initDataRegions(DataStorageConfiguration memCfg)
                        throws IgniteCheckedException

Parameters:

memCfg - Database config.

Throws:

IgniteCheckedException - If failed to initialize swap path.

initDataRegions0

protected void initDataRegions0(DataStorageConfiguration memCfg)
                         throws IgniteCheckedException

Parameters:

memCfg - Database config.

Throws:

IgniteCheckedException - If failed to initialize swap path.

getDatabaseListeners

protected List<DatabaseLifecycleListener> getDatabaseListeners(GridKernalContext kctx)

Parameters:

kctx - Kernal context.

Returns:

Database lifecycle listeners.

addDataRegion

public DataRegion addDataRegion(DataStorageConfiguration dataStorageCfg,
                                DataRegionConfiguration dataRegionCfg,
                                boolean trackable)
                         throws IgniteCheckedException

Parameters:

dataStorageCfg - Database config.

dataRegionCfg - Data region config.

Throws:

IgniteCheckedException - If failed to initialize swap path.

addDataRegion

protected DataRegion addDataRegion(DataStorageConfiguration dataStorageCfg,
                                   DataRegionConfiguration dataRegionCfg,
                                   boolean trackable,
                                   PageReadWriteManager pmPageMgr)
                            throws IgniteCheckedException

Parameters:

dataStorageCfg - Database config.

dataRegionCfg - Data region config.

pmPageMgr - Page manager.

Throws:

IgniteCheckedException - If failed to initialize swap path.

freeSpaceProvider

@Deprecated
protected IgniteOutClosure<Long> freeSpaceProvider(DataRegionConfiguration dataRegCfg)

Deprecated.

use dataRegionMetricsProvider(DataRegionConfiguration) instead.

Closure that can be used to compute fill factor for provided data region.

Parameters:

dataRegCfg - Data region configuration.

Returns:

Closure.

dataRegionMetricsProvider

protected DataRegionMetricsProvider dataRegionMetricsProvider(DataRegionConfiguration dataRegCfg)

Provide that can be used to compute some metrics for provided data region.

Parameters:

dataRegCfg - Data region configuration.

Returns:

DataRegionMetricsProvider.

checkPageSize

protected void checkPageSize(DataStorageConfiguration memCfg)

Parameters:

memCfg - Memory config.

checkRegionEvictionProperties

protected void checkRegionEvictionProperties(DataRegionConfiguration regCfg,
                                             DataStorageConfiguration dbCfg)
                                      throws IgniteCheckedException

Parameters:

regCfg - DataRegionConfiguration to validate.

dbCfg - Memory configuration.

Throws:

IgniteCheckedException - If config is invalid.

dumpStatistics

public void dumpStatistics(IgniteLogger log)

Parameters:

log - Logger.

dataRegions

public Collection<DataRegion> dataRegions()

Getting registered data regions.

Returns:

Collection of all configured policies.

memoryMetrics

public Collection<DataRegionMetrics> memoryMetrics()

Returns:

DataRegionMetrics for all MemoryPolicies configured in Ignite instance.

dataStorageMetricsImpl

public DataStorageMetricsImpl dataStorageMetricsImpl()

Returns:

Data storage metrics implementation.

memoryMetrics

@Nullable
public @Nullable DataRegionMetrics memoryMetrics(String dataRegionName)

Parameters:

dataRegionName - Name of DataRegion to obtain DataRegionMetrics for.

Returns:

DataRegionMetrics snapshot for specified DataRegion or null if no DataRegion is configured for specified name.

dataRegion

@Nullable
public @Nullable DataRegion dataRegion(@Nullable
                                       @Nullable String memPlcName)
                                throws IgniteCheckedException

Getting data region by name.

Parameters:

memPlcName - Data region name. In case of null, default data region will be returned.

Returns:

DataRegion instance associated with a given DataRegionConfiguration, or null if there are no registered data regions.

Throws:

IgniteCheckedException - in case of request for unknown DataRegion.

freeList

public FreeList freeList(String memPlcName)

Parameters:

memPlcName - DataRegionConfiguration name.

Returns:

FreeList instance associated with a given DataRegionConfiguration.

reuseList

public ReuseList reuseList(String memPlcName)

Parameters:

memPlcName - DataRegionConfiguration name.

Returns:

ReuseList instance associated with a given DataRegionConfiguration.

stop0

protected void stop0(boolean cancel)

Overrides:

stop0 in class GridCacheSharedManagerAdapter

Parameters:

cancel - Cancel flag.

checkpointLockIsHeldByThread

public boolean checkpointLockIsHeldByThread()

Specified by:

checkpointLockIsHeldByThread in interface CheckpointLockStateChecker

Returns:

true if checkpoint lock is held by current thread

checkpointReadLock

public void checkpointReadLock()

No-op for non-persistent storage.

checkpointReadUnlock

public void checkpointReadUnlock()

No-op for non-persistent storage.

checkpointReadLockTimeout

public long checkpointReadLockTimeout()

Returns:

0 for non-persistent storage.

checkpointReadLockTimeout

public void checkpointReadLockTimeout(long val)

No-op for non-persistent storage.

cleanupRestoredCaches

public void cleanupRestoredCaches()

Method will perform cleanup cache page memory and each cache partition store.

cleanupCheckpointDirectory

public void cleanupCheckpointDirectory()
                                throws IgniteCheckedException

Clean checkpoint directory CheckpointMarkersStorage.cpDir. The operation is necessary when local node joined to baseline topology with different consistentId.

Throws:

IgniteCheckedException

cleanupTempCheckpointDirectory

public void cleanupTempCheckpointDirectory()
                                    throws IgniteCheckedException

No-op for non-persistent storage.

Throws:

IgniteCheckedException

wakeupForCheckpoint

@Nullable
public @Nullable IgniteInternalFuture wakeupForCheckpoint(String reason)

lastCheckpointMarkWalPointer

@Nullable
public @Nullable WALPointer lastCheckpointMarkWalPointer()

Returns:

Last checkpoint mark WAL pointer.

forceCheckpoint

@Nullable
public @Nullable CheckpointProgress forceCheckpoint(String reason)

Schedule a new checkpoint.

Note: if a checkpoint is already running and the locks have not been taken yet, then a new checkpoint will not be forced.

Parameters:

reason - Reason.

forceNewCheckpoint

@Nullable
public <R> @Nullable CheckpointProgress forceNewCheckpoint(String reason,
                                                           IgniteInClosure<? super IgniteInternalFuture<R>> lsnr)

Schedule a new checkpoint.

Parameters:

reason - Reason.

lsnr - Listener which will be called on scheduled checkpoint finish.

waitForCheckpoint

public void waitForCheckpoint(String reason)
                       throws IgniteCheckedException

Waits until current state is checkpointed.

Throws:

IgniteCheckedException - If failed.

waitForCheckpoint

public <R> void waitForCheckpoint(String reason,
                                  IgniteInClosure<? super IgniteInternalFuture<R>> lsnr)
                           throws IgniteCheckedException

Waits until current state is checkpointed and execution listeners after finish.

Parameters:

reason - Reason for checkpoint wakeup if it would be required.

lsnr - Listeners which should be called in checkpoint thread after current checkpoint finished.

Throws:

IgniteCheckedException - If failed.

beforeExchange

public void beforeExchange(GridDhtPartitionsExchangeFuture discoEvt)
                    throws IgniteCheckedException

Parameters:

discoEvt - Before exchange for the given discovery event.

Throws:

IgniteCheckedException

startMemoryRestore

public void startMemoryRestore(GridKernalContext kctx,
                               TimeBag startTimer)
                        throws IgniteCheckedException

Perform memory restore before GridDiscoveryManager start.

Parameters:

kctx - Current kernal context.

startTimer - Holder of start time of stages.

Throws:

IgniteCheckedException - If fails.

onStateRestored

public void onStateRestored(AffinityTopologyVersion topVer)
                     throws IgniteCheckedException

Called when all partitions have been fully restored and pre-created on node start.

Throws:

IgniteCheckedException - If failed.

rebuildIndexesIfNeeded

public void rebuildIndexesIfNeeded(GridDhtPartitionsExchangeFuture fut)

Parameters:

fut - Partition exchange future.

forceRebuildIndexes

public Collection<GridCacheContext> forceRebuildIndexes(Collection<GridCacheContext> contexts)

Initiate an asynchronous forced index rebuild for caches.

Parameters:

contexts - Cache contexts.

Returns:

Cache contexts for which index rebuilding is not initiated by this call because they are already in the process of rebuilding.

prepareCachesStop

public void prepareCachesStop()

Needed action before any cache will stop

onCacheGroupsStopped

public void onCacheGroupsStopped(Collection<IgniteBiTuple<CacheGroupContext,Boolean>> stoppedGrps)

Parameters:

stoppedGrps - A collection of tuples (cache group, destroy flag).

reserveHistoryForExchange

public Map<Integer,Map<Integer,Long>> reserveHistoryForExchange()

Reserve update history for exchange.

Returns:

Reserved update counters per cache and partition.

releaseHistoryForExchange

public void releaseHistoryForExchange()

Release reserved update history.

reserveHistoryForPreloading

public boolean reserveHistoryForPreloading(Map<T2<Integer,Integer>,Long> reservationMap)

Reserve update history for preloading.

Parameters:

reservationMap - Map contains of counters for partitions of groups.

Returns:

True if successfully reserved.

releaseHistoryForPreloading

public void releaseHistoryForPreloading()

Release reserved update history.

latestWalPointerReservedForPreloading

public WALPointer latestWalPointerReservedForPreloading()

Returns the latest WAL pointer that reserved for preloading or null.

Returns:

WAL pointer or null if nothing reserved.

ensureFreeSpaceForInsert

public void ensureFreeSpaceForInsert(DataRegion region,
                                     int dataRowSize)
                              throws IgniteOutOfMemoryException

Checks that the given region has enough space for putting a new entry. This method makes sense then and only then the data region is not persisted DataRegionConfiguration.isPersistenceEnabled() and page eviction is disabled DataPageEvictionMode.DISABLED. The non-persistent region should reserve a number of pages to support a free list AbstractFreeList. For example, removing a row from underlying store may require allocating a new data page in order to move a tracked page from one bucket to another one which does not have a free space for a new stripe. See AbstractFreeList.removeDataRowByLink(long, org.apache.ignite.internal.metric.IoStatisticsHolder). Therefore, inserting a new entry should be prevented in case of some threshold is exceeded.

Parameters:

region - Data region to be checked.

dataRowSize - Size of data row to be inserted.

Throws:

IgniteOutOfMemoryException - In case of the given data region does not have enough free space for putting a new entry.

ensureFreeSpace

public void ensureFreeSpace(DataRegion memPlc)
                     throws IgniteCheckedException

See GridCacheMapEntry#ensureFreeSpace()

Parameters:

memPlc - data region.

Throws:

IgniteCheckedException

supportsMemoryReuse

public boolean supportsMemoryReuse(DataRegionConfiguration plcCfg)

Parameters:

plcCfg - Policy config.

Returns:

True if policy supports memory reuse.

createPageEvictionTracker

protected PageEvictionTracker createPageEvictionTracker(DataRegionConfiguration plc,
                                                        PageMemory pageMem)

Parameters:

plc - data region Configuration.

pageMem - Page memory.

buildAllocPath

@Nullable
protected @Nullable File buildAllocPath(DataRegionConfiguration plc)
                                 throws IgniteCheckedException

Builds allocation path for memory mapped file to be used with PageMemory.

Parameters:

plc - DataRegionConfiguration.

Throws:

IgniteCheckedException - If resolving swap directory fails.

createPageMemory

protected PageMemory createPageMemory(DirectMemoryProvider memProvider,
                                      DataStorageConfiguration dsCfg,
                                      DataRegionConfiguration regCfg,
                                      DataRegionMetricsImpl regMetrics,
                                      boolean trackable,
                                      PageReadWriteManager pageMgr)

Creates PageMemory with given size and memory provider.

Parameters:

memProvider - Direct memory provider.

dsCfg - Data storage configuration.

regCfg - Data region configuration.

regMetrics - Data region metrics to collect memory usage metrics.

pageMgr - Page read/write manager.

Returns:

PageMemory instance.

buildPath

protected File buildPath(String path,
                         String consId)
                  throws IgniteCheckedException

Parameters:

path - Path to the working directory.

consId - Consistent ID of the local node.

Returns:

DB storage path.

Throws:

IgniteCheckedException - If resolving swap directory fails.

onActivate

public void onActivate(GridKernalContext kctx)
                throws IgniteCheckedException

Called when cluster performing activation.

Specified by:

onActivate in interface IgniteChangeGlobalStateSupport

Parameters:

kctx - Kernal context.

Throws:

IgniteCheckedException - If failed.

initAndStartRegions

protected void initAndStartRegions(DataStorageConfiguration cfg)
                            throws IgniteCheckedException

Parameters:

cfg - Current data storage configuration.

Throws:

IgniteCheckedException - If fails.

onDeActivate

public void onDeActivate(GridKernalContext kctx)

Called when cluster performing deactivation.

Specified by:

onDeActivate in interface IgniteChangeGlobalStateSupport

Parameters:

kctx - Kernal context.

systemDateRegionName

public String systemDateRegionName()

Returns:

Name of DataRegionConfiguration for internal caches.

setPageSize

protected void setPageSize(int pageSize)

Method for fake (standalone) context initialization. Not to be called in production code

Parameters:

pageSize - configured page size

metaStorage

public MetaStorage metaStorage()

Returns:

MetaStorage

notifyMetaStorageSubscribersOnReadyForRead

public void notifyMetaStorageSubscribersOnReadyForRead()
                                                throws IgniteCheckedException

Notifies MetastorageLifecycleListener that MetaStorage is ready for read. This method is called when all processors and managers have already started and right before discovery manager.

Throws:

IgniteCheckedException - If failed.

walEnabled

public boolean walEnabled(int grpId,
                          boolean local)

Parameters:

grpId - Group ID.

Returns:

WAL enabled flag.

walEnabled

public void walEnabled(int grpId,
                       boolean enabled,
                       boolean local)

Marks cache group as with disabled WAL.

Parameters:

grpId - Group id.

enabled - flag.

lastCheckpointInapplicableForWalRebalance

public void lastCheckpointInapplicableForWalRebalance(int grpId)

Marks last checkpoint as inapplicable for WAL rebalance for given group grpId.

Parameters:

grpId - Group id.

onWalTruncated

public void onWalTruncated(WALPointer highBound)
                    throws IgniteCheckedException

Wal truncate callback.

Parameters:

highBound - Upper bound.

Throws:

IgniteCheckedException - If failed.