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

Class GridDhtPartitionsStateValidator

java.lang.Object

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

public class GridDhtPartitionsStateValidator
extends Object

Class to validate partitions update counters and cache sizes during exchange process.

Constructor Summary

Constructors

Constructor and Description
GridDhtPartitionsStateValidator(GridCacheSharedContext<?,?> cctx) Constructor.

Method Summary

Modifier and Type	Method and Description
void	validatePartitionCountersAndSizes(GridDhtPartitionsExchangeFuture fut, GridDhtPartitionTopology top, Map<UUID,GridDhtPartitionsSingleMessage> messages) Validates partition states - update counters and cache sizes for all nodes.

Methods inherited from class java.lang.Object

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

Constructor Detail

GridDhtPartitionsStateValidator

public GridDhtPartitionsStateValidator(GridCacheSharedContext<?,?> cctx)

Constructor.

Parameters:

cctx - Cache shared context.

Method Detail

validatePartitionCountersAndSizes

public void validatePartitionCountersAndSizes(GridDhtPartitionsExchangeFuture fut,
                                              GridDhtPartitionTopology top,
                                              Map<UUID,GridDhtPartitionsSingleMessage> messages)
                                       throws IgniteCheckedException

Validates partition states - update counters and cache sizes for all nodes. If update counter value or cache size for the same partitions are different on some nodes method throws exception with full information about inconsistent partitions.

Parameters:

fut - Current exchange future.

top - Topology to validate.

messages - Single messages received from all nodes.

Throws:

IgniteCheckedException - If validation failed. Exception message contains full information about all partitions which update counters or cache sizes are not consistent.