From 7ad03e91bc34cd1b2f75f97509d65b6c50beb3d4 Mon Sep 17 00:00:00 2001 From: slonkazoid Date: Thu, 13 Jun 2024 23:43:03 +0300 Subject: [PATCH] move sigterm functionality out --- src/main.rs | 17 +++-------------- 1 file changed, 3 insertions(+), 14 deletions(-) diff --git a/src/main.rs b/src/main.rs index c352c95..86cae0e 100644 --- a/src/main.rs +++ b/src/main.rs @@ -6,6 +6,7 @@ mod error; mod filters; mod hash_arc_store; mod markdown_render; +mod platform; mod post; mod ranged_i128_visitor; mod systemtime_as_secs; @@ -93,13 +94,7 @@ async fn main() -> eyre::Result<()> { info!("listening on http://{}", local_addr); let sigint = signal::ctrl_c(); - #[cfg(unix)] - let mut sigterm_handler = - tokio::signal::unix::signal(tokio::signal::unix::SignalKind::terminate())?; - #[cfg(unix)] - let sigterm = sigterm_handler.recv(); - #[cfg(not(unix))] // TODO: kill all windows server users - let sigterm = std::future::pending::<()>(); + let sigterm = platform::sigterm(); let axum_token = cancellation_token.child_token(); @@ -135,13 +130,7 @@ async fn main() -> eyre::Result<()> { }; let sigint = signal::ctrl_c(); - #[cfg(unix)] - let mut sigterm_handler = - tokio::signal::unix::signal(tokio::signal::unix::SignalKind::terminate())?; - #[cfg(unix)] - let sigterm = sigterm_handler.recv(); - #[cfg(not(unix))] - let sigterm = std::future::pending::<()>(); + let sigterm = platform::sigterm(); tokio::select! { result = cleanup => {