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

Class SnapshotResponseRemoteFutureTask

java.lang.Object

org.apache.ignite.internal.util.future.GridFutureAdapter<T>

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

All Implemented Interfaces:

IgniteInternalFuture<Void>

public class SnapshotResponseRemoteFutureTask
extends GridFutureAdapter<T>

Field Summary

Fields

Modifier and Type	Field	Description
protected GridCacheSharedContext<?,?>	cctx	Shared context.
protected AtomicReference<Throwable>	err	An exception which has been occurred during snapshot processing.
protected IgniteLogger	log	Ignite logger.
protected Map<Integer,Set<Integer>>	parts	Partition to be processed.
protected UUID	reqId	Snapshot operation request ID.
protected String	snpName	Unique identifier of snapshot process.
protected SnapshotSender	snpSndr	Snapshot data sender.
protected UUID	srcNodeId	Node id which cause snapshot operation.

Constructor Summary

Constructors

Constructor	Description
SnapshotResponseRemoteFutureTask(GridCacheSharedContext<?,?> cctx, UUID srcNodeId, UUID reqId, String snpName, String snpPath, SnapshotSender snpSndr, Map<Integer,Set<Integer>> parts)

Method Summary

Modifier and Type	Method	Description
void	acceptException(Throwable th)
Set<Integer>	affectedCacheGroups()
boolean	cancel()	Default no-op implementation that always returns false.
UUID	requestId()
String	snapshotName()
UUID	sourceNodeId()
boolean	start()	Initiates snapshot task.
String	toString()

Methods inherited from class org.apache.ignite.internal.util.future.GridFutureAdapter

chain, chain, chain, chain, chainCompose, chainCompose, error, get, get, get, getUninterruptibly, ignoreInterrupts, isCancelled, isDone, isFailed, listen, listen, logger, onCancelled, onDone, onDone, onDone, onDone, onDone, reset, result

Methods inherited from class java.lang.Object

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

Field Detail

cctx

protected final GridCacheSharedContext<?,?> cctx

Shared context.

log

protected final IgniteLogger log

Ignite logger.

srcNodeId

protected final UUID srcNodeId

Node id which cause snapshot operation.

reqId

protected final UUID reqId

Snapshot operation request ID.

snpName

protected final String snpName

Unique identifier of snapshot process.

snpSndr

@GridToStringExclude
protected final SnapshotSender snpSndr

Snapshot data sender.

parts

protected final Map<Integer,Set<Integer>> parts

Partition to be processed.

err

protected final AtomicReference<Throwable> err

An exception which has been occurred during snapshot processing.

Constructor Detail

SnapshotResponseRemoteFutureTask

public SnapshotResponseRemoteFutureTask(GridCacheSharedContext<?,?> cctx,
                                        UUID srcNodeId,
                                        UUID reqId,
                                        String snpName,
                                        String snpPath,
                                        SnapshotSender snpSndr,
                                        Map<Integer,Set<Integer>> parts)

Parameters:

cctx - Shared context.

srcNodeId - Node id which cause snapshot task creation.

reqId - Snapshot operation request ID.

snpName - Unique identifier of snapshot process.

snpPath - Snapshot directory path.

snpSndr - Factory which produces snapshot receiver instance.

parts - Partition to be processed.

Method Detail

start

public boolean start()

Initiates snapshot task.

Returns:

true if task started by this call.

acceptException

public void acceptException(Throwable th)

Parameters:

th - An exception which occurred during snapshot processing.

snapshotName

public String snapshotName()

Returns:

Snapshot name.

sourceNodeId

public UUID sourceNodeId()

Returns:

Node id which triggers this operation.

requestId

public UUID requestId()

Returns:

Snapshot operation request ID.

affectedCacheGroups

public Set<Integer> affectedCacheGroups()

Returns:

Set of cache groups included into snapshot operation.

cancel

public boolean cancel()

Default no-op implementation that always returns false. Futures that do support cancellation should override this method and call GridFutureAdapter.onCancelled() callback explicitly if cancellation indeed did happen.

Specified by:

cancel in interface IgniteInternalFuture<T>

Overrides:

cancel in class GridFutureAdapter<T>

Returns:

True if future was canceled (i.e. was not finished prior to this call).

toString

public String toString()

Overrides:

toString in class GridFutureAdapter<T>