dope-uring 0.26.0

Owned io_uring backend for dope
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55

use std::{task, time};

use dope_sys::{
    engine::{self, ring},
    io::reactor::{ready::store::Quota, submit::Queue as _},
    ring::{Source, ready::Ready as _},
};

use crate::{
    Engine, Uring,
    driver::tuning::{self, Progress as _},
};

impl<C: ring::Context> engine::raw::Poll for Engine<C>
where
    C::Tuning: tuning::Progress<C::Token>,
{
    type Context = C;
    type Error = <Uring as Source>::Poll;

    unsafe fn commit<'a, Q: Quota>(
        &'a mut self,
        quota: Q,
        deferred: impl FnOnce() -> bool,
    ) -> Result<task::Poll<()>, Self::Error>
    where
        C: 'a,
    {
        quota.refund();
        let busy = deferred() || self.tuning.has_pending();
        self.ring.commit()?;
        Ok(if busy || !self.ring.submission().is_empty() {
            task::Poll::Pending
        } else {
            task::Poll::Ready(())
        })
    }

    unsafe fn wait<'a, Q: Quota>(
        &'a mut self,
        quota: Q,
        timeout: Option<time::Duration>,
        busy: impl FnOnce() -> bool,
    ) -> Result<(), Self::Error>
    where
        C: 'a,
    {
        quota.refund();
        if busy() || self.tuning.has_pending() || timeout.is_some_and(|span| span.is_zero()) {
            self.ring.commit()
        } else {
            self.ring.try_wait(timeout)
        }
    }
}