You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
233 lines
6.6 KiB
233 lines
6.6 KiB
/**
|
|
* Higher level UART driver that makes os_printf work and supports async Rx on UART0
|
|
*/
|
|
|
|
/*
|
|
* ----------------------------------------------------------------------------
|
|
* "THE BEER-WARE LICENSE" (Revision 42):
|
|
* Jeroen Domburg <jeroen@spritesmods.com> wrote this file. As long as you retain
|
|
* this notice you can do whatever you want with this stuff. If we meet some day,
|
|
* and you think this stuff is worth it, you can buy me a beer in return.
|
|
* ----------------------------------------------------------------------------
|
|
*/
|
|
|
|
#include <esp8266.h>
|
|
#include "uart_driver.h"
|
|
#include "uart_handler.h"
|
|
#include "uart_buffer.h"
|
|
|
|
// messy irq/task based UART handling below
|
|
|
|
static void uart0_rx_intr_handler(void *para);
|
|
|
|
static void uart_recvTask(os_event_t *events);
|
|
static void uart_processTask(os_event_t *events);
|
|
|
|
// Those heavily affect the byte loss ratio
|
|
#define PROCESS_CHUNK_LEN 10
|
|
#define RX_FIFO_FULL_THRES 40
|
|
|
|
#define uart_recvTaskPrio 1
|
|
#define uart_recvTaskQueueLen 25
|
|
static os_event_t uart_recvTaskQueue[uart_recvTaskQueueLen];
|
|
//
|
|
#define uart_processTaskPrio 0
|
|
#define uart_processTaskQueueLen 25
|
|
static os_event_t uart_processTaskQueue[uart_processTaskQueueLen];
|
|
|
|
/** Clear the fifos */
|
|
void ICACHE_FLASH_ATTR clear_rxtx(int uart_no)
|
|
{
|
|
SET_PERI_REG_MASK(UART_CONF0(uart_no), UART_RXFIFO_RST | UART_TXFIFO_RST);
|
|
CLEAR_PERI_REG_MASK(UART_CONF0(uart_no), UART_RXFIFO_RST | UART_TXFIFO_RST);
|
|
}
|
|
|
|
|
|
/** Configure basic UART func and pins */
|
|
void ICACHE_FLASH_ATTR UART_Init(void)
|
|
{
|
|
// U0TXD
|
|
PIN_FUNC_SELECT(PERIPHS_IO_MUX_U0TXD_U, FUNC_U0TXD);
|
|
PIN_PULLUP_DIS(PERIPHS_IO_MUX_U0TXD_U);
|
|
|
|
// U0RXD
|
|
PIN_FUNC_SELECT(PERIPHS_IO_MUX_U0RXD_U, FUNC_U0RXD);
|
|
PIN_PULLUP_DIS(PERIPHS_IO_MUX_U0RXD_U);
|
|
|
|
// U1TXD (GPIO2)
|
|
PIN_FUNC_SELECT(PERIPHS_IO_MUX_GPIO2_U, FUNC_U1TXD_BK);
|
|
PIN_PULLUP_DIS(PERIPHS_IO_MUX_GPIO2_U);
|
|
|
|
// Configure the UART peripherals
|
|
UART_SetWordLength(UART0, EIGHT_BITS); // main
|
|
UART_ResetFifo(UART0);
|
|
UART_SetWordLength(UART1, EIGHT_BITS); // debug (output only)
|
|
UART_ResetFifo(UART1);
|
|
|
|
// remainder is configured based on user settings in serial.c
|
|
}
|
|
|
|
/** Configure Rx on UART0 */
|
|
void ICACHE_FLASH_ATTR UART_SetupAsyncReceiver(void)
|
|
{
|
|
UART_AllocBuffers();
|
|
|
|
// Start the Rx reading task
|
|
system_os_task(uart_recvTask, uart_recvTaskPrio, uart_recvTaskQueue, uart_recvTaskQueueLen);
|
|
system_os_task(uart_processTask, uart_processTaskPrio, uart_processTaskQueue, uart_processTaskQueueLen);
|
|
|
|
// set handler
|
|
ETS_UART_INTR_ATTACH((void *)uart0_rx_intr_handler, &(UartDev.rcv_buff)); // the buf will be used as an arg
|
|
|
|
// fifo threshold config (max: UART_RXFIFO_FULL_THRHD = 127)
|
|
uint32_t conf = ((RX_FIFO_FULL_THRES & UART_RXFIFO_FULL_THRHD) << UART_RXFIFO_FULL_THRHD_S);
|
|
conf |= ((0x05 & UART_TXFIFO_EMPTY_THRHD) << UART_TXFIFO_EMPTY_THRHD_S);
|
|
// timeout config
|
|
conf |= ((0x06 & UART_RX_TOUT_THRHD) << UART_RX_TOUT_THRHD_S); // timeout threshold
|
|
conf |= UART_RX_TOUT_EN; // enable timeout
|
|
WRITE_PERI_REG(UART_CONF1(UART0), conf);
|
|
|
|
// enable TOUT and ERR irqs
|
|
SET_PERI_REG_MASK(UART_INT_ENA(UART0), UART_RXFIFO_TOUT_INT_ENA | UART_FRM_ERR_INT_ENA);
|
|
/* clear interrupt flags */
|
|
WRITE_PERI_REG(UART_INT_CLR(UART0), 0xffff);
|
|
/* enable RX interrupts */
|
|
SET_PERI_REG_MASK(UART_INT_ENA(UART0), UART_RXFIFO_FULL_INT_ENA | UART_RXFIFO_OVF_INT_ENA);
|
|
|
|
// Enable IRQ in Extensa
|
|
ETS_UART_INTR_ENABLE();
|
|
}
|
|
|
|
|
|
// ---- async receive stuff ----
|
|
|
|
|
|
|
|
//
|
|
//void ICACHE_FLASH_ATTR UART_PollRx(void)
|
|
//{
|
|
// uint8 fifo_len = (uint8) UART_GetRxFifoCount(UART0);
|
|
//
|
|
// for (uint8 idx = 0; idx < fifo_len; idx++) {
|
|
// uint8 d_tmp = (uint8) (READ_PERI_REG(UART_FIFO(UART0)) & 0xFF);
|
|
// UART_HandleRxByte(d_tmp);
|
|
// }
|
|
//}
|
|
|
|
/**
|
|
* This is the system task handling UART Rx bytes.
|
|
* The function must be re-entrant.
|
|
*
|
|
* @param events
|
|
*/
|
|
static void ICACHE_FLASH_ATTR
|
|
uart_recvTask(os_event_t *events)
|
|
{
|
|
//#define PROCESS_CHUNK_LEN 64
|
|
// static char buf[PROCESS_CHUNK_LEN];
|
|
|
|
if (events->sig == 0) {
|
|
UART_RxFifoCollect();
|
|
|
|
// clear irq flags
|
|
WRITE_PERI_REG(UART_INT_CLR(UART0), UART_RXFIFO_FULL_INT_CLR | UART_RXFIFO_TOUT_INT_CLR);
|
|
// enable rx irq again
|
|
uart_rx_intr_enable(UART0);
|
|
|
|
// Trigger the Reading task
|
|
system_os_post(uart_processTaskPrio, 5, 0);
|
|
}
|
|
else if (events->sig == 1) {
|
|
// ???
|
|
}
|
|
// else if (events->sig == 5) {
|
|
// // Send a few to the parser...
|
|
// int bytes = UART_ReadAsync(buf, PROCESS_CHUNK_LEN);
|
|
// for (uint8 idx = 0; idx < bytes; idx++) {
|
|
// UART_HandleRxByte(buf[idx]);
|
|
// }
|
|
//
|
|
// // ask for another run
|
|
// if (UART_AsyncRxCount() > 0) {
|
|
// system_os_post(uart_recvTaskPrio, 5, 0);
|
|
// }
|
|
// }
|
|
}
|
|
|
|
|
|
/**
|
|
* This is the system task handling UART Rx bytes.
|
|
* The function must be re-entrant.
|
|
*
|
|
* @param events
|
|
*/
|
|
static void ICACHE_FLASH_ATTR
|
|
uart_processTask(os_event_t *events)
|
|
{
|
|
static char buf[PROCESS_CHUNK_LEN];
|
|
|
|
if (events->sig == 5) {
|
|
// Send a few to the parser...
|
|
int bytes = UART_ReadAsync(buf, PROCESS_CHUNK_LEN);
|
|
for (uint8 idx = 0; idx < bytes; idx++) {
|
|
UART_HandleRxByte(buf[idx]);
|
|
}
|
|
|
|
// ask for another run
|
|
if (UART_AsyncRxCount() > 0) {
|
|
system_os_post(uart_processTaskPrio, 5, 0);
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
/******************************************************************************
|
|
* FunctionName : uart0_rx_intr_handler
|
|
* Description : Internal used function
|
|
* UART0 interrupt handler, add self handle code inside
|
|
* Parameters : void *para - point to ETS_UART_INTR_ATTACH's arg
|
|
* Returns : NONE
|
|
*******************************************************************************/
|
|
static void
|
|
uart0_rx_intr_handler(void *para)
|
|
{
|
|
(void)para;
|
|
|
|
uint32_t status_reg = READ_PERI_REG(UART_INT_ST(UART0));
|
|
|
|
if (status_reg & UART_FRM_ERR_INT_ST) {
|
|
// Framing Error
|
|
WRITE_PERI_REG(UART_INT_CLR(UART0), UART_FRM_ERR_INT_CLR);
|
|
}
|
|
|
|
if (status_reg & UART_RXFIFO_FULL_INT_ST) {
|
|
// RX fifo full
|
|
uart_rx_intr_disable(UART0);
|
|
WRITE_PERI_REG(UART_INT_CLR(UART0), UART_RXFIFO_FULL_INT_CLR);
|
|
|
|
// run handler
|
|
system_os_post(uart_recvTaskPrio, 0, 1); /* -> notify the polling thread */
|
|
}
|
|
|
|
if (status_reg & UART_RXFIFO_TOUT_INT_ST) {
|
|
// Fifo timeout
|
|
uart_rx_intr_disable(UART0);
|
|
WRITE_PERI_REG(UART_INT_CLR(UART0), UART_RXFIFO_TOUT_INT_CLR);
|
|
|
|
// run handler
|
|
system_os_post(uart_recvTaskPrio, 0, 0); /* -> notify the polling thread */
|
|
}
|
|
|
|
if (status_reg & UART_TXFIFO_EMPTY_INT_ST) {
|
|
CLEAR_PERI_REG_MASK(UART_INT_ENA(UART0), UART_TXFIFO_EMPTY_INT_ENA);
|
|
UART_DispatchFromTxBuffer(UART0);
|
|
// WRITE_PERI_REG(UART_INT_CLR(UART0), UART_TXFIFO_EMPTY_INT_CLR); //- is called by the dispatch func if more data is to be sent.
|
|
}
|
|
|
|
if (status_reg & UART_RXFIFO_OVF_INT_ST) {
|
|
WRITE_PERI_REG(UART_INT_CLR(UART0), UART_RXFIFO_OVF_INT_CLR);
|
|
|
|
// overflow error
|
|
UART_WriteChar(UART1, '!', 100);
|
|
}
|
|
}
|
|
|