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 and 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	rawRetval Raw return value flag.
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 UUID	subjId Subject ID.
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 and Description

protected

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

Method Summary

Modifier and Type	Method and 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, error, get, get, get, getUninterruptibly, ignoreInterrupts, isCancelled, isDone, isFailed, 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, error, get, get, get, getUninterruptibly, isCancelled, isDone, 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.

rawRetval

protected final boolean rawRetval

Raw return value flag.

expiryPlc

protected final javax.cache.expiry.ExpiryPolicy expiryPlc

Expiry policy.

filter

protected final CacheEntryPredicate[] filter

Optional filter.

subjId

protected final UUID subjId

Subject ID.

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,
                                             boolean rawRetval,
                                             @Nullable
                                             @Nullable javax.cache.expiry.ExpiryPolicy expiryPlc,
                                             CacheEntryPredicate[] filter,
                                             UUID subjId,
                                             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.

rawRetval - Raw return value flag.

expiryPlc - Expiry policy.

filter - Filter.

subjId - Subject ID.

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>