From 4987d5ee1f6865ba068928c33c3abc3b361d0e34 Mon Sep 17 00:00:00 2001 From: Stas Kelvich Date: Fri, 9 Jul 2021 16:45:48 +0300 Subject: [PATCH] reduce lodding in wal_acceptor --- walkeeper/src/bin/wal_acceptor.rs | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/walkeeper/src/bin/wal_acceptor.rs b/walkeeper/src/bin/wal_acceptor.rs index 0ef0436605..6d9e60bddf 100644 --- a/walkeeper/src/bin/wal_acceptor.rs +++ b/walkeeper/src/bin/wal_acceptor.rs @@ -195,12 +195,19 @@ fn init_logging( if conf.daemonize { let decorator = slog_term::PlainSyncDecorator::new(log_file); let drain = slog_term::CompactFormat::new(decorator).build(); + let drain = slog::Filter::new(drain, |record: &slog::Record| { + record.level().is_at_least(slog::Level::Info) + }); let drain = std::sync::Mutex::new(drain).fuse(); let logger = slog::Logger::root(drain, slog::o!()); Ok(slog_scope::set_global_logger(logger)) } else { let decorator = slog_term::TermDecorator::new().build(); let drain = slog_term::FullFormat::new(decorator).build().fuse(); + let drain = slog::Filter::new(drain, |record: &slog::Record| { + record.level().is_at_least(slog::Level::Info) + }) + .fuse(); let drain = slog_async::Async::new(drain).chan_size(1000).build().fuse(); let logger = slog::Logger::root(drain, slog::o!()); Ok(slog_scope::set_global_logger(logger))