From 1bc60950eb070700d779f552d252e8f8274610bf Mon Sep 17 00:00:00 2001 From: Ian Jackson Date: Tue, 17 Aug 2021 00:41:33 +0100 Subject: [PATCH] server: reorganise setup Signed-off-by: Ian Jackson --- src/bin/server.rs | 13 +++++++------ 1 file changed, 7 insertions(+), 6 deletions(-) diff --git a/src/bin/server.rs b/src/bin/server.rs index b0d347c..297740a 100644 --- a/src/bin/server.rs +++ b/src/bin/server.rs @@ -425,6 +425,7 @@ async fn main() { let ipif = Ipif::start(&global_config.ipif, None)?; + let ics = ics.into_iter().map(Arc::new).collect_vec(); let (client_handles_send, client_handles_recv) = ics.iter() .map(|_ic| mpsc::channel( 5 // xxx should me max_requests_outstanding but that's @@ -436,18 +437,18 @@ async fn main() { client_handles_send, client_handles_recv, ).map(|(ic, web_send, web_recv)| { - let ic = Arc::new(ic); + let r = (ic.link.client, + Client { + ic: ic.clone(), + web: web_send, + }); let ic_ = ic.clone(); tasks.push((tokio::spawn(async move { run_client(ic_, web_recv).await.void_unwrap_err() }), format!("client {}", &ic))); - (ic.link.client, - Client { - ic, - web: web_send, - }) + r }).collect(); let global = Arc::new(Global { config: global_config, -- 2.30.2