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 2017/06/20 06:00:44 UTC
[42/50] ignite git commit: Do not need process missed handler error
on stopping node.
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 <sb...@gridgain.com>
Authored: Mon Jun 19 17:52:08 2017 +0300
Committer: sboikov <sb...@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);
}