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

Additional metrics on shutdown from rusage.

Browse Source 
Signed-off-by: Jason Volk <jason@zemos.net>
This commit is contained in:
Jason Volk
2026-02-26 00:03:41 +00:00
parent 37818e1a25
commit 081394c313
1 changed files with 20 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

29
src/main/runtime.rs
View File

@@ -14,7 +14,10 @@ pub use tokio::runtime::{Handle, Runtime};
use tuwunel_core::result::LogDebugErr; use tuwunel_core::result::LogDebugErr;
use tuwunel_core::{ use tuwunel_core::{
Result, debug, is_true, Result, debug, is_true,
utils::sys::compute::{nth_core_available, set_affinity}, utils::sys::{
compute::{nth_core_available, set_affinity},
thread_usage, usage,
},
}; };
use crate::{Args, Server}; use crate::{Args, Server};
@@ -95,20 +98,22 @@ pub fn shutdown(server: &Arc<Server>, runtime: Runtime) -> Result {
// The final metrics output is promoted to INFO when tokio_unstable is active in // The final metrics output is promoted to INFO when tokio_unstable is active in
// a release/bench mode and DEBUG is likely optimized out // a release/bench mode and DEBUG is likely optimized out
const LEVEL: Level = if cfg!(debug_assertions) { const LEVEL: Level = if cfg!(not(any(tokio_unstable, feature = "release_max_log_level"))) {
Level::DEBUG Level::DEBUG
} else { } else {
Level::INFO Level::INFO
}; };
wait_shutdown(server, runtime); wait_shutdown(server, runtime);
let runtime_metrics = server
.server
.metrics
.runtime_interval()
.unwrap_or_default();
tuwunel_core::event!(LEVEL, ?runtime_metrics, "Final runtime metrics"); if let Some(runtime_metrics) = server.server.metrics.runtime_interval() {
tuwunel_core::event!(LEVEL, ?runtime_metrics, "Final runtime metrics.");
}
if let Ok(resource_usage) = usage() {
tuwunel_core::event!(LEVEL, ?resource_usage, "Final resource usage.");
}
Ok(()) Ok(())
} }
@@ -201,7 +206,13 @@ fn set_worker_mallctl(_: usize) {}
name = %thread::current().name().unwrap_or("None"), name = %thread::current().name().unwrap_or("None"),
), ),
)] )]
fn thread_stop() {} fn thread_stop() {
if cfg!(any(tokio_unstable, not(feature = "release_max_log_level")))
&& let Ok(resource_usage) = thread_usage()
{
tuwunel_core::debug!(?resource_usage, "Thread resource usage.");
}
}
#[tracing::instrument( #[tracing::instrument(
name = "work", name = "work",