one_uart

分支 (2)

管理

管理

one_uart

multi_uart

at_-f415_-dap
/
CherryDAP
/
dap_main.c

#include "dap_main.h"
#include "usbd_hid.h"
#include "user_param.h"
#include "dap_hid.h"
#include "mbcrc.h"

#define CONFIG_USBRX_RINGBUF_SIZE  (4 * 1024)

#define HID_STATE_IDLE 0
#define HID_STATE_BUSY 1

static volatile uint16_t USB_RequestIndexI; // Request  Index In
static volatile uint16_t USB_RequestIndexO; // Request  Index Out
static volatile uint16_t USB_RequestCountI; // Request  Count In
static volatile uint16_t USB_RequestCountO; // Request  Count Out
static volatile uint8_t USB_RequestIdle;    // Request  Idle  Flag

static volatile uint16_t USB_ResponseIndexI; // Response Index In
static volatile uint16_t USB_ResponseIndexO; // Response Index Out
static volatile uint16_t USB_ResponseCountI; // Response Count In
static volatile uint16_t USB_ResponseCountO; // Response Count Out
static volatile uint8_t USB_ResponseIdle;    // Response Idle  Flag

static USB_NOCACHE_RAM_SECTION USB_MEM_ALIGNX uint8_t USB_Request[DAP_PACKET_COUNT][DAP_PACKET_SIZE];  // Request  Buffer
static USB_NOCACHE_RAM_SECTION USB_MEM_ALIGNX uint8_t USB_Response[DAP_PACKET_COUNT][DAP_PACKET_SIZE]; // Response Buffer
static uint16_t USB_RespSize[DAP_PACKET_COUNT];                                                        // Response Size

volatile struct cdc_line_coding g_cdc_lincoding;
volatile uint8_t config_uart = 0;
volatile uint8_t config_uart_transfer = 0;

static USB_NOCACHE_RAM_SECTION USB_MEM_ALIGNX uint8_t usbrx_ringbuffer[CONFIG_USBRX_RINGBUF_SIZE];
static volatile uint16_t Rx_DealPtr;                                                         /* Pointer to serial x data receive buffer processing */

static USB_NOCACHE_RAM_SECTION USB_MEM_ALIGNX uint8_t usb_tmpbuffer[DAP_PACKET_SIZE];

static volatile uint8_t usbrx_idle_flag = 0;
static volatile uint8_t usbtx_idle_flag = 0;
static volatile uint8_t uarttx_idle_flag = 0;

USB_NOCACHE_RAM_SECTION chry_ringbuffer_t g_usbrx;

USB_NOCACHE_RAM_SECTION USB_MEM_ALIGNX uint8_t hid_read_buffer[HIDRAW_OUT_EP_SIZE];
USB_NOCACHE_RAM_SECTION USB_MEM_ALIGNX uint8_t hid_send_buffer[HIDRAW_IN_EP_SIZE];

/*!< hid state ! Data can be sent only when state is idle  */
static volatile uint8_t hid_state;
static volatile uint8_t hid_received = 0;

uint32_t IC_UID;

void usbd_event_handler(uint8_t busid, uint8_t event)
{
    switch (event) {
        case USBD_EVENT_RESET:
            usbrx_idle_flag = 0;
            usbtx_idle_flag = 0;
            uarttx_idle_flag = 0;
            config_uart_transfer = 0;
            break;
        case USBD_EVENT_CONNECTED:
            break;
        case USBD_EVENT_DISCONNECTED:
            break;
        case USBD_EVENT_RESUME:
            break;
        case USBD_EVENT_SUSPEND:
            break;
        case USBD_EVENT_CONFIGURED:
            /* setup first out ep read transfer */
            USB_RequestIdle = 0U;

            usbd_ep_start_read(DAP_BUS_ID, DAP_OUT_EP, USB_Request[0], DAP_PACKET_SIZE);
            usbd_ep_start_read(DAP_BUS_ID, CDC_OUT_EP, usb_tmpbuffer, DAP_PACKET_SIZE);
            usbd_ep_start_read(DAP_BUS_ID, HIDRAW_OUT_EP, hid_read_buffer, HIDRAW_OUT_EP_SIZE);
            break;
        case USBD_EVENT_SET_REMOTE_WAKEUP:
            break;
        case USBD_EVENT_CLR_REMOTE_WAKEUP:
            break;

        default:
            break;
    }
}

void dap_out_callback(uint8_t busid, uint8_t ep, uint32_t nbytes)
{
    if (USB_Request[USB_RequestIndexI][0] == ID_DAP_TransferAbort) {
        DAP_TransferAbort = 1U;
    } else {
        USB_RequestIndexI++;
        if (USB_RequestIndexI == DAP_PACKET_COUNT) {
            USB_RequestIndexI = 0U;
        }
        USB_RequestCountI++;
    }

    // Start reception of next request packet
    if ((uint16_t)(USB_RequestCountI - USB_RequestCountO) != DAP_PACKET_COUNT) {
        usbd_ep_start_read(DAP_BUS_ID, DAP_OUT_EP, USB_Request[USB_RequestIndexI], DAP_PACKET_SIZE);
    } else {
        USB_RequestIdle = 1U;
    }
}

void dap_in_callback(uint8_t busid, uint8_t ep, uint32_t nbytes)
{
    if (USB_ResponseCountI != USB_ResponseCountO) {
        // Load data from response buffer to be sent back
        usbd_ep_start_write(DAP_BUS_ID, DAP_IN_EP, USB_Response[USB_ResponseIndexO], USB_RespSize[USB_ResponseIndexO]);
        USB_ResponseIndexO++;
        if (USB_ResponseIndexO == DAP_PACKET_COUNT) {
            USB_ResponseIndexO = 0U;
        }
        USB_ResponseCountO++;
    } else {
        USB_ResponseIdle = 1U;
    }
}

void usbd_cdc_acm_bulk_out(uint8_t busid, uint8_t ep, uint32_t nbytes)
{
    chry_ringbuffer_write(&g_usbrx, usb_tmpbuffer, nbytes);
    if (chry_ringbuffer_get_free(&g_usbrx) >= DAP_PACKET_SIZE) {
        usbd_ep_start_read(DAP_BUS_ID, CDC_OUT_EP, usb_tmpbuffer, DAP_PACKET_SIZE);
    } else {
        usbrx_idle_flag = 1;
    }
}

void usbd_cdc_acm_bulk_in(uint8_t busid, uint8_t ep, uint32_t nbytes)
{
    // 发完之后处理
    /* Calculate the variables of interest */
    Rx_RemainLen -= nbytes;
    Rx_DealPtr += nbytes;
    if( Rx_DealPtr >= USART_BUFFER_SIZE )
    {
        Rx_DealPtr = 0x00;
    }

    if ((nbytes % DAP_PACKET_SIZE) == 0 && nbytes) {
        /* send zlp */
        usbd_ep_start_write(DAP_BUS_ID, CDC_IN_EP, NULL, 0);
    } else {
        usbtx_idle_flag = 1;
    }
}

static void usbd_hid_custom_in_callback(uint8_t busid, uint8_t ep, uint32_t nbytes)
{
    hid_state = HID_STATE_IDLE;
}

static void usbd_hid_custom_out_callback(uint8_t busid, uint8_t ep, uint32_t nbytes)
{
    usbd_ep_start_read(busid, ep, hid_read_buffer, HIDRAW_IN_EP_SIZE);
    hid_received = 1; // received
//    hid_read_buffer[0] = 0x02; /* IN: report id */
//    usbd_ep_start_write(busid, HIDRAW_IN_EP, hid_read_buffer, nbytes);
}

static struct usbd_endpoint dap_out_ep = {
    .ep_addr = DAP_OUT_EP,
    .ep_cb = dap_out_callback
};

static struct usbd_endpoint dap_in_ep = {
    .ep_addr = DAP_IN_EP,
    .ep_cb = dap_in_callback
};

static struct usbd_endpoint cdc_out_ep = {
    .ep_addr = CDC_OUT_EP,
    .ep_cb = usbd_cdc_acm_bulk_out
};

static struct usbd_endpoint cdc_in_ep = {
    .ep_addr = CDC_IN_EP,
    .ep_cb = usbd_cdc_acm_bulk_in
};

static struct usbd_endpoint custom_in_ep = {
    .ep_cb = usbd_hid_custom_in_callback,
    .ep_addr = HIDRAW_IN_EP
};

static struct usbd_endpoint custom_out_ep = {
    .ep_cb = usbd_hid_custom_out_callback,
    .ep_addr = HIDRAW_OUT_EP
};

struct usbd_interface dap_intf;
struct usbd_interface intf1;
struct usbd_interface intf2;
struct usbd_interface intf3;

static void chry_dap_state_init(void)
{
    // Initialize variables
    USB_RequestIndexI = 0U;
    USB_RequestIndexO = 0U;
    USB_RequestCountI = 0U;
    USB_RequestCountO = 0U;
    USB_RequestIdle = 1U;
    USB_ResponseIndexI = 0U;
    USB_ResponseIndexO = 0U;
    USB_ResponseCountI = 0U;
    USB_ResponseCountO = 0U;
    USB_ResponseIdle = 1U;
}

void chry_dap_init(void)
{
    chry_ringbuffer_init(&g_usbrx, usbrx_ringbuffer, CONFIG_USBRX_RINGBUF_SIZE);

    DAP_Setup();
    chry_dap_state_init();

    IC_UID = *(uint32_t *)0x1FFFF7E8 & 0x0001FFFF;                                    //取前面0~16位,17位，对应唯一识别码0~16位
    IC_UID |= (((*(uint32_t *)(0x1FFFF7E8)) & (0x0000000F << 28)) >> 28 << 17);       //取28到31位，4位 ，对应17-20
    IC_UID |= (((*(uint32_t *)(0x1FFFF7E8 + 4)) & 0x00000003) << 21);                 //取32~33，2位，对应21~22
    IC_UID |= ((((*(uint32_t *)(0x1FFFF7E8 + 8)) & (0x000001FF << 15)) >> 15) << 23); //取最后9位,对应唯一识别码23~31

//    // Fix UID
//    IC_UID = *(uint32_t*)(0x1FFFF7E8);
//    IC_UID ^= *(uint32_t*)(0x1FFFF7E8 + 4);
//    IC_UID ^= *(uint32_t*)(0x1FFFF7E8 + 8);

    char UID_BUF[9] = { 0 };
    sprintf(UID_BUF, "%08X", IC_UID);
    string3_descriptor[0] = UID_BUF[0];
    string3_descriptor[1] = UID_BUF[1];
    string3_descriptor[2] = UID_BUF[2];
    string3_descriptor[3] = UID_BUF[3];
    string3_descriptor[4] = UID_BUF[4];
    string3_descriptor[5] = UID_BUF[5];
    string3_descriptor[6] = UID_BUF[6];
    string3_descriptor[7] = UID_BUF[7];

    char ID_BUF[4] = { 0 };
    sprintf(ID_BUF, "%03d", (uint8_t)user_param.dap_id);
    string2_descriptor[1] = ID_BUF[0];
    string2_descriptor[2] = ID_BUF[1];
    string2_descriptor[3] = ID_BUF[2];

    usbd_desc_register(DAP_BUS_ID, &cmsisdap_descriptor);

    /*!< winusb */
    usbd_add_interface(DAP_BUS_ID, &dap_intf);
    usbd_add_endpoint(DAP_BUS_ID, &dap_out_ep);
    usbd_add_endpoint(DAP_BUS_ID, &dap_in_ep);

    /*!< cdc acm */
    usbd_add_interface(DAP_BUS_ID, usbd_cdc_acm_init_intf(DAP_BUS_ID, &intf1));
    usbd_add_interface(DAP_BUS_ID, usbd_cdc_acm_init_intf(DAP_BUS_ID, &intf2));
    usbd_add_endpoint(DAP_BUS_ID, &cdc_out_ep);
    usbd_add_endpoint(DAP_BUS_ID, &cdc_in_ep);

    usbd_add_interface(DAP_BUS_ID, usbd_hid_init_intf(DAP_BUS_ID, &intf3, hid_custom_report_desc, HID_CUSTOM_REPORT_DESC_SIZE));
    usbd_add_endpoint(DAP_BUS_ID, &custom_in_ep);
    usbd_add_endpoint(DAP_BUS_ID, &custom_out_ep);

    usbd_initialize(DAP_BUS_ID, 0x50000000UL, &usbd_event_handler);
}

void chry_dap_handle(void)
{
    uint32_t n;

    // Process pending requests
    while (USB_RequestCountI != USB_RequestCountO) {
        // Handle Queue Commands
        n = USB_RequestIndexO;
        while (USB_Request[n][0] == ID_DAP_QueueCommands) {
            USB_Request[n][0] = ID_DAP_ExecuteCommands;
            n++;
            if (n == DAP_PACKET_COUNT) {
                n = 0U;
            }
            if (n == USB_RequestIndexI) {
                // flags = osThreadFlagsWait(0x81U, osFlagsWaitAny, osWaitForever);
                // if (flags & 0x80U) {
                //     break;
                // }
            }
        }

        // Execute DAP Command (process request and prepare response)
        USB_RespSize[USB_ResponseIndexI] =
            (uint16_t)DAP_ExecuteCommand(USB_Request[USB_RequestIndexO], USB_Response[USB_ResponseIndexI]);

        // Update Request Index and Count
        USB_RequestIndexO++;
        if (USB_RequestIndexO == DAP_PACKET_COUNT) {
            USB_RequestIndexO = 0U;
        }
        USB_RequestCountO++;

        if (USB_RequestIdle) {
            if ((uint16_t)(USB_RequestCountI - USB_RequestCountO) != DAP_PACKET_COUNT) {
                USB_RequestIdle = 0U;
                usbd_ep_start_read(DAP_BUS_ID, DAP_OUT_EP, USB_Request[USB_RequestIndexI], DAP_PACKET_SIZE);
            }
        }

        // Update Response Index and Count
        USB_ResponseIndexI++;
        if (USB_ResponseIndexI == DAP_PACKET_COUNT) {
            USB_ResponseIndexI = 0U;
        }
        USB_ResponseCountI++;

        if (USB_ResponseIdle) {
            if (USB_ResponseCountI != USB_ResponseCountO) {
                // Load data from response buffer to be sent back
                n = USB_ResponseIndexO++;
                if (USB_ResponseIndexO == DAP_PACKET_COUNT) {
                    USB_ResponseIndexO = 0U;
                }
                USB_ResponseCountO++;
                USB_ResponseIdle = 0U;
                usbd_ep_start_write(DAP_BUS_ID, DAP_IN_EP, USB_Response[n], USB_RespSize[n]);
            }
        }
    }
}

void usbd_cdc_acm_set_line_coding(uint8_t busid, uint8_t intf, struct cdc_line_coding *line_coding)
{
    if (memcmp(line_coding, (uint8_t *)&g_cdc_lincoding, sizeof(struct cdc_line_coding)) != 0) {
        memcpy((uint8_t *)&g_cdc_lincoding, line_coding, sizeof(struct cdc_line_coding));
        config_uart = 1;
        config_uart_transfer = 0;
    }
}

void usbd_cdc_acm_get_line_coding(uint8_t busid, uint8_t intf, struct cdc_line_coding *line_coding)
{
    memcpy(line_coding, (uint8_t *)&g_cdc_lincoding, sizeof(struct cdc_line_coding));
}

/* called by user */
void chry_dap_usb2uart_uart_send_complete(uint32_t size)
{
    uint8_t *buffer;

    chry_ringbuffer_linear_read_done(&g_usbrx, size);

    if (chry_ringbuffer_get_used(&g_usbrx)) {
        buffer = chry_ringbuffer_linear_read_setup(&g_usbrx, &size);
        chry_dap_usb2uart_uart_send_bydma(buffer, size);
    } else {
        uarttx_idle_flag = 1;
    }
}

void chry_dap_usb2uart_handle(void)
{
    uint32_t size;
    uint8_t *buffer;

    if (config_uart) {
        /* disable irq here */
        config_uart = 0;
        /* config uart here */
        chry_dap_usb2uart_uart_config_callback((struct cdc_line_coding *)&g_cdc_lincoding);
        usbtx_idle_flag = 1;
        uarttx_idle_flag = 1;
        config_uart_transfer = 1;
        Rx_DealPtr = 0;
        //chry_ringbuffer_reset_read(&g_uartrx);
        /* enable irq here */
    }

    if (config_uart_transfer == 0) {
        return;
    }

    /* why we use chry_ringbuffer_linear_read_setup?
     * becase we use dma and we do not want to use temp buffer to memcpy from ringbuffer
     *
    */
    /* Serial port 1 data processing via USB upload and reception */
    if(usbtx_idle_flag)
    {
        if(Rx_RemainLen)
        {
            usbtx_idle_flag = 0;

            //uint32_t remain_len;
            uint16_t packlen;
            /* Calculate the length of this upload */
            packlen = Rx_RemainLen;
            // 这里防止一次性发太多直接越界了
            if( packlen > ( USART_BUFFER_SIZE - Rx_DealPtr ) )
            {
                packlen = ( USART_BUFFER_SIZE - Rx_DealPtr );
            }

            /* Upload serial data via usb */
            if( packlen )
            {
                usbd_ep_start_write(DAP_BUS_ID, CDC_IN_EP, &usart_rx_buffer[ Rx_DealPtr ], packlen);
            }
        }
    }

    /* usbrx to uart tx */
    if (uarttx_idle_flag) {
        if (chry_ringbuffer_get_used(&g_usbrx)) {
            uarttx_idle_flag = 0;
            /* start first transfer */
            buffer = chry_ringbuffer_linear_read_setup(&g_usbrx, &size);
            chry_dap_usb2uart_uart_send_bydma(buffer, size);
        }
    }

    /* check whether usb rx ringbuffer have space to store */
    if (usbrx_idle_flag) {
        if (chry_ringbuffer_get_free(&g_usbrx) >= DAP_PACKET_SIZE) {
            usbrx_idle_flag = 0;
            usbd_ep_start_read(DAP_BUS_ID,CDC_OUT_EP, usb_tmpbuffer, DAP_PACKET_SIZE);
        }
    }
}

void chry_dap_hid_handle(void)
{
    if(!hid_received)
    {
        return;
    }
    /**
    report id | Front         |  CMD    |  Length |  Data  |  Check
    0x01      | 0x55 0xaa     |  0x01   |  0x00   |  0x0   |  0x11  0x22
    0         | 1             |  3      |  4      |  5     |  6
    */
    hid_received = 0;
    // check header
    if(hid_read_buffer[1] != HID_PACK_HEADER_0 || hid_read_buffer[2] != HID_PACK_HEADER_1)
    {
        return;
    }
    uint8_t data_len = hid_read_buffer[4];
    // check len, remove header+len+crc+hid report id
    if(data_len > (HIDRAW_OUT_EP_SIZE - (HID_PACK_REPORT_ID_LEN + HID_PACK_FRONT_LEN + HID_PACK_CMD_LEN + HID_PACK_LENGTH_LEN)))
    {
        return;
    }
    // CRC
    if(usMBCRC16( &hid_read_buffer[1], data_len + 6 ) != 0 )
    {
        return;
    }

    chry_dap_hid_exec(&hid_read_buffer[3] ,data_len);
}