[AsyncCAN] Handle RecvError::Lagged

I-CAN-hack · Apr 1, 2024 · 2051824 · 2051824
1 parent 65e8465
commit 2051824
Showing 1 changed file with 6 additions and 4 deletions.
diff --git a/src/can/async_can.rs b/src/can/async_can.rs
@@ -7,6 +7,7 @@ use crate::can::Frame;
 use crate::can::Identifier;
 use crate::Stream;
 use async_stream::stream;
+use tokio::sync::broadcast::error::RecvError;
 use tokio::sync::{broadcast, mpsc, oneshot};
 use tracing::debug;
 
@@ -142,11 +143,12 @@ impl AsyncCanAdapter {
  Ok(frame) => {
  if filter(&frame) {
  yield frame
- } else {
- continue
  }
- }
- Err(_) => continue,
+ },
+ Err(RecvError::Closed) => panic!("Adapter thread has exited"),
+ Err(RecvError::Lagged(n)) => {
+ tracing::warn!("Receive too slow, dropping {} frame(s).", n)
+ },
  }
  }
  })