From 4f852a6ea254ea48f745b59c076c783965497af7 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Patrick=20Jos=C3=A9=20Pereira?= Date: Tue, 12 Mar 2024 11:12:52 -0300 Subject: [PATCH 1/2] mavlink: manager: Update channel size to 4k messages MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Signed-off-by: Patrick José Pereira --- src/mavlink/manager.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/mavlink/manager.rs b/src/mavlink/manager.rs index 34f4932c..6697df6a 100644 --- a/src/mavlink/manager.rs +++ b/src/mavlink/manager.rs @@ -36,7 +36,7 @@ impl Default for Manager { let address = settings::manager::mavlink_endpoint().expect("No configured mavlink endpoint"); - let (sender, _receiver) = broadcast::channel(100); + let (sender, _receiver) = broadcast::channel(4000); let this = Self { connection: Arc::new(RwLock::new(Connection { From 5c06eba042770e4facc202233823d9d6ad86ddb0 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Patrick=20Jos=C3=A9=20Pereira?= Date: Tue, 12 Mar 2024 11:13:54 -0300 Subject: [PATCH 2/2] mavlink: manager: Decrease sleed loop for receiver to 1ms MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Signed-off-by: Patrick José Pereira --- src/mavlink/manager.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/mavlink/manager.rs b/src/mavlink/manager.rs index 6697df6a..0337c26d 100644 --- a/src/mavlink/manager.rs +++ b/src/mavlink/manager.rs @@ -74,7 +74,7 @@ impl Manager { fn receiver_loop(inner: Arc>) { loop { loop { - std::thread::sleep(std::time::Duration::from_millis(10)); + std::thread::sleep(std::time::Duration::from_millis(1)); let Ok(inner_guard) = inner.read() else { break; // Break to trigger reconnection