ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [2/2] incubator-ignite git commit: #ignite-732: wip.
Date Thu, 30 Apr 2015 15:40:31 GMT
#ignite-732: wip.


Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/a276a450
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/a276a450
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/a276a450

Branch: refs/heads/ignite-732
Commit: a276a450c02f8959f2b6eb8e13e59850c171761b
Parents: e8ae0ac
Author: ivasilinets <ivasilinets@gridgain.com>
Authored: Thu Apr 30 18:40:14 2015 +0300
Committer: ivasilinets <ivasilinets@gridgain.com>
Committed: Thu Apr 30 18:40:14 2015 +0300

----------------------------------------------------------------------
 .../internal/processors/cache/GridCacheAdapter.java       | 10 ++--------
 1 file changed, 2 insertions(+), 8 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/a276a450/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java
index 943968d..39f19b1 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java
@@ -1118,17 +1118,11 @@ public abstract class GridCacheAdapter<K, V> implements IgniteInternalCache<K,
V
      */
     private void clearAll(long timeout, TopologyVersionAwareCallable clearCall) throws IgniteCheckedException
{
         try {
-            // Send job to remote nodes only.
-            Collection<ClusterNode> nodes =
-                ctx.grid().cluster().forCacheNodes(name(), true, true, false).forRemotes().nodes();
-
             IgniteInternalFuture<Object> fut = null;
 
-            if (!nodes.isEmpty()) {
-                ctx.kernalContext().task().setThreadContext(TC_TIMEOUT, timeout);
+            ctx.kernalContext().task().setThreadContext(TC_TIMEOUT, timeout);
 
-                fut = new ClearFuture(ctx, clearCall);
-            }
+            fut = new ClearFuture(ctx, clearCall);
 
             if (fut != null)
                 fut.get();


Mime
View raw message