ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [42/50] ignite git commit: Do not need process missed handler error on stopping node.
Date Tue, 20 Jun 2017 06:00:44 GMT
Do not need process missed handler error on stopping node.


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

Branch: refs/heads/ignite-2.1.2-exchange
Commit: f6f5e49413072a74c3712f3fba03946807ff58c7
Parents: 6143bc9
Author: sboikov <sboikov@gridgain.com>
Authored: Mon Jun 19 17:52:08 2017 +0300
Committer: sboikov <sboikov@gridgain.com>
Committed: Mon Jun 19 17:52:08 2017 +0300

----------------------------------------------------------------------
 .../processors/cache/GridCacheIoManager.java    | 20 +++++++++++---------
 1 file changed, 11 insertions(+), 9 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/f6f5e494/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 2be3df4..010723d 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
@@ -25,7 +25,6 @@ import java.util.Iterator;
 import java.util.List;
 import java.util.Map;
 import java.util.UUID;
-import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.ConcurrentMap;
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicLong;
@@ -355,18 +354,21 @@ public class GridCacheIoManager extends GridCacheSharedManagerAdapter
{
                     if (log.isDebugEnabled())
                         log.debug(msg0.toString());
                 }
-                else
+                else {
                     U.error(log, msg0.toString());
 
-            try {
-                cacheMsg.onClassError(new IgniteCheckedException("Failed to find message
handler for message: " + cacheMsg));
+                    try {
+                        cacheMsg.onClassError(new IgniteCheckedException("Failed to find
message handler for message: " + cacheMsg));
 
-                processFailedMessage(nodeId, cacheMsg, c);
+                        processFailedMessage(nodeId, cacheMsg, c);
+                    }
+                    catch (Exception e) {
+                        U.error(log, "Failed to process failed message: " + e, e);
+                    }
+                }
+
+                return;
             }
-            catch (Exception e) {
-                U.error(log, "Failed to process failed message: " + e, e);
-            }return;
-        }
 
             onMessage0(nodeId, cacheMsg, c);
         }


Mime
View raw message