runx-runtime 0.6.19

Native Rust runtime for local runx execution, adapters, harness replay, receipts, and sandboxing.
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

use std::process::Child;

use super::{
    ProcessSignal, ProcessSpec, ProcessSupervisorError, kill_timed_out_context,
    poll_timed_out_context, signal_process_group_id,
};

#[cfg(unix)]
pub(super) fn signal_timed_out_process(
    child: &mut Child,
    signal: ProcessSignal,
    spec: &ProcessSpec,
) -> Result<(), ProcessSupervisorError> {
    if signal_process_group_id(child.id(), signal) {
        return Ok(());
    }
    if child
        .try_wait()
        .map_err(|source| ProcessSupervisorError::io(poll_timed_out_context(spec.label), source))?
        .is_some()
    {
        return Ok(());
    }
    kill_direct_child_if_running(child, spec)
}

#[cfg(not(unix))]
pub(super) fn signal_timed_out_process(
    child: &mut Child,
    _signal: ProcessSignal,
    spec: &ProcessSpec,
) -> Result<(), ProcessSupervisorError> {
    kill_direct_child_if_running(child, spec)
}

fn kill_direct_child_if_running(
    child: &mut Child,
    spec: &ProcessSpec,
) -> Result<(), ProcessSupervisorError> {
    if child
        .try_wait()
        .map_err(|source| ProcessSupervisorError::io(poll_timed_out_context(spec.label), source))?
        .is_some()
    {
        return Ok(());
    }
    child
        .kill()
        .map_err(|source| ProcessSupervisorError::io(kill_timed_out_context(spec.label), source))
}