NaxdyOrg/embassy
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

Make usb-logger read and discard input data

Browse source 
This allows normal linux terminal emulators, like screen or picocom
to be used with the usb_logger. Without this, calling `tcsetattr` with
`TCSAFLUSH` will hang.
This commit is contained in:
Dave Hylands 2023-08-06 13:08:08 -07:00
parent 477a90b8e3
commit 8b837fae07
1 changed files with 12 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

17
embassy-usb-logger/src/lib.rs
View file

@ -77,22 +77,29 @@ impl<const N: usize> UsbLogger<N> {
); );
// Create classes on the builder. // Create classes on the builder.
let mut class = CdcAcmClass::new(&mut builder, &mut state.state, MAX_PACKET_SIZE as u16); let class = CdcAcmClass::new(&mut builder, &mut state.state, MAX_PACKET_SIZE as u16);
let (mut sender, mut receiver) = class.split();
// Build the builder. // Build the builder.
let mut device = builder.build(); let mut device = builder.build();
loop { loop {
let run_fut = device.run(); let run_fut = device.run();
let log_fut = async { let log_fut = async {
let mut rx: [u8; MAX_PACKET_SIZE as usize] = [0; MAX_PACKET_SIZE as usize]; let mut rx: [u8; MAX_PACKET_SIZE as usize] = [0; MAX_PACKET_SIZE as usize];
class.wait_connection().await; sender.wait_connection().await;
loop { loop {
let len = self.buffer.read(&mut rx[..]).await; let len = self.buffer.read(&mut rx[..]).await;
let _ = class.write_packet(&rx[..len]).await; let _ = sender.write_packet(&rx[..len]).await;
} }
}; };
join(run_fut, log_fut).await; let discard_fut = async {
let mut discard_buf: [u8; MAX_PACKET_SIZE as usize] = [0; MAX_PACKET_SIZE as usize];
receiver.wait_connection().await;
loop {
let _ = receiver.read_packet(&mut discard_buf).await;
}
};
join(run_fut, join(log_fut, discard_fut)).await;
} }
} }
} }