Lines Matching refs:uring
867 uring: &URingContext, in check_one_read()
875 uring in check_one_read()
878 uring.wait().unwrap().next().unwrap() in check_one_read()
885 uring: &URingContext, in check_one_readv()
899 uring in check_one_readv()
902 uring.wait().unwrap().next().unwrap() in check_one_readv()
920 let uring = URingContext::new(QUEUE_SIZE).unwrap(); in read_parallel() localVariable
930 match uring.add_read( in read_parallel()
939 let _ = uring.wait().unwrap().next().unwrap(); in read_parallel()
951 let uring = URingContext::new(queue_size).unwrap(); in read_readv() localVariable
959 check_one_read(&uring, &mut buf, f.as_raw_fd(), (index % 2) * 0x1000, index); in read_readv()
960 check_one_readv(&uring, &mut buf, f.as_raw_fd(), (index % 2) * 0x1000, index); in read_readv()
969 let uring = URingContext::new(queue_size).unwrap(); in readv_vec() localVariable
988 uring in readv_vec()
991 uring.wait().unwrap().next().unwrap() in readv_vec()
999 let uring = URingContext::new(16).unwrap(); in write_one_block() localVariable
1007 uring in write_one_block()
1010 let (user_data, res) = uring.wait().unwrap().next().unwrap(); in write_one_block()
1018 let uring = URingContext::new(16).unwrap(); in write_one_submit_poll() localVariable
1024 let ctx: PollContext<u64> = PollContext::build_with(&[(&uring, 1)]).unwrap(); in write_one_submit_poll()
1033 uring in write_one_submit_poll()
1036 uring.submit().unwrap(); in write_one_submit_poll()
1041 let (user_data, res) = uring.wait().unwrap().next().unwrap(); in write_one_submit_poll()
1053 let uring = URingContext::new(queue_size).unwrap(); in writev_vec() localVariable
1068 uring in writev_vec()
1071 uring.wait().unwrap().next().unwrap() in writev_vec()
1112 let uring = URingContext::new(16).unwrap(); in fallocate_fsync() localVariable
1113 uring in fallocate_fsync()
1116 let (user_data, res) = uring.wait().unwrap().next().unwrap(); in fallocate_fsync()
1133 uring in fallocate_fsync()
1137 uring in fallocate_fsync()
1141 uring in fallocate_fsync()
1146 uring.add_fsync(f.as_raw_fd(), 70).unwrap(); in fallocate_fsync()
1152 let events = uring.wait().unwrap(); in fallocate_fsync()
1162 uring in fallocate_fsync()
1171 let (user_data, res) = uring.wait().unwrap().next().unwrap(); in fallocate_fsync()
1184 let uring = URingContext::new(16).unwrap(); in dev_zero_readable() localVariable
1185 uring in dev_zero_readable()
1188 let (user_data, res) = uring.wait().unwrap().next().unwrap(); in dev_zero_readable()
1197 let uring = URingContext::new(num_entries).unwrap(); in queue_many_ebusy_retry() localVariable
1201 uring in queue_many_ebusy_retry()
1209 uring.submit().unwrap(); in queue_many_ebusy_retry()
1213 uring in queue_many_ebusy_retry()
1222 let mut results = uring.wait().unwrap(); in queue_many_ebusy_retry()
1229 let mut results = uring.wait().unwrap(); in queue_many_ebusy_retry()
1242 let uring = URingContext::new(4).map(Arc::new).unwrap(); in wake_with_nop() localVariable
1246 let uring2 = uring.clone(); in wake_with_nop()
1277 uring.add_nop(NOP).unwrap(); in wake_with_nop()
1278 uring.submit().unwrap(); in wake_with_nop()
1292 let uring = URingContext::new(num_entries).map(Arc::new).unwrap(); in complete_from_any_thread() localVariable
1297 uring.add_nop((sqe_batch * num_entries + i) as u64).unwrap(); in complete_from_any_thread()
1299 uring.submit().unwrap(); in complete_from_any_thread()
1311 let uring = uring.clone(); in complete_from_any_thread() localVariable
1319 for (user_data, result) in uring.wait().unwrap() { in complete_from_any_thread()
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
1369 match uring.add_nop(((idx * NUM_THREADS) + iter) as UserData) { in submit_from_any_thread()
1381 match uring.submit() { in submit_from_any_thread()
1393 for (_, res) in uring.wait().unwrap() { in submit_from_any_thread()
1418 assert_eq!(uring.submit_ring.lock().added, 0); in submit_from_any_thread()
1419 assert_eq!(uring.complete_ring.num_ready(), 0); in submit_from_any_thread()
1421 uring.stats.total_ops.load(Ordering::Relaxed), in submit_from_any_thread()
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
1454 match uring.add_nop(((idx * NUM_SUBMITTERS) + iter) as UserData) { in multi_thread_submit_and_complete()
1466 match uring.submit() { in multi_thread_submit_and_complete()
1478 let uring = uring.clone(); in multi_thread_submit_and_complete() localVariable
1484 for (_, res) in uring.wait().unwrap() { in multi_thread_submit_and_complete()
1512 uring in multi_thread_submit_and_complete()
1516 uring.submit().unwrap(); in multi_thread_submit_and_complete()
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()
1529 assert_eq!(uring.submit_ring.lock().added, 0); in multi_thread_submit_and_complete()
1531 uring.stats.total_ops.load(Ordering::Relaxed), in multi_thread_submit_and_complete()