1 files changed, 131 insertions, 0 deletions
diff --git a/vendor/tracing-subscriber/tests/multiple_layer_filter_interests_cached.rs b/vendor/tracing-subscriber/tests/multiple_layer_filter_interests_cached.rs
new file mode 100644
index 000000000..5c25e7f03
--- /dev/null
+++ b/vendor/tracing-subscriber/tests/multiple_layer_filter_interests_cached.rs
@@ -0,0 +1,131 @@
+#![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() {
+    // This layer will return Interest::always for INFO and lower.
+    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);
+
+    // This layer will return Interest::always for WARN and lower.
+    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();
+}