ante-exec 0.2.2

Standalone process execution utilities for Ante
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

use std::sync::{Mutex, MutexGuard};

pub mod buffer;
pub mod handle;
pub mod pool;
pub mod process_group;
pub mod receiver;
pub mod subprocess;

pub use buffer::HeadTailBuffer;
pub use handle::{OutputChunk, ProcessHandle, SpawnedProcess, Stream};
pub use pool::{
    ExecError, ExecRequest, ExecResponse, PollRequest, PoolConfig, ProcessPool, StdinRequest,
};
pub use process_group::{kill_by_pid, kill_process_group, process_group_is_alive};
pub use receiver::OutputReceiver;
pub use subprocess::{
    CommandOptions, RunOutput, StdinMode, run_with_timeout, terminate_child_process_group,
};

pub(crate) fn lock_or_recover<T>(mutex: &Mutex<T>) -> MutexGuard<'_, T> {
    match mutex.lock() {
        Ok(guard) => guard,
        Err(poisoned) => poisoned.into_inner(),
    }
}

#[cfg(test)]
mod tests;