This is an automated email from the ASF dual-hosted git repository.
isapego pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
The following commit(s) were added to refs/heads/main by this push:
new 302cf2137ed IGNITE-28014 Client Connector: Fix race condition (#7688)
302cf2137ed is described below
commit 302cf2137ed10f0efe817a60393b148ba3bfbe08
Author: Igor Sapego <[email protected]>
AuthorDate: Mon Mar 2 16:54:35 2026 +0100
IGNITE-28014 Client Connector: Fix race condition (#7688)
---
.../org/apache/ignite/client/handler/ClientInboundMessageHandler.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/modules/client-handler/src/main/java/org/apache/ignite/client/handler/ClientInboundMessageHandler.java
b/modules/client-handler/src/main/java/org/apache/ignite/client/handler/ClientInboundMessageHandler.java
index e1f2ed29ae4..26108010f82 100644
---
a/modules/client-handler/src/main/java/org/apache/ignite/client/handler/ClientInboundMessageHandler.java
+++
b/modules/client-handler/src/main/java/org/apache/ignite/client/handler/ClientInboundMessageHandler.java
@@ -579,6 +579,8 @@ public class ClientInboundMessageHandler
}
private void sendHandshakeResponse(ChannelHandlerContext ctx, BitSet
mutuallySupportedFeatures) {
+ state = STATE_HANDSHAKE_RESPONSE_SENT;
+
ClientMessagePacker packer = getPacker(ctx.alloc());
try {
@@ -589,8 +591,6 @@ public class ClientInboundMessageHandler
throw t;
}
- state = STATE_HANDSHAKE_RESPONSE_SENT;
-
metrics.sessionsAcceptedIncrement();
metrics.sessionsActiveIncrement();