From 44d849dccfbd5a21cc18a991259e66aeb66a4aed Mon Sep 17 00:00:00 2001 From: irriden Date: Tue, 25 Jul 2023 17:47:40 +0000 Subject: [PATCH] broker: switch pub_timeout from 9 to 4 secs --- broker/src/mqtt.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/broker/src/mqtt.rs b/broker/src/mqtt.rs index a0ebc2d..f16c425 100644 --- a/broker/src/mqtt.rs +++ b/broker/src/mqtt.rs @@ -218,7 +218,7 @@ fn pub_timeout( log::error!("failed to pub to link_tx! {:?}", e); } // and receive from the correct client (or timeout to next) - let dur = Duration::from_secs(9); + let dur = Duration::from_secs(4); if let Ok((cid, topic_end, reply)) = msg_rx.recv_timeout(dur) { if &cid == client_id { return Some(ChannelReply::new(topic_end, reply));