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/ecc32163 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/ecc32163 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/ecc32163 Branch: refs/heads/ignite-426-2-reb Commit: ecc321639aa5aa5b0b45acdfaf8014487b7a69c0 Parents: 926a001 Author: Tikhonov Nikolay <[email protected]> Authored: Sun Oct 25 18:16:32 2015 +0300 Committer: nikolay_tikhonov <[email protected]> Committed: Wed Oct 28 15:26:46 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/ecc32163/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 c6ab45d..d26ad97 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 @@ -1799,12 +1799,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/ecc32163/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 ecc778b..14fe195 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)
