Lines Matching refs:URingContext
190 pub struct URingContext { struct
198 impl URingContext { argument
201 pub fn new(num_entries: usize) -> Result<URingContext> { in new() argument
255 Ok(URingContext { in new()
624 impl AsRawFd for URingContext { implementation
867 uring: &URingContext, in check_one_read() argument
885 uring: &URingContext, in check_one_readv() argument
920 let uring = URingContext::new(QUEUE_SIZE).unwrap(); in read_parallel()
951 let uring = URingContext::new(queue_size).unwrap(); in read_readv()
969 let uring = URingContext::new(queue_size).unwrap(); in readv_vec()
999 let uring = URingContext::new(16).unwrap(); in write_one_block()
1018 let uring = URingContext::new(16).unwrap(); in write_one_submit_poll()
1053 let uring = URingContext::new(queue_size).unwrap(); in writev_vec()
1112 let uring = URingContext::new(16).unwrap(); in fallocate_fsync()
1184 let uring = URingContext::new(16).unwrap(); in dev_zero_readable()
1197 let uring = URingContext::new(num_entries).unwrap(); in queue_many_ebusy_retry()
1242 let uring = URingContext::new(4).map(Arc::new).unwrap(); in wake_with_nop()
1292 let uring = URingContext::new(num_entries).map(Arc::new).unwrap(); in complete_from_any_thread()
1357 let uring = URingContext::new(NUM_ENTRIES).map(Arc::new).unwrap(); in submit_from_any_thread()
1442 let uring = URingContext::new(NUM_ENTRIES).map(Arc::new).unwrap(); in multi_thread_submit_and_complete()