dope-core 0.9.1

The manifold runtime
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

use std::io;
use std::time::Duration;

use crate::backend::Backend;
use crate::backend::ops::completion::CompletionBackend;
use crate::io::Event;

use super::DriverContext;

pub trait Completion<'d> {
    fn drain(&mut self, buf: &mut [Option<Event<'d>>]) -> usize;
    fn wait(&mut self, timeout: Option<Duration>) -> io::Result<()>;
}

impl<'d> Completion<'d> for DriverContext<'_, 'd> {
    fn drain(&mut self, buf: &mut [Option<Event<'d>>]) -> usize {
        self.flush_returned_buffers();
        let reference = self.driver_ref();
        <Backend as CompletionBackend>::drain(self.backend(), reference, buf)
    }

    fn wait(&mut self, timeout: Option<Duration>) -> io::Result<()> {
        self.flush_returned_buffers();
        <Backend as CompletionBackend>::wait(self.backend(), timeout)
    }
}