Repository: ignite Updated Branches: refs/heads/ignite-5569-debug 4a86a24cf -> cc9204227
debug Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/649085b2 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/649085b2 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/649085b2 Branch: refs/heads/ignite-5569-debug Commit: 649085b2893877bbb38687246b7a1616a325a195 Parents: b8fee2a Author: sboikov <[email protected]> Authored: Tue Jul 25 16:45:56 2017 +0300 Committer: sboikov <[email protected]> Committed: Tue Jul 25 16:45:56 2017 +0300 ---------------------------------------------------------------------- .../ignite/spi/discovery/tcp/ServerImpl.java | 28 ++++++++++++++++++-- 1 file changed, 26 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/649085b2/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 85e2666..be19828 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 @@ -2790,7 +2790,8 @@ class ServerImpl extends TcpDiscoveryImpl { log.info("New next node [newNext=" + newNext.id() + ", formerNext=" + (next != null ? next.id() : null) + - ", failedNodes=" + failedNodes + ']'); + ", failedNodes=" + failedNodes + + ", msg=" + msg + ']'); if (debugMode) debugLog(msg, "New next node [newNext=" + newNext + ", formerNext=" + next + @@ -2857,6 +2858,8 @@ class ServerImpl extends TcpDiscoveryImpl { if (log.isDebugEnabled()) log.debug("Handshake response from local node: " + res); + log.info("Handshake response from local node: " + res); + U.closeQuiet(sock); sock = null; @@ -5840,6 +5843,8 @@ class ServerImpl extends TcpDiscoveryImpl { // Handshake. TcpDiscoveryHandshakeRequest req = (TcpDiscoveryHandshakeRequest)msg; + log.info("Read handshake request [sock=" + sock + ", req=" + req + ']'); + srvSock = !req.client(); UUID nodeId = req.creatorNodeId(); @@ -5862,6 +5867,8 @@ class ServerImpl extends TcpDiscoveryImpl { if (log.isDebugEnabled()) log.debug("Handshake request from local node: " + req); + log.info("Handshake request from local node: " + req); + return; } @@ -5910,6 +5917,9 @@ class ServerImpl extends TcpDiscoveryImpl { log.debug("Initialized connection with remote node [nodeId=" + nodeId + ", client=" + req.client() + ']'); + log.info("Initialized connection with remote node [nodeId=" + nodeId + + ", client=" + req.client() + ']'); + if (debugMode) { debugLog(msg, "Initialized connection with remote node [nodeId=" + nodeId + ", client=" + req.client() + ']'); @@ -5919,6 +5929,8 @@ class ServerImpl extends TcpDiscoveryImpl { if (log.isDebugEnabled()) U.error(log, "Caught exception on handshake [err=" + e +", sock=" + sock + ']', e); + U.error(log, "Caught exception on handshake [err=" + e +", sock=" + sock + ']', e); + if (X.hasCause(e, SSLException.class) && spi.isSslEnabled() && !spi.isNodeStopping0()) LT.warn(log, "Failed to initialize connection " + "(missing SSL configuration on remote node?) " + @@ -5946,6 +5958,8 @@ class ServerImpl extends TcpDiscoveryImpl { if (log.isDebugEnabled()) U.error(log, "Caught exception on handshake [err=" + e +", sock=" + sock + ']', e); + U.error(log, "Caught exception on handshake [err=" + e +", sock=" + sock + ']', e); + onException("Caught exception on handshake [err=" + e +", sock=" + sock + ']', e); if (e.hasCause(SocketTimeoutException.class)) @@ -6001,9 +6015,13 @@ class ServerImpl extends TcpDiscoveryImpl { if (clientMsgWrk != null && ok) continue; - else + else { // Direct join request - no need to handle this socket anymore. + log.info("Received join request, stop handle connection [sock=" + sock + + ", msg=" + msg + ']'); + break; + } } } else if (msg instanceof TcpDiscoveryClientReconnectMessage) { @@ -6186,6 +6204,9 @@ class ServerImpl extends TcpDiscoveryImpl { U.error(log, "Caught exception on message read [sock=" + sock + ", locNodeId=" + locNodeId + ", rmtNodeId=" + nodeId + ']', e); + U.error(log, "Caught exception on message read [sock=" + sock + + ", locNodeId=" + locNodeId + ", rmtNodeId=" + nodeId + ']', e); + onException("Caught exception on message read [sock=" + sock + ", locNodeId=" + locNodeId + ", rmtNodeId=" + nodeId + ']', e); @@ -6213,6 +6234,9 @@ class ServerImpl extends TcpDiscoveryImpl { U.error(log, "Caught exception on message read [sock=" + sock + ", locNodeId=" + locNodeId + ", rmtNodeId=" + nodeId + ']', e); + U.error(log, "Caught exception on message read [sock=" + sock + ", locNodeId=" + locNodeId + + ", rmtNodeId=" + nodeId + ']', e); + if (isInterrupted() || sock.isClosed()) return;
