prefork 0.6.0

A library for forking processes
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
67
68
69
70
71
72

//! An example of an unmanaged fork where the caller is responsible for looking
//! after the children.

use std::{collections::HashSet, process};

use log::{debug, info};

use nix::sys::signal::{kill, Signal};
use prefork::{Pid, Prefork, Result};
use signal_hook::{
    consts::{SIGCHLD, SIGINT, SIGQUIT, SIGTERM, SIGUSR1, SIGUSR2},
    iterator::Signals,
};

// Children wait forever and print a message when they receive SIGUSR1 or SIGUSR2.
fn child(child_num: u32, _: ()) {
    info!("Starting child {child_num}");
    let mut signals = Signals::new([SIGUSR1, SIGUSR2]).expect("catch signals");
    for signal in signals.forever() {
        info!("Child {child_num} got signal {signal}");
    }
    info!("Stopping child {child_num}");
}

// The parent forwards SIGUSR1 and SIGUSR2 to the children.
// Other signals cause the children to be reaped.
fn manage_children(mut pids: HashSet<Pid>) -> Result<()> {
    let parent_pid = process::id();
    debug!("Handling signals in parent {parent_pid}");
    let mut signals = Signals::new([SIGINT, SIGTERM, SIGQUIT, SIGUSR1, SIGUSR2, SIGCHLD])?;
    for signal in signals.forever() {
        match signal {
            SIGCHLD => {
                prefork::wait_process(&mut pids);
                if pids.is_empty() {
                    break;
                }
            }
            SIGUSR1 | SIGUSR2 => {
                // Pass signals to children.
                let signal = Signal::try_from(signal).expect("convert i32 signal for kill");
                for child in &pids {
                    kill(child.clone(), signal).expect("forward signal to child");
                }
            }
            _ => break,
        }
    }
    prefork::kill_all(pids)
}

fn main() {
    // Send logs to tracing crate.
    tracing_subscriber::fmt()
        .with_max_level(tracing::Level::DEBUG)
        .without_time()
        .init();

    // Create a prefork server.
    let mut server = Prefork::from_resource(())
        .with_num_processes(10)
        .with_init(child)
        .server();

    let Some(pids) = server.prefork().expect("fork") else {
        // We're the child process.
        return;
    };

    // Manage signals and reap children
    manage_children(pids).expect("well behaved children");
}