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 <vkuliche...@gridgain.com> Authored: Fri Aug 7 15:14:12 2015 -0700 Committer: Valentin Kulichenko <vkuliche...@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 {
