From 81379a11660687e6eb060cdcbee321731cb6fded Mon Sep 17 00:00:00 2001
From: Federico Lolli <federico123579@gmail.com>
Date: Mon, 12 Feb 2024 19:14:30 +0100
Subject: [PATCH] removed CTS control (unavailable on macos)
---
src/main.rs | 27 +++++++--------------------
1 file changed, 7 insertions(+), 20 deletions(-)
diff --git a/src/main.rs b/src/main.rs
index 47d4b0c..bf6c009 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -73,27 +73,14 @@ fn main() {
let mut start: Option<Instant> = None;
let mut times = Vec::new();
- loop {
- // wait clear to send
- port.write_request_to_send(true).expect("Unable to set RTS");
- while !port.read_clear_to_send().expect("Unable to read CTS") {
- std::thread::sleep(Duration::from_millis(100));
- debug!("waiting for CTS");
- }
-
- // send packet if there is one
- if let Some(packet) = packets.wait_next() {
- if let Some(t) = start {
- times.push(t.elapsed().as_millis());
- }
- start = Some(Instant::now());
- write_port.write_packet(packet.to_owned());
- debug!("sent packet ({}/{})", packets.index, packets.packets.len());
- port.write_request_to_send(false)
- .expect("Unable to set RTS");
- } else {
- break;
+ // send packet if there is one
+ while let Some(packet) = packets.wait_next() {
+ if let Some(t) = start {
+ times.push(t.elapsed().as_millis());
}
+ start = Some(Instant::now());
+ write_port.write_packet(packet.to_owned());
+ debug!("sent packet ({}/{})", packets.index, packets.packets.len());
// wait ACK
loop {
--
GitLab