ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [11/50] incubator-ignite git commit: ignite-646
Date Thu, 23 Apr 2015 16:12:51 GMT
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-646
Commit: 9a79e70a11eec1688968f33f99892b399b94254b
Parents: 03c54d8
Author: avinogradov <avinogradov@gridgain.com>
Authored: Tue Apr 21 17:02:23 2015 +0300
Committer: avinogradov <avinogradov@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 + "]");
         }
     }
 


Mime
View raw message