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

Pass network

Browse Source
This commit is contained in:
Gregor Reitzenstein 2020-12-15 13:04:03 +01:00
parent 6d5802c0a5
commit 7b5d8de93f
2 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/main.rs
View File

@ -176,7 +176,7 @@ 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) server::serve_api_connections(log.clone(), config, db, network)
// Signal is dropped here, stopping all executor threads as well. // Signal is dropped here, stopping all executor threads as well.
} }
} }

4
src/server.rs
View File

@ -27,7 +27,9 @@ use std::sync::Arc;
use crate::db::Databases; use crate::db::Databases;
/// Handle all API connections and run the RPC tasks spawned from that on the local thread. /// Handle all API connections and run the RPC tasks spawned from that on the local thread.
pub fn serve_api_connections(log: Arc<Logger>, config: Settings, db: Databases) -> Result<(), Error> { pub fn serve_api_connections(log: Arc<Logger>, config: Settings, db: Databases, nw: Network)
-> Result<(), Error>
{
let signal = Box::pin(async { let signal = Box::pin(async {
let (tx, mut rx) = UnixStream::pair()?; let (tx, mut rx) = UnixStream::pair()?;
// Initialize signal handler. // Initialize signal handler.