Repository: incubator-ignite Updated Branches: refs/heads/ignite-709_2 7449c6056 -> 0ac6a73a4
# IGNITE-709 Remove test code. Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/16694d3b Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/16694d3b Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/16694d3b Branch: refs/heads/ignite-709_2 Commit: 16694d3b2dd2b38ff8e63392de00f05aaaba284f Parents: 7449c60 Author: sevdokimov <sevdoki...@gridgain.com> Authored: Thu May 7 17:08:40 2015 +0300 Committer: sevdokimov <sevdoki...@gridgain.com> Committed: Thu May 7 17:08:40 2015 +0300 ---------------------------------------------------------------------- .../spi/discovery/tcp/TcpClientDiscoverySpi.java | 13 ------------- 1 file changed, 13 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/16694d3b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpi.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpi.java b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpi.java index def9568..c319f9e 100644 --- a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpi.java +++ b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpi.java @@ -466,14 +466,10 @@ public class TcpClientDiscoverySpi extends TcpDiscoverySpiAdapter implements Tcp msg.client(true); - System.out.println("TcpClientDiscoverySpi.SocketReader: join write: " + msg); - writeToSocket(sock, msg); int res = readReceipt(sock, ackTimeout); - System.out.println("TcpClientDiscoverySpi.SocketReader: join res: " + (res == RES_OK ? "OK" : "" + res)); - switch (res) { case RES_OK: return sock; @@ -671,9 +667,6 @@ public class TcpClientDiscoverySpi extends TcpDiscoverySpiAdapter implements Tcp msg.senderNodeId(rmtNodeId); - if (!(msg instanceof TcpDiscoveryHeartbeatMessage)) - System.out.println("TcpClientDiscoverySpi.SocketReader: read: " + msg); - if (log.isDebugEnabled()) log.debug("Message has been received: " + msg); @@ -784,9 +777,6 @@ public class TcpClientDiscoverySpi extends TcpDiscoverySpiAdapter implements Tcp } try { - if (!(msg instanceof TcpDiscoveryHeartbeatMessage)) - System.out.println("TcpClientDiscoverySpi.SocketReader: write: " + msg); - writeToSocket(sock, msg); msg = null; @@ -934,9 +924,6 @@ public class TcpClientDiscoverySpi extends TcpDiscoverySpiAdapter implements Tcp while (true) { Object msg = queue.take(); - if (!(msg instanceof TcpDiscoveryHeartbeatMessage)) - System.out.println("TcpClientDiscoverySpi.MessageWorker: process: " + msg); - if (msg == JOIN_TIMEOUT) { if (joinLatch.getCount() > 0) { joinErr = new IgniteSpiException("Join process timed out [sock=" + sock +
