ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From vkuliche...@apache.org
Subject ignite git commit: Added warning prineted out when client is reconnected with new ID
Date Mon, 07 Mar 2016 23:20:55 GMT
Repository: ignite
Updated Branches:
  refs/heads/master a5acf5d71 -> cd203a7be


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/master
Commit: cd203a7bee49a1d37cd43e7d13150f275d0fed3a
Parents: a5acf5d
Author: Valentin Kulichenko <valentin.kulichenko@gmail.com>
Authored: Mon Mar 7 15:20:29 2016 -0800
Committer: Valentin Kulichenko <valentin.kulichenko@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();
                 }


Mime
View raw message