luckyimnotanigger/tun2proxy
1
0
Fork 0
mirror of https://github.com/tun2proxy/tun2proxy.git synced 2025-04-20 13:59:10 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 2

refine ctrl-c logic

Browse source
This commit is contained in:
ssrlive 2024-10-09 16:58:37 +08:00
parent 4ef71a5b4c
commit d093973160
1 changed files with 10 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
src/bin/main.rs
View file

@ -28,7 +28,7 @@ async fn main() -> Result<(), BoxError> {
env_logger::Builder::from_env(env_logger::Env::default().default_filter_or(default)).init();
let shutdown_token = tokio_util::sync::CancellationToken::new();
let join_handle = tokio::spawn({
let main_loop_handle = tokio::spawn({
let shutdown_token = shutdown_token.clone();
async move {
#[cfg(target_os = "linux")]
@ -51,14 +51,20 @@ async fn main() -> Result<(), BoxError> {
}
});
ctrlc2::set_async_handler(async move {
let ctrlc_fired = std::sync::Arc::new(std::sync::atomic::AtomicBool::new(false));
let ctrlc_fired_clone = ctrlc_fired.clone();
let ctrlc_handel = ctrlc2::set_async_handler(async move {
log::info!("Ctrl-C received, exiting...");
ctrlc_fired_clone.store(true, std::sync::atomic::Ordering::SeqCst);
shutdown_token.cancel();
})
.await;
if let Err(err) = join_handle.await {
log::error!("main_entry error {}", err);
main_loop_handle.await?;
if ctrlc_fired.load(std::sync::atomic::Ordering::SeqCst) {
log::info!("Ctrl-C fired, waiting the handler to finish...");
ctrlc_handel.await.map_err(|err| err.to_string())?;
}
Ok(())