(ignite) branch master updated: IGNITE-24945 Fixed node failure with CancelledKeyException on session close with SSL enabled. (#11973)

[mpetrov]

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

mpetrov 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 32438e3a378 IGNITE-24945 Fixed node failure with CancelledKeyException 
on session close with SSL enabled. (#11973)
32438e3a378 is described below

commit 32438e3a3789895b609e4d3cda201a3a9901d541
Author: Mikhail Petrov <32207922+petrov...@users.noreply.github.com>
AuthorDate: Mon Apr 7 10:00:00 2025 +0300

    IGNITE-24945 Fixed node failure with CancelledKeyException on session close 
with SSL enabled. (#11973)
---
 .../org/apache/ignite/internal/util/nio/GridNioServer.java  | 13 ++++++++-----
 .../org/apache/ignite/internal/util/nio/GridNioWorker.java  |  5 -----
 2 files changed, 8 insertions(+), 10 deletions(-)

diff --git 
a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioServer.java
 
b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioServer.java
index 70562e3d4cd..67f386a049e 100644
--- 
a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioServer.java
+++ 
b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioServer.java
@@ -2145,9 +2145,7 @@ public class GridNioServer<T> {
                             }
 
                             case REQUIRE_WRITE: {
-                                SessionWriteRequest req = 
(SessionWriteRequest)req0;
-
-                                
registerWrite((GridSelectorNioSessionImpl)req.session());
+                                
registerWrite((GridSelectorNioSessionImpl)req0.session());
 
                                 break;
                             }
@@ -2345,7 +2343,7 @@ public class GridNioServer<T> {
         /**
          * @param ses Session.
          */
-        @Override public final void registerWrite(GridSelectorNioSessionImpl 
ses) {
+        protected void registerWrite(GridSelectorNioSessionImpl ses) {
             SelectionKey key = ses.key();
 
             if (key.isValid()) {
@@ -3242,6 +3240,11 @@ public class GridNioServer<T> {
         /** */
         private Span span;
 
+        /** @param ses Session. */
+        WriteRequestSystemImpl(GridNioSession ses) {
+            this(ses, null);
+        }
+
         /**
          * @param ses Session.
          * @param msg Message.
@@ -3735,7 +3738,7 @@ public class GridNioServer<T> {
                         GridNioWorker worker = ses0.worker();
 
                         if (worker != null)
-                            worker.registerWrite(ses0);
+                            worker.offer(new WriteRequestSystemImpl(ses0));
                     }
 
                     return null;
diff --git 
a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioWorker.java
 
b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioWorker.java
index 62985ff5d8d..3419b4cd307 100644
--- 
a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioWorker.java
+++ 
b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioWorker.java
@@ -40,9 +40,4 @@ interface GridNioWorker {
      * @return Session state change requests.
      */
     @Nullable public List<GridNioServer.SessionChangeRequest> 
clearSessionRequests(GridNioSession ses);
-
-    /**
-     * @param ses Session to register write interest for.
-     */
-    public void registerWrite(GridSelectorNioSessionImpl ses);
 }