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
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
56
57
58
59
60
61
62
63
64
65
66

use std::os::fd;

use crate::{
    backend::{
        self, fixed,
        kqueue::engine::{event, write},
    },
    driver::{self, flight},
    io,
};

#[repr(transparent)]
pub(crate) struct Control<'a> {
    backend: &'a mut backend::Kqueue,
}

impl<'a> Control<'a> {
    pub(in crate::backend::kqueue) fn new(backend: &'a mut backend::Kqueue) -> Self {
        Self { backend }
    }
}

impl Control<'_> {
    pub(in crate::backend::kqueue) fn reclaim(
        &mut self,
        completion: event::Completion,
        drain: &flight::Drain<'_, '_>,
    ) {
        let driver = drain.driver();
        let completion = completion.into_completion(&mut self.backend.files, drain);
        match completion.into_reclaim(driver) {
            io::Reclaim::Accepted(accepted) => fixed::Lifecycle::close(
                self.backend,
                driver::Close::untracked(accepted.into_slot()),
                driver,
                fixed::Phase::Active,
            ),
            io::Reclaim::Close(close) => {
                fixed::Lifecycle::close(self.backend, close, driver, fixed::Phase::Active)
            }
            io::Reclaim::Slots(retired) => {
                let slots = driver.outbound().take_retired_slots(retired);
                fixed::Lifecycle::release_slots(self.backend, slots);
            }
            io::Reclaim::Buffer(_) | io::Reclaim::None => {}
        }
    }

    pub(crate) fn close_owned(&mut self, fd: fd::OwnedFd) {
        let raw = fd::AsRawFd::as_raw_fd(&fd);
        if let Some(target) = self.backend.reads.remove_fd(raw) {
            self.backend.pending.suppress_target(target);
        }
        if let Some(target) = write::Retry::new(self.backend).cancel_write_retry(raw) {
            self.backend.pending.suppress_target(target);
        }
        self.backend
            .poll
            .changes
            .remove(raw as libc::uintptr_t, libc::EVFILT_READ);
        self.backend
            .poll
            .changes
            .remove(raw as libc::uintptr_t, libc::EVFILT_WRITE);
    }
}