Lines Matching defs:uring

98     let uring = URingContext::new(QUEUE_SIZE, None).unwrap();  in read_parallel()  localVariable
132 let uring = URingContext::new(queue_size, None).unwrap(); in read_readv() localVariable
165 let uring = URingContext::new(queue_size, None).unwrap(); in readv_vec() localVariable
197 let uring = URingContext::new(16, None).unwrap(); in write_one_block() localVariable
223 let uring = URingContext::new(16, None).unwrap(); in write_one_submit_poll() localVariable
266 let uring = URingContext::new(queue_size, None).unwrap(); in writev_vec() localVariable
327 let uring = URingContext::new(16, None).unwrap(); in fallocate_fsync() localVariable
411 let uring = URingContext::new(16, None).unwrap(); in dev_zero_readable() localVariable
424 let uring = URingContext::new(num_entries, None).unwrap(); in queue_many_ebusy_retry() localVariable
465 let uring = URingContext::new(4, None).map(Arc::new).unwrap(); in wake_with_nop() localVariable
523 let uring = URingContext::new(num_entries, None).map(Arc::new).unwrap(); in complete_from_any_thread() localVariable
542 let uring = uring.clone(); in complete_from_any_thread() localVariable
588 let uring = URingContext::new(NUM_ENTRIES, None).map(Arc::new).unwrap(); in submit_from_any_thread() localVariable
594 let uring = uring.clone(); in submit_from_any_thread() localVariable
669 let uring = URingContext::new(NUM_ENTRIES, None).map(Arc::new).unwrap(); in multi_thread_submit_and_complete() localVariable
675 let uring = uring.clone(); in multi_thread_submit_and_complete() localVariable
705 let uring = uring.clone(); in multi_thread_submit_and_complete() localVariable
769 let uring = URingContext::new(queue_size, Some(&restriction)).unwrap(); in restrict_ops() localVariable