hex/wstunnel
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Add log when closing remote tunnel

Browse source
This commit is contained in:
Σrebe - Romain GERARD 2024-04-25 21:22:38 +02:00
parent 37d1e50dd4
commit 727e92902c
No known key found for this signature in database
GPG key ID: 7A42B4B97E0332F4
1 changed files with 3 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
src/tunnel/server.rs
View file

@ -194,6 +194,7 @@ where
listening_server listening_server
} else { } else {
let listening_server = gen_listening_server.await?; let listening_server = gen_listening_server.await?;
let send_timeout = Duration::from_secs(30);
let (tx, rx) = mpsc::channel::<T>(1); let (tx, rx) = mpsc::channel::<T>(1);
let fut = async move { let fut = async move {
pin_mut!(listening_server); pin_mut!(listening_server);
@ -208,7 +209,8 @@ where
continue; continue;
} }
Some(Ok(cnx)) => { Some(Ok(cnx)) => {
if tx.send_timeout(cnx, Duration::from_secs(30)).await.is_err() { if tx.send_timeout(cnx, send_timeout).await.is_err() {
info!("New remote connection failed to be picked by client after {}s. Closing remote tunnel server", send_timeout.as_secs());
break; break;
} }
} }