qi-hardware/ben-wpan
1
0
Fork 0
mirror of git://projects.qi-hardware.com/ben-wpan.git synced 2024-11-22 12:59:21 +02:00
Code

atusb/fw/mac.c: queue frame reception if USB is busy

Browse Source 
This way we we make sure we retrieve the frame and thus release dynamic
buffer protection (if enabled).
This commit is contained in:
Werner Almesberger 2013-04-01 15:17:37 -03:00
parent ad70d7c129
commit 65722d417a
1 changed files with 23 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
atusb/fw/mac.c
View File

@ -30,6 +30,7 @@ static uint8_t tx_buf[MAX_PSDU];
static uint8_t tx_size = 0; static uint8_t tx_size = 0;
static bool txing = 0; static bool txing = 0;
static bool queued_tx_ack = 0; static bool queued_tx_ack = 0;
static bool queued_rx = 0;
static uint8_t reg_read(uint8_t reg) static uint8_t reg_read(uint8_t reg)
@ -54,9 +55,17 @@ static void reg_write(uint8_t reg, uint8_t value)
} }
static void receive_frame(void);
static void rx_done(void *user) static void rx_done(void *user)
{ {
led(0); led(0);
if (queued_rx) {
receive_frame();
queued_rx = 0;
return;
}
if (queued_tx_ack) { if (queued_tx_ack) {
usb_send(&eps[1], "", 1, rx_done, NULL); usb_send(&eps[1], "", 1, rx_done, NULL);
queued_tx_ack = 0; queued_tx_ack = 0;
@ -88,6 +97,14 @@ static void receive_frame(void)
} }
static void flush_queued_rx(void)
{
if (queued_rx)
receive_frame();
queued_rx = 0;
}
static bool handle_irq(void) static bool handle_irq(void)
{ {
uint8_t irq; uint8_t irq;
@ -109,8 +126,10 @@ static bool handle_irq(void)
} }
/* unlikely */ /* unlikely */
if (eps[1].state != EP_IDLE) if (eps[1].state != EP_IDLE) {
queued_rx = 1;
return 1; return 1;
}
receive_frame(); receive_frame();
@ -165,7 +184,9 @@ static void do_tx(void *user)
*/ */
reg_write(REG_TRX_STATE, TRX_CMD_FORCE_PLL_ON); reg_write(REG_TRX_STATE, TRX_CMD_FORCE_PLL_ON);
flush_queued_rx();
handle_irq(); handle_irq();
queued_rx = 0;
spi_begin(); spi_begin();
spi_send(AT86RF230_BUF_WRITE); spi_send(AT86RF230_BUF_WRITE);
@ -201,6 +222,7 @@ void mac_reset(void)
mac_irq = NULL; mac_irq = NULL;
txing = 0; txing = 0;
queued_tx_ack = 0; queued_tx_ack = 0;
queued_rx = 0;
/* enable CRC and PHY_RSSI (with RX_CRC_VALID) in SPI status return */ /* enable CRC and PHY_RSSI (with RX_CRC_VALID) in SPI status return */
reg_write(REG_TRX_CTRL_1, reg_write(REG_TRX_CTRL_1,