reactor
/
ptth
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Add forced shutdown to ptth_relay.

main
_ 2020-11-07 02:29:45 +00:00
parent 9e134d55aa
commit e0b8c8cb58
2 changed files with 11 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/bin/ptth_relay.rs
View File

@ -25,8 +25,14 @@ async fn main () -> Result <(), Box <dyn Error>> {
info! ("ptth_relay Git version: {:?}", ptth::git_version::GIT_VERSION); info! ("ptth_relay Git version: {:?}", ptth::git_version::GIT_VERSION);
relay::run_relay ( let (shutdown_rx, forced_shutdown) = ptth::graceful_shutdown::init_with_force ();
Arc::new (RelayState::from (&config_file)),
ptth::graceful_shutdown::init () forced_shutdown.wrap_server (
).await relay::run_relay (
Arc::new (RelayState::from (&config_file)),
shutdown_rx
)
).await??;
Ok (())
} }

4
src/relay/mod.rs
View File

@ -586,7 +586,6 @@ pub async fn run_relay (
server.with_graceful_shutdown (async { server.with_graceful_shutdown (async {
shutdown_oneshot.await.ok (); shutdown_oneshot.await.ok ();
info! ("Received graceful shutdown");
state.shutdown_watch_tx.broadcast (true).unwrap (); state.shutdown_watch_tx.broadcast (true).unwrap ();
@ -612,10 +611,9 @@ pub async fn run_relay (
} }
} }
info! ("Performed all cleanup"); debug! ("Performed all cleanup");
}).await?; }).await?;
info! ("Exiting");
Ok (()) Ok (())
} }