max/embassy
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

wpan/mac: incr. runner msdu handle

Browse Source
This commit is contained in:
xoviat 2023-07-20 17:00:03 -05:00
parent 809d3476aa
commit 83ff626c47
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
embassy-stm32-wpan/src/mac/runner.rs
View File

@ -46,6 +46,8 @@ impl<'a> Runner<'a> {
} }
}, },
async { async {
let mut msdu_handle = 0x02;
loop { loop {
let (buf, len) = self.tx_channel.recv().await; let (buf, len) = self.tx_channel.recv().await;
@ -56,7 +58,7 @@ impl<'a> Runner<'a> {
dst_addr_mode: AddressMode::Short, dst_addr_mode: AddressMode::Short,
dst_pan_id: PanId([0x1A, 0xAA]), dst_pan_id: PanId([0x1A, 0xAA]),
dst_address: MacAddress::BROADCAST, dst_address: MacAddress::BROADCAST,
msdu_handle: 0x02, msdu_handle: msdu_handle,
ack_tx: 0x00, ack_tx: 0x00,
gts_tx: false, gts_tx: false,
security_level: SecurityLevel::Unsecure, security_level: SecurityLevel::Unsecure,
@ -67,6 +69,8 @@ impl<'a> Runner<'a> {
.await .await
.unwrap(); .unwrap();
msdu_handle += 1;
// The tx channel should always be of equal capacity to the tx_buf channel // The tx channel should always be of equal capacity to the tx_buf channel
self.tx_buf_channel.try_send(buf).unwrap(); self.tx_buf_channel.try_send(buf).unwrap();
} }