bastion-rs
/
bastion
mirror of https://github.com/bastion-rs/bastion
1
0
Fork 0
Code Issues Releases Wiki Activity

Lower dispatcher log to debug (#315)

This commit is contained in:
Theo M. Bulut 2021-03-21 11:12:10 +01:00 committed by GitHub
parent 93b66e4f7c
commit c8f1506380
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/bastion/src/dispatcher.rs
View File

@ -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
);