Method create_async_io

block/src/raw_disk.rs:130–143

(&self, ring_depth: u32)

    }

    fn create_async_io(&self, ring_depth: u32) -> BlockResult<Box<dyn AsyncIo>> {
        match self.backend {
            RawBackend::Sync => Ok(Box::new(RawFileSync::new(self.file.as_raw_fd()))),
            #[cfg(feature = "io_uring")]
            RawBackend::IoUring => Ok(Box::new(RawFileAsync::new(
                self.file.as_raw_fd(),
                ring_depth,
            )?)),
            RawBackend::Aio => Ok(Box::new(RawFileAsyncAio::new(
                self.file.as_raw_fd(),
                ring_depth,
            )?)),
        }
    }
}

#[cfg(test)]