vmario/fabaccess-bffh
1
0
Fork 0
mirror of https://gitlab.com/fabinfra/fabaccess/bffh.git synced 2024-11-22 06:47:56 +01:00
Code Issues Packages Projects Releases Wiki Activity

Properly stop api server

Browse Source
This commit is contained in:
Gregor Reitzenstein 2020-12-16 12:27:34 +01:00
parent be73385758
commit 7bdbdac86b
2 changed files with 8 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/main.rs
View File

@ -175,8 +175,11 @@ fn maybe(matches: clap::ArgMatches, log: Arc<Logger>) -> Result<(), Error> {
// TODO: Spawn api connections on their own (non-main) thread, use the main thread to // TODO: Spawn api connections on their own (non-main) thread, use the main thread to
// handle signals (a cli if stdin is not closed?) and make it stop and clean up all threads // handle signals (a cli if stdin is not closed?) and make it stop and clean up all threads
// when bffh should exit // when bffh should exit
server::serve_api_connections(log.clone(), config, db, network) let r = server::serve_api_connections(log.clone(), config, db, network);
// Signal is dropped here, stopping all executor threads as well.
signal.try_send(());
std::mem::drop(signal);
return r;
}); });
return r; return r;

3
src/server.rs
View File

@ -54,6 +54,7 @@ pub fn serve_api_connections(log: Arc<Logger>, config: Settings, db: Databases,
.map(|l| { .map(|l| {
let addr = l.address.clone(); let addr = l.address.clone();
let port = l.port.unwrap_or(config::DEFAULT_PORT); let port = l.port.unwrap_or(config::DEFAULT_PORT);
info!(&log, "Binding to {} port {}.", l.address.as_str(), &port);
TcpListener::bind((l.address.as_str(), port)) TcpListener::bind((l.address.as_str(), port))
// If the bind errors, include the address so we can log it // If the bind errors, include the address so we can log it
// Since this closure is lazy we need to have a cloned addr // Since this closure is lazy we need to have a cloned addr
@ -124,6 +125,8 @@ pub fn serve_api_connections(log: Arc<Logger>, config: Settings, db: Databases,
return LoopResult::Continue; return LoopResult::Continue;
}); });
info!(&log, "Started");
// Check each signal as it arrives // Check each signal as it arrives
let handle_signals = signal.map(|r| { r.unwrap() }).into_stream(); let handle_signals = signal.map(|r| { r.unwrap() }).into_stream();