Repository: ignite Updated Branches: refs/heads/ignite-comm-balance 51e9bf887 -> 21805aef8
conn Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/dbfd6ead Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/dbfd6ead Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/dbfd6ead Branch: refs/heads/ignite-comm-balance Commit: dbfd6eadfebad98d72fcc801e98ad358d0327c12 Parents: 8d21741 Author: sboikov <sboi...@gridgain.com> Authored: Thu Sep 22 17:39:07 2016 +0300 Committer: sboikov <sboi...@gridgain.com> Committed: Thu Sep 22 17:39:07 2016 +0300 ---------------------------------------------------------------------- .../ignite/spi/communication/tcp/TcpCommunicationSpi.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/dbfd6ead/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 784b081..92022df 100644 --- 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 @@ -44,7 +44,6 @@ import java.util.concurrent.BlockingQueue; import java.util.concurrent.ConcurrentMap; import java.util.concurrent.CountDownLatch; import java.util.concurrent.LinkedBlockingQueue; -import java.util.concurrent.ThreadLocalRandom; import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicBoolean; import java.util.concurrent.atomic.AtomicInteger; @@ -3110,8 +3109,8 @@ public class TcpCommunicationSpi extends IgniteSpiAdapter rcvCnt = buf.getLong(1); } - // if (log.isDebugEnabled()) - log.info("Received handshake message [rmtNode=" + rmtNodeId + ", rcvCnt=" + rcvCnt + ']'); + if (log.isDebugEnabled()) + log.debug("Received handshake message [rmtNode=" + rmtNodeId + ", rcvCnt=" + rcvCnt + ']'); if (rcvCnt == -1) { if (log.isDebugEnabled())
