ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject ignite git commit: ignite-1.5 Properly handle duplicated job responses in GridTaskWorker.onResponse.
Date Thu, 17 Dec 2015 13:03:53 GMT
Repository: ignite
Updated Branches:
  refs/heads/ignite-1537 e63fd3c91 -> 0cb04ba7d


ignite-1.5 Properly handle duplicated job responses in GridTaskWorker.onResponse.


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

Branch: refs/heads/ignite-1537
Commit: 0cb04ba7dd5e26ff1f2cee3a5f91e6acb651ee51
Parents: e63fd3c
Author: sboikov <sboikov@gridgain.com>
Authored: Thu Dec 17 16:03:44 2015 +0300
Committer: sboikov <sboikov@gridgain.com>
Committed: Thu Dec 17 16:03:44 2015 +0300

----------------------------------------------------------------------
 .../org/apache/ignite/internal/util/nio/GridNioServer.java     | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/0cb04ba7/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioServer.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioServer.java
b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioServer.java
index b0ce2f2..be28c30 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioServer.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioServer.java
@@ -425,10 +425,10 @@ public class GridNioServer<T> {
 
         int msgCnt = sys ? ses.offerSystemFuture(fut) : ses.offerFuture(fut);
 
-        IgniteInClosure<IgniteException> ackClosure;
+        IgniteInClosure<IgniteException> ackC;
 
-        if (!sys && (ackClosure = ses.removeMeta(ACK_CLOSURE.ordinal())) != null)
-            fut.ackClosure(ackClosure);
+        if (!sys && (ackC = ses.removeMeta(ACK_CLOSURE.ordinal())) != null)
+            fut.ackClosure(ackC);
 
         if (ses.closed()) {
             if (ses.removeFuture(fut))


Mime
View raw message