Fix socket close process for polling driver (#730)

Author: fafhrd91

Cargo.toml

@@ -47,7 +47,7 @@ ntex-bytes = "1.4.1"
 ntex-codec = "1.1.0"
 ntex-io = "3.6.0"
 ntex-dispatcher = "3.0.0"
-ntex-net = "3.5.1"
+ntex-net = "3.5.2"
 ntex-http = "1.0.0"
 ntex-router = "1.0.0"
 ntex-rt = "3.5.0"

ntex-net/CHANGES.md

@@ -1,5 +1,9 @@
 # Changes
 
+## [3.5.2] - 2026-01-29
+
+* Fix socket close process for polling driver
+
 ## [3.5.1] - 2026-01-08
 
 * Remove changes queue checks for io-uring driver

ntex-net/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "ntex-net"
-version = "3.5.1"
+version = "3.5.2"
 authors = ["ntex contributors <team@ntex.rs>"]
 description = "ntexwork utils for ntex framework"
 keywords = ["network", "framework", "async", "futures"]

ntex-net/src/polling/stream.rs

@@ -221,14 +221,14 @@ impl StreamOpsInner {
                 item.ctx.stop(None);
             }
             self.api.detach(fd, id);
-            ntex_rt::spawn_blocking(move || {
-                if let Err(err) = syscall!(libc::close(fd)) {
-                    log::error!("Cannot close file descriptor ({fd:?}), {err:?}");
-                }
-            });
 
             if item.flags.contains(Flags::DROPPED_SEC) {
                 let item = streams.remove(idx);
+                ntex_rt::spawn_blocking(move || {
+                    if let Err(err) = syscall!(libc::close(fd)) {
+                        log::error!("Cannot close file descriptor ({fd:?}), {err:?}");
+                    }
+                });
                 mem::forget(item.io);
             } else {
                 item.flags.insert(Flags::DROPPED_PRI);
@@ -247,6 +247,12 @@ impl StreamOpsInner {
 
             if item.flags.contains(Flags::DROPPED_PRI) {
                 let item = streams.remove(idx);
+                let fd = item.fd();
+                ntex_rt::spawn_blocking(move || {
+                    if let Err(err) = syscall!(libc::close(fd)) {
+                        log::error!("Cannot close file descriptor ({fd:?}), {err:?}");
+                    }
+                });
                 mem::forget(item.io);
             } else {
                 item.flags.insert(Flags::DROPPED_SEC);