WIP: listen for sighups and reconfigure?
This commit is contained in:
parent
2c4a176e66
commit
7a3fec6fec
|
@ -192,6 +192,8 @@ pub use cfg::{
|
|||
ApplicationConfig, ApplicationConfigBuilder, ArtiCombinedConfig, ArtiConfig, ArtiConfigBuilder,
|
||||
ProxyConfig, ProxyConfigBuilder, SystemConfig, SystemConfigBuilder, ARTI_EXAMPLE_CONFIG,
|
||||
};
|
||||
use futures::stream::StreamExt;
|
||||
use futures::task::SpawnExt;
|
||||
pub use logging::{LoggingConfig, LoggingConfigBuilder};
|
||||
|
||||
use arti_client::config::default_config_files;
|
||||
|
@ -266,6 +268,17 @@ async fn run<R: Runtime>(
|
|||
watch_cfg::watch_for_config_changes(config_sources, arti_config, client.clone())?;
|
||||
}
|
||||
|
||||
#[cfg(target_family = "unix")]
|
||||
{
|
||||
// let client = client.clone();
|
||||
let mut sighup_stream = process::sighup_stream()?;
|
||||
runtime.spawn(async move {
|
||||
while let Some(()) = sighup_stream.next().await {
|
||||
info!("SIGHUP!");
|
||||
}
|
||||
})?;
|
||||
}
|
||||
|
||||
let mut proxy: Vec<PinnedFuture<(Result<()>, &str)>> = Vec::new();
|
||||
if socks_port != 0 {
|
||||
let runtime = runtime.clone();
|
||||
|
|
Loading…
Reference in New Issue