Repository: ignite Updated Branches: refs/heads/ignite-1093-2 48397aef5 -> ee13dd6fc
1093 Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/ee13dd6f Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/ee13dd6f Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/ee13dd6f Branch: refs/heads/ignite-1093-2 Commit: ee13dd6fc4ff94ad5f7ea01b9fa91204e73a1301 Parents: 48397ae Author: Anton Vinogradov <[email protected]> Authored: Sun Oct 11 15:30:00 2015 +0300 Committer: Anton Vinogradov <[email protected]> Committed: Sun Oct 11 15:30:00 2015 +0300 ---------------------------------------------------------------------- .../cache/distributed/dht/preloader/GridDhtPartitionDemander.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/ee13dd6f/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionDemander.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionDemander.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionDemander.java index f965c02..9b079ec 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionDemander.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionDemander.java @@ -487,8 +487,7 @@ public class GridDhtPartitionDemander { assert node != null; - if (//!fut.topologyVersion().equals(topVer) || // Current future based on another topology. - !fut.isActual(supply.updateSequence())) // Current future have same topology, but another update sequence. + if (!fut.isActual(supply.updateSequence())) // Current future have another update sequence. return; // Supple message based on another future. if (topologyChanged(fut)) { // Topology already changed (for the future that supply message based on).
