You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by vk...@apache.org on 2015/08/11 09:27:53 UTC

[44/50] incubator-ignite git commit: IGNITE-104 - Ordered ATOMIC updates

IGNITE-104 - Ordered ATOMIC updates


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

Branch: refs/heads/ignite-426
Commit: 2a8b548955581857b53c312f8ce9d1bfa1c853a7
Parents: 99e998a
Author: Valentin Kulichenko <vk...@gridgain.com>
Authored: Fri Aug 7 15:14:12 2015 -0700
Committer: Valentin Kulichenko <vk...@gridgain.com>
Committed: Fri Aug 7 15:14:12 2015 -0700

----------------------------------------------------------------------
 .../ignite/internal/processors/cache/GridCacheIoManager.java     | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/2a8b5489/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 490a5d8..7e7042c 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
@@ -292,6 +292,8 @@ public class GridCacheIoManager extends GridCacheSharedManagerAdapter {
 
             if (e instanceof Error)
                 throw (Error)e;
+            else if (e instanceof RuntimeException)
+                throw (RuntimeException)e;
         }
         finally {
             if (depEnabled)
@@ -541,7 +543,7 @@ public class GridCacheIoManager extends GridCacheSharedManagerAdapter {
         catch (Throwable e) {
             U.error(log, "Failed processing message [senderId=" + nodeId + ", msg=" + msg + ']', e);
 
-            if (e instanceof Error)
+            if (e instanceof Error || e instanceof RuntimeException)
                 throw e;
         }
         finally {