You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sb...@apache.org on 2017/04/06 13:31:33 UTC

[26/50] [abbrv] ignite git commit: IGNITE-4827: Minor bug fix in ServerImpl invariant.

IGNITE-4827: Minor bug fix in ServerImpl invariant.


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

Branch: refs/heads/ignite-2893
Commit: eff3185d790b57118a9eaaa35057d712bc59b3f7
Parents: d449493
Author: tledkov-gridgain <tl...@gridgain.com>
Authored: Mon Apr 3 12:37:45 2017 +0300
Committer: devozerov <vo...@gridgain.com>
Committed: Mon Apr 3 12:37:45 2017 +0300

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


http://git-wip-us.apache.org/repos/asf/ignite/blob/eff3185d/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 f9df356..91baca6 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
@@ -6229,7 +6229,8 @@ class ServerImpl extends TcpDiscoveryImpl {
                                 "[sock=" + sock + ", locNodeId=" + getLocalNodeId() +
                                 ", rmtNodeId=" + clientNodeId + ", msg=" + msg + ']');
                     }
-                    else {
+
+                    if (clientVer != null) {
                         if (msgLog.isDebugEnabled())
                             msgLog.debug("Sending message ack to client [sock=" + sock + ", locNodeId="
                                 + getLocalNodeId() + ", rmtNodeId=" + clientNodeId + ", msg=" + msg + ']');