#Tests: fix GridIoManager
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/99961407 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/99961407 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/99961407 Branch: refs/heads/ignite-102 Commit: 999614076c45dbe69d7d2ccb2eff30bcab345365 Parents: 099b6b3 Author: ivasilinets <ivasilin...@gridgain.com> Authored: Wed Jan 28 17:08:42 2015 +0300 Committer: ivasilinets <ivasilin...@gridgain.com> Committed: Wed Jan 28 17:08:42 2015 +0300 ---------------------------------------------------------------------- .../ignite/internal/managers/communication/GridIoManager.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/99961407/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java b/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java index 8ef4853..6996e6f 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java @@ -718,7 +718,8 @@ public class GridIoManager extends GridManagerAdapter<CommunicationSpi<Serializa if (set.reserved()) { // Set is reserved which means that it is currently processed by worker thread. - msgC.run(); + if (msgC != null) + msgC.run(); return; }
