aramperes/onetun
1
0
Fork 0
mirror of https://github.com/aramperes/onetun.git synced 2025-09-08 23:58:31 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Spawn tunnels in entirely separate threads

Browse source
This commit is contained in:
Aram 🍐 2021-10-18 03:54:13 -04:00
parent 651ddaec49
commit ed835c47d3
1 changed files with 12 additions and 12 deletions
Download patch file Download diff file Expand all files Collapse all files

24
src/main.rs
View file

@ -58,22 +58,22 @@ async fn main() -> anyhow::Result<()> {
let port_forwards = config.port_forwards;
let source_peer_ip = config.source_peer_ip;
futures::future::try_join_all(
port_forwards
.into_iter()
.map(|pf| (pf, wg.clone(), port_pool.clone()))
.map(|(pf, wg, port_pool)| {
tokio::spawn(async move {
port_forwards
.into_iter()
.map(|pf| (pf, wg.clone(), port_pool.clone()))
.for_each(move |(pf, wg, port_pool)| {
std::thread::spawn(move || {
let cpu_pool = tokio::runtime::Runtime::new().unwrap();
cpu_pool.block_on(async move {
port_forward(pf, source_peer_ip, port_pool, wg)
.await
.unwrap_or_else(|e| error!("Port-forward failed for {} : {}", pf, e))
})
}),
)
.await
.with_context(|| "A port-forward instance failed.")
.map(|_| ())
});
});
});
}
futures::future::pending().await
}
async fn port_forward(