cqe: cqe.res will auto check and raise exception. No need to

manually check with `trap_error(cqe.res)` at python side anymore.

Author: YoSTEALTH

README.md

@@ -116,9 +116,10 @@ def _submit_and_wait(ring, cqe):
     io_uring_submit(ring)  # submit entry
     io_uring_wait_cqe(ring, cqe)  # wait for entry to finish
     entry = cqe[0]
-    result = trap_error(entry.res)  # auto raise appropriate exception if failed
-    # note `entry.res` returns results, if ``< 0`` its an error, if ``>= 0`` its the value
-
+    try:
+        result = entry.res  # auto raises appropriate exception if failed
+    except Exception as e:
+        raise e  # do stuff with error
     # done with current entry so clear it from completion queue.
     io_uring_cqe_seen(ring, entry)
     return result  # type: int
@@ -130,22 +131,22 @@ def main():
     try:
         io_uring_queue_init(8, ring)
 
-        fd = open(ring, cqe, '/tmp/liburing-test-file.txt', O_CREAT | O_RDWR)
-        print('fd:', fd)
+        fd = open(ring, cqe, "/tmp/liburing-test-file.txt", O_CREAT | O_RDWR)
+        print("fd:", fd)
 
-        length = write(ring, cqe, fd, b'hi... bye!')
-        print('wrote:', length)
+        length = write(ring, cqe, fd, b"hi... bye!")
+        print("wrote:", length)
 
         content = read(ring, cqe, fd, length)
-        print('read:', content)
+        print("read:", content)
 
         close(ring, cqe, fd)
-        print('closed.')
+        print("closed.")
     finally:
         io_uring_queue_exit(ring)
 
 
-if __name__ == '__main__':
+if __name__ == "__main__":
     main()
 
 ```

build.zig.zon

@@ -1,6 +1,6 @@
 .{
     .name = .liburing,
-    .version = "2026.3.25",
+    .version = "2026.3.26",
     .fingerprint = 0x26de882ff0030dfe,
     .dependencies = .{
         .PyOZ = .{

example/open_write_read_close.py

@@ -1,7 +1,19 @@
-from liburing import O_CREAT, O_RDWR, Ring, Cqe, io_uring_get_sqe, \
-                     io_uring_prep_open, io_uring_prep_write, io_uring_prep_read, \
-                     io_uring_prep_close, io_uring_submit, io_uring_wait_cqe, \
-                     io_uring_cqe_seen, io_uring_queue_init, io_uring_queue_exit, trap_error
+from liburing import (
+    O_CREAT,
+    O_RDWR,
+    Ring,
+    Cqe,
+    io_uring_get_sqe,
+    io_uring_prep_open,
+    io_uring_prep_write,
+    io_uring_prep_read,
+    io_uring_prep_close,
+    io_uring_submit,
+    io_uring_wait_cqe,
+    io_uring_cqe_seen,
+    io_uring_queue_init,
+    io_uring_queue_exit,
+)
 
 
 def open(ring, cqe, path, flags):
@@ -40,9 +52,10 @@ def _submit_and_wait(ring, cqe):
     io_uring_submit(ring)  # submit entry
     io_uring_wait_cqe(ring, cqe)  # wait for entry to finish
     entry = cqe[0]
-    result = trap_error(entry.res)  # auto raise appropriate exception if failed
-    # note `entry.res` returns results, if ``< 0`` its an error, if ``>= 0`` its the value
-
+    try:
+        result = entry.res  # auto raises appropriate exception if failed
+    except Exception as e:
+        raise e  # do stuff with error
     # done with current entry so clear it from completion queue.
     io_uring_cqe_seen(ring, entry)
     return result  # type: int
@@ -54,20 +67,20 @@ def main():
     try:
         io_uring_queue_init(8, ring)
 
-        fd = open(ring, cqe, '/tmp/liburing-test-file.txt', O_CREAT | O_RDWR)
-        print('fd:', fd)
+        fd = open(ring, cqe, "/tmp/liburing-test-file.txt", O_CREAT | O_RDWR)
+        print("fd:", fd)
 
-        length = write(ring, cqe, fd, b'hi... bye!')
-        print('wrote:', length)
+        length = write(ring, cqe, fd, b"hi... bye!")
+        print("wrote:", length)
 
         content = read(ring, cqe, fd, length)
-        print('read:', content)
+        print("read:", content)
 
         close(ring, cqe, fd)
-        print('closed.')
+        print("closed.")
     finally:
         io_uring_queue_exit(ring)
 
 
-if __name__ == '__main__':
+if __name__ == "__main__":
     main()

pyproject.toml

@@ -6,7 +6,7 @@ build-backend = "pyoz.backend"
 name = "liburing"
 readme = "README.md"
 license = "CC0-1.0"
-version = "2026.3.25"
+version = "2026.3.26"
 authors = [{name="Ritesh"}]
 keywords = ["python", "socket", "async", "cython", "file", "python3", "io", "syscall", "futex", "statx",
             "io-uring", "uring", "liburing"]
@@ -64,5 +64,5 @@ include-ext = ["py", "zig"]
 
 # Linux platform tag for wheel builds (default: "linux_x86_64" or "linux_aarch64")
 # Use manylinux tags only if building in a manylinux container
-# linux-platform-tag = "manylinux_2_17_x86_64"
+linux-platform-tag = "manylinux_2_17_x86_64"
 

src/liburing/__init__.py

@@ -2,4 +2,4 @@
 from .version import *  # noqa
 
 
-__version__ = "2026.3.25"
+__version__ = "2026.3.26"

src/liburing/class.zig

@@ -1,5 +1,6 @@
 //! Liburing - io_uring related classes
 const c = @import("c.zig").c;
+const e = @import("error.zig");
 const oz = @import("PyOZ");
 const std = @import("std");
 const consts = @import("const.zig");
@@ -164,8 +165,8 @@ pub const CQE = extern struct {
         return self._cqe.user_data;
     }
 
-    pub fn get_res(self: *const Self) i32 {
-        return self._cqe.res;
+    pub fn get_res(self: *const Self) ?i32 {
+        return e.trap_error(self._cqe.res);
     }
 
     pub fn get_flags(self: *const Self) u32 {
@@ -199,8 +200,8 @@ pub const Cqe = extern struct {
     // _array: ?[*]CQE = null, // custom memory for batch cqe
     _io_uring_cqe: ?[*]c.io_uring_cqe, // Note: Memory is managed by `io_uring`
 
-    // TODO:
     pub fn __new__(no: ?u32) ?Cqe {
+        // TODO: `no` is need to get `io_uring_peek_batch_cqe` working
         if (no) |_| return oz.raiseNotImplementedError("`Cqe(no)` - Custom memory allocation not coded yet!");
         return .{ ._io_uring_cqe = null };
     }

test/file/file_test.py

@@ -61,7 +61,7 @@ def test_readv_writev(ring, cqe, tmp_dir):
         liburing.io_uring_wait_cqe(ring, cqe)
 
         entry = cqe[0]
-        liburing.trap_error(entry.res)
+        assert entry.res == 10
         assert entry.user_data == 0
         liburing.io_uring_cqe_seen(ring, entry)
 
@@ -79,7 +79,7 @@ def test_readv_writev(ring, cqe, tmp_dir):
         liburing.io_uring_wait_cqe(ring, cqe)
 
         entry = cqe[0]
-        liburing.trap_error(entry.res)
+        assert entry.res == 10
         assert entry.user_data == 1
         liburing.io_uring_cqe_seen(ring, entry)
 
@@ -132,7 +132,7 @@ def _onwait_flag(ring, cqe, path):
                 pass  # print("test_rwf_nowait_flag BlockingIOError", flush=True)
             else:
                 entry = cqe[0]
-                liburing.trap_error(entry.res)
+                assert entry.res == 10
                 assert entry.res == 6 + 4
                 assert entry.user_data == 1
                 assert one == b"hi... "

test/file/open_close_test.py

@@ -12,7 +12,7 @@ def test_open_close(ring, cqe):
     liburing.io_uring_submit(ring)
     liburing.io_uring_wait_cqe(ring, cqe)  # bug: liburing.io_uring_wait_cqe
     entry = cqe[0]
-    fd = liburing.trap_error(entry.res)
+    fd = entry.res
     assert entry.user_data == 123
     liburing.io_uring_cqe_seen(ring, entry)
     # close
@@ -23,7 +23,7 @@ def test_open_close(ring, cqe):
     liburing.io_uring_submit(ring)
     liburing.io_uring_wait_cqe(ring, cqe)
     entry = cqe[0]
-    assert liburing.trap_error(entry.res) == 0
+    assert entry.res == 0
     assert entry.user_data == 321
 
 
@@ -37,7 +37,7 @@ def test_openat2_close(ring, cqe):
     liburing.io_uring_submit(ring)
     liburing.io_uring_wait_cqe(ring, cqe)
     entry = cqe[0]
-    fd = liburing.trap_error(entry.res)
+    fd = entry.res
     assert entry.user_data == 123
     liburing.io_uring_cqe_seen(ring, entry)
     # close
@@ -48,7 +48,7 @@ def test_openat2_close(ring, cqe):
     liburing.io_uring_submit(ring)
     liburing.io_uring_wait_cqe(ring, cqe)
     entry = cqe[0]
-    assert liburing.trap_error(entry.res) == 0
+    assert entry.res == 0
     assert entry.user_data == 321
 
 
@@ -66,7 +66,7 @@ def test_open_close_direct(ring, cqe):
     liburing.io_uring_submit(ring)
     liburing.io_uring_wait_cqe(ring, cqe)
     entry = cqe[0]
-    assert liburing.trap_error(entry.res) == 0
+    assert entry.res == 0
     assert entry.user_data == 123
     liburing.io_uring_cqe_seen(ring, entry)
     # close
@@ -77,7 +77,7 @@ def test_open_close_direct(ring, cqe):
     liburing.io_uring_submit(ring)
     liburing.io_uring_wait_cqe(ring, cqe)
     entry = cqe[0]
-    assert liburing.trap_error(entry.res) == 0
+    assert entry.res == 0
     assert entry.user_data == 321
     # unregister
     liburing.io_uring_unregister_files(ring)
@@ -97,8 +97,7 @@ def test_openat2_close_direct(ring, cqe, tmp_dir):
     liburing.io_uring_submit(ring)
     liburing.io_uring_wait_cqe(ring, cqe)
     entry = cqe[0]
-    result = liburing.trap_error(entry.res)
-    assert result == 0
+    assert entry.res == 0
     assert entry.user_data == 123
     liburing.io_uring_cqe_seen(ring, entry)
     # close
@@ -109,7 +108,7 @@ def test_openat2_close_direct(ring, cqe, tmp_dir):
     liburing.io_uring_submit(ring)
     liburing.io_uring_wait_cqe(ring, cqe)
     entry = cqe[0]
-    assert liburing.trap_error(entry.res) == 0
+    assert entry.res == 0
     assert entry.user_data == 321
     # unregister
     liburing.io_uring_unregister_files(ring)
@@ -128,7 +127,7 @@ def test_openat2_close_direct_auto_file_index_alloc(ring, cqe):
     assert liburing.io_uring_submit(ring) == 1
     assert liburing.io_uring_wait_cqe(ring, cqe) == 0
     entry = cqe[0]
-    find_index = liburing.trap_error(entry.res)
+    find_index = entry.res
     assert entry.user_data == 123
     liburing.io_uring_cqe_seen(ring, entry)
     # close
@@ -139,7 +138,7 @@ def test_openat2_close_direct_auto_file_index_alloc(ring, cqe):
     assert liburing.io_uring_submit(ring) == 1
     assert liburing.io_uring_wait_cqe(ring, cqe) == 0
     entry = cqe[0]
-    assert liburing.trap_error(entry.res) == 0
+    assert entry.res == 0
     assert entry.user_data == 321
     liburing.io_uring_cqe_seen(ring, entry)
     # unregister
@@ -154,4 +153,4 @@ def test_close_error(ring, cqe):
     assert liburing.io_uring_wait_cqe(ring, cqe) == 0
     assert cqe[0].user_data == 123
     with pytest.raises(OSError, match="Bad file descriptor"):
-        liburing.trap_error(cqe[0].res)
+        cqe[0].res

test/futex_test.py

@@ -95,7 +95,8 @@ def test_multi_wake(ring, cqe):
     for i in range(3):
         assert liburing.io_uring_wait_cqe(ring, cqe) == 0
         entry = cqe[0]
-        liburing.trap_error(entry.res)
+        if not i:
+            assert entry.res == 2
         liburing.io_uring_cqe_seen(ring, entry)
     try:
         liburing.io_uring_peek_cqe(ring, cqe)
@@ -165,7 +166,8 @@ def test_multi_wake_waitv(ring, cqe):
     for i in range(3):
         assert liburing.io_uring_wait_cqe(ring, cqe) == 0
         entry = cqe[0]
-        liburing.trap_error(entry.res)
+        if not i:
+            assert entry.res == 2
         liburing.io_uring_cqe_seen(ring, entry)
     try:
         liburing.io_uring_peek_cqe(ring, cqe)

test/os/unlink_test.py

@@ -28,7 +28,7 @@ def test_unlink(tmp_dir, ring, cqe):
 
     for i in range(2):
         entry = cqe[i]
-        assert liburing.trap_error(entry.res) == 0
+        assert entry.res == 0
         assert entry.user_data == i + 1
     liburing.io_uring_cq_advance(ring, 2)
 
@@ -58,7 +58,7 @@ def test_unlinkat_error(tmp_dir, ring, cqe):
 
     entry = cqe[0]
     with pytest.raises(NotADirectoryError):
-        assert liburing.trap_error(entry.res) == 0
+        assert entry.res == 0
     assert entry.user_data == 1
     liburing.io_uring_cqe_seen(ring, entry)
 
@@ -71,7 +71,7 @@ def test_unlinkat_error(tmp_dir, ring, cqe):
 
     entry = cqe[0]
     with pytest.raises(IsADirectoryError):
-        assert liburing.trap_error(entry.res) == 0
+        assert entry.res == 0
     assert entry.user_data == 1
 
     liburing.io_uring_cqe_seen(ring, entry)