#![cfg(feature = "registry")]
mod support;
use self::support::*;
use std::{
collections::HashMap,
sync::{Arc, Mutex},
};
use tracing::{Level, Subscriber};
use tracing_subscriber::{filter, prelude::*};
#[test]
fn multiple_layer_filter_interests_are_cached() {
let seen_info = Arc::new(Mutex::new(HashMap::new()));
let seen_info2 = seen_info.clone();
let filter = filter::filter_fn(move |meta| {
*seen_info
.lock()
.unwrap()
.entry(*meta.level())
.or_insert(0usize) += 1;
meta.level() <= &Level::INFO
});
let seen_info = seen_info2;
let (info_layer, info_handle) = layer::named("info")
.event(event::mock().at_level(Level::INFO))
.event(event::mock().at_level(Level::WARN))
.event(event::mock().at_level(Level::ERROR))
.event(event::mock().at_level(Level::INFO))
.event(event::mock().at_level(Level::WARN))
.event(event::mock().at_level(Level::ERROR))
.done()
.run_with_handle();
let info_layer = info_layer.with_filter(filter);
let seen_warn = Arc::new(Mutex::new(HashMap::new()));
let seen_warn2 = seen_warn.clone();
let filter = filter::filter_fn(move |meta| {
*seen_warn
.lock()
.unwrap()
.entry(*meta.level())
.or_insert(0usize) += 1;
meta.level() <= &Level::WARN
});
let seen_warn = seen_warn2;
let (warn_layer, warn_handle) = layer::named("warn")
.event(event::mock().at_level(Level::WARN))
.event(event::mock().at_level(Level::ERROR))
.event(event::mock().at_level(Level::WARN))
.event(event::mock().at_level(Level::ERROR))
.done()
.run_with_handle();
let warn_layer = warn_layer.with_filter(filter);
let subscriber = tracing_subscriber::registry()
.with(warn_layer)
.with(info_layer);
assert!(subscriber.max_level_hint().is_none());
let _subscriber = subscriber.set_default();
fn events() {
tracing::trace!("hello trace");
tracing::debug!("hello debug");
tracing::info!("hello info");
tracing::warn!("hello warn");
tracing::error!("hello error");
}
events();
{
let lock = seen_info.lock().unwrap();
for (&level, &count) in lock.iter() {
if level == Level::INFO {
continue;
}
assert_eq!(
count, 1,
"level {:?} should have been seen 1 time by the INFO layer (after first set of events)",
level
);
}
let lock = seen_warn.lock().unwrap();
for (&level, &count) in lock.iter() {
if level == Level::INFO {
continue;
}
assert_eq!(
count, 1,
"level {:?} should have been seen 1 time by the WARN layer (after first set of events)",
level
);
}
}
events();
{
let lock = seen_info.lock().unwrap();
for (&level, &count) in lock.iter() {
if level == Level::INFO {
continue;
}
assert_eq!(
count, 1,
"level {:?} should have been seen 1 time by the INFO layer (after second set of events)",
level
);
}
let lock = seen_warn.lock().unwrap();
for (&level, &count) in lock.iter() {
if level == Level::INFO {
continue;
}
assert_eq!(
count, 1,
"level {:?} should have been seen 1 time by the WARN layer (after second set of events)",
level
);
}
}
info_handle.assert_finished();
warn_handle.assert_finished();
}