From f9739b05335005d6ed46d8e2642ccbbe11ea0eeb Mon Sep 17 00:00:00 2001 From: irriden Date: Tue, 25 Jul 2023 19:05:02 +0000 Subject: [PATCH] broker: nit clarify comment and logging --- broker/src/mqtt.rs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/broker/src/mqtt.rs b/broker/src/mqtt.rs index f16c425..0fbed70 100644 --- a/broker/src/mqtt.rs +++ b/broker/src/mqtt.rs @@ -160,8 +160,6 @@ fn pub_and_wait( // for a specific client log::debug!("publishing to a specific client"); let res_opt = pub_timeout(&cid, &msg.topic, &msg.message, &msg_rx, link_tx); - log::debug!("client responded!"); - // control topic should be able to fail early without retrying res_opt } else { log::debug!("publishing to all clients"); @@ -191,6 +189,8 @@ fn pub_and_wait( log::warn!("could not send on reply_tx"); } break; + } else { + log::debug!("couldn't reach any clients..."); } if let Some(attempt) = retries { if counter == attempt {