diff options
Diffstat (limited to 'platform')
| -rw-r--r-- | platform/daplink/dap_main.c | 41 | ||||
| -rw-r--r-- | platform/idf/usbh_fatfs.c | 5 | ||||
| -rw-r--r-- | platform/rtthread/rt_usbd_adb.c | 1 | ||||
| -rw-r--r-- | platform/rtthread/rt_usbd_serial.c | 1 | ||||
| -rw-r--r-- | platform/zephyr/usbh_msc_disk.c | 126 |
5 files changed, 126 insertions, 48 deletions
diff --git a/platform/daplink/dap_main.c b/platform/daplink/dap_main.c index 27e0355b..b145c223 100644 --- a/platform/daplink/dap_main.c +++ b/platform/daplink/dap_main.c @@ -335,17 +335,16 @@ static USB_NOCACHE_RAM_SECTION USB_MEM_ALIGNX uint8_t USB_Request[DAP_PACKET_COU 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; - USB_NOCACHE_RAM_SECTION USB_MEM_ALIGNX uint8_t uartrx_ringbuffer[CONFIG_UARTRX_RINGBUF_SIZE]; USB_NOCACHE_RAM_SECTION USB_MEM_ALIGNX uint8_t usbrx_ringbuffer[CONFIG_USBRX_RINGBUF_SIZE]; USB_NOCACHE_RAM_SECTION USB_MEM_ALIGNX uint8_t usb_tmpbuffer[DAP_PACKET_SIZE]; +static volatile struct cdc_line_coding g_cdc_lincoding; +static volatile uint8_t config_uart = 0; +static volatile uint8_t config_uart_transfer = 0; static volatile uint8_t usbrx_idle_flag = 0; -static volatile uint8_t usbtx_idle_flag = 0; -static volatile uint8_t uarttx_idle_flag = 0; +static volatile uint8_t usbtx_idle_flag = 1; +static volatile uint8_t uarttx_idle_flag = 1; USB_NOCACHE_RAM_SECTION chry_ringbuffer_t g_uartrx; USB_NOCACHE_RAM_SECTION chry_ringbuffer_t g_usbrx; @@ -356,9 +355,6 @@ 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; @@ -437,20 +433,13 @@ void usbd_cdc_acm_bulk_out(uint8_t busid, uint8_t ep, uint32_t nbytes) void usbd_cdc_acm_bulk_in(uint8_t busid, uint8_t ep, uint32_t nbytes) { (void)busid; - uint32_t size; - uint8_t *buffer; chry_ringbuffer_linear_read_done(&g_uartrx, nbytes); if ((nbytes % DAP_PACKET_SIZE) == 0 && nbytes) { /* send zlp */ usbd_ep_start_write(0, CDC_IN_EP, NULL, 0); } else { - if (chry_ringbuffer_get_used(&g_uartrx)) { - buffer = chry_ringbuffer_linear_read_setup(&g_uartrx, &size); - usbd_ep_start_write(0, CDC_IN_EP, buffer, size); - } else { - usbtx_idle_flag = 1; - } + usbtx_idle_flag = 1; } } @@ -624,7 +613,8 @@ void chry_dap_handle(void) void usbd_cdc_acm_set_line_coding(uint8_t busid, uint8_t intf, struct cdc_line_coding *line_coding) { (void)busid; - if (memcmp(line_coding, (uint8_t *)&g_cdc_lincoding, sizeof(struct cdc_line_coding)) != 0) { + + if (memcmp((uint8_t *)&g_cdc_lincoding, line_coding, sizeof(struct cdc_line_coding)) != 0 && line_coding->dwDTERate != 0) { memcpy((uint8_t *)&g_cdc_lincoding, line_coding, sizeof(struct cdc_line_coding)); config_uart = 1; config_uart_transfer = 0; @@ -642,6 +632,10 @@ void chry_dap_usb2uart_handle(void) uint32_t size; uint8_t *buffer; + if (usb_device_is_configured(0) == 0) { + return; + } + if (config_uart) { /* disable irq here */ config_uart = 0; @@ -700,16 +694,9 @@ __WEAK void chry_dap_usb2uart_uart_config_callback(struct cdc_line_coding *line_ /* 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; - } + uarttx_idle_flag = 1; } /* implment by user */ @@ -746,4 +733,4 @@ int usbd_msc_sector_write(uint32_t sector, uint8_t *buffer, uint32_t length) memcpy(mass_block[sector].BlockSpace, buffer, length); return 0; } -#endif +#endif
\ No newline at end of file diff --git a/platform/idf/usbh_fatfs.c b/platform/idf/usbh_fatfs.c index fef0798f..ca2713ae 100644 --- a/platform/idf/usbh_fatfs.c +++ b/platform/idf/usbh_fatfs.c @@ -9,6 +9,7 @@ #include "sdkconfig.h" #include "freertos/FreeRTOS.h" #include "freertos/task.h" +#include "esp_idf_version.h" #include "esp_log.h" #include "esp_check.h" #include "diskio_impl.h" @@ -215,12 +216,16 @@ esp_err_t msc_host_vfs_register(struct usbh_msc *msc_class, strcpy(vfs->base_path, base_path); vfs->pdrv = pdrv; +#if ESP_IDF_VERSION > ESP_IDF_VERSION_VAL(6, 0, 0) esp_vfs_fat_conf_t conf = { .base_path = base_path, .fat_drive = drive, .max_files = mount_config->max_files, }; ret = esp_vfs_fat_register(&conf, &fs); +#else + ret = esp_vfs_fat_register(base_path, drive, mount_config->max_files, &fs); +#endif ESP_GOTO_ON_ERROR(ret, fail, TAG, "Failed to register filesystem, error=%s", esp_err_to_name(ret)); vfs->fs = fs; diff --git a/platform/rtthread/rt_usbd_adb.c b/platform/rtthread/rt_usbd_adb.c index 4ab7f59a..4ab7bbe1 100644 --- a/platform/rtthread/rt_usbd_adb.c +++ b/platform/rtthread/rt_usbd_adb.c @@ -126,6 +126,7 @@ void usbd_adb_shell_init(uint8_t in_ep, uint8_t out_ep) #endif g_usbd_adb_shell.tx_done = usb_osal_sem_create(0); + USB_ASSERT(g_usbd_adb_shell.tx_done != NULL); rt_ringbuffer_init(&g_usbd_adb_shell.rx_rb, g_usbd_adb_shell.rx_rb_buffer, sizeof(g_usbd_adb_shell.rx_rb_buffer)); } diff --git a/platform/rtthread/rt_usbd_serial.c b/platform/rtthread/rt_usbd_serial.c index 41fb01af..138f4cc8 100644 --- a/platform/rtthread/rt_usbd_serial.c +++ b/platform/rtthread/rt_usbd_serial.c @@ -258,6 +258,7 @@ void usbd_cdc_acm_serial_init(uint8_t busid, uint8_t in_ep, uint8_t out_ep) serial->in_ep = in_ep; serial->out_ep = out_ep; serial->tx_done = usb_osal_sem_create(0); + USB_ASSERT(serial->tx_done != NULL); usbd_add_interface(busid, usbd_cdc_acm_init_intf(busid, &serial->intf_ctrl)); usbd_add_interface(busid, usbd_cdc_acm_init_intf(busid, &serial->intf_data)); diff --git a/platform/zephyr/usbh_msc_disk.c b/platform/zephyr/usbh_msc_disk.c index 6890f985..129cbfe4 100644 --- a/platform/zephyr/usbh_msc_disk.c +++ b/platform/zephyr/usbh_msc_disk.c @@ -1,5 +1,5 @@ /* - * Copyright (c) 2025, sakumisu + * Copyright (c) 2025-2026 sakumisu * * SPDX-License-Identifier: Apache-2.0 */ @@ -13,16 +13,37 @@ #endif #endif -struct usbh_msc *active_msc_class; +struct usbh_msc_disk_context { + struct usbh_msc *msc_class; + struct disk_info disk; + char name[CONFIG_USBHOST_DEV_NAMELEN]; + char devname[CONFIG_USBHOST_DEV_NAMELEN]; +}; + +static struct usbh_msc_disk_context + msc_disk_context[CONFIG_USBHOST_MAX_MSC_CLASS]; + +static struct usbh_msc_disk_context *disk_msc_context(struct disk_info *disk) +{ + return CONTAINER_OF(disk, struct usbh_msc_disk_context, disk); +} + +static bool disk_msc_connected(const struct usbh_msc *msc_class) +{ + return msc_class != NULL && msc_class->hport != NULL && + msc_class->hport->connected; +} static int disk_msc_access_init(struct disk_info *disk) { - active_msc_class = (struct usbh_msc *)usbh_find_class_instance("/dev/sda"); - if (active_msc_class == NULL) { - printf("do not find /dev/sda\r\n"); + struct usbh_msc_disk_context *ctx = disk_msc_context(disk); + + ctx->msc_class = (struct usbh_msc *)usbh_find_class_instance(ctx->devname); + if (ctx->msc_class == NULL) { + printf("do not find %s\r\n", ctx->devname); return -ENODEV; } - if (usbh_msc_scsi_init(active_msc_class) < 0) { + if (usbh_msc_scsi_init(ctx->msc_class) < 0) { return -EIO; } return 0; @@ -30,6 +51,12 @@ static int disk_msc_access_init(struct disk_info *disk) static int disk_msc_access_status(struct disk_info *disk) { + struct usbh_msc_disk_context *ctx = disk_msc_context(disk); + + if (!disk_msc_connected(ctx->msc_class)) { + return DISK_STATUS_NOMEDIA; + } + return DISK_STATUS_OK; } @@ -38,25 +65,30 @@ static int disk_msc_access_read(struct disk_info *disk, uint8_t *buff, { int ret; uint8_t *align_buf; + struct usbh_msc_disk_context *ctx = disk_msc_context(disk); + + if (!disk_msc_connected(ctx->msc_class)) { + return -ENODEV; + } align_buf = (uint8_t *)buff; #ifdef CONFIG_DCACHE if ((uint32_t)buff & (CONFIG_USB_ALIGN_SIZE - 1)) { - align_buf = (uint8_t *)k_aligned_alloc(CONFIG_USB_ALIGN_SIZE, count * active_msc_class->blocksize); + align_buf = (uint8_t *)k_aligned_alloc(CONFIG_USB_ALIGN_SIZE, count * ctx->msc_class->blocksize); if (!align_buf) { printf("msc get align buf failed\r\n"); return -ENOMEM; } } #endif - if (usbh_msc_scsi_read10(active_msc_class, sector, align_buf, count) < 0) { + if (usbh_msc_scsi_read10(ctx->msc_class, sector, align_buf, count) < 0) { ret = -EIO; } else { ret = 0; } #ifdef CONFIG_DCACHE if ((uint32_t)buff & (CONFIG_USB_ALIGN_SIZE - 1)) { - usb_memcpy(buff, align_buf, count * active_msc_class->blocksize); + usb_memcpy(buff, align_buf, count * ctx->msc_class->blocksize); k_free(align_buf); } #endif @@ -68,19 +100,24 @@ static int disk_msc_access_write(struct disk_info *disk, const uint8_t *buff, { int ret; uint8_t *align_buf; + struct usbh_msc_disk_context *ctx = disk_msc_context(disk); + + if (!disk_msc_connected(ctx->msc_class)) { + return -ENODEV; + } align_buf = (uint8_t *)buff; #ifdef CONFIG_DCACHE if ((uint32_t)buff & (CONFIG_USB_ALIGN_SIZE - 1)) { - align_buf = (uint8_t *)k_aligned_alloc(CONFIG_USB_ALIGN_SIZE, count * active_msc_class->blocksize); + align_buf = (uint8_t *)k_aligned_alloc(CONFIG_USB_ALIGN_SIZE, count * ctx->msc_class->blocksize); if (!align_buf) { printf("msc get align buf failed\r\n"); return -ENOMEM; } - usb_memcpy(align_buf, buff, count * active_msc_class->blocksize); + usb_memcpy(align_buf, buff, count * ctx->msc_class->blocksize); } #endif - if (usbh_msc_scsi_write10(active_msc_class, sector, align_buf, count) < 0) { + if (usbh_msc_scsi_write10(ctx->msc_class, sector, align_buf, count) < 0) { ret = -EIO; } else { ret = 0; @@ -95,14 +132,22 @@ static int disk_msc_access_write(struct disk_info *disk, const uint8_t *buff, static int disk_msc_access_ioctl(struct disk_info *disk, uint8_t cmd, void *buff) { + struct usbh_msc_disk_context *ctx = disk_msc_context(disk); + switch (cmd) { case DISK_IOCTL_CTRL_SYNC: break; case DISK_IOCTL_GET_SECTOR_COUNT: - *(uint32_t *)buff = active_msc_class->blocknum; + if (!disk_msc_connected(ctx->msc_class)) { + return -ENODEV; + } + *(uint32_t *)buff = ctx->msc_class->blocknum; break; case DISK_IOCTL_GET_SECTOR_SIZE: - *(uint32_t *)buff = active_msc_class->blocksize; + if (!disk_msc_connected(ctx->msc_class)) { + return -ENODEV; + } + *(uint32_t *)buff = ctx->msc_class->blocksize; break; case DISK_IOCTL_GET_ERASE_BLOCK_SZ: *(uint32_t *)buff = 1U; @@ -126,17 +171,56 @@ static const struct disk_operations msc_disk_ops = { .ioctl = disk_msc_access_ioctl, }; -static struct disk_info usbh_msc_disk = { - .name = "USB", - .ops = &msc_disk_ops, -}; +__WEAK void usbh_msc_app_run(struct usbh_msc *msc_class) +{ + (void)msc_class; +} + +__WEAK void usbh_msc_app_stop(struct usbh_msc *msc_class) +{ + (void)msc_class; +} void usbh_msc_run(struct usbh_msc *msc_class) { - disk_access_register(&usbh_msc_disk); + uint8_t index; + struct usbh_msc_disk_context *ctx; + + if (msc_class == NULL || msc_class->sdchar < 'a' || + msc_class->sdchar >= 'a' + CONFIG_USBHOST_MAX_MSC_CLASS) { + return; + } + + index = msc_class->sdchar - 'a'; + ctx = &msc_disk_context[index]; + memset(ctx, 0, sizeof(*ctx)); + snprintf(ctx->name, sizeof(ctx->name), "USB%u", index); + snprintf(ctx->devname, sizeof(ctx->devname), "/dev/sd%c", msc_class->sdchar); + ctx->msc_class = msc_class; + ctx->disk.name = ctx->name; + ctx->disk.ops = &msc_disk_ops; + + if (disk_access_register(&ctx->disk) < 0) { + return; + } + + usbh_msc_app_run(msc_class); } void usbh_msc_stop(struct usbh_msc *msc_class) { - disk_access_unregister(&usbh_msc_disk); -}
\ No newline at end of file + uint8_t index; + struct usbh_msc_disk_context *ctx; + + usbh_msc_app_stop(msc_class); + + if (msc_class == NULL || msc_class->sdchar < 'a' || + msc_class->sdchar >= 'a' + CONFIG_USBHOST_MAX_MSC_CLASS) { + return; + } + + index = msc_class->sdchar - 'a'; + ctx = &msc_disk_context[index]; + disk_access_unregister(&ctx->disk); + ctx->msc_class = NULL; +} |
