dope-core 0.15.0

The manifold runtime
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

use io_uring::squeue;

use crate::{backend::uring::ring, driver};

pub(in crate::backend::uring) struct Batch<'entries>(&'entries [squeue::Entry]);

impl<'entries> Batch<'entries> {
    /// The caller proves that every address captured by `entries` remains live
    /// until its terminal completion or ring quiescence.
    pub(in crate::backend::uring) unsafe fn new(entries: &'entries [squeue::Entry]) -> Self {
        Self(entries)
    }

    pub(in crate::backend::uring) fn submit(
        self,
        ring: &mut ring::Ready,
    ) -> Result<(), driver::SubmitError> {
        ring.push_multiple(self.0).map_err(|_| driver::SubmitError)
    }
}