You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by nt...@apache.org on 2015/10/28 14:15:25 UTC
[49/50] [abbrv] ignite git commit: ignite-426-2-reb WIP
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 <ti...@gmail.com>
Authored: Sun Oct 25 18:16:32 2015 +0300
Committer: nikolay_tikhonov <nt...@gridgain.com>
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)