reduces buffered lines limit to 8000

zebrad/src/components/tracing/component.rs

@@ -10,7 +10,7 @@ use tracing_subscriber::{
     EnvFilter,
 };
 
-use tracing_appender::non_blocking::{NonBlocking, WorkerGuard};
+use tracing_appender::non_blocking::{NonBlocking, NonBlockingBuilder, WorkerGuard};
 
 use crate::{application::app_version, config::TracingSection};
 
@@ -47,9 +47,13 @@ impl Tracing {
         let filter = config.filter.unwrap_or_else(|| "".to_string());
         let flame_root = &config.flamegraph;
 
-        // By default, the built NonBlocking will be lossy with a line limit of 128_000, lines sent to the worker past
-        // this limit will be dropped without being written to stdout
-        let (non_blocking, _guard) = tracing_appender::non_blocking(std::io::stdout());
+        // Builds a lossy NonBlocking logger with a line limit of 8_000, lines sent to the worker past
+        // this limit (via the write method which sends it to a crossbeam::bounded channel) 
+        // will be dropped without being written to stdout
+        let (non_blocking, _guard) = NonBlockingBuilder::default()
+            .lossy(true)
+            .buffered_lines_limit(8_000)
+            .finish(std::io::stdout());
 
         // Only use color if tracing output is being sent to a terminal or if it was explicitly
         // forced to.

zebrad/tests/acceptance.rs

@@ -1233,7 +1233,7 @@ async fn non_blocking_logger() -> Result<()> {
     // Create an http client
     let client = reqwest::Client::new();
 
-    for _ in 0..10_000 {
+    for _ in 0..20_000 {
         let res = client
             .post(format!("http://{}", &zebra_rpc_address))
             .body(r#"{"jsonrpc":"1.0","method":"getinfo","params":[],"id":123}"#)