ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From se...@apache.org
Subject [43/50] incubator-ignite git commit: sp-3
Date Wed, 01 Apr 2015 15:23:25 GMT
sp-3


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

Branch: refs/heads/ignite-gg-10002
Commit: 39cfcbdf68a20aad45fd8f5802f2f1d78a16e6ea
Parents: 091369c
Author: Yakov Zhdanov <yzhdanov@gridgain.com>
Authored: Wed Apr 1 16:26:10 2015 +0300
Committer: Yakov Zhdanov <yzhdanov@gridgain.com>
Committed: Wed Apr 1 16:26:10 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/39cfcbdf/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 02d373c..74a070f 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
@@ -4695,7 +4695,7 @@ public class TcpDiscoverySpi extends TcpDiscoverySpiAdapter implements
TcpDiscov
 
                     // Ping.
                     if (msg instanceof TcpDiscoveryPingRequest) {
-                        if (!getSpiContext().isStopping()) {
+                        if (ctxInitLatch.getCount() > 0 || !getSpiContext().isStopping())
{
                             TcpDiscoveryPingRequest req = (TcpDiscoveryPingRequest)msg;
 
                             TcpDiscoveryPingResponse res = new TcpDiscoveryPingResponse(locNodeId);


Mime
View raw message