GRIN/nym
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Add timeouts

Browse Source
This commit is contained in:
Jon Häggblad
2022-11-22 23:25:06 +01:00
parent c10f788a89
commit c61eb014c5
1 changed files with 24 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
common/socks5/proxy-helpers/src/proxy_runner/inbound.rs
+24 -10
View File
@@ -106,23 +106,37 @@ where
}
async fn wait_until_lane_empty(lane_queue_lengths: LaneQueueLengths, connection_id: u64) {
wait_for_lane(
lane_queue_lengths,
connection_id,
0,
Duration::from_millis(500),
if tokio::time::timeout(
Duration::from_secs(15),
wait_for_lane(
lane_queue_lengths,
connection_id,
0,
Duration::from_millis(500),
),
)
.await
.is_err()
{
log::warn!("Wait until lane empty timed out");
}
}
async fn wait_until_lane_almost_empty(lane_queue_lengths: LaneQueueLengths, connection_id: u64) {
wait_for_lane(
lane_queue_lengths,
connection_id,
10,
Duration::from_millis(100),
if tokio::time::timeout(
Duration::from_secs(15),
wait_for_lane(
lane_queue_lengths,
connection_id,
10,
Duration::from_millis(100),
),
)
.await
.is_err()
{
log::warn!("Wait until lane almost empty timed out");
}
}
async fn wait_for_lane(