ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject incubator-ignite git commit: #ignite-834: Small change
Date Tue, 05 May 2015 12:41:03 GMT
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 <ivasilinets@gridgain.com>
Authored: Tue May 5 15:40:46 2015 +0300
Committer: ivasilinets <ivasilinets@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,


Mime
View raw message