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

Class SnapshotRestoreProcess

java.lang.Object

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

public class SnapshotRestoreProcess
extends Object

Distributed process to restore cache group from the snapshot.

Field Summary

Fields

Modifier and Type	Field and Description
static String	TMP_CACHE_DIR_PREFIX Temporary cache directory prefix.

Constructor Summary

Constructors

Constructor and Description
SnapshotRestoreProcess(GridKernalContext ctx)

Method Summary

Modifier and Type	Method and Description
Set<UUID>	cacheStartRequiredAliveNodes(IgniteUuid reqId)
IgniteFuture<Boolean>	cancel(IgniteCheckedException reason, String snpName) Cancel the currently running local restore procedure.
protected void	cleanup() Cleanup temporary directories if any exists.
void	interrupt(IgniteCheckedException reason) Interrupt the currently running local restore procedure.
boolean	isRestoring(String cacheName, @Nullable String grpName) Check if the cache or group with the specified name is currently being restored from the snapshot.
void	onNodeLeft(UUID leftNodeId) Node left callback.
@Nullable String	restoringSnapshotName() Get the name of the snapshot currently being restored
IgniteFuture<Void>	start(String snpName, @Nullable Collection<String> cacheGrpNames) Start cache group restore operation.

Methods inherited from class java.lang.Object

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

Field Detail

TMP_CACHE_DIR_PREFIX

public static final String TMP_CACHE_DIR_PREFIX

Temporary cache directory prefix.

See Also:

Constant Field Values

Constructor Detail

SnapshotRestoreProcess

public SnapshotRestoreProcess(GridKernalContext ctx)

Parameters:

ctx - Kernal context.

Method Detail

cleanup

protected void cleanup()
                throws IgniteCheckedException

Cleanup temporary directories if any exists.

Throws:

IgniteCheckedException - If it was not possible to delete some temporary directory.

start

public IgniteFuture<Void> start(String snpName,
                                @Nullable
                                @Nullable Collection<String> cacheGrpNames)

Start cache group restore operation.

Parameters:

snpName - Snapshot name.

cacheGrpNames - Cache groups to be restored or null to restore all cache groups from the snapshot.

Returns:

Future that will be completed when the restore operation is complete and the cache groups are started.

restoringSnapshotName

@Nullable
public @Nullable String restoringSnapshotName()

Get the name of the snapshot currently being restored

Returns:

Name of the snapshot currently being restored or null if the restore process is not running.

isRestoring

public boolean isRestoring(String cacheName,
                           @Nullable
                           @Nullable String grpName)

Check if the cache or group with the specified name is currently being restored from the snapshot.

Parameters:

cacheName - Cache name.

grpName - Cache group name.

Returns:

True if the cache or group with the specified name is currently being restored.

cacheStartRequiredAliveNodes

public Set<UUID> cacheStartRequiredAliveNodes(IgniteUuid reqId)

Parameters:

reqId - Request ID.

Returns:

Server nodes on which a successful start of the cache(s) is required, if any of these nodes fails when starting the cache(s), the whole procedure is rolled back.

onNodeLeft

public void onNodeLeft(UUID leftNodeId)

Node left callback.

Parameters:

leftNodeId - Left node ID.

cancel

public IgniteFuture<Boolean> cancel(IgniteCheckedException reason,
                                    String snpName)

Cancel the currently running local restore procedure.

Parameters:

reason - Interruption reason.

snpName - Snapshot name.

Returns:

Future that will be finished when process the process is complete. The result of this future will be false if the restore process with the specified snapshot name is not running at all.

interrupt

public void interrupt(IgniteCheckedException reason)

Interrupt the currently running local restore procedure.

Parameters:

reason - Interruption reason.