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 2015/05/06 14:07:04 UTC
[05/36] incubator-ignite git commit: ignite-646
ignite-646
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/9a79e70a
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/9a79e70a
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/9a79e70a
Branch: refs/heads/ignite-695
Commit: 9a79e70a11eec1688968f33f99892b399b94254b
Parents: 03c54d8
Author: avinogradov <av...@gridgain.com>
Authored: Tue Apr 21 17:02:23 2015 +0300
Committer: avinogradov <av...@gridgain.com>
Committed: Tue Apr 21 17:02:23 2015 +0300
----------------------------------------------------------------------
.../internal/processors/cache/GridCacheIoManager.java | 10 ++++++++--
1 file changed, 8 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/9a79e70a/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 0df824f..957f3c8 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
@@ -302,12 +302,12 @@ public class GridCacheIoManager extends GridCacheSharedManagerAdapter {
ctx.io().send(nodeId, res, ctx.ioPolicy());
}
catch (IgniteCheckedException e) {
- U.error(log, "Failed to send get response to node (is node still alive?) [nodeId=" + nodeId +
+ U.error(log, "Failed to send response to node (is node still alive?) [nodeId=" + nodeId +
",res=" + res + ']', e);
}
}
- private void processFailedMessage(UUID nodeId, GridCacheMessage msg) {
+ private void processFailedMessage(UUID nodeId, GridCacheMessage msg) throws IgniteCheckedException{
GridCacheContext ctx = cctx.cacheContext(msg.cacheId());
switch (msg.directType()) {
@@ -322,6 +322,7 @@ public class GridCacheIoManager extends GridCacheSharedManagerAdapter {
}
break;
+
case 40: {
GridNearAtomicUpdateRequest req = (GridNearAtomicUpdateRequest)msg;
@@ -335,6 +336,7 @@ public class GridCacheIoManager extends GridCacheSharedManagerAdapter {
}
break;
+
case 49: {
GridNearGetRequest req = (GridNearGetRequest)msg;
@@ -349,6 +351,10 @@ public class GridCacheIoManager extends GridCacheSharedManagerAdapter {
}
break;
+
+ default:
+ throw new IgniteCheckedException("Failed to send response to node. Unsupported direct type [message="
+ + msg + "]");
}
}