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

Class GridNearAtomicSingleUpdateFuture

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

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

All Implemented Interfaces:

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

public class GridNearAtomicSingleUpdateFuture
extends GridNearAtomicAbstractUpdateFuture

DHT atomic cache near update future.

Field Summary

Fields inherited from class org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridNearAtomicAbstractUpdateFuture

cache, cctx, err, expiryPlc, filter, futId, invokeArgs, keepBinary, log, msgLog, nearEnabled, op, opRes, rawRetval, recovery, remapCnt, remapTopVer, retval, skipStore, subjId, syncMode, taskNameHash, topLocked, topVer

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
protected void	map(AffinityTopologyVersion topVer)
protected void	mapOnTopology() Maps future on ready topology.
void	onDhtResponse(UUID nodeId, GridDhtAtomicNearResponse res)
boolean	onNodeLeft(UUID nodeId) Callback for when node left.
void	onPrimaryResponse(UUID nodeId, GridNearAtomicUpdateResponse res, boolean nodeErr) Response callback.
String	toString()

Methods inherited from class org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridNearAtomicAbstractUpdateFuture

completeFuture, futureId, map, markNotTrackable, onDone, 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, startTime

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

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

Constructor Detail

GridNearAtomicSingleUpdateFuture

public GridNearAtomicSingleUpdateFuture(GridCacheContext cctx,
                                        GridDhtAtomicCache cache,
                                        CacheWriteSynchronizationMode syncMode,
                                        GridCacheOperation op,
                                        Object key,
                                        @Nullable
                                        Object val,
                                        @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)

Parameters:

cctx - Cache context.

cache - Cache instance.

syncMode - Write synchronization mode.

op - Update operation.

key - Keys to update.

val - Values or transform closure.

invokeArgs - Optional arguments for entry processor.

retval - Return value require flag.

rawRetval - True if should return GridCacheReturn as future result.

expiryPlc - Expiry policy explicitly specified for cache operation.

filter - Entry filter.

subjId - Subject ID.

taskNameHash - Task name hash code.

skipStore - Skip store flag.

keepBinary - Keep binary flag.

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

remapCnt - Maximum number of retries.

Method Detail

onNodeLeft

public boolean onNodeLeft(UUID nodeId)

Callback for when node left.

Parameters:

nodeId - Left node ID.

Returns:

True if future cared about this node.

onDhtResponse

public void onDhtResponse(UUID nodeId,
                          GridDhtAtomicNearResponse res)

Specified by:

onDhtResponse in class GridNearAtomicAbstractUpdateFuture

Parameters:

nodeId - Node ID.

res - Response.

onPrimaryResponse

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

Response callback.

Specified by:

onPrimaryResponse in class GridNearAtomicAbstractUpdateFuture

Parameters:

nodeId - Node ID.

res - Update response.

nodeErr - True if response was created on node failure.

mapOnTopology

protected void mapOnTopology()

Maps future on ready topology.

Specified by:

mapOnTopology in class GridNearAtomicAbstractUpdateFuture

map

protected void map(AffinityTopologyVersion topVer)

Specified by:

map in class GridNearAtomicAbstractUpdateFuture

Parameters:

topVer - Topology version.

toString

public String toString()

Overrides:

toString in class GridNearAtomicAbstractUpdateFuture