mirror
/
rqbit
mirror of https://github.com/ikatson/rqbit
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Trying to see if simply reordering filters would help tracing

This commit is contained in:
Igor Katson 2025-06-27 07:31:53 +01:00
parent 2d5db26a2a
commit ed9a68ea43
No known key found for this signature in database
GPG Key ID: B4EC22B66D61A3F5
1 changed files with 8 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
crates/librqbit/src/tracing_subscriber_config_utils.rs
View File

@ -4,7 +4,7 @@ use anyhow::Context;
use bytes::Bytes;
use librqbit_core::spawn_utils::spawn;
use tracing::error_span;
use tracing_subscriber::fmt::MakeWriter;
use tracing_subscriber::{filter::FilterExt, fmt::MakeWriter};
struct Subscriber {
tx: tokio::sync::broadcast::Sender<Bytes>,
@ -89,11 +89,13 @@ pub fn init_logging(opts: InitLoggingOptions) -> anyhow::Result<InitLoggingResul
.fmt_fields(tracing_subscriber::fmt::format::JsonFields::new())
.event_format(fmt::format().with_ansi(false).json())
.with_writer(line_sub)
.with_filter(tracing_subscriber::filter::filter_fn({
let line_broadcast = line_broadcast.clone();
move |_| line_broadcast.receiver_count() > 0
}))
.with_filter(EnvFilter::builder().parse("info,librqbit=debug").unwrap()),
.with_filter(
tracing_subscriber::filter::filter_fn({
let line_broadcast = line_broadcast.clone();
move |_| line_broadcast.receiver_count() > 0
})
.and(EnvFilter::builder().parse("info,librqbit=debug").unwrap()),
),
);
#[cfg(feature = "tokio-console")]