ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject ignite git commit: ignite-4705
Date Mon, 06 Mar 2017 08:35:20 GMT
Repository: ignite
Updated Branches:
  refs/heads/ignite-4705-2 3ed32e60d -> 73b9413fd


ignite-4705


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

Branch: refs/heads/ignite-4705-2
Commit: 73b9413fd7fc48043b31aa77d2fbe6c5e641bb2d
Parents: 3ed32e6
Author: sboikov <sboikov@gridgain.com>
Authored: Mon Mar 6 11:35:13 2017 +0300
Committer: sboikov <sboikov@gridgain.com>
Committed: Mon Mar 6 11:35:13 2017 +0300

----------------------------------------------------------------------
 .../ignite/internal/processors/cache/GridCacheIoManager.java | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/73b9413f/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheIoManager.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheIoManager.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheIoManager.java
index 6047133..50820ae 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheIoManager.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheIoManager.java
@@ -214,6 +214,10 @@ public class GridCacheIoManager extends GridCacheSharedManagerAdapter
{
             }
 
             if (fut != null && !fut.isDone()) {
+                Thread curThread = Thread.currentThread();
+
+                final int stripe = curThread instanceof IgniteThread ? ((IgniteThread)curThread).stripe()
: -1;
+
                 fut.listen(new CI1<IgniteInternalFuture<?>>() {
                     @Override public void apply(IgniteInternalFuture<?> t) {
                         Runnable c = new Runnable() {
@@ -233,10 +237,6 @@ public class GridCacheIoManager extends GridCacheSharedManagerAdapter
{
                             }
                         };
 
-                        Thread curThread = Thread.currentThread();
-
-                        int stripe = curThread instanceof IgniteThread ? ((IgniteThread)curThread).stripe()
: -1;
-
                         if (stripe >= 0)
                             cctx.kernalContext().getStripedExecutorService().execute(stripe,
c);
                         else


Mime
View raw message