diff options
Diffstat (limited to 'embassy-usb-logger')
| -rw-r--r-- | embassy-usb-logger/src/lib.rs | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/embassy-usb-logger/src/lib.rs b/embassy-usb-logger/src/lib.rs index 422cefb59..5142d9073 100644 --- a/embassy-usb-logger/src/lib.rs +++ b/embassy-usb-logger/src/lib.rs | |||
| @@ -93,6 +93,9 @@ impl<const N: usize> UsbLogger<N> { | |||
| 93 | loop { | 93 | loop { |
| 94 | let len = self.buffer.read(&mut rx[..]).await; | 94 | let len = self.buffer.read(&mut rx[..]).await; |
| 95 | let _ = sender.write_packet(&rx[..len]).await; | 95 | let _ = sender.write_packet(&rx[..len]).await; |
| 96 | if len as u8 == MAX_PACKET_SIZE { | ||
| 97 | let _ = sender.write_packet(&[]).await; | ||
| 98 | } | ||
| 96 | } | 99 | } |
| 97 | }; | 100 | }; |
| 98 | let discard_fut = async { | 101 | let discard_fut = async { |
| @@ -121,6 +124,9 @@ impl<const N: usize> UsbLogger<N> { | |||
| 121 | loop { | 124 | loop { |
| 122 | let len = self.buffer.read(&mut rx[..]).await; | 125 | let len = self.buffer.read(&mut rx[..]).await; |
| 123 | let _ = sender.write_packet(&rx[..len]).await; | 126 | let _ = sender.write_packet(&rx[..len]).await; |
| 127 | if len as u8 == MAX_PACKET_SIZE { | ||
| 128 | let _ = sender.write_packet(&[]).await; | ||
| 129 | } | ||
| 124 | } | 130 | } |
| 125 | }; | 131 | }; |
| 126 | let discard_fut = async { | 132 | let discard_fut = async { |