Repository: ignite Updated Branches: refs/heads/ignite-4154 a099e9117 -> 752c9bed5
ignite-4154 Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/752c9bed Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/752c9bed Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/752c9bed Branch: refs/heads/ignite-4154 Commit: 752c9bed50b57ca3dbe12d17b942ad905ce833ad Parents: a099e91 Author: sboikov <[email protected]> Authored: Thu Nov 10 11:39:33 2016 +0300 Committer: sboikov <[email protected]> Committed: Thu Nov 10 11:39:33 2016 +0300 ---------------------------------------------------------------------- .../GridCachePartitionExchangeManager.java | 36 ++++++++++---------- 1 file changed, 18 insertions(+), 18 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/752c9bed/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCachePartitionExchangeManager.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCachePartitionExchangeManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCachePartitionExchangeManager.java index 07d1d4c..f7f0080 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCachePartitionExchangeManager.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCachePartitionExchangeManager.java @@ -910,24 +910,24 @@ public class GridCachePartitionExchangeManager<K, V> extends GridCacheSharedMana Object affKey) { Integer dupDataCache = null; - if (compress && affKey != null && !m.containsCache(cacheId)) { - T2<Integer, GridDhtPartitionFullMap> state0 = dupData.get(affKey); - - if (state0 != null && state0.get2().partitionStateEquals(map)) { - GridDhtPartitionFullMap map0 = new GridDhtPartitionFullMap(map.nodeId(), - map.nodeOrder(), - map.updateSequence()); - - for (Map.Entry<UUID, GridDhtPartitionMap2> e : map.entrySet()) - map0.put(e.getKey(), e.getValue().emptyCopy()); - - map = map0; - - dupDataCache = state0.get1(); - } - else - dupData.put(affKey, new T2<>(cacheId, map)); - } +// if (compress && affKey != null && !m.containsCache(cacheId)) { +// T2<Integer, GridDhtPartitionFullMap> state0 = dupData.get(affKey); +// +// if (state0 != null && state0.get2().partitionStateEquals(map)) { +// GridDhtPartitionFullMap map0 = new GridDhtPartitionFullMap(map.nodeId(), +// map.nodeOrder(), +// map.updateSequence()); +// +// for (Map.Entry<UUID, GridDhtPartitionMap2> e : map.entrySet()) +// map0.put(e.getKey(), e.getValue().emptyCopy()); +// +// map = map0; +// +// dupDataCache = state0.get1(); +// } +// else +// dupData.put(affKey, new T2<>(cacheId, map)); +// } m.addFullPartitionsMap(cacheId, map, dupDataCache); }
