71     submit_ring: SubmitQueueState,  field
93         let tail = self.submit_ring.pointers.tail(Ordering::Relaxed);  in prep_next_sqe()
95         if next_tail == self.submit_ring.pointers.head(Ordering::Acquire) {  in prep_next_sqe()
99         let index = (tail & self.submit_ring.ring_mask) as usize;  in prep_next_sqe()
105         self.submit_ring.set_array_entry(index, index as u32);  in prep_next_sqe()
108         self.submit_ring.pointers.set_tail(next_tail);  in prep_next_sqe()
192     submit_ring: Mutex<SubmitQueue>,  field
216             let submit_ring = SubmitQueueState::new(  in new()  localVariable
257                 submit_ring: Mutex::new(SubmitQueue {  in new()
258                     submit_ring,  in new()
287         self.submit_ring  in add_write()
308         self.submit_ring  in add_read()
356         self.submit_ring.lock().prep_next_sqe(|sqe, _iovec| {  in add_writev()
414         self.submit_ring.lock().prep_next_sqe(|sqe, _iovec| {  in add_readv()
432         self.submit_ring.lock().prep_next_sqe(|sqe, _iovec| {  in add_nop()
450         self.submit_ring.lock().prep_next_sqe(|sqe, _iovec| {  in add_fsync()
476         self.submit_ring.lock().prep_next_sqe(|sqe, _iovec| {  in add_fallocate()
503         self.submit_ring.lock().prep_next_sqe(|sqe, _iovec| {  in add_poll_fd()
525         self.submit_ring.lock().prep_next_sqe(|sqe, _iovec| {  in remove_poll_fd()
549         let added = self.submit_ring.lock().prepare_submit();  in enter()
567                 self.submit_ring.lock().complete_submit(added);  in enter()
576                 self.submit_ring.lock().fail_submit(added);  in enter()
1418         assert_eq!(uring.submit_ring.lock().added, 0);  in submit_from_any_thread()
1529         assert_eq!(uring.submit_ring.lock().added, 0);  in multi_thread_submit_and_complete()