# IGNITE-709 Fix TcpClientDiscoverySelfTest#testClientNodeLeaveOneServer().


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

Branch: refs/heads/ignite-709_2
Commit: 4903dcec4270eccf2756ba4e693b1484f796e3d4
Parents: 87cb5ce
Author: sevdokimov <sergey.evdoki...@jetbrains.com>
Authored: Sat May 2 17:53:56 2015 +0300
Committer: sevdokimov <sergey.evdoki...@jetbrains.com>
Committed: Sat May 2 17:53:56 2015 +0300

----------------------------------------------------------------------
 .../java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4903dcec/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java
----------------------------------------------------------------------
diff --git 
a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java
 
b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java
index ba67ca7..eaf0857 100644
--- 
a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java
+++ 
b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java
@@ -1167,7 +1167,7 @@ public class TcpDiscoverySpi extends 
TcpDiscoverySpiAdapter implements TcpDiscov
         UUID locNodeId = getLocalNodeId();
 
         if (F.contains(locNodeAddrs, addr))
-            return F.t(getLocalNodeId(), false);
+            return F.t(getLocalNodeId(), clientNodeId != null && 
clientMsgWorkers.containsKey(clientNodeId));
 
         GridFutureAdapter<IgniteBiTuple<UUID, Boolean>> fut = new 
GridFutureAdapter<>();
 

Reply via email to