Repository: incubator-ignite Updated Branches: refs/heads/ignite-834 863d6bf69 -> 9df497f92
#ignite-834: Small change Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/9df497f9 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/9df497f9 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/9df497f9 Branch: refs/heads/ignite-834 Commit: 9df497f92b0ac9381359587c9ba838c68d974c16 Parents: 863d6bf Author: ivasilinets <ivasilin...@gridgain.com> Authored: Tue May 5 15:40:46 2015 +0300 Committer: ivasilinets <ivasilin...@gridgain.com> Committed: Tue May 5 15:40:46 2015 +0300 ---------------------------------------------------------------------- .../internal/processors/cache/GridCacheAdapter.java | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/9df497f9/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 596705e..876d66d 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 @@ -1129,9 +1129,9 @@ public abstract class GridCacheAdapter<K, V> implements IgniteInternalCache<K, V if (!nodes.nodes().isEmpty()) { ctx.kernalContext().task().setThreadContext(TC_TIMEOUT, timeout); - ctx.grid().context().task().setThreadContext(TC_SUBGRID, nodes); + ctx.kernalContext().task().setThreadContext(TC_SUBGRID, nodes); - ctx.grid().context().task().execute(new ComputeTaskAdapter<Object, Object>() { + ctx.kernalContext().task().execute(new ComputeTaskAdapter<Object, Object>() { /** {@inheritDoc} */ @Nullable @Override public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> subgrid, @Nullable Object arg) throws IgniteException { @@ -1163,9 +1163,9 @@ public abstract class GridCacheAdapter<K, V> implements IgniteInternalCache<K, V Collection<ClusterNode> nodes = ctx.grid().cluster().forCacheNodes(name(), true, true, false).nodes(); if (!nodes.isEmpty()) { - ctx.grid().context().task().setThreadContext(TC_SUBGRID, nodes); + ctx.kernalContext().task().setThreadContext(TC_SUBGRID, nodes); - return ctx.grid().context().task().execute(new ComputeTaskAdapter<Object, Object>() { + return ctx.kernalContext().task().execute(new ComputeTaskAdapter<Object, Object>() { /** {@inheritDoc} */ @Nullable @Override public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> subgrid, @Nullable Object arg) throws IgniteException { @@ -3581,9 +3581,9 @@ public abstract class GridCacheAdapter<K, V> implements IgniteInternalCache<K, V if (nodes.isEmpty()) return new GridFinishedFuture<>(0); - ctx.grid().context().task().setThreadContext(TC_SUBGRID, nodes); + ctx.kernalContext().task().setThreadContext(TC_SUBGRID, nodes); - return ctx.grid().context().task().execute(new ComputeTaskAdapter<Object, Integer>() { + return ctx.kernalContext().task().execute(new ComputeTaskAdapter<Object, Integer>() { /** {@inheritDoc} */ @Nullable @Override public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> subgrid,
