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-5566
Date Thu, 22 Jun 2017 09:15:14 GMT
Repository: ignite
Updated Branches:
  refs/heads/ignite-5566 097ab4d60 -> 060feac70


ignite-5566


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

Branch: refs/heads/ignite-5566
Commit: 060feac7009dc30dea5e6aae05a75fc2006ecb9f
Parents: 097ab4d
Author: sboikov <sboikov@gridgain.com>
Authored: Thu Jun 22 12:15:07 2017 +0300
Committer: sboikov <sboikov@gridgain.com>
Committed: Thu Jun 22 12:15:07 2017 +0300

----------------------------------------------------------------------
 .../spi/communication/tcp/TcpCommunicationSpi.java    | 14 +++-----------
 1 file changed, 3 insertions(+), 11 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/060feac7/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java
b/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java
index 11c2418..9fc69b7 100755
--- a/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java
+++ b/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java
@@ -2332,6 +2332,9 @@ public class TcpCommunicationSpi extends IgniteSpiAdapter implements
Communicati
 
         unregisterMBean();
 
+        if (nioSrvr != null)
+            nioSrvr.stop();
+
         U.interrupt(commWorker);
         U.join(commWorker, log);
 
@@ -2373,17 +2376,6 @@ public class TcpCommunicationSpi extends IgniteSpiAdapter implements
Communicati
         if (connectGate != null)
             connectGate.stopped();
 
-        if (nioSrvr != null)
-            nioSrvr.stop();
-
-        // Force closing.
-        for (GridCommunicationClient[] clients0 : clients.values()) {
-            for (GridCommunicationClient client : clients0) {
-                if (client != null)
-                    client.forceClose();
-            }
-        }
-
         getSpiContext().deregisterPorts();
 
         getSpiContext().removeLocalEventListener(discoLsnr);


Mime
View raw message