This is an automated email from the ASF dual-hosted git repository.

ibessonov pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite.git


The following commit(s) were added to refs/heads/master by this push:
     new 626168e  IGNITE-14729 Fix race condition in ClientImpl (#9102)
626168e is described below

commit 626168e11e0ec70abb4539bb897aabeb07b39698
Author: Semyon Danilov <[email protected]>
AuthorDate: Tue May 18 15:27:52 2021 +0300

    IGNITE-14729 Fix race condition in ClientImpl (#9102)
---
 .../src/main/java/org/apache/ignite/spi/discovery/tcp/ClientImpl.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

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 794382de..208e2c0 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
@@ -2330,12 +2330,12 @@ class ClientImpl extends TcpDiscoveryImpl {
 
                     Collection<ClusterNode> nodes = 
updateTopologyHistory(topVer, msg);
 
-                    notifyDiscovery(EVT_NODE_JOINED, topVer, locNode, nodes, 
msg.spanContainer());
-
                     boolean disconnected = disconnected();
 
                     state = CONNECTED;
 
+                    notifyDiscovery(EVT_NODE_JOINED, topVer, locNode, nodes, 
msg.spanContainer());
+
                     if (disconnected) {
                         notifyDiscovery(EVT_CLIENT_NODE_RECONNECTED, topVer, 
locNode, nodes, null);
 

Reply via email to