compio-process 0.1.0

Processes for compio
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

use std::{io, process};

use compio_driver::{
    op::{Interest, PollOnce},
    SharedFd,
};

pub async fn child_wait(mut child: process::Child) -> io::Result<process::ExitStatus> {
    #[cfg(feature = "linux_pidfd")]
    let fd = {
        use std::os::linux::process::ChildExt;

        use compio_driver::AsRawFd;

        child.pidfd().ok().map(|fd| fd.as_raw_fd())
    };
    #[cfg(not(feature = "linux_pidfd"))]
    let fd = None::<compio_driver::RawFd>;
    if let Some(fd) = fd {
        // pidfd won't be closed, and the child has not been reaped.
        let fd = SharedFd::new(fd);
        let op = PollOnce::new(fd, Interest::Readable);
        compio_runtime::submit(op).await.0?;
        child.wait()
    } else {
        unix::child_wait(child).await
    }
}

// For trait impls and fallback.
#[path = "unix.rs"]
mod unix;