[05/50] incubator-ignite git commit: ignite-646

[sboikov]

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-286
Commit: 9a79e70a11eec1688968f33f99892b399b94254b
Parents: 03c54d8
Author: avinogradov <avinogra...@gridgain.com>
Authored: Tue Apr 21 17:02:23 2015 +0300
Committer: avinogradov <avinogra...@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 + "]");
         }
     }