ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From vkuliche...@apache.org
Subject [44/50] incubator-ignite git commit: IGNITE-104 - Ordered ATOMIC updates
Date Tue, 11 Aug 2015 07:27:53 GMT
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 <vkulichenko@gridgain.com>
Authored: Fri Aug 7 15:14:12 2015 -0700
Committer: Valentin Kulichenko <vkulichenko@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 {


Mime
View raw message