studio/tuwunel
2
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

Log debug_warn msg for client disconnect from request.

Browse Source 
Signed-off-by: Jason Volk <jason@zemos.net>
This commit is contained in:
Jason Volk
2026-02-14 01:59:57 +00:00
parent 289eaa57a3
commit 75e63c93ab
1 changed files with 9 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
src/router/request.rs
View File

@@ -12,7 +12,7 @@ use futures::FutureExt;
use http::{Method, StatusCode, Uri}; use http::{Method, StatusCode, Uri};
use tokio::{task, time::sleep}; use tokio::{task, time::sleep};
use tracing::Span; use tracing::Span;
use tuwunel_core::{Result, debug, debug_error, debug_warn, err, error, trace}; use tuwunel_core::{Result, debug, debug_error, debug_warn, defer, err, error, trace};
use tuwunel_service::Services; use tuwunel_service::Services;
#[tracing::instrument( #[tracing::instrument(
@@ -62,6 +62,13 @@ pub(crate) async fn handle(
} }
}); });
let abort = task.abort_handle();
defer! {{
if !abort.is_finished() {
debug_warn!(task = ?abort.id(), "Client disconnected; detached request.");
}
}}
task.await task.await
.map_err(unhandled) .map_err(unhandled)
.and_then(move |result| handle_result(&method, &uri, result)) .and_then(move |result| handle_result(&method, &uri, result))
@@ -95,7 +102,7 @@ async fn execute(
.fetch_add(1, Ordering::Relaxed); .fetch_add(1, Ordering::Relaxed);
#[cfg(debug_assertions)] #[cfg(debug_assertions)]
tuwunel_core::defer! {{ defer! {{
_ = services.server _ = services.server
.metrics .metrics
.requests_handle_finished .requests_handle_finished