dope 0.2.3

Thin io_uring adaptor with "Manifolds"
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

use std::time::{Duration, Instant};

use dope_core::driver::{CompletionBackend, DriverLifecycle, PoolDriver};
use dope_futures::conn::Conn;
use dope_transport::Transport;

pub struct Drive;

impl Drive {
    pub fn until<T, B, F>(
        conn: &mut Conn<T, B>,
        driver: &mut B::Driver,
        timeout: Duration,
        mut done: F,
    ) where
        T: Transport,
        B: PoolDriver,
        F: FnMut(&mut Conn<T, B>) -> bool,
    {
        let deadline = Instant::now() + timeout;
        while !done(conn) {
            assert!(
                Instant::now() < deadline,
                "Drive::until: deadline exceeded; state={:?}",
                conn.state()
            );
            B::dispatch_completions(driver, conn);
            conn.drive(driver);
            let _ = driver.submit_only();
            let _ = driver.park_for(Duration::from_millis(10));
        }
    }
}