Method submit_batch_requests

block/src/raw_async.rs:156–235

(&mut self, batch_request: &[BatchRequest])

    }

    fn submit_batch_requests(&mut self, batch_request: &[BatchRequest]) -> AsyncIoResult<()> {
        if !self.batch_requests_enabled() {
            return Ok(());
        }

        let (submitter, mut sq, _) = self.io_uring.split();
        let mut submitted = false;

        // Refuse the whole batch if it can't fit in the SQ to avoid having to unroll a partially
        // successful push.
        if batch_request.len() > sq.capacity() - sq.len() {
            return Err(AsyncIoError::SubmitBatchRequests(Error::other(
                "io_uring submission queue is full",
            )));
        }

        for req in batch_request {
            match req.request_type {
                RequestType::In => {
                    // SAFETY: we know the file descriptor is valid and we
                    // relied on vm-memory to provide the buffer address.
                    unsafe {
                        sq.push(
                            &opcode::Readv::new(
                                types::Fd(self.fd),
                                req.iovecs.as_ptr(),
                                req.iovecs.len() as u32,
                            )
                            .offset(req.offset as u64)
                            .build()
                            .user_data(req.user_data),
                        )
                        .map_err(|e| {
                            AsyncIoError::ReadVectored(Error::other(format!(
                                "Submission queue is full: {e:?}"
                            )))
                        })?;
                    };
                    submitted = true;
                }
                RequestType::Out => {
                    // SAFETY: we know the file descriptor is valid and we
                    // relied on vm-memory to provide the buffer address.
                    unsafe {
                        sq.push(
                            &opcode::Writev::new(
                                types::Fd(self.fd),
                                req.iovecs.as_ptr(),
                                req.iovecs.len() as u32,
                            )
                            .offset(req.offset as u64)
                            .build()
                            .user_data(req.user_data),
                        )
                        .map_err(|e| {
                            AsyncIoError::WriteVectored(Error::other(format!(
                                "Submission queue is full: {e:?}"
                            )))