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);