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 <sboi...@gridgain.com> Authored: Wed Jun 24 18:45:02 2015 +0300 Committer: sboikov <sboi...@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);
