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 <[email protected]> Authored: Mon Mar 7 15:20:29 2016 -0800 Committer: Valentin Kulichenko <[email protected]> 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(); }
