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

av 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 00060b18443 IGNITE-27708 Update ClientImpl#sendJoinRequest (#12688)
00060b18443 is described below

commit 00060b1844391acc202ba91a26e88c1ab831a3af
Author: Aleksandr Chesnokov <[email protected]>
AuthorDate: Fri Feb 6 14:18:06 2026 +0300

    IGNITE-27708 Update ClientImpl#sendJoinRequest (#12688)
---
 .../src/main/java/org/apache/ignite/spi/discovery/tcp/ClientImpl.java | 4 ++++
 1 file changed, 4 insertions(+)

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 151c0857ce4..9e1714867d2 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
@@ -728,6 +728,8 @@ class ClientImpl extends TcpDiscoveryImpl {
 
                 sock = spi.openSocket(addr, timeoutHelper);
 
+                openSock = true;
+
                 TcpDiscoveryIoSession ses = createSession(sock);
 
                 TcpDiscoveryHandshakeRequest req = new 
TcpDiscoveryHandshakeRequest(locNodeId);
@@ -745,6 +747,8 @@ class ClientImpl extends TcpDiscoveryImpl {
                 if (redirectAddrs != null) {
                     U.closeQuiet(sock);
 
+                    openSock = false;
+
                     if (log.isInfoEnabled())
                         log.info("Reconnecting to the addresses of a proper DC 
[addrs=" + redirectAddrs + ']');
 

Reply via email to