🩹 logging
This commit is contained in:
parent
f381f30e27
commit
00e448ac31
2 changed files with 1 additions and 2 deletions
|
@ -368,7 +368,6 @@ impl<
|
||||||
}
|
}
|
||||||
|
|
||||||
pub fn send_async(&self, param: I) -> JobResult<O> {
|
pub fn send_async(&self, param: I) -> JobResult<O> {
|
||||||
log::info!("Sending async reqeust");
|
|
||||||
let d = get_random_item(&self.dispatchers).unwrap();
|
let d = get_random_item(&self.dispatchers).unwrap();
|
||||||
d.send_async(param)
|
d.send_async(param)
|
||||||
}
|
}
|
||||||
|
|
|
@ -120,7 +120,7 @@ impl ServiceManager {
|
||||||
|
|
||||||
for (service, (t, dm)) in &mut threads {
|
for (service, (t, dm)) in &mut threads {
|
||||||
let alive = dm.alive();
|
let alive = dm.alive();
|
||||||
log::debug!(
|
log::trace!(
|
||||||
"Checking up on {service} -- {}",
|
"Checking up on {service} -- {}",
|
||||||
if alive { "ALIVE" } else { "DEAD" }
|
if alive { "ALIVE" } else { "DEAD" }
|
||||||
);
|
);
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue