From c8f1506380f55b548cb452ac434931ca6955d9ac Mon Sep 17 00:00:00 2001 From: "Theo M. Bulut" Date: Sun, 21 Mar 2021 11:12:10 +0100 Subject: [PATCH] Lower dispatcher log to debug (#315) --- src/bastion/src/dispatcher.rs | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/bastion/src/dispatcher.rs b/src/bastion/src/dispatcher.rs index 7306e9d8..67667777 100644 --- a/src/bastion/src/dispatcher.rs +++ b/src/bastion/src/dispatcher.rs @@ -12,7 +12,7 @@ use std::sync::{ atomic::{AtomicUsize, Ordering}, Arc, }; -use tracing::{debug, trace, warn}; +use tracing::{debug, trace}; /// Type alias for the concurrency hashmap. Each key-value pair stores /// the Bastion identifier as the key and the module name as the value. @@ -92,7 +92,7 @@ impl DispatcherHandler for RoundRobinHandler { let current_index = self.index.load(Ordering::SeqCst) % entries.len(); if let Some(entry) = entries.get(current_index) { - warn!( + debug!( "sending message to child {}/{} - {}", current_index + 1, entries.len(), @@ -354,7 +354,7 @@ impl GlobalDispatcher { // TODO: Put the message into the dead queue None => { let name = dispatcher_type.name(); - warn!( + debug!( "The message can't be delivered to the group with the '{}' name.", name ); @@ -369,7 +369,7 @@ impl GlobalDispatcher { let is_registered = self.dispatchers.contains_key(&dispatcher_type); if is_registered && dispatcher_type != DispatcherType::Anonymous { - warn!( + debug!( "The dispatcher with the '{:?}' name already registered in the cluster.", dispatcher_type );