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

Class GridNearAtomicUpdateFuture

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.GridNearAtomicUpdateFuture

All Implemented Interfaces:

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

public class GridNearAtomicUpdateFuture
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, deploymentLdrId, err, expiryPlc, filter, futId, invokeArgs, keepBinary, log, msgLog, nearEnabled, op, opRes, recovery, remapCnt, remapTopVer, retval, skipStore, syncMode, taskNameHash, topLocked, topVer

Constructor Summary

Constructors

Constructor

Description

GridNearAtomicUpdateFuture(GridCacheContext cctx, GridDhtAtomicCache cache, CacheWriteSynchronizationMode syncMode, GridCacheOperation op, Collection<?> keys, @Nullable Collection<?> vals, @Nullable Object[] invokeArgs, @Nullable Collection<GridCacheDrInfo> conflictPutVals, @Nullable Collection<GridCacheVersion> conflictRmvVals, boolean retval, @Nullable javax.cache.expiry.ExpiryPolicy expiryPlc, CacheEntryPredicate[] filter, int taskNameHash, boolean skipStore, boolean keepBinary, boolean recovery, int remapCnt)

Method Summary

Modifier and Type	Method	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, 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, 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

Constructor Detail

GridNearAtomicUpdateFuture

public GridNearAtomicUpdateFuture(GridCacheContext cctx,
                                  GridDhtAtomicCache cache,
                                  CacheWriteSynchronizationMode syncMode,
                                  GridCacheOperation op,
                                  Collection<?> keys,
                                  @Nullable
                                  @Nullable Collection<?> vals,
                                  @Nullable
                                  @Nullable Object[] invokeArgs,
                                  @Nullable
                                  @Nullable Collection<GridCacheDrInfo> conflictPutVals,
                                  @Nullable
                                  @Nullable Collection<GridCacheVersion> conflictRmvVals,
                                  boolean retval,
                                  @Nullable
                                  @Nullable javax.cache.expiry.ExpiryPolicy expiryPlc,
                                  CacheEntryPredicate[] filter,
                                  int taskNameHash,
                                  boolean skipStore,
                                  boolean keepBinary,
                                  boolean recovery,
                                  int remapCnt)

Parameters:

cctx - Cache context.

cache - Cache instance.

syncMode - Write synchronization mode.

op - Update operation.

keys - Keys to update.

vals - Values or transform closure.

invokeArgs - Optional arguments for entry processor.

conflictPutVals - Conflict put values (optional).

conflictRmvVals - Conflict remove values (optional).

retval - Return value require flag.

expiryPlc - Expiry policy explicitly specified for cache operation.

filter - Entry filter.

taskNameHash - Task name hash code.

skipStore - Skip store flag.

keepBinary - Keep binary flag.

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