move CQE increment until after processing

lhoward · lhoward · commit 0f3fb5dd40a4 · 2025-09-30T06:56:49.000+10:00
diff --git a/Sources/CIORingShims/CQHandler.cpp b/Sources/CIORingShims/CQHandler.cpp
@@ -41,14 +41,14 @@ int io_uring_cq_handler(struct io_uring *ring) {
 
   io_uring_for_each_cqe(ring, head, cqe) {
     assert(cqe != nullptr);
-    i++;
 #if PTHREAD_IO_URING
     if (cqe->user_data == ~0ULL) {
       err = -ECANCELED;
       break;
     }
 #endif
     invoke_cqe_block(cqe);
+    i++;
   }
   io_uring_cq_advance(ring, i);
 

Original file line number	Diff line number	Diff line change
`@@ -41,14 +41,14 @@ int io_uring_cq_handler(struct io_uring *ring) {`
`41`	`41`
`42`	`42`	`io_uring_for_each_cqe(ring, head, cqe) {`
`43`	`43`	`assert(cqe != nullptr);`
`44`		`- i++;`
`45`	`44`	`#if PTHREAD_IO_URING`
`46`	`45`	`if (cqe->user_data == ~0ULL) {`
`47`	`46`	`err = -ECANCELED;`
`48`	`47`	`break;`
`49`	`48`	`}`
`50`	`49`	`#endif`
`51`	`50`	`invoke_cqe_block(cqe);`
	`51`	`+ i++;`
`52`	`52`	`}`
`53`	`53`	`io_uring_cq_advance(ring, i);`
`54`	`54`