Repository: ignite Updated Branches: refs/heads/ignite-1758 c3962c443 -> 94119c29e
ignite-1758 debug Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/94119c29 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/94119c29 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/94119c29 Branch: refs/heads/ignite-1758 Commit: 94119c29ed74895c07bcdf450e235a8e6a9f71ae Parents: c3962c4 Author: sboikov <[email protected]> Authored: Thu Nov 5 14:45:34 2015 +0300 Committer: sboikov <[email protected]> Committed: Thu Nov 5 14:45:34 2015 +0300 ---------------------------------------------------------------------- .../java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/94119c29/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 0cc3546..2c1cfac 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 @@ -2200,7 +2200,7 @@ class ServerImpl extends TcpDiscoveryImpl { e.printStackTrace(); synchronized (System.out) { - System.out.println("Error: " + e + " " + Thread.currentThread().getName()); + System.out.println("Error: " + e + " " + Thread.currentThread().getName() + ", msg=" + msg); debugLog(msg, "Error: " + e); @@ -3322,7 +3322,7 @@ class ServerImpl extends TcpDiscoveryImpl { TcpDiscoveryNodeAddFinishedMessage addFinishMsg = new TcpDiscoveryNodeAddFinishedMessage(locNodeId, node.id()); - debugLog(addFinishMsg, "Created finish message: " + addFinishMsg); + debugLog(addFinishMsg, "Created finish message: " + addFinishMsg + ", ring=" + ring + ']'); if (node.isClient()) { addFinishMsg.clientDiscoData(msg.oldNodesDiscoveryData()); @@ -3564,6 +3564,8 @@ class ServerImpl extends TcpDiscoveryImpl { log.debug("Discarding node add finished message since node is not found " + "[msg=" + msg + ']'); + debugLog(msg, "Discarding node add finished message " + msg + ", ring=" + ring + ']'); + return; }
