org.gridgain.grid.persistentstore.snapshot.file

Class FileDatabaseSnapshotSpi

java.lang.Object

org.gridgain.grid.persistentstore.snapshot.file.FileDatabaseSnapshotSpi

All Implemented Interfaces:

org.gridgain.grid.internal.processors.cache.database.snapshot.DatabaseSnapshotSpi

public class FileDatabaseSnapshotSpi
extends Object
implements org.gridgain.grid.internal.processors.cache.database.snapshot.DatabaseSnapshotSpi

File-based database snapshot SPI. Snapshot folder structure: - SNAPSHOT_BASE_FOLDER/SNAPSHOT_ID_FOLDER/CONSISTENG_ID_FOLDER/GRP_ID_FOLDER/

Field Summary

Fields

Modifier and Type	Field and Description
static String	CANCELLED_FILENAME Cancelled filename.
static String	COPY_MARKER_FILENAME Copy marker filename.
static String	LOCK_FILENAME Lock filename.
static String	SNAPSHOT_DIR_SUFFIX Snapshot directory suffix.
static String	SNAPSHOT_WAL_DIR Snapshot wal directory.

Constructor Summary

Constructors

Constructor and Description
FileDatabaseSnapshotSpi() Default constructor.

Method Summary

Modifier and Type	Method and Description
void	copyDigestRegistry(long snapshotId, org.gridgain.grid.internal.processors.cache.database.snapshot.file.SnapshotPath file, org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotOperationContext context)
void	copyMetadata(long snapshotId, org.gridgain.grid.internal.processors.cache.database.snapshot.file.SnapshotPath pathToMove, org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotOperationContext context)
void	copySinglePartition(long snapshotId, int grpId, int partId, org.gridgain.grid.internal.processors.cache.database.snapshot.file.SnapshotPath pathToCopy, org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotOperationContext context) Will copy only single partition.
void	copySnapshotEntirely(long snapshotId, org.gridgain.grid.internal.processors.cache.database.snapshot.file.SnapshotPath pathToCopy, org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotOperationContext ctx, ExecutorService taskExecutor) Will copy snapshot completely to the path.
void	copyWalSegments(long snapshotId, Collection<File> segments, org.gridgain.grid.internal.processors.cache.database.snapshot.file.SnapshotPath dir, org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotOperationContext ctx)
protected FileSnapshot	createFileSnapshot(IgniteConfiguration igCfg, FileDatabaseSnapshotSpi snapshotSpi, long id, org.gridgain.grid.internal.processors.cache.database.snapshot.file.SnapshotPath snapshotDir, Collection<org.gridgain.grid.internal.processors.cache.database.snapshot.file.SnapshotPath> optSearchPath, IgniteBiClosure<String,CacheConfiguration,CacheConfiguration> c, boolean ignoreMissedClasses, boolean remote, SnapshotSecurityLevel securityLevel, MessageDigestFactory msgDigestFactory, SnapshotRegistryTransformer registryTransformer, org.apache.ignite.internal.processors.cache.GridCacheSharedContext cctx) To facilitate tests we need to wrap constructor of FileSnapshot in this method.
void	deleteSnapshot(long id, org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotOperationContext ctx)
static long	extractIdFromSnapshotDirName(String dirName) Get snapshot id from directory name.
<T extends org.gridgain.grid.internal.processors.cache.database.snapshot.file.SnapshotPath> T	findCurNodeSnapshotDir(T snapshotBaseFolder, long id) Find snapshot for curent node.
@Nullable org.gridgain.grid.internal.processors.cache.database.snapshot.file.FsSnapshotPath	findLocalCurNodeSnapshotDir(long id)
@Nullable org.gridgain.grid.internal.processors.cache.database.snapshot.file.FsSnapshotPath	findLocalSnapshotDir(long id)
<T extends org.gridgain.grid.internal.processors.cache.database.snapshot.file.SnapshotPath> T	findSnapshotDir(T snapshotBaseFolder, long id)
void	finishCopy(long snapshotId, org.gridgain.grid.internal.processors.cache.database.snapshot.file.SnapshotPath pathToCopy) Removes copy marker file to indicate the end of copy operation.
@NotNull org.gridgain.grid.internal.processors.cache.database.snapshot.file.FsSnapshotPath	generateCurNodeSnapshotFolderPath(long id)
<T extends org.gridgain.grid.internal.processors.cache.database.snapshot.file.SnapshotPath> T	generateCurNodeSnapshotFolderPathWithLabel(T snapshotBaseFolder, long id, String label) Generate path with label for snapshot.
static String	generateSnapshotDirName(long id, @Nullable String lb) !!!
<T extends org.gridgain.grid.internal.processors.cache.database.snapshot.file.SnapshotPath> T	generateSnapshotFolderPath(T snapshotBaseFolder, long id)
boolean	isCopyRequired(long snapshotId, org.gridgain.grid.internal.processors.cache.database.snapshot.file.SnapshotPath targetDirectory) Method checks whether copy is required or not.
Iterable<org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotMetadataV2>	listRemoteSnapshots(@Nullable org.gridgain.grid.internal.processors.cache.database.snapshot.file.SnapshotPath searchPath) Returns all completed snapshots that can be restored.
Iterable<org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotMetadataV2>	localSnapshots(boolean sort) Returns all completed snapshots that can be restored.
@Nullable org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotMetadataV2	nextLocalSnapshot(long id) Search for meta of next ascending snapshot, or null if not found.
Map<Long,Long>	remoteSnapshotWalSizes(@Nullable org.gridgain.grid.internal.processors.cache.database.snapshot.file.SnapshotPath searchPath) Retrieving total segment sizes for remote snapshots.
long	remoteSnapshotWalSizes(@Nullable org.gridgain.grid.internal.processors.cache.database.snapshot.file.SnapshotPath searchPath, long snapshotId) Retrieving total segment sizes for a remote snapshot.
org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotSession	sessionForSnapshotCreation(long id, boolean fullSnapshot, @Nullable File storePath, org.gridgain.grid.internal.processors.cache.database.snapshot.CompressionOption compression, int compressionLevel, org.gridgain.grid.internal.processors.cache.database.snapshot.FutureTaskQueue<org.apache.ignite.internal.processors.cache.persistence.partstate.GroupPartitionId> futureTaskQueue, org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotOperationContext snapshotOperationContext, @Nullable MessageDigestFactory msgDigestFactory, @Nullable org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotEncryptionOptions encryptionOptions) Starts a snapshot session.
void	setSnapshotDirectory(String snapshotDir)
void	setSnapshotMetrics(SnapshotMetricsMXBean snapshotMetrics) Set SnapshotMetricsMXBean reference.
@Nullable FileSnapshot	snapshot(long id, @Nullable Collection<org.gridgain.grid.internal.processors.cache.database.snapshot.file.SnapshotPath> optSearchPaths, @Nullable IgniteBiClosure<String,CacheConfiguration,CacheConfiguration> c, boolean ignoreMissedClasses, @Nullable SnapshotSecurityLevel securityLevel, boolean needDecryptKeys) Getting snapshot.
File	snapshotWorkingDirectory()
void	start() Starts SPI.
void	startCopy(long snapshotId, org.gridgain.grid.internal.processors.cache.database.snapshot.file.SnapshotPath pathToCopy) Marks directory with copy marker file, to indicate the beginning of copy operation.
void	stop() Stops SPI.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.gridgain.grid.internal.processors.cache.database.snapshot.DatabaseSnapshotSpi

generateCurNodeSnapshotFolderPath

Field Detail

SNAPSHOT_DIR_SUFFIX

public static final String SNAPSHOT_DIR_SUFFIX

Snapshot directory suffix.

See Also:

Constant Field Values

SNAPSHOT_WAL_DIR

public static final String SNAPSHOT_WAL_DIR

Snapshot wal directory.

See Also:

Constant Field Values

LOCK_FILENAME

public static final String LOCK_FILENAME

Lock filename.

See Also:

Constant Field Values

CANCELLED_FILENAME

public static final String CANCELLED_FILENAME

Cancelled filename.

See Also:

Constant Field Values

COPY_MARKER_FILENAME

public static final String COPY_MARKER_FILENAME

Copy marker filename.

See Also:

Constant Field Values

Constructor Detail

FileDatabaseSnapshotSpi

public FileDatabaseSnapshotSpi()

Default constructor.

Method Detail

snapshotWorkingDirectory

public File snapshotWorkingDirectory()

Specified by:

snapshotWorkingDirectory in interface org.gridgain.grid.internal.processors.cache.database.snapshot.DatabaseSnapshotSpi

Returns:

Fully resolved snapshot working directory.

setSnapshotDirectory

public void setSnapshotDirectory(String snapshotDir)

Parameters:

snapshotDir - Snapshot directory.

setSnapshotMetrics

public void setSnapshotMetrics(SnapshotMetricsMXBean snapshotMetrics)

Set SnapshotMetricsMXBean reference.

Specified by:

setSnapshotMetrics in interface org.gridgain.grid.internal.processors.cache.database.snapshot.DatabaseSnapshotSpi

Parameters:

snapshotMetrics - Instance of metrics.

start

public void start()
           throws IgniteCheckedException

Starts SPI.

Specified by:

start in interface org.gridgain.grid.internal.processors.cache.database.snapshot.DatabaseSnapshotSpi

Throws:

IgniteCheckedException - If failed to start.

stop

public void stop()
          throws IgniteCheckedException

Stops SPI.

Specified by:

stop in interface org.gridgain.grid.internal.processors.cache.database.snapshot.DatabaseSnapshotSpi

Throws:

IgniteCheckedException - If failed to stop.

sessionForSnapshotCreation

public org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotSession sessionForSnapshotCreation(long id,
                                                                                                                boolean fullSnapshot,
                                                                                                                @Nullable
                                                                                                                @Nullable File storePath,
                                                                                                                org.gridgain.grid.internal.processors.cache.database.snapshot.CompressionOption compression,
                                                                                                                int compressionLevel,
                                                                                                                org.gridgain.grid.internal.processors.cache.database.snapshot.FutureTaskQueue<org.apache.ignite.internal.processors.cache.persistence.partstate.GroupPartitionId> futureTaskQueue,
                                                                                                                org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotOperationContext snapshotOperationContext,
                                                                                                                @Nullable
                                                                                                                @Nullable MessageDigestFactory msgDigestFactory,
                                                                                                                @Nullable
                                                                                                                @Nullable org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotEncryptionOptions encryptionOptions)
                                                                                                         throws IgniteCheckedException

Starts a snapshot session. Only one snapshot session can be active at any moment in time.

Specified by:

sessionForSnapshotCreation in interface org.gridgain.grid.internal.processors.cache.database.snapshot.DatabaseSnapshotSpi

Parameters:

id - Snapshot ID.

fullSnapshot - Incremental flag.

storePath - Path to directory where snapshot will be stored. If storePath null then storePath will default snapshot work dir.

compression - If ZIP then compressionOption of snapshot files is enabled.

compressionLevel - Level of compression in case of compression is enabled.

futureTaskQueue - Partitions future task post processor.

snapshotOperationContext - Level of compression in case of compression is enabled.

msgDigestFactory - Message digest factory, or null if security level is disabled.

encryptionOptions - Snapshot encryption options.

Returns:

Snapshot session.

Throws:

IgniteCheckedException

localSnapshots

public Iterable<org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotMetadataV2> localSnapshots(boolean sort)
                                                                                                          throws IgniteCheckedException

Returns all completed snapshots that can be restored. Store all results into collection may bring to strong heap usage and OOM. Each call of next directly reads appropriate snapshots meta.

Specified by:

localSnapshots in interface org.gridgain.grid.internal.processors.cache.database.snapshot.DatabaseSnapshotSpi

Parameters:

sort - Sort by id.

Returns:

Iterable of snapshots meta.

Throws:

IgniteCheckedException

listRemoteSnapshots

public Iterable<org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotMetadataV2> listRemoteSnapshots(@Nullable
                                                                                                                      @Nullable org.gridgain.grid.internal.processors.cache.database.snapshot.file.SnapshotPath searchPath)
                                                                                                               throws IgniteCheckedException

Returns all completed snapshots that can be restored. Store all results into collection may bring to strong heap usage and OOM. Each call of next directly reads appropriate snapshots meta.

Specified by:

listRemoteSnapshots in interface org.gridgain.grid.internal.processors.cache.database.snapshot.DatabaseSnapshotSpi

Parameters:

searchPath - Snapshot work directory.

Returns:

Iterable of snapshots meta.

Throws:

IgniteCheckedException

remoteSnapshotWalSizes

public Map<Long,Long> remoteSnapshotWalSizes(@Nullable
                                             @Nullable org.gridgain.grid.internal.processors.cache.database.snapshot.file.SnapshotPath searchPath)

Retrieving total segment sizes for remote snapshots.

Specified by:

remoteSnapshotWalSizes in interface org.gridgain.grid.internal.processors.cache.database.snapshot.DatabaseSnapshotSpi

Parameters:

searchPath - Snapshot work directory.

Returns:

Mapping: snapshotId -> sum of all WAL segments by consistentId.

remoteSnapshotWalSizes

public long remoteSnapshotWalSizes(@Nullable
                                   @Nullable org.gridgain.grid.internal.processors.cache.database.snapshot.file.SnapshotPath searchPath,
                                   long snapshotId)

Retrieving total segment sizes for a remote snapshot.

Specified by:

remoteSnapshotWalSizes in interface org.gridgain.grid.internal.processors.cache.database.snapshot.DatabaseSnapshotSpi

Parameters:

searchPath - Snapshot work directory.

snapshotId - ID of a specific snapshot.

Returns:

Sum of all WAL segments by consistentId.

nextLocalSnapshot

@Nullable
public @Nullable org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotMetadataV2 nextLocalSnapshot(long id)

Search for meta of next ascending snapshot, or null if not found. It is not recommended to use for iteration, you should use DatabaseSnapshotSpi.localSnapshots(boolean) for this.

Specified by:

nextLocalSnapshot in interface org.gridgain.grid.internal.processors.cache.database.snapshot.DatabaseSnapshotSpi

Parameters:

id - Id of current snapshot.

Returns:

Meta for next snapshot.

createFileSnapshot

protected FileSnapshot createFileSnapshot(IgniteConfiguration igCfg,
                                          FileDatabaseSnapshotSpi snapshotSpi,
                                          long id,
                                          org.gridgain.grid.internal.processors.cache.database.snapshot.file.SnapshotPath snapshotDir,
                                          Collection<org.gridgain.grid.internal.processors.cache.database.snapshot.file.SnapshotPath> optSearchPath,
                                          IgniteBiClosure<String,CacheConfiguration,CacheConfiguration> c,
                                          boolean ignoreMissedClasses,
                                          boolean remote,
                                          SnapshotSecurityLevel securityLevel,
                                          MessageDigestFactory msgDigestFactory,
                                          SnapshotRegistryTransformer registryTransformer,
                                          org.apache.ignite.internal.processors.cache.GridCacheSharedContext cctx)

To facilitate tests we need to wrap constructor of FileSnapshot in this method.

Parameters:

snapshotSpi - Snapshot SPI.

id - Snapshot ID.

snapshotDir - The directory where this snapshot was found.

optSearchPath - Collection of directories to search for snapshots.

c - CacheConfig conversion closure.

ignoreMissedClasses - If true ignore ClassNotFoundException when read snapshot.

remote - false if local

securityLevel - Snapshot security level.

cctx - Cache shared context.

snapshot

@Nullable
public @Nullable FileSnapshot snapshot(long id,
                                                 @Nullable
                                                 @Nullable Collection<org.gridgain.grid.internal.processors.cache.database.snapshot.file.SnapshotPath> optSearchPaths,
                                                 @Nullable
                                                 @Nullable IgniteBiClosure<String,CacheConfiguration,CacheConfiguration> c,
                                                 boolean ignoreMissedClasses,
                                                 @Nullable
                                                 @Nullable SnapshotSecurityLevel securityLevel,
                                                 boolean needDecryptKeys)

Getting snapshot.

Specified by:

snapshot in interface org.gridgain.grid.internal.processors.cache.database.snapshot.DatabaseSnapshotSpi

Parameters:

id - Id.

optSearchPaths - Opt search paths.

c - CacheConfig conversion closure.

ignoreMissedClasses - Ignore missed classes during metadata deserialization.

securityLevel - Snapshot security level, or null for DISABLED which is default.

needDecryptKeys - True when encryption keys stored in snapshot needed to be decrypted, false otherwise.

deleteSnapshot

public void deleteSnapshot(long id,
                           org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotOperationContext ctx)
                    throws IgniteCheckedException

Specified by:

deleteSnapshot in interface org.gridgain.grid.internal.processors.cache.database.snapshot.DatabaseSnapshotSpi

Parameters:

id - Snapshot id.

ctx - Context.

Throws:

IgniteCheckedException

isCopyRequired

public boolean isCopyRequired(long snapshotId,
                              org.gridgain.grid.internal.processors.cache.database.snapshot.file.SnapshotPath targetDirectory)
                       throws IgniteCheckedException

Method checks whether copy is required or not. If marker file exists, we consider cpoy is required. If marker file doesn't exist, we verify content of the metadata, if it is ok copy is not required otherwise copy is required and method returns true.

Specified by:

isCopyRequired in interface org.gridgain.grid.internal.processors.cache.database.snapshot.DatabaseSnapshotSpi

Parameters:

snapshotId - Snapshot id.

targetDirectory - Target directory to perform copy to.

Returns:

True if copy is needed to be done into target directory.

Throws:

IgniteCheckedException - In case filesystem exception.

copySnapshotEntirely

public void copySnapshotEntirely(long snapshotId,
                                 org.gridgain.grid.internal.processors.cache.database.snapshot.file.SnapshotPath pathToCopy,
                                 org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotOperationContext ctx,
                                 ExecutorService taskExecutor)
                          throws IgniteCheckedException

Will copy snapshot completely to the path.

Specified by:

copySnapshotEntirely in interface org.gridgain.grid.internal.processors.cache.database.snapshot.DatabaseSnapshotSpi

Parameters:

snapshotId - Snapshot id.

pathToCopy - Path.

ctx - Context.

taskExecutor - Task executor.

Throws:

IgniteCheckedException

copySinglePartition

public void copySinglePartition(long snapshotId,
                                int grpId,
                                int partId,
                                org.gridgain.grid.internal.processors.cache.database.snapshot.file.SnapshotPath pathToCopy,
                                org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotOperationContext context)
                         throws IgniteCheckedException

Will copy only single partition.

Specified by:

copySinglePartition in interface org.gridgain.grid.internal.processors.cache.database.snapshot.DatabaseSnapshotSpi

Parameters:

snapshotId - Snapshot id.

grpId - Group id.

partId - Partition id.

pathToCopy - Path where to copy.

context - Context.

Throws:

IgniteCheckedException

copyWalSegments

public void copyWalSegments(long snapshotId,
                            Collection<File> segments,
                            org.gridgain.grid.internal.processors.cache.database.snapshot.file.SnapshotPath dir,
                            org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotOperationContext ctx)
                     throws IgniteCheckedException

Specified by:

copyWalSegments in interface org.gridgain.grid.internal.processors.cache.database.snapshot.DatabaseSnapshotSpi

Parameters:

snapshotId - Snapshot id.

segments - Wal segments.

dir - Target directory..

ctx - Snapshot operation context.

Throws:

IgniteCheckedException

copyMetadata

public void copyMetadata(long snapshotId,
                         org.gridgain.grid.internal.processors.cache.database.snapshot.file.SnapshotPath pathToMove,
                         org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotOperationContext context)
                  throws IgniteCheckedException

Specified by:

copyMetadata in interface org.gridgain.grid.internal.processors.cache.database.snapshot.DatabaseSnapshotSpi

Parameters:

snapshotId - Snapshot id.

pathToMove - Path.

context - Context.

Throws:

IgniteCheckedException

copyDigestRegistry

public void copyDigestRegistry(long snapshotId,
                               org.gridgain.grid.internal.processors.cache.database.snapshot.file.SnapshotPath file,
                               org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotOperationContext context)
                        throws IgniteCheckedException

Specified by:

copyDigestRegistry in interface org.gridgain.grid.internal.processors.cache.database.snapshot.DatabaseSnapshotSpi

Parameters:

snapshotId - Snapshot id.

file - Path.

context - Context.

Throws:

IgniteCheckedException

startCopy

public void startCopy(long snapshotId,
                      org.gridgain.grid.internal.processors.cache.database.snapshot.file.SnapshotPath pathToCopy)
               throws IgniteCheckedException

Marks directory with copy marker file, to indicate the beginning of copy operation.

Specified by:

startCopy in interface org.gridgain.grid.internal.processors.cache.database.snapshot.DatabaseSnapshotSpi

Parameters:

snapshotId - Snapshot id.

pathToCopy - Target consistent id directory.

Throws:

IgniteCheckedException - In case of failure to create copy marker file.

finishCopy

public void finishCopy(long snapshotId,
                       org.gridgain.grid.internal.processors.cache.database.snapshot.file.SnapshotPath pathToCopy)

Removes copy marker file to indicate the end of copy operation.

Specified by:

finishCopy in interface org.gridgain.grid.internal.processors.cache.database.snapshot.DatabaseSnapshotSpi

Parameters:

snapshotId - Snapshot id.

pathToCopy - Target consistent id directory.

generateSnapshotFolderPath

public <T extends org.gridgain.grid.internal.processors.cache.database.snapshot.file.SnapshotPath> T generateSnapshotFolderPath(T snapshotBaseFolder,
                                                                                                                                long id)

Specified by:

generateSnapshotFolderPath in interface org.gridgain.grid.internal.processors.cache.database.snapshot.DatabaseSnapshotSpi

Parameters:

snapshotBaseFolder - Snapshot base folder.

id - Snapshot id.

Returns:

Path for snapshot with given id in given path.

generateCurNodeSnapshotFolderPath

@NotNull
public @NotNull org.gridgain.grid.internal.processors.cache.database.snapshot.file.FsSnapshotPath generateCurNodeSnapshotFolderPath(long id)

Specified by:

generateCurNodeSnapshotFolderPath in interface org.gridgain.grid.internal.processors.cache.database.snapshot.DatabaseSnapshotSpi

Parameters:

id - Snapshot id.

Returns:

File for current node in local snapshot folder.

generateCurNodeSnapshotFolderPathWithLabel

public <T extends org.gridgain.grid.internal.processors.cache.database.snapshot.file.SnapshotPath> T generateCurNodeSnapshotFolderPathWithLabel(T snapshotBaseFolder,
                                                                                                                                                long id,
                                                                                                                                                String label)

Generate path with label for snapshot.

Specified by:

generateCurNodeSnapshotFolderPathWithLabel in interface org.gridgain.grid.internal.processors.cache.database.snapshot.DatabaseSnapshotSpi

Parameters:

snapshotBaseFolder - Where to generate folder.

id - Snapshot id to generate folder path.

label - Label for snapshot folder.

Returns:

File in given folder with snapshot or null.

findSnapshotDir

@Nullable
public <T extends org.gridgain.grid.internal.processors.cache.database.snapshot.file.SnapshotPath> T findSnapshotDir(T snapshotBaseFolder,
                                                                                                                               long id)

Specified by:

findSnapshotDir in interface org.gridgain.grid.internal.processors.cache.database.snapshot.DatabaseSnapshotSpi

Parameters:

snapshotBaseFolder - Snapshot base folder.

id - Snapshot id to find folder.

Returns:

first found File which match the given snapshot id.

Throws:

IgniteException - If something happened.

findCurNodeSnapshotDir

@Nullable
public <T extends org.gridgain.grid.internal.processors.cache.database.snapshot.file.SnapshotPath> T findCurNodeSnapshotDir(T snapshotBaseFolder,
                                                                                                                                      long id)

Description copied from interface: org.gridgain.grid.internal.processors.cache.database.snapshot.DatabaseSnapshotSpi

Find snapshot for curent node.

Specified by:

findCurNodeSnapshotDir in interface org.gridgain.grid.internal.processors.cache.database.snapshot.DatabaseSnapshotSpi

Parameters:

snapshotBaseFolder - Snapshot base folder.

id - Snapshot id.

Returns:

Path in cIdDir for snapshot with given id.

findLocalCurNodeSnapshotDir

@Nullable
public @Nullable org.gridgain.grid.internal.processors.cache.database.snapshot.file.FsSnapshotPath findLocalCurNodeSnapshotDir(long id)

Specified by:

findLocalCurNodeSnapshotDir in interface org.gridgain.grid.internal.processors.cache.database.snapshot.DatabaseSnapshotSpi

Parameters:

id - Snapshot id.

Returns:

Path in cIdDir for snapshot with given id.

findLocalSnapshotDir

@Nullable
public @Nullable org.gridgain.grid.internal.processors.cache.database.snapshot.file.FsSnapshotPath findLocalSnapshotDir(long id)
                                                                                                                           throws IgniteCheckedException

Parameters:

id - Snapshot id.

Returns:

Path for snapshot with given id if it exists.

Throws:

IgniteCheckedException - If failed.

generateSnapshotDirName

public static String generateSnapshotDirName(long id,
                                             @Nullable
                                             @Nullable String lb)

!!! FOR TEST PURPOSE ONLY !!! Generate snapshot folder name by its id. Do not use this method for snapshot searching because of the different time zones.

Parameters:

id - Snapshot id.

lb - Snapshot folder label.

extractIdFromSnapshotDirName

public static long extractIdFromSnapshotDirName(String dirName)

Get snapshot id from directory name.

Parameters:

dirName - Snapshot directory obtained from generateSnapshotDirName(long, java.lang.String).

Returns:

Snapshot id, or -1 if failed to get.