* sse: fixed memory leak under heavy load

Signed-off-by: neo <1100909+neowu@users.noreply.github.com>

Author: neowu

CHANGELOG.md

@@ -10,6 +10,8 @@
 * migrate from ThreadLocal to ScopedValue
   > updated WebContext
   > updated LogManager
+* sse: fixed memory leak under heavy load
+  > exchange was not properly closed under heavy IO + throwing error on connect
 
 ### 9.2.4 (8/8/2025 - 8/21/2025)
 

build.gradle.kts

@@ -6,7 +6,7 @@ plugins {
 
 subprojects {
     group = "core.framework"
-    version = "9.3.0-b1"
+    version = "9.3.0-b2"
     repositories {
         maven {
             url = uri("https://neowu.github.io/maven-repo/")

core-ng/src/main/java/core/framework/internal/web/sse/ChannelImpl.java

@@ -103,10 +103,16 @@ public void close() {
                 lock.lock();
                 if (closed) return;
 
-                closed = true;
-                if (queue.isEmpty()) {
-                    exchange.endExchange();
+                // for flow like
+                // channel.sendBytes("error");
+                // channel.close();
+                // the close logic (this closure) could run first in different IO thread while sendBytes is blocked due to lock
+                // so here we should try to send remaining messages in queue before close
+                if (!queue.isEmpty()) {
+                    writeListener.handleEvent(sink);
                 }
+                exchange.endExchange();
+                closed = true;  // make sure mark closed after endExchange, to make sure no leak of exchange
             } finally {
                 lock.unlock();
             }
@@ -119,9 +125,9 @@ public void shutdown() {
             if (closed) return;
 
             LOGGER.debug("shutdown sse connection, channel={}", id);
-            closed = true;
             queue.clear();
             exchange.endExchange();
+            closed = true;  // make sure mark closed after endExchange, to make sure no leak of exchange
         } finally {
             lock.unlock();
         }