ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [39/50] [abbrv] ignite git commit: ignite-3054 - Fix closuing server channel
Date Mon, 24 Apr 2017 15:04:02 GMT
ignite-3054 - Fix closuing server channel


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

Branch: refs/heads/ignite-3054
Commit: 698728bf644411af068fdbab61b162cbd0bb7adc
Parents: a4dea11
Author: dkarachentsev <dkarachentsev@gridgain.com>
Authored: Thu Dec 15 13:11:43 2016 +0300
Committer: dkarachentsev <dkarachentsev@gridgain.com>
Committed: Thu Dec 15 13:11:43 2016 +0300

----------------------------------------------------------------------
 .../java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java   | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/698728bf/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java
b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java
index 3980932..8af1e91 100644
--- a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java
+++ b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java
@@ -5614,10 +5614,10 @@ class ServerImpl extends TcpDiscoveryImpl {
                     onException("Failed to bind to local port. " +
                         "[port=" + port + ", localHost=" + spi.locHost + ']', e);
                 }
-            }
 
-            // If free port wasn't found.
-            U.closeQuiet(srvCh);
+                // If free port wasn't found.
+                U.closeQuiet(srvCh);
+            }
 
             throw new IgniteSpiException("Failed to bind TCP server socket (possibly all
ports in range " +
                 "are in use) [firstPort=" + spi.locPort + ", lastPort=" + lastPort +


Mime
View raw message