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

Class IgniteCacheSnapshotManager<T extends SnapshotOperation>

java.lang.Object

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

org.apache.ignite.internal.processors.cache.persistence.snapshot.IgniteCacheSnapshotManager<T>

All Implemented Interfaces:

GridCacheSharedManager, IgniteChangeGlobalStateSupport

public class IgniteCacheSnapshotManager<T extends SnapshotOperation>
extends GridCacheSharedManagerAdapter
implements IgniteChangeGlobalStateSupport

Snapshot manager stub.

Field Summary

Fields

Modifier and Type	Field and Description
static String	SNAPSHOT_RESTORE_STARTED_LOCK_FILENAME Snapshot started lock filename.
static String	TEMP_FILES_COMPLETENESS_MARKER Temp files completeness marker.

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

cctx, diagnosticLog, log

Constructor Summary

Constructors

Constructor and Description
IgniteCacheSnapshotManager()

Method Summary

Modifier and Type	Method and Description
void	afterCheckpointPageWritten()
void	beforeCheckpointPageWritten()
void	beforePageWrite(FullPageId fullId)
boolean	needTxReadLogging()
void	onActivate(GridKernalContext kctx) Called when cluster performing activation.
void	onCacheGroupStop(CacheGroupContext gctx, boolean destroy)
void	onCacheStop(GridCacheContext cctx, boolean destroy)
void	onChangeTrackerPage(Long page, FullPageId fullId, PageMemory pageMem)
void	onDeActivate(GridKernalContext kctx) Called when cluster performing deactivation.
IgniteFuture<?>	onMarkCheckPointBegin(T snapshotOperation, PartitionAllocationMap map)
boolean	partitionsAreFrozen(CacheGroupContext grp)
boolean	snapshotOperationInProgress()
@Nullable IgniteInternalFuture	startLocalSnapshotOperation(UUID initiatorNodeId, T snapshotOperation, AffinityTopologyVersion topVer)
@Nullable IgniteInternalFuture	tryStartLocalSnapshotOperation(@Nullable DiscoveryEvent discoveryEvt, AffinityTopologyVersion topVer) Try to start local snapshot operation if it's required by discovery event.

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

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

Methods inherited from class java.lang.Object

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

Field Detail

SNAPSHOT_RESTORE_STARTED_LOCK_FILENAME

public static final String SNAPSHOT_RESTORE_STARTED_LOCK_FILENAME

Snapshot started lock filename.

See Also:

Constant Field Values

TEMP_FILES_COMPLETENESS_MARKER

public static final String TEMP_FILES_COMPLETENESS_MARKER

Temp files completeness marker.

See Also:

Constant Field Values

Constructor Detail

IgniteCacheSnapshotManager

public IgniteCacheSnapshotManager()

Method Detail

tryStartLocalSnapshotOperation

@Nullable
public @Nullable IgniteInternalFuture tryStartLocalSnapshotOperation(@Nullable
                                                                               @Nullable DiscoveryEvent discoveryEvt,
                                                                               AffinityTopologyVersion topVer)
                                                                        throws IgniteCheckedException

Try to start local snapshot operation if it's required by discovery event.

Parameters:

discoveryEvt - Discovery event.

topVer - topology version on the moment when this method was called

Throws:

IgniteCheckedException - if failed

startLocalSnapshotOperation

@Nullable
public @Nullable IgniteInternalFuture startLocalSnapshotOperation(UUID initiatorNodeId,
                                                                            T snapshotOperation,
                                                                            AffinityTopologyVersion topVer)
                                                                     throws IgniteCheckedException

Parameters:

initiatorNodeId - Initiator node id.

snapshotOperation - Snapshot operation.

Throws:

IgniteCheckedException

onMarkCheckPointBegin

public IgniteFuture<?> onMarkCheckPointBegin(T snapshotOperation,
                                             PartitionAllocationMap map)
                                      throws IgniteCheckedException

Parameters:

snapshotOperation - current snapshot operation.

map - (cacheId, partId) -> (lastAllocatedIndex, count)

Returns:

true if next operation must be snapshot, false if checkpoint must be executed.

Throws:

IgniteCheckedException

partitionsAreFrozen

public boolean partitionsAreFrozen(CacheGroupContext grp)

snapshotOperationInProgress

public boolean snapshotOperationInProgress()

beforeCheckpointPageWritten

public void beforeCheckpointPageWritten()

afterCheckpointPageWritten

public void afterCheckpointPageWritten()

beforePageWrite

public void beforePageWrite(FullPageId fullId)

Parameters:

fullId - Full id.

onCacheStop

public void onCacheStop(GridCacheContext cctx,
                        boolean destroy)

Parameters:

cctx - Cctx.

destroy - Destroy flag.

onCacheGroupStop

public void onCacheGroupStop(CacheGroupContext gctx,
                             boolean destroy)

Parameters:

gctx - Cctx.

destroy - Destroy flag.

onChangeTrackerPage

public void onChangeTrackerPage(Long page,
                                FullPageId fullId,
                                PageMemory pageMem)
                         throws IgniteCheckedException

Throws:

IgniteCheckedException

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.

onDeActivate

public void onDeActivate(GridKernalContext kctx)

Called when cluster performing deactivation.

Specified by:

onDeActivate in interface IgniteChangeGlobalStateSupport

Parameters:

kctx - Kernal context.

needTxReadLogging

public boolean needTxReadLogging()

Returns:

True if TX READ records must be logged in WAL.