diff --git a/src/io_uring/uring.rs b/src/io_uring/uring.rs index 3e53a74..14c204d 100644 --- a/src/io_uring/uring.rs +++ b/src/io_uring/uring.rs @@ -675,7 +675,9 @@ impl Uring { self.sq.lock().unwrap() }; let _hold_sq_mu = Measure::new(&M.sq_mu_hold); - sq.submit_all(self.flags, self.ring_fd); + let submitted = + sq.submit_all(self.flags, self.ring_fd); + self.submitted.fetch_add(submitted, Release); } fn with_sqe<'a, F, C>(