Lines Matching refs:complete_ring
193 complete_ring: CompleteQueueState, field
242 let complete_ring = CompleteQueueState::new( in new() localVariable
265 complete_ring, in new()
367 self.complete_ring.add_op_data(user_data, iovecs); in add_writev()
425 self.complete_ring.add_op_data(user_data, iovecs); in add_readv()
543 let completed = self.complete_ring.num_completed(); in enter()
606 let wait_nr = if self.complete_ring.num_ready() > 0 { in wait()
614 Ok(()) => Ok(&self.complete_ring), in wait()
618 Err(Error::RingEnter(libc::EBUSY)) => Ok(&self.complete_ring), in wait()
1419 assert_eq!(uring.complete_ring.num_ready(), 0); in submit_from_any_thread()
1524 assert!(uring.complete_ring.num_ready() <= NUM_COMPLETERS as u32); in multi_thread_submit_and_complete()
1526 in_flight.lock().abs() as u32 + uring.complete_ring.num_ready(), in multi_thread_submit_and_complete()