Package org.apache.ignite.internal.processors.cache.distributed.dht.atomic

Class GridNearAtomicAbstractUpdateFuture

java.lang.Object

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

org.apache.ignite.internal.processors.cache.GridCacheFutureAdapter<Object>

org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridNearAtomicAbstractUpdateFuture

All Implemented Interfaces:

IgniteInternalFuture<Object>, GridCacheAtomicFuture<Object>, GridCacheFuture<Object>

Direct Known Subclasses:

GridNearAtomicSingleUpdateFuture, GridNearAtomicUpdateFuture

public abstract class GridNearAtomicAbstractUpdateFuture
extends GridCacheFutureAdapter<Object>
implements GridCacheAtomicFuture<Object>

Base for near atomic update futures.

Field Summary

Fields

Modifier and Type	Field	Description
protected GridDhtAtomicCache	cache	Cache.
protected GridCacheContext	cctx	Cache context.
protected IgniteUuid	deploymentLdrId	Deployment class loader id which will be used for deserialization of entries on a distributed task.
protected CachePartialUpdateCheckedException	err	Error.
protected javax.cache.expiry.ExpiryPolicy	expiryPlc	Expiry policy.
protected CacheEntryPredicate[]	filter	Optional filter.
protected long	futId	Future ID, changes when operation is remapped.
protected Object[]	invokeArgs	Optional arguments for entry processor.
protected boolean	keepBinary	Keep binary flag.
protected static IgniteLogger	log	Logger.
protected static IgniteLogger	msgLog	Logger.
protected boolean	nearEnabled	Near cache flag.
protected GridCacheOperation	op	Update operation.
protected GridCacheReturn	opRes	Operation result.
protected boolean	recovery	Recovery flag.
protected int	remapCnt	Remap count.
protected AffinityTopologyVersion	remapTopVer
protected boolean	retval	Return value require flag.
protected boolean	skipStore	Skip store flag.
protected CacheWriteSynchronizationMode	syncMode	Write synchronization mode.
protected int	taskNameHash	Task name hash.
protected boolean	topLocked	Topology locked flag.
protected AffinityTopologyVersion	topVer	Current topology version.

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	GridNearAtomicAbstractUpdateFuture(GridCacheContext cctx, GridDhtAtomicCache cache, CacheWriteSynchronizationMode syncMode, GridCacheOperation op, @Nullable Object[] invokeArgs, boolean retval, @Nullable javax.cache.expiry.ExpiryPolicy expiryPlc, CacheEntryPredicate[] filter, int taskNameHash, boolean skipStore, boolean keepBinary, boolean recovery, int remapCnt)	Constructor.

Method Summary

Modifier and Type	Method	Description
IgniteInternalFuture<Void>	completeFuture(AffinityTopologyVersion topVer)	Gets future that will be completed when it is safe when update is finished on the given version of topology.
IgniteUuid	futureId()
void	map()	Performs future mapping.
protected abstract void	map(AffinityTopologyVersion topVer)
protected abstract void	mapOnTopology()	Maps future on ready topology.
void	markNotTrackable()	Marks this future as non-trackable.
abstract void	onDhtResponse(UUID nodeId, GridDhtAtomicNearResponse res)
boolean	onDone(@Nullable Object res, @Nullable Throwable err)	Callback to notify that future is finished.
abstract void	onPrimaryResponse(UUID nodeId, GridNearAtomicUpdateResponse res, boolean nodeErr)	Response callback.
String	toString()
boolean	trackable()

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

duration, onDone, startTime

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

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

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.ignite.internal.processors.cache.GridCacheFuture

duration, onNodeLeft, startTime

Methods inherited from interface org.apache.ignite.internal.IgniteInternalFuture

cancel, chain, chain, chain, chain, chainCompose, chainCompose, error, get, get, get, getUninterruptibly, isCancelled, isDone, listen, listen, result

Field Detail

log

protected static IgniteLogger log

Logger.

msgLog

protected static IgniteLogger msgLog

Logger.

cctx

protected final GridCacheContext cctx

Cache context.

cache

protected final GridDhtAtomicCache cache

Cache.

syncMode

protected final CacheWriteSynchronizationMode syncMode

Write synchronization mode.

op

protected final GridCacheOperation op

Update operation.

invokeArgs

protected final Object[] invokeArgs

Optional arguments for entry processor.

retval

protected final boolean retval

Return value require flag.

expiryPlc

protected final javax.cache.expiry.ExpiryPolicy expiryPlc

Expiry policy.

filter

protected final CacheEntryPredicate[] filter

Optional filter.

taskNameHash

protected final int taskNameHash

Task name hash.

skipStore

protected final boolean skipStore

Skip store flag.

keepBinary

protected final boolean keepBinary

Keep binary flag.

recovery

protected final boolean recovery

Recovery flag.

nearEnabled

protected final boolean nearEnabled

Near cache flag.

deploymentLdrId

@GridToStringExclude
protected final IgniteUuid deploymentLdrId

Deployment class loader id which will be used for deserialization of entries on a distributed task.

topLocked

protected boolean topLocked

Topology locked flag. Set if atomic update is performed inside a TX or explicit lock.

remapCnt

@GridToStringInclude
protected int remapCnt

Remap count.

topVer

@GridToStringInclude
protected AffinityTopologyVersion topVer

Current topology version.

remapTopVer

@GridToStringInclude
protected AffinityTopologyVersion remapTopVer

err

@GridToStringInclude
protected CachePartialUpdateCheckedException err

Error.

futId

@GridToStringInclude
protected long futId

Future ID, changes when operation is remapped.

opRes

protected GridCacheReturn opRes

Operation result.

Constructor Detail

GridNearAtomicAbstractUpdateFuture

protected GridNearAtomicAbstractUpdateFuture(GridCacheContext cctx,
                                             GridDhtAtomicCache cache,
                                             CacheWriteSynchronizationMode syncMode,
                                             GridCacheOperation op,
                                             @Nullable
                                             @Nullable Object[] invokeArgs,
                                             boolean retval,
                                             @Nullable
                                             @Nullable javax.cache.expiry.ExpiryPolicy expiryPlc,
                                             CacheEntryPredicate[] filter,
                                             int taskNameHash,
                                             boolean skipStore,
                                             boolean keepBinary,
                                             boolean recovery,
                                             int remapCnt)

Constructor.

Parameters:

cctx - Cache context.

cache - Cache.

syncMode - Synchronization mode.

op - Operation.

invokeArgs - Invoke arguments.

retval - Return value flag.

expiryPlc - Expiry policy.

filter - Filter.

taskNameHash - Task name hash.

skipStore - Skip store flag.

keepBinary - Keep binary flag.

recovery - True if cache operation is called in recovery mode.

remapCnt - Remap count.

Method Detail

completeFuture

public final IgniteInternalFuture<Void> completeFuture(AffinityTopologyVersion topVer)

Gets future that will be completed when it is safe when update is finished on the given version of topology.

Specified by:

completeFuture in interface GridCacheAtomicFuture<Object>

Parameters:

topVer - Topology version to finish.

Returns:

Future or null if no need to wait.

map

public final void map()

Performs future mapping.

map

protected abstract void map(AffinityTopologyVersion topVer)

Parameters:

topVer - Topology version.

mapOnTopology

protected abstract void mapOnTopology()

Maps future on ready topology.

futureId

public IgniteUuid futureId()

Specified by:

futureId in interface GridCacheFuture<Object>

Returns:

Unique identifier for this future.

trackable

public boolean trackable()

Specified by:

trackable in interface GridCacheFuture<Object>

Returns:

True if future should be tracked.

markNotTrackable

public void markNotTrackable()

Marks this future as non-trackable.

Specified by:

markNotTrackable in interface GridCacheFuture<Object>

onPrimaryResponse

public abstract void onPrimaryResponse(UUID nodeId,
                                       GridNearAtomicUpdateResponse res,
                                       boolean nodeErr)

Response callback.

Parameters:

nodeId - Node ID.

res - Update response.

nodeErr - True if response was created on node failure.

onDhtResponse

public abstract void onDhtResponse(UUID nodeId,
                                   GridDhtAtomicNearResponse res)

Parameters:

nodeId - Node ID.

res - Response.

onDone

public final boolean onDone(@Nullable
                            @Nullable Object res,
                            @Nullable
                            @Nullable Throwable err)

Callback to notify that future is finished. Note that if non-null exception is passed in the result value will be ignored.

Overrides:

onDone in class GridFutureAdapter<Object>

Parameters:

res - Optional result.

err - Optional error.

Returns:

True if result was set by this call.

toString

public String toString()

Overrides:

toString in class GridFutureAdapter<Object>