Struct IoUring

pub struct IoUring { /* private fields */ }

Implementations

impl IoUring

pub fn new(queue_size: u32) -> Result<Self, Error>

pub fn queue_read( &mut self, user_data: u64, fd: FdRef<'_>, buffer: *mut u8, length: u32, ) -> Result<(), Error>

pub fn queue_timeout( &mut self, user_data: u64, event_count: u32, duration: Duration, ) -> Result<(), Error>

pub fn queue_futex_wait( &mut self, user_data: u64, futex: *const AtomicU32, expected_value: u32, ) -> Result<(), Error>

pub fn queue_futex_wake_one( &mut self, user_data: u64, futex: *const AtomicU32, ) -> Result<(), Error>

pub fn queue_length(&self) -> usize

pub fn queue_capacity(&self) -> usize

pub unsafe fn submit_and_wait(&mut self, min_complete: u32) -> Result<(), Error>

pub fn finished_count(&self) -> usize

pub fn pop_finished(&mut self) -> Option<io_uring_cqe>

Trait Implementations

impl Send for IoUring

impl Sync for IoUring