You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by vo...@apache.org on 2016/03/09 10:28:03 UTC
[48/50] [abbrv] ignite git commit: Added warning prineted out when
client is reconnected with new ID
Added warning prineted out when client is reconnected with new ID
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/cd203a7b
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/cd203a7b
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/cd203a7b
Branch: refs/heads/ignite-1786
Commit: cd203a7bee49a1d37cd43e7d13150f275d0fed3a
Parents: a5acf5d
Author: Valentin Kulichenko <va...@gmail.com>
Authored: Mon Mar 7 15:20:29 2016 -0800
Committer: Valentin Kulichenko <va...@gmail.com>
Committed: Mon Mar 7 15:20:29 2016 -0800
----------------------------------------------------------------------
.../apache/ignite/spi/discovery/tcp/ClientImpl.java | 13 ++++++++++---
1 file changed, 10 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/cd203a7b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ClientImpl.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ClientImpl.java b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ClientImpl.java
index 65b94ca..950c680 100644
--- a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ClientImpl.java
+++ b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ClientImpl.java
@@ -1182,7 +1182,7 @@ class ClientImpl extends TcpDiscoveryImpl {
}
else
U.error(log, "Failed to reconnect to cluster (consider increasing 'networkTimeout'" +
- " configuration property) [networkTimeout=" + spi.netTimeout + ']');
+ " configuration property) [networkTimeout=" + spi.netTimeout + ']');
return;
}
@@ -1691,12 +1691,19 @@ class ClientImpl extends TcpDiscoveryImpl {
state = CONNECTED;
- if (disconnected)
+ if (disconnected) {
notifyDiscovery(EVT_CLIENT_NODE_RECONNECTED, topVer, locNode, nodes);
+
+ U.quietAndWarn(log, "Client node was reconnected after it was already considered " +
+ "failed by the server topology (this could happen after all servers restarted or due " +
+ "to a long network outage between the client and servers). All continuous queries and " +
+ "remote event listeners created by this client will be unsubscribed, consider " +
+ "listening to EVT_CLIENT_NODE_RECONNECTED event to restore them.");
+ }
else
spi.stats.onJoinFinished();
- joinErr.set(null);;
+ joinErr.set(null);
joinLatch.countDown();
}