Repository: ignite Updated Branches: refs/heads/ignite-426-2-reb f9a1753c9 -> 94a1d0cad
ignite-426-2-reb WIP Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/94a1d0ca Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/94a1d0ca Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/94a1d0ca Branch: refs/heads/ignite-426-2-reb Commit: 94a1d0cada34c9eb916e8d86078cba91cdbf5db2 Parents: f9a1753 Author: Tikhonov Nikolay <[email protected]> Authored: Sun Oct 25 18:16:32 2015 +0300 Committer: Tikhonov Nikolay <[email protected]> Committed: Sun Oct 25 18:16:32 2015 +0300 ---------------------------------------------------------------------- .../cache/distributed/dht/atomic/GridDhtAtomicCache.java | 6 ------ .../cache/query/continuous/CacheContinuousQueryManager.java | 6 ------ 2 files changed, 12 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/94a1d0ca/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java index c78f3bd..11099b9 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java @@ -1806,12 +1806,6 @@ public class GridDhtAtomicCache<K, V> extends GridDhtCacheAdapter<K, V> { readersOnly = true; } - if (!primary) { - int z = 0; - - ++z; - } - if (updRes.contQryNtfy() != null) { if (primary && dhtFut != null) { dhtFut.listen(new CI1<IgniteInternalFuture<Void>>() { http://git-wip-us.apache.org/repos/asf/ignite/blob/94a1d0ca/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryManager.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryManager.java index b558a0a..b8922a3 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryManager.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryManager.java @@ -189,12 +189,6 @@ public class CacheContinuousQueryManager extends GridCacheManagerAdapter { if (preload && !internal) return; - if (!primary) { - int z = 0; - - ++z; - } - ConcurrentMap<UUID, CacheContinuousQueryListener> lsnrCol; if (internal)
