1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
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();
}
|
