From 1f3406d8bc3258d4e967b540e8745e42cbaf42eb Mon Sep 17 00:00:00 2001
From: Nikolay Kim <fafhrd91@gmail.com>
Date: Mon, 17 Mar 2025 09:22:00 +0100
Subject: [PATCH] Add check for required io-uring opcodes

---
 ntex-net/CHANGES.md              |  4 ++++
 ntex-net/Cargo.toml              |  2 +-
 ntex-net/src/rt_uring/connect.rs |  4 ++++
 ntex-net/src/rt_uring/driver.rs  | 10 ++++++++++
 4 files changed, 19 insertions(+), 1 deletion(-)

diff --git a/ntex-net/CHANGES.md b/ntex-net/CHANGES.md
index 2109e1aa..d2c24373 100644
--- a/ntex-net/CHANGES.md
+++ b/ntex-net/CHANGES.md
@@ -1,5 +1,9 @@
 # Changes
 
+## [2.5.5] - 2025-03-xx
+
+* Add check for required io-uring opcodes
+
 ## [2.5.4] - 2025-03-15
 
 * Close FD in various case for poll driver
diff --git a/ntex-net/Cargo.toml b/ntex-net/Cargo.toml
index 177d043a..520669f7 100644
--- a/ntex-net/Cargo.toml
+++ b/ntex-net/Cargo.toml
@@ -40,7 +40,7 @@ ntex-util = "2.5"
 
 ntex-tokio = { version = "0.5.3", optional = true }
 ntex-compio = { version = "0.2.4", optional = true }
-ntex-neon = { version = "0.1.4", optional = true }
+ntex-neon = { version = "0.1.5", optional = true }
 
 bitflags = { workspace = true }
 cfg-if = { workspace = true }
diff --git a/ntex-net/src/rt_uring/connect.rs b/ntex-net/src/rt_uring/connect.rs
index 715c4763..ea9be3e1 100644
--- a/ntex-net/src/rt_uring/connect.rs
+++ b/ntex-net/src/rt_uring/connect.rs
@@ -32,6 +32,10 @@ impl ConnectOps {
         Runtime::value(|rt| {
             let mut inner = None;
             rt.driver().register(|api| {
+                if !api.is_supported(opcode::Connect::CODE) {
+                    panic!("opcode::Connect is required for io-uring support");
+                }
+
                 let ops = Rc::new(ConnectOpsInner {
                     api,
                     ops: RefCell::new(Slab::new()),
diff --git a/ntex-net/src/rt_uring/driver.rs b/ntex-net/src/rt_uring/driver.rs
index 6a2ba777..f2368d1a 100644
--- a/ntex-net/src/rt_uring/driver.rs
+++ b/ntex-net/src/rt_uring/driver.rs
@@ -61,6 +61,16 @@ impl<T: os::fd::AsRawFd + 'static> StreamOps<T> {
         Runtime::value(|rt| {
             let mut inner = None;
             rt.driver().register(|api| {
+                if !api.is_supported(opcode::Recv::CODE) {
+                    panic!("opcode::Recv is required for io-uring support");
+                }
+                if !api.is_supported(opcode::Send::CODE) {
+                    panic!("opcode::Send is required for io-uring support");
+                }
+                if !api.is_supported(opcode::Close::CODE) {
+                    panic!("opcode::Close is required for io-uring support");
+                }
+
                 let mut ops = Slab::new();
                 ops.insert(Operation::Nop);