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-1.8 debug
Date Fri, 02 Dec 2016 11:59:02 GMT
Repository: ignite
Updated Branches:
  refs/heads/ignite-1.8-drop1 [created] b54ae7692


ignite-1.8 debug


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

Branch: refs/heads/ignite-1.8-drop1
Commit: b54ae7692e8d1f64a8622c9331a26eda398738b0
Parents: 445cde7
Author: sboikov <sboikov@gridgain.com>
Authored: Fri Dec 2 14:58:54 2016 +0300
Committer: sboikov <sboikov@gridgain.com>
Committed: Fri Dec 2 14:58:54 2016 +0300

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


http://git-wip-us.apache.org/repos/asf/ignite/blob/b54ae769/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 924ce79..2fb5458 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
@@ -106,7 +106,7 @@ public class GridCacheIoManager extends GridCacheSharedManagerAdapter
{
     private int retryCnt;
 
     /** Indexed class handlers. */
-    private volatile Map<Integer, IgniteBiInClosure[]> idxClsHandlers = new HashMap<>();
+    private Map<Integer, IgniteBiInClosure[]> idxClsHandlers = new HashMap<>();
 
     /** Handler registry. */
     private ConcurrentMap<ListenerKey, IgniteBiInClosure<UUID, GridCacheMessage>>
@@ -250,9 +250,7 @@ public class GridCacheIoManager extends GridCacheSharedManagerAdapter
{
         IgniteBiInClosure<UUID, GridCacheMessage> c = null;
 
         if (msgIdx >= 0) {
-            Map<Integer, IgniteBiInClosure[]> idxClsHandlers0 = idxClsHandlers;
-
-            IgniteBiInClosure[] cacheClsHandlers = idxClsHandlers0.get(cacheMsg.cacheId());
+            IgniteBiInClosure[] cacheClsHandlers = idxClsHandlers.get(cacheMsg.cacheId());
 
             if (cacheClsHandlers != null)
                 c = cacheClsHandlers[msgIdx];
@@ -1154,14 +1152,12 @@ public class GridCacheIoManager extends GridCacheSharedManagerAdapter
{
         int msgIdx = messageIndex(type);
 
         if (msgIdx != -1) {
-            Map<Integer, IgniteBiInClosure[]> idxClsHandlers0 = idxClsHandlers;
-
-            IgniteBiInClosure[] cacheClsHandlers = idxClsHandlers0.get(cacheId);
+            IgniteBiInClosure[] cacheClsHandlers = idxClsHandlers.get(cacheId);
 
             if (cacheClsHandlers == null) {
                 cacheClsHandlers = new IgniteBiInClosure[GridCacheMessage.MAX_CACHE_MSG_LOOKUP_INDEX];
 
-                idxClsHandlers0.put(cacheId, cacheClsHandlers);
+                idxClsHandlers.put(cacheId, cacheClsHandlers);
             }
 
             if (cacheClsHandlers[msgIdx] != null)
@@ -1170,8 +1166,6 @@ public class GridCacheIoManager extends GridCacheSharedManagerAdapter
{
 
             cacheClsHandlers[msgIdx] = c;
 
-            idxClsHandlers = idxClsHandlers0;
-
             return;
         }
         else {


Mime
View raw message