You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by ag...@apache.org on 2017/12/20 13:46:38 UTC
ignite git commit: IGNITE-7206 Stop pings if current node is stopping.
Repository: ignite
Updated Branches:
refs/heads/master e70b01d02 -> db7873548
IGNITE-7206 Stop pings if current node is stopping.
Signed-off-by: Andrey Gura <ag...@apache.org>
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/db787354
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/db787354
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/db787354
Branch: refs/heads/master
Commit: db7873548e8b6bc33ce600dcc6e56bbc62729131
Parents: e70b01d
Author: dkarachentsev <dk...@gridgain.com>
Authored: Wed Dec 20 16:40:55 2017 +0300
Committer: Andrey Gura <ag...@apache.org>
Committed: Wed Dec 20 16:40:55 2017 +0300
----------------------------------------------------------------------
.../java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java | 7 +++++++
1 file changed, 7 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/db787354/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 57d2faf..b9f381b 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
@@ -729,6 +729,13 @@ class ServerImpl extends TcpDiscoveryImpl {
break;
else if (!spi.failureDetectionTimeoutEnabled() && reconCnt == spi.getReconnectCount())
break;
+
+ if (spi.isNodeStopping0()) {
+ if (log.isDebugEnabled())
+ log.debug("Stop pinging node, because node is stopping: [rmtNodeId=" + nodeId + ']');
+
+ break;
+ }
}
finally {
U.closeQuiet(sock);