Function handle_shutdown_signals

supervisor/src/web_api.rs:108–138

(supervisor: Supervisor)

}

async fn handle_shutdown_signals(supervisor: Supervisor) {
    let ctrl_c = async {
        signal::ctrl_c()
            .await
            .or_panic("failed to install Ctrl+C handler");
    };

    #[cfg(unix)]
    let terminate = async {
        signal::unix::signal(signal::unix::SignalKind::terminate())
            .or_panic("failed to install signal handler")
            .recv()
            .await;
    };

    #[cfg(not(unix))]
    let terminate = std::future::pending::<()>();

    tokio::select! {
        _ = ctrl_c => {
            println!("Received Ctrl+C signal, initiating shutdown...");
        }
        _ = terminate => {
            println!("Received terminate signal, initiating shutdown...");
        }
    }

    perform_shutdown(&supervisor, true)
        .await
        .or_panic("Force shutdown should never return");
}