implement spacejam#49

CramBL · Jul 19, 2024 · a4c4501 · a4c4501
1 parent eb52d05
commit a4c4501
Showing 1 changed file with 3 additions and 1 deletion.
diff --git 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>(