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/05 14:41:03 UTC
incubator-ignite git commit: #ignite-834: Small change
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 <iv...@gridgain.com>
Authored: Tue May 5 15:40:46 2015 +0300
Committer: ivasilinets <iv...@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,