Update compio to 0.18 (#736)

Author: fafhrd91

Cargo.toml

@@ -129,8 +129,8 @@ url = "2.5.2"
 url-pkg = { version = "2.5.2", package = "url" }
 uuid = { version = "1.19", features = ["v7"] }
 
-compio-buf = "0.7"
-compio-io = "0.8"
-compio-net = "0.10"
-compio-driver = "0.10"
-compio-runtime = "0.10"
+compio-buf = "0.8.0"
+compio-io = "0.9.0"
+compio-net = "0.11.0"
+compio-driver = "0.11.1"
+compio-runtime = "0.11.0"

ntex-net/CHANGES.md

@@ -1,5 +1,9 @@
 # Changes
 
+## [3.6.0] - 2026-02-01
+
+* Update compio to 0.18
+
 ## [3.5.2] - 2026-01-29
 
 * Fix socket close process for polling driver

ntex-net/Cargo.toml

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

ntex-net/src/compio/io_impl.rs

@@ -1,8 +1,8 @@
-use std::{any, future::poll_fn, io, task::Poll};
+use std::{any, future::poll_fn, io, mem, slice, task::Poll};
 
-use compio_buf::{BufResult, IoBuf, IoBufMut, SetBufInit};
+use compio_buf::{BufResult, IoBuf, IoBufMut, SetLen};
 use compio_io::{AsyncRead, AsyncWrite};
-use ntex_bytes::{Buf, BufMut, BytesMut};
+use ntex_bytes::{BufMut, BytesMut};
 use ntex_io::{Handle, IoContext, IoStream, IoTaskStatus, Readiness, types};
 use ntex_util::future::{Either, select};
 
@@ -37,31 +37,26 @@ impl Handle for HandleWrapper {
 
 struct CompioBuf(BytesMut);
 
-unsafe impl IoBuf for CompioBuf {
+impl IoBuf for CompioBuf {
     #[inline]
-    fn as_buf_ptr(&self) -> *const u8 {
-        self.0.chunk().as_ptr()
-    }
-
-    #[inline]
-    fn buf_len(&self) -> usize {
-        self.0.len()
-    }
-
-    #[inline]
-    fn buf_capacity(&self) -> usize {
-        self.0.remaining_mut()
+    fn as_init(&self) -> &[u8] {
+        &self.0
     }
 }
 
-unsafe impl IoBufMut for CompioBuf {
-    fn as_buf_mut_ptr(&mut self) -> *mut u8 {
-        self.0.chunk_mut().as_mut_ptr()
+impl IoBufMut for CompioBuf {
+    fn as_uninit(&mut self) -> &mut [mem::MaybeUninit<u8>] {
+        unsafe {
+            slice::from_raw_parts_mut(
+                self.0.chunk_mut().as_mut_ptr() as *mut _,
+                self.0.remaining_mut(),
+            )
+        }
     }
 }
 
-impl SetBufInit for CompioBuf {
-    unsafe fn set_buf_init(&mut self, len: usize) {
+impl SetLen for CompioBuf {
+    unsafe fn set_len(&mut self, len: usize) {
         unsafe {
             self.0.set_len(len + self.0.len());
         }

ntex-rt/CHANGES.md

@@ -1,5 +1,9 @@
 # Changes
 
+## [3.5.0] - 2026-02-01
+
+* Update compio to 0.18
+
 ## [3.5.0] - 2026-01-28
 
 * Use system name for arbiters

ntex-rt/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "ntex-rt"
-version = "3.5.0"
+version = "3.6.0"
 authors = ["ntex contributors <team@ntex.rs>"]
 description = "ntex runtime"
 keywords = ["network", "framework", "async", "futures"]