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/15 08:45:02 UTC
incubator-ignite git commit: # IGNITE-709 Bug fix: don't brake
connection is reconnect successfull.
Repository: incubator-ignite
Updated Branches:
refs/heads/ignite-709_2 98743efe6 -> 7099c560b
# IGNITE-709 Bug fix: don't brake connection is reconnect successfull.
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/7099c560
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/7099c560
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/7099c560
Branch: refs/heads/ignite-709_2
Commit: 7099c560b9fbb2f9029548fc0ea8830a18d37fc9
Parents: 98743ef
Author: sevdokimov <se...@jetbrains.com>
Authored: Fri May 15 09:44:50 2015 +0300
Committer: sevdokimov <se...@jetbrains.com>
Committed: Fri May 15 09:44:50 2015 +0300
----------------------------------------------------------------------
.../apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpi.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7099c560/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpi.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpi.java b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpi.java
index 9678b87..6514b6f 100644
--- a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpi.java
+++ b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpi.java
@@ -1086,7 +1086,8 @@ public class TcpClientDiscoverySpi extends TcpDiscoverySpiAdapter implements Tcp
timer.schedule(new TimerTask() {
@Override public void run() {
- reconnector.cancel();
+ if (reconnector.isAlive())
+ reconnector.cancel();
}
}, netTimeout);
}