Method with_config

nodedb/src/data/io/uring_reader.rs:66–91

Create with custom configuration.

(queue_depth: u32, pool_size: usize, buf_size: usize)

    /// Create with custom configuration.
    pub fn with_config(queue_depth: u32, pool_size: usize, buf_size: usize) -> Option<Self> {
        let ring = io_uring::IoUring::new(queue_depth).ok()?;

        let mut pool = Vec::with_capacity(pool_size);
        let mut free = Vec::with_capacity(pool_size);
        for i in 0..pool_size {
            match AlignedBuf::new(buf_size) {
                Ok(buf) => {
                    pool.push(buf);
                    free.push(i);
                }
                Err(_) => break,
            }
        }

        if pool.is_empty() {
            return None;
        }

        Some(Self {
            ring,
            pool,
            free,
            buf_size,
        })
    }

    /// Read multiple files in a single batched io_uring submission.
    ///