ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject ignite git commit: debug
Date Wed, 26 Jul 2017 16:16:59 GMT
Repository: ignite
Updated Branches:
  refs/heads/ignite-5569-debug e40e79928 -> db1ef231b


debug


Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/db1ef231
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/db1ef231
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/db1ef231

Branch: refs/heads/ignite-5569-debug
Commit: db1ef231b72473eae3f0bdb1d8243d3522706b80
Parents: e40e799
Author: sboikov <sboikov@gridgain.com>
Authored: Wed Jul 26 19:16:53 2017 +0300
Committer: sboikov <sboikov@gridgain.com>
Committed: Wed Jul 26 19:16:53 2017 +0300

----------------------------------------------------------------------
 .../java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java  | 7 +++++++
 1 file changed, 7 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/db1ef231/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 3ea144d..674fd42 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
@@ -3080,6 +3080,8 @@ class ServerImpl extends TcpDiscoveryImpl {
                                 if (latencyCheck && log.isInfoEnabled())
                                     log.info("Latency check message has been written to socket:
" + msg.id());
 
+                                long s = 0;
+
                                 if (msg instanceof TcpDiscoveryNodeAddedMessage) {
                                     ByteArrayOutputStream byteOut = new ByteArrayOutputStream();
 
@@ -3088,10 +3090,15 @@ class ServerImpl extends TcpDiscoveryImpl {
                                     log.info("Send TcpDiscoveryNodeAddedMessage [size=" +
byteOut.size() +
                                         ", node=" + ((TcpDiscoveryNodeAddedMessage)msg).node().id()
+
                                         ", next=" + next.id() + ']');
+
+                                    s = U.currentTimeMillis();
                                 }
 
                                 spi.writeToSocket(sock, out, msg, timeoutHelper.nextTimeoutChunk(spi.getSocketTimeout()));
 
+                                if (msg instanceof TcpDiscoveryNodeAddedMessage)
+                                    log.info("Sent TcpDiscoveryNodeAddedMessage [time=" +
(U.currentTimeMillis() - s) + ']');
+
                                 if (msg instanceof TcpDiscoveryNodeAddFinishedMessage) {
                                     TcpDiscoveryNodeAddFinishedMessage msg0 = (TcpDiscoveryNodeAddFinishedMessage)msg;
 


Mime
View raw message