ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject incubator-ignite git commit: # add logging
Date Wed, 24 Jun 2015 15:45:11 GMT
Repository: incubator-ignite
Updated Branches:
  refs/heads/ignite-yardstick-client 2eeac66cf -> c97f013cc


# add logging


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

Branch: refs/heads/ignite-yardstick-client
Commit: c97f013cc635a27279db0c69157892acd1fc2a6c
Parents: 2eeac66
Author: sboikov <sboikov@gridgain.com>
Authored: Wed Jun 24 18:45:02 2015 +0300
Committer: sboikov <sboikov@gridgain.com>
Committed: Wed Jun 24 18:45:02 2015 +0300

----------------------------------------------------------------------
 .../apache/ignite/spi/discovery/tcp/ClientImpl.java    | 13 ++++++++-----
 1 file changed, 8 insertions(+), 5 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c97f013c/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ClientImpl.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ClientImpl.java
b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ClientImpl.java
index a806d82..4ba20dc 100644
--- a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ClientImpl.java
+++ b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ClientImpl.java
@@ -404,7 +404,7 @@ class ClientImpl extends TcpDiscoveryImpl {
 
                 T2<Socket, Integer> sockAndRes = sendJoinRequest(recon, addr);
 
-                log.info("sendJoinRequest :" + addr);
+                log.info("sentJoinRequest :" + addr + ", res=" + sockAndRes);
 
                 if (sockAndRes == null) {
                     it.remove();
@@ -474,6 +474,9 @@ class ClientImpl extends TcpDiscoveryImpl {
             try {
                 long tstamp = U.currentTimeMillis();
 
+                log.info("Open socket [addr=" + addr + ", reconnect=" + recon +
+                    ", locNodeId=" + getLocalNodeId() + ", ackTimeout=" + ackTimeout0 +']');
+
                 sock = spi.openSocket(addr);
 
                 openSock = true;
@@ -507,8 +510,8 @@ class ClientImpl extends TcpDiscoveryImpl {
 
                 spi.stats.onMessageSent(msg, U.currentTimeMillis() - tstamp);
 
-                if (log.isDebugEnabled())
-                    log.debug("Message has been sent to address [msg=" + msg + ", addr="
+ addr +
+                //if (log.isDebugEnabled())
+                log.info("Message has been sent to address [msg=" + msg + ", addr=" + addr
+
                         ", rmtNodeId=" + rmtNodeId + ']');
 
                 return new T2<>(sock, spi.readReceipt(sock, ackTimeout0));
@@ -516,7 +519,7 @@ class ClientImpl extends TcpDiscoveryImpl {
             catch (IOException | IgniteCheckedException e) {
                 U.closeQuiet(sock);
 
-                if (log.isDebugEnabled())
+                //if (log.isDebugEnabled())
                     log.error("Exception on joining: " + e.getMessage(), e);
 
                 onException("Exception on joining: " + e.getMessage(), e);
@@ -763,7 +766,7 @@ class ClientImpl extends TcpDiscoveryImpl {
                             msg = spi.marsh.unmarshal(in, U.gridClassLoader());
                         }
                         catch (IgniteCheckedException e) {
-                            if (log.isDebugEnabled())
+                            //if (log.isDebugEnabled())
                                 U.error(log, "Failed to read message [sock=" + sock + ",
" +
                                     "locNodeId=" + getLocalNodeId() + ", rmtNodeId=" + rmtNodeId
+ ']', e);
 


Mime
View raw message