Lines Matching defs:uring
920 let uring = URingContext::new(QUEUE_SIZE).unwrap(); in read_parallel() localVariable
951 let uring = URingContext::new(queue_size).unwrap(); in read_readv() localVariable
969 let uring = URingContext::new(queue_size).unwrap(); in readv_vec() localVariable
999 let uring = URingContext::new(16).unwrap(); in write_one_block() localVariable
1018 let uring = URingContext::new(16).unwrap(); in write_one_submit_poll() localVariable
1053 let uring = URingContext::new(queue_size).unwrap(); in writev_vec() localVariable
1112 let uring = URingContext::new(16).unwrap(); in fallocate_fsync() localVariable
1184 let uring = URingContext::new(16).unwrap(); in dev_zero_readable() localVariable
1197 let uring = URingContext::new(num_entries).unwrap(); in queue_many_ebusy_retry() localVariable
1242 let uring = URingContext::new(4).map(Arc::new).unwrap(); in wake_with_nop() localVariable
1292 let uring = URingContext::new(num_entries).map(Arc::new).unwrap(); in complete_from_any_thread() localVariable
1311 let uring = uring.clone(); in complete_from_any_thread() localVariable
1357 let uring = URingContext::new(NUM_ENTRIES).map(Arc::new).unwrap(); in submit_from_any_thread() localVariable
1363 let uring = uring.clone(); in submit_from_any_thread() localVariable
1442 let uring = URingContext::new(NUM_ENTRIES).map(Arc::new).unwrap(); in multi_thread_submit_and_complete() localVariable
1448 let uring = uring.clone(); in multi_thread_submit_and_complete() localVariable
1478 let uring = uring.clone(); in multi_thread_submit_and_complete() localVariable