org.apache.ignite.internal.processors.cache.distributed.near.consistency

Class GridNearReadRepairFuture

java.lang.Object

org.apache.ignite.internal.util.future.GridFutureAdapter<Map<KeyCacheObject,EntryGetResult>>

org.apache.ignite.internal.processors.cache.distributed.near.consistency.GridNearReadRepairAbstractFuture

org.apache.ignite.internal.processors.cache.distributed.near.consistency.GridNearReadRepairFuture

All Implemented Interfaces:

IgniteInternalFuture<Map<KeyCacheObject,EntryGetResult>>

public class GridNearReadRepairFuture
extends GridNearReadRepairAbstractFuture

Checks data consistency. Checks that each affinity node's value equals other's. Prepares recovery data. Records consistency violation event.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.ignite.internal.processors.cache.distributed.near.consistency.GridNearReadRepairAbstractFuture

GridNearReadRepairAbstractFuture.ByteArrayWrapper

Field Summary

Fields inherited from class org.apache.ignite.internal.processors.cache.distributed.near.consistency.GridNearReadRepairAbstractFuture

ctx, deserializeBinary, expiryPlc, futs, keys, MAX_REMAP_CNT, primaries, readThrough, recovery, remapCnt, strategy, taskName, tx

Constructor Summary

Constructors

Constructor and Description
GridNearReadRepairFuture(AffinityTopologyVersion topVer, GridCacheContext ctx, Collection<KeyCacheObject> keys, ReadRepairStrategy strategy, boolean readThrough, String taskName, boolean deserializeBinary, boolean recovery, IgniteCacheExpiryPolicy expiryPlc, IgniteInternalTx tx) Creates a new instance of GridNearReadRepairFuture.

Method Summary

Modifier and Type	Method and Description
Map<KeyCacheObject,EntryGetResult>	fixWithLww(Set<KeyCacheObject> inconsistentKeys)
Map<KeyCacheObject,EntryGetResult>	fixWithMajority(Collection<KeyCacheObject> inconsistentKeys)
Map<KeyCacheObject,EntryGetResult>	fixWithPrimary(Collection<KeyCacheObject> inconsistentKeys)
Map<KeyCacheObject,EntryGetResult>	fixWithRemove(Collection<KeyCacheObject> inconsistentKeys)
protected void	reduce() Reduces fut's results.
protected GridNearReadRepairAbstractFuture	remapFuture(AffinityTopologyVersion topVer)

Methods inherited from class org.apache.ignite.internal.processors.cache.distributed.near.consistency.GridNearReadRepairAbstractFuture

check, onResult, recordConsistencyViolation, remap

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, onDone, onDone, reset, result, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

GridNearReadRepairFuture

public GridNearReadRepairFuture(AffinityTopologyVersion topVer,
                                GridCacheContext ctx,
                                Collection<KeyCacheObject> keys,
                                ReadRepairStrategy strategy,
                                boolean readThrough,
                                String taskName,
                                boolean deserializeBinary,
                                boolean recovery,
                                IgniteCacheExpiryPolicy expiryPlc,
                                IgniteInternalTx tx)

Creates a new instance of GridNearReadRepairFuture.

Parameters:

topVer - Affinity topology version.

ctx - Cache context.

keys - Keys.

strategy - Read repair strategy.

readThrough - Read-through flag.

taskName - Task name.

deserializeBinary - Deserialize binary flag.

recovery - Partition recovery flag.

expiryPlc - Expiry policy.

tx - Transaction.

Method Detail

remapFuture

protected GridNearReadRepairAbstractFuture remapFuture(AffinityTopologyVersion topVer)

Specified by:

remapFuture in class GridNearReadRepairAbstractFuture

Parameters:

topVer - Topology version.

reduce

protected void reduce()

Reduces fut's results.

Specified by:

reduce in class GridNearReadRepairAbstractFuture

fixWithLww

public Map<KeyCacheObject,EntryGetResult> fixWithLww(Set<KeyCacheObject> inconsistentKeys)
                                              throws IgniteCheckedException

Throws:

IgniteCheckedException

fixWithPrimary

public Map<KeyCacheObject,EntryGetResult> fixWithPrimary(Collection<KeyCacheObject> inconsistentKeys)

fixWithRemove

public Map<KeyCacheObject,EntryGetResult> fixWithRemove(Collection<KeyCacheObject> inconsistentKeys)

fixWithMajority

public Map<KeyCacheObject,EntryGetResult> fixWithMajority(Collection<KeyCacheObject> inconsistentKeys)
                                                   throws IgniteCheckedException

Throws:

IgniteCheckedException