#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 <ivasilin...@gridgain.com> Authored: Thu Apr 30 18:40:14 2015 +0300 Committer: ivasilinets <ivasilin...@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();
