You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sb...@apache.org on 2015/05/12 13:30:47 UTC
[28/37] incubator-ignite git commit: #ignite-373: Remove unused debug.
#ignite-373: Remove unused debug.
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/7624e447
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/7624e447
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/7624e447
Branch: refs/heads/ignite-373
Commit: 7624e4474ae0783a151e8e3d97b456c30c77a069
Parents: 735e9cf
Author: ivasilinets <iv...@gridgain.com>
Authored: Tue May 12 12:03:40 2015 +0300
Committer: ivasilinets <iv...@gridgain.com>
Committed: Tue May 12 12:03:40 2015 +0300
----------------------------------------------------------------------
.../cache/distributed/GridDistributedCacheAdapter.java | 10 ++--------
1 file changed, 2 insertions(+), 8 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7624e447/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedCacheAdapter.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedCacheAdapter.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedCacheAdapter.java
index edad1d2..8958637 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedCacheAdapter.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedCacheAdapter.java
@@ -147,7 +147,6 @@ public abstract class GridDistributedCacheAdapter<K, V> extends GridCacheAdapter
do {
removed = true;
- System.out.println("!!!!Redone remove all");
topVer = ctx.affinity().affinityTopologyVersion();
// Send job to all data nodes.
@@ -293,10 +292,8 @@ public abstract class GridDistributedCacheAdapter<K, V> extends GridCacheAdapter
ctx.gate().enter();
try {
- if (!ctx.affinity().affinityTopologyVersion().equals(topVer)) {
- System.out.println("!!!! have different version");
+ if (!ctx.affinity().affinityTopologyVersion().equals(topVer))
return new Integer(-1); // Ignore this remove request because remove request will be sent again.
- }
GridDhtCacheAdapter<K, V> dht;
GridNearCacheAdapter<K, V> near = null;
@@ -349,11 +346,8 @@ public abstract class GridDistributedCacheAdapter<K, V> extends GridCacheAdapter
ctx.gate().leave();
}
- if (!ctx.affinity().affinityTopologyVersion().equals(topVer)) {
- System.out.println("!!!! have different version in the end.");
-
+ if (!ctx.affinity().affinityTopologyVersion().equals(topVer))
return new Integer(-1);
- }
return null;
}