diff options
Diffstat (limited to 'tests/option_filter_interest_caching.rs')
-rw-r--r-- | tests/option_filter_interest_caching.rs | 53 |
1 files changed, 53 insertions, 0 deletions
diff --git a/tests/option_filter_interest_caching.rs b/tests/option_filter_interest_caching.rs new file mode 100644 index 0000000..609007c --- /dev/null +++ b/tests/option_filter_interest_caching.rs @@ -0,0 +1,53 @@ +// A separate test crate for `Option<Filter>` for isolation from other tests +// that may influence the interest cache. + +use std::sync::{ + atomic::{AtomicUsize, Ordering}, + Arc, +}; +use tracing_mock::{expect, layer}; +use tracing_subscriber::{filter, prelude::*, Layer}; + +/// A `None` filter should always be interested in events, and it should not +/// needlessly degrade the caching of other filters. +#[test] +fn none_interest_cache() { + let (layer_none, handle_none) = layer::mock() + .event(expect::event()) + .event(expect::event()) + .only() + .run_with_handle(); + let layer_none = layer_none.with_filter(None::<filter::DynFilterFn<_>>); + + let times_filtered = Arc::new(AtomicUsize::new(0)); + let (layer_filter_fn, handle_filter_fn) = layer::mock() + .event(expect::event()) + .event(expect::event()) + .only() + .run_with_handle(); + let layer_filter_fn = layer_filter_fn.with_filter(filter::filter_fn({ + let times_filtered = Arc::clone(×_filtered); + move |_| { + times_filtered.fetch_add(1, Ordering::Relaxed); + true + } + })); + + let subscriber = tracing_subscriber::registry() + .with(layer_none) + .with(layer_filter_fn); + + let _guard = subscriber.set_default(); + for _ in 0..2 { + tracing::debug!(target: "always_interesting", x="bar"); + } + + // The `None` filter is unchanging and performs no filtering, so it should + // be cacheable and always be interested in events. The filter fn is a + // non-dynamic filter fn, which means the result can be cached per callsite. + // The filter fn should only need to be called once, and the `Option` filter + // should not interfere in the caching of that result. + assert_eq!(times_filtered.load(Ordering::Relaxed), 1); + handle_none.assert_finished(); + handle_filter_fn.assert_finished(); +} |