ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From akuznet...@apache.org
Subject [39/50] [abbrv] incubator-ignite git commit: #Tests: fix GridIoManager
Date Thu, 29 Jan 2015 03:14:14 GMT
#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 <ivasilinets@gridgain.com>
Authored: Wed Jan 28 17:08:42 2015 +0300
Committer: ivasilinets <ivasilinets@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;
         }


Mime
View raw message