Do not expect second notification when cqe returns error

2025-11-16 02:19:48 +03:00
1 changed files with 1 additions and 1 deletions
@@ -120,7 +120,7 @@ void ring_loop_t::loop()
        if (mt)
            mu.lock();
        struct ring_data_t *d = (struct ring_data_t*)cqe->user_data;
-        if (cqe->flags & IORING_CQE_F_MORE)
+        if ((cqe->flags & IORING_CQE_F_MORE) && cqe->res >= 0)
        {
            // There will be a second notification
            if (mt)