You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by se...@apache.org on 2015/05/02 16:54:08 UTC
[3/3] incubator-ignite git commit: # IGNITE-709 Fix
TcpClientDiscoverySelfTest#testClientNodeLeaveOneServer().
# 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 <se...@jetbrains.com>
Authored: Sat May 2 17:53:56 2015 +0300
Committer: sevdokimov <se...@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<>();