diff options
| author | Dario Nieuwenhuis <[email protected]> | 2022-12-27 01:07:58 +0100 |
|---|---|---|
| committer | Dario Nieuwenhuis <[email protected]> | 2022-12-27 01:07:58 +0100 |
| commit | 771806be790a2758f1314d6460defe7c2f0d3e99 (patch) | |
| tree | ea20047099f48b1ac3014ffb36b892ef25f25de8 /embassy-usb/src/class | |
| parent | 4a4b59369482572c415487b9d90166e7c19b592a (diff) | |
net/chan: split state runner.
Diffstat (limited to 'embassy-usb/src/class')
| -rw-r--r-- | embassy-usb/src/class/cdc_ncm/embassy_net.rs | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/embassy-usb/src/class/cdc_ncm/embassy_net.rs b/embassy-usb/src/class/cdc_ncm/embassy_net.rs index 7ecf693d2..501df2d8c 100644 --- a/embassy-usb/src/class/cdc_ncm/embassy_net.rs +++ b/embassy-usb/src/class/cdc_ncm/embassy_net.rs | |||
| @@ -25,16 +25,16 @@ pub struct Runner<'d, D: Driver<'d>, const MTU: usize> { | |||
| 25 | 25 | ||
| 26 | impl<'d, D: Driver<'d>, const MTU: usize> Runner<'d, D, MTU> { | 26 | impl<'d, D: Driver<'d>, const MTU: usize> Runner<'d, D, MTU> { |
| 27 | pub async fn run(mut self) -> ! { | 27 | pub async fn run(mut self) -> ! { |
| 28 | let (mut rx_chan, mut tx_chan) = self.ch.split(); | 28 | let (state_chan, mut rx_chan, mut tx_chan) = self.ch.split(); |
| 29 | let rx_fut = async move { | 29 | let rx_fut = async move { |
| 30 | loop { | 30 | loop { |
| 31 | trace!("WAITING for connection"); | 31 | trace!("WAITING for connection"); |
| 32 | rx_chan.set_link_state(LinkState::Down); | 32 | state_chan.set_link_state(LinkState::Down); |
| 33 | 33 | ||
| 34 | self.rx_usb.wait_connection().await.unwrap(); | 34 | self.rx_usb.wait_connection().await.unwrap(); |
| 35 | 35 | ||
| 36 | trace!("Connected"); | 36 | trace!("Connected"); |
| 37 | rx_chan.set_link_state(LinkState::Up); | 37 | state_chan.set_link_state(LinkState::Up); |
| 38 | 38 | ||
| 39 | loop { | 39 | loop { |
| 40 | let p = rx_chan.rx_buf().await; | 40 | let p = rx_chan.rx_buf().await; |