Repository: ignite
Updated Branches:
  refs/heads/ignite-1758 7f150cc7f -> 1d87e9360


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/1d87e936
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/1d87e936
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/1d87e936

Branch: refs/heads/ignite-1758
Commit: 1d87e93606949708179cd10e30e86842d4b818c9
Parents: 7f150cc
Author: sboikov <[email protected]>
Authored: Thu Nov 5 10:50:56 2015 +0300
Committer: sboikov <[email protected]>
Committed: Thu Nov 5 10:50:56 2015 +0300

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


http://git-wip-us.apache.org/repos/asf/ignite/blob/1d87e936/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoveryImpl.java
----------------------------------------------------------------------
diff --git 
a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoveryImpl.java
 
b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoveryImpl.java
index 2a1ee46..40a4536 100644
--- 
a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoveryImpl.java
+++ 
b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoveryImpl.java
@@ -39,6 +39,7 @@ import 
org.apache.ignite.spi.discovery.DiscoverySpiCustomMessage;
 import org.apache.ignite.spi.discovery.tcp.internal.TcpDiscoveryNode;
 import 
org.apache.ignite.spi.discovery.tcp.messages.TcpDiscoveryAbstractMessage;
 import 
org.apache.ignite.spi.discovery.tcp.messages.TcpDiscoveryCustomEventMessage;
+import org.apache.ignite.spi.discovery.tcp.messages.TcpDiscoveryDiscardMessage;
 import org.jetbrains.annotations.Nullable;
 
 /**
@@ -67,7 +68,7 @@ abstract class TcpDiscoveryImpl {
     protected boolean debugMode = true;
 
     /** Debug messages history. */
-    private int debugMsgHist = 100 * 1024;
+    private int debugMsgHist = 20 * 1024;
 
     /** Received messages. */
     @SuppressWarnings("FieldAccessedSynchronizedAndUnsynchronized")
@@ -106,7 +107,7 @@ abstract class TcpDiscoveryImpl {
     protected void debugLog(TcpDiscoveryAbstractMessage discoMsg, String msg) {
         assert debugMode;
 
-        if (discoMsg != null && discoMsg instanceof 
TcpDiscoveryCustomEventMessage)
+        if ((discoMsg instanceof TcpDiscoveryCustomEventMessage) || (discoMsg 
instanceof TcpDiscoveryDiscardMessage))
             return;
 
         String msg0 = new SimpleDateFormat("[HH:mm:ss,SSS]").format(new 
Date(System.currentTimeMillis())) +

Reply via email to