refactor(serial): add host serial framework

Signed-off-by: sakumisu <[email protected]>

3 files changed, 215 insertions, 899 deletions

diff --git a/platform/rtthread/usb_msh.c b/platform/rtthread/usb_msh.c
index fc5cdaee..8dd61164 100644
--- a/platform/rtthread/usb_msh.c
+++ b/platform/rtthread/usb_msh.c
@@ -44,4 +44,10 @@ int usbh_deinit(int argc, char **argv)
 MSH_CMD_EXPORT(usbh_init, init usb host);
 MSH_CMD_EXPORT(usbh_deinit, deinit usb host);
 MSH_CMD_EXPORT(lsusb, ls usb devices);
+
+#ifdef CONFIG_USBHOST_SERIAL
+#include "usbh_serial.h"
+MSH_CMD_EXPORT(usbh_serial, usbh_serial test);
+#endif
+
 #endif
diff --git a/platform/rtthread/usbh_rtserial.c b/platform/rtthread/usbh_rtserial.c
new file mode 100644
index 00000000..f1e25503
--- /dev/null
+++ b/platform/rtthread/usbh_rtserial.c
@@ -0,0 +1,209 @@
+/*
+ * Copyright (c) 2025, sakumisu
+ *
+ * SPDX-License-Identifier: Apache-2.0
+ */
+#include <rtthread.h>
+#include <rtdevice.h>
+
+#include "usbh_core.h"
+#include "usbh_serial.h"
+
+static rt_err_t rt_usbh_serial_open(struct rt_device *dev, rt_uint16_t oflag)
+{
+    struct usbh_serial *serial;
+
+    RT_ASSERT(dev != RT_NULL && dev->user_data != RT_NULL);
+
+    serial = (struct usbh_serial *)dev->user_data;
+
+    serial = usbh_serial_open(serial->hport->config.intf[serial->intf].devname, USBH_SERIAL_O_RDWR | USBH_SERIAL_O_NONBLOCK);
+    if (serial == RT_NULL) {
+        USB_LOG_ERR("serial open failed\n");
+        return -RT_ERROR;
+    }
+
+    struct usbh_serial_termios termios;
+
+    memset(&termios, 0, sizeof(termios));
+    termios.baudrate = 115200;
+    termios.stopbits = 0;
+    termios.parity = 0;
+    termios.databits = 8;
+    termios.rtscts = false;
+    termios.rx_timeout = 0;
+
+    usbh_serial_control(serial, USBH_SERIAL_CMD_SET_ATTR, &termios);
+
+    return RT_EOK;
+}
+
+static rt_err_t rt_usbh_serial_close(struct rt_device *dev)
+{
+    struct usbh_serial *serial;
+
+    RT_ASSERT(dev != RT_NULL && dev->user_data != RT_NULL);
+
+    serial = (struct usbh_serial *)dev->user_data;
+
+    usbh_serial_close(serial);
+
+    return RT_EOK;
+}
+
+static rt_ssize_t rt_usbh_serial_read(struct rt_device *dev,
+                                      rt_off_t pos,
+                                      void *buffer,
+                                      rt_size_t size)
+{
+    struct usbh_serial *serial;
+
+    RT_ASSERT(dev != RT_NULL && dev->user_data != RT_NULL);
+
+    serial = (struct usbh_serial *)dev->user_data;
+
+    return usbh_serial_read(serial, buffer, size);
+}
+
+static rt_ssize_t rt_usbh_serial_write(struct rt_device *dev,
+                                       rt_off_t pos,
+                                       const void *buffer,
+                                       rt_size_t size)
+{
+    struct usbh_serial *serial;
+    int ret = 0;
+    rt_uint8_t *align_buf;
+
+    RT_ASSERT(dev != RT_NULL && dev->user_data != RT_NULL);
+
+    serial = (struct usbh_serial *)dev->user_data;
+
+    align_buf = (rt_uint8_t *)buffer;
+
+    if ((uint32_t)buffer & (CONFIG_USB_ALIGN_SIZE - 1)) {
+        align_buf = rt_malloc_align(USB_ALIGN_UP(size, CONFIG_USB_ALIGN_SIZE), CONFIG_USB_ALIGN_SIZE);
+        if (!align_buf) {
+            USB_LOG_ERR("serial get align buf failed\n");
+            return 0;
+        }
+
+        usb_memcpy(align_buf, buffer, size);
+    }
+
+    ret = usbh_serial_write(serial, align_buf, size);
+
+    if ((uint32_t)buffer & (CONFIG_USB_ALIGN_SIZE - 1)) {
+        rt_free_align(align_buf);
+    }
+
+    return ret;
+}
+
+static rt_err_t rt_usbh_serial_control(struct rt_device *dev,
+                                       int cmd,
+                                       void *args)
+{
+    struct usbh_serial *serial;
+    struct serial_configure *config;
+    int ret = -RT_EINVAL;
+
+    RT_ASSERT(dev != RT_NULL && dev->user_data != RT_NULL);
+
+    serial = (struct usbh_serial *)dev->user_data;
+
+    switch (cmd) {
+        case RT_DEVICE_CTRL_CONFIG: {
+            config = (struct serial_configure *)args;
+
+            struct usbh_serial_termios termios;
+
+            memset(&termios, 0, sizeof(termios));
+            termios.baudrate = config->baud_rate;
+            termios.stopbits = 0;
+            termios.parity = config->parity;
+            termios.databits = config->data_bits;
+            termios.rtscts = false;
+            termios.rx_timeout = 0;
+
+            usbh_serial_control(serial, USBH_SERIAL_CMD_SET_ATTR, &termios);
+        } break;
+
+        default:
+            break;
+    }
+
+    return ret;
+}
+
+#ifdef RT_USING_DEVICE_OPS
+const static struct rt_device_ops usbh_serial_ops = {
+    NULL,
+    rt_usbh_serial_open,
+    rt_usbh_serial_close,
+    rt_usbh_serial_read,
+    rt_usbh_serial_write,
+    rt_usbh_serial_control
+};
+#endif
+
+rt_err_t usbh_serial_register(struct usbh_serial *serial)
+{
+    rt_err_t ret;
+    struct rt_device *device;
+    RT_ASSERT(serial != RT_NULL);
+
+    device = rt_malloc(sizeof(struct rt_device));
+    if (device == RT_NULL) {
+        USB_LOG_ERR("serial device malloc failed\n");
+        return -RT_ENOMEM;
+    }
+    memset(device, 0, sizeof(struct rt_device));
+
+    device->type = RT_Device_Class_Char;
+    device->rx_indicate = RT_NULL;
+    device->tx_complete = RT_NULL;
+
+#ifdef RT_USING_DEVICE_OPS
+    device->ops = &usbh_serial_ops;
+#else
+    device->init = NULL;
+    device->open = rt_usbh_serial_open;
+    device->close = rt_usbh_serial_close;
+    device->read = rt_usbh_serial_read;
+    device->write = rt_usbh_serial_write;
+    device->control = rt_usbh_serial_control;
+#endif
+    device->user_data = serial;
+    serial->user_data = device;
+
+    /* register a character device */
+    ret = rt_device_register(device, serial->hport->config.intf[serial->intf].devname, RT_DEVICE_FLAG_RDWR | RT_DEVICE_FLAG_INT_RX | RT_DEVICE_FLAG_REMOVABLE);
+
+#ifdef RT_USING_POSIX_DEVIO
+    /* set fops */
+    device->fops = &usbh_serial_fops;
+#endif
+    return ret;
+}
+
+void usbh_serial_unregister(struct usbh_serial *serial)
+{
+    struct rt_device *device;
+
+    RT_ASSERT(serial != NULL && serial->user_data != NULL);
+
+    device = (struct rt_device *)serial->user_data;
+
+    rt_device_unregister(device);
+    rt_free(device);
+}
+
+void usbh_serial_run(struct usbh_serial *serial)
+{
+    usbh_serial_register(serial);
+}
+
+void usbh_serial_stop(struct usbh_serial *serial)
+{
+    usbh_serial_unregister(serial);
+}
\ No newline at end of file
diff --git a/platform/rtthread/usbh_serial.c b/platform/rtthread/usbh_serial.c
deleted file mode 100644
index 912258e0..00000000
--- a/platform/rtthread/usbh_serial.c
+++ /dev/null
@@ -1,899 +0,0 @@
-/*
- * Copyright (c) 2025, sakumisu
- *
- * SPDX-License-Identifier: Apache-2.0
- */
-#include <rtthread.h>
-#include <rtdevice.h>
-
-#include "usbh_core.h"
-#include "usbh_cdc_acm.h"
-#include "usbh_ftdi.h"
-#include "usbh_cp210x.h"
-#include "usbh_ch34x.h"
-#include "usbh_pl2303.h"
-
-#define DEV_FORMAT_VENDOR  "ttyUSB%d"
-#define DEV_FORMAT_CDC_ACM "ttyACM%d"
-
-#define USBH_RX_MAX_SIZE 2048
-
-#ifndef CONFIG_USBHOST_MAX_VENDOR_SERIAL_CLASS
-#define CONFIG_USBHOST_MAX_VENDOR_SERIAL_CLASS (4)
-#endif
-
-#ifndef CONFIG_USBHOST_SERIAL_RX_BUFSIZE
-#define CONFIG_USBHOST_SERIAL_RX_BUFSIZE (USBH_RX_MAX_SIZE * 2)
-#endif
-
-enum usbh_serial_type {
-    USBH_SERIAL_TYPE_CDC_ACM = 0,
-    USBH_SERIAL_TYPE_FTDI,
-    USBH_SERIAL_TYPE_CP210X,
-    USBH_SERIAL_TYPE_CH34X,
-    USBH_SERIAL_TYPE_PL2303,
-};
-
-struct usbh_serial {
-    struct rt_device parent;
-    enum usbh_serial_type type;
-    uint8_t minor;
-    char name[CONFIG_USBHOST_DEV_NAMELEN];
-    struct rt_ringbuffer rx_rb;
-    rt_uint8_t rx_rb_buffer[CONFIG_USBHOST_SERIAL_RX_BUFSIZE];
-};
-
-static uint32_t g_devinuse_vendor = 0;
-static uint32_t g_devinuse_cdc_acm = 0;
-
-static USB_NOCACHE_RAM_SECTION USB_MEM_ALIGNX uint8_t g_usbh_serial_vendor_rx_buf[CONFIG_USBHOST_MAX_VENDOR_SERIAL_CLASS][USB_ALIGN_UP(USBH_RX_MAX_SIZE, CONFIG_USB_ALIGN_SIZE)];
-static USB_NOCACHE_RAM_SECTION USB_MEM_ALIGNX uint8_t g_usbh_serial_cdc_acm_rx_buf[CONFIG_USBHOST_MAX_CDC_ACM_CLASS][USB_ALIGN_UP(USBH_RX_MAX_SIZE, CONFIG_USB_ALIGN_SIZE)];
-
-static struct usbh_serial *usbh_serial_alloc(uint8_t type)
-{
-    uint8_t devno;
-    struct usbh_serial *serial;
-
-    for (devno = 0; devno < CONFIG_USBHOST_MAX_VENDOR_SERIAL_CLASS; devno++) {
-        if ((g_devinuse_vendor & (1U << devno)) == 0) {
-            g_devinuse_vendor |= (1U << devno);
-
-            serial = rt_malloc(sizeof(struct usbh_serial));
-            memset(serial, 0, sizeof(struct usbh_serial));
-            serial->type = type;
-            serial->minor = devno;
-            snprintf(serial->name, CONFIG_USBHOST_DEV_NAMELEN, DEV_FORMAT_VENDOR, serial->minor);
-            return serial;
-        }
-    }
-    return NULL;
-}
-
-static void usbh_serial_free(struct usbh_serial *serial)
-{
-    uint8_t devno = serial->minor;
-
-    if (devno < 32) {
-        g_devinuse_vendor &= ~(1U << devno);
-    }
-    memset(serial, 0, sizeof(struct usbh_serial));
-    rt_free(serial);
-}
-
-static struct usbh_serial *usbh_serial_cdc_acm_alloc(uint8_t type)
-{
-    uint8_t devno;
-    struct usbh_serial *serial;
-
-    for (devno = 0; devno < CONFIG_USBHOST_MAX_CDC_ACM_CLASS; devno++) {
-        if ((g_devinuse_cdc_acm & (1U << devno)) == 0) {
-            g_devinuse_cdc_acm |= (1U << devno);
-
-            serial = rt_malloc(sizeof(struct usbh_serial));
-            memset(serial, 0, sizeof(struct usbh_serial));
-            serial->type = type;
-            serial->minor = devno;
-            snprintf(serial->name, CONFIG_USBHOST_DEV_NAMELEN, DEV_FORMAT_CDC_ACM, serial->minor);
-            return serial;
-        }
-    }
-    return NULL;
-}
-
-static void usbh_serial_cdc_acm_free(struct usbh_serial *serial)
-{
-    uint8_t devno = serial->minor;
-
-    if (devno < 32) {
-        g_devinuse_cdc_acm &= ~(1U << devno);
-    }
-    memset(serial, 0, sizeof(struct usbh_serial));
-    rt_free(serial);
-}
-
-static rt_err_t usbh_serial_open(struct rt_device *dev, rt_uint16_t oflag)
-{
-    struct usbh_serial *serial;
-
-    RT_ASSERT(dev != RT_NULL);
-
-    serial = (struct usbh_serial *)dev;
-
-    switch (serial->type) {
-        case USBH_SERIAL_TYPE_CDC_ACM:
-            break;
-        case USBH_SERIAL_TYPE_FTDI:
-            break;
-        case USBH_SERIAL_TYPE_CP210X:
-            break;
-        case USBH_SERIAL_TYPE_CH34X:
-            break;
-        case USBH_SERIAL_TYPE_PL2303:
-            break;
-
-        default:
-            break;
-    }
-
-    return RT_EOK;
-}
-
-static rt_err_t usbh_serial_close(struct rt_device *dev)
-{
-    struct usbh_serial *serial;
-
-    RT_ASSERT(dev != RT_NULL);
-
-    serial = (struct usbh_serial *)dev;
-
-    switch (serial->type) {
-        case USBH_SERIAL_TYPE_CDC_ACM:
-            break;
-        case USBH_SERIAL_TYPE_FTDI:
-            break;
-        case USBH_SERIAL_TYPE_CP210X:
-            break;
-        case USBH_SERIAL_TYPE_CH34X:
-            break;
-        case USBH_SERIAL_TYPE_PL2303:
-            break;
-
-        default:
-            break;
-    }
-
-    return RT_EOK;
-}
-
-static rt_ssize_t usbh_serial_read(struct rt_device *dev,
-                                   rt_off_t pos,
-                                   void *buffer,
-                                   rt_size_t size)
-{
-    struct usbh_serial *serial;
-
-    RT_ASSERT(dev != RT_NULL);
-
-    serial = (struct usbh_serial *)dev;
-
-    return rt_ringbuffer_get(&serial->rx_rb, (rt_uint8_t *)buffer, size);
-}
-
-static rt_ssize_t usbh_serial_write(struct rt_device *dev,
-                                    rt_off_t pos,
-                                    const void *buffer,
-                                    rt_size_t size)
-{
-    struct usbh_serial *serial;
-    int ret = 0;
-    rt_uint8_t *align_buf;
-
-    RT_ASSERT(dev != RT_NULL);
-
-    serial = (struct usbh_serial *)dev;
-
-    align_buf = (rt_uint8_t *)buffer;
-
-    if ((uint32_t)buffer & (CONFIG_USB_ALIGN_SIZE - 1)) {
-        align_buf = rt_malloc_align(USB_ALIGN_UP(size, CONFIG_USB_ALIGN_SIZE), CONFIG_USB_ALIGN_SIZE);
-        if (!align_buf) {
-            USB_LOG_ERR("serial get align buf failed\n");
-            return 0;
-        }
-
-        usb_memcpy(align_buf, buffer, size);
-    }
-
-    switch (serial->type) {
-#if defined(PKG_CHERRYUSB_HOST_CDC_ACM) || defined(RT_CHERRYUSB_HOST_CDC_ACM)
-        case USBH_SERIAL_TYPE_CDC_ACM:
-            ret = usbh_cdc_acm_bulk_out_transfer((struct usbh_cdc_acm *)dev->user_data, (uint8_t *)align_buf, size, RT_WAITING_FOREVER);
-            if (ret < 0) {
-                USB_LOG_ERR("usbh_cdc_acm_bulk_out_transfer failed: %d\n", ret);
-                ret = 0;
-            }
-            break;
-#endif
-#if defined(PKG_CHERRYUSB_HOST_FTDI) || defined(RT_CHERRYUSB_HOST_FTDI)
-        case USBH_SERIAL_TYPE_FTDI:
-            ret = usbh_ftdi_bulk_out_transfer((struct usbh_ftdi *)dev->user_data, (uint8_t *)align_buf, size, RT_WAITING_FOREVER);
-            if (ret < 0) {
-                USB_LOG_ERR("usbh_ftdi_bulk_out_transfer failed: %d\n", ret);
-                ret = 0;
-            }
-            break;
-#endif
-#if defined(PKG_CHERRYUSB_HOST_CH34X) || defined(RT_CHERRYUSB_HOST_CH34X)
-        case USBH_SERIAL_TYPE_CH34X:
-            ret = usbh_ch34x_bulk_out_transfer((struct usbh_ch34x *)dev->user_data, (uint8_t *)align_buf, size, RT_WAITING_FOREVER);
-            if (ret < 0) {
-                USB_LOG_ERR("usbh_ch34x_bulk_out_transfer failed: %d\n", ret);
-                ret = 0;
-            }
-            break;
-#endif
-#if defined(PKG_CHERRYUSB_HOST_PL2303) || defined(RT_CHERRYUSB_HOST_PL2303)
-        case USBH_SERIAL_TYPE_PL2303:
-            ret = usbh_pl2303_bulk_out_transfer((struct usbh_pl2303 *)dev->user_data, (uint8_t *)align_buf, size, RT_WAITING_FOREVER);
-            if (ret < 0) {
-                USB_LOG_ERR("usbh_pl2303_bulk_out_transfer failed: %d\n", ret);
-                ret = 0;
-            }
-            break;
-#endif
-        default:
-            break;
-    }
-
-    if ((uint32_t)buffer & (CONFIG_USB_ALIGN_SIZE - 1)) {
-        rt_free_align(align_buf);
-    }
-
-    return ret;
-}
-
-static rt_err_t usbh_serial_control(struct rt_device *dev,
-                                    int cmd,
-                                    void *args)
-{
-    struct usbh_serial *serial;
-    struct serial_configure *config;
-    struct cdc_line_coding line_coding;
-    int ret = -RT_EINVAL;
-
-    RT_ASSERT(dev != RT_NULL);
-
-    serial = (struct usbh_serial *)dev;
-
-    switch (serial->type) {
-#if defined(PKG_CHERRYUSB_HOST_CDC_ACM) || defined(RT_CHERRYUSB_HOST_CDC_ACM)
-        case USBH_SERIAL_TYPE_CDC_ACM:
-            if (cmd == RT_DEVICE_CTRL_CONFIG) {
-                struct usbh_cdc_acm *cdc_acm_class;
-                cdc_acm_class = (struct usbh_cdc_acm *)dev->user_data;
-
-                config = (struct serial_configure *)args;
-
-                line_coding.dwDTERate = config->baud_rate;
-                line_coding.bDataBits = config->data_bits;
-                line_coding.bCharFormat = 0; // STOP_BITS_1
-                line_coding.bParityType = config->parity;
-
-                usbh_cdc_acm_set_line_coding(cdc_acm_class, &line_coding);
-            }
-
-            ret = RT_EOK;
-            break;
-#endif
-#if defined(PKG_CHERRYUSB_HOST_FTDI) || defined(RT_CHERRYUSB_HOST_FTDI)
-        case USBH_SERIAL_TYPE_FTDI:
-            if (cmd == RT_DEVICE_CTRL_CONFIG) {
-                struct usbh_ftdi *ftdi_class;
-                ftdi_class = (struct usbh_ftdi *)dev->user_data;
-
-                config = (struct serial_configure *)args;
-
-                line_coding.dwDTERate = config->baud_rate;
-                line_coding.bDataBits = config->data_bits;
-                line_coding.bCharFormat = 0; // STOP_BITS_1
-                line_coding.bParityType = config->parity;
-
-                usbh_ftdi_set_line_coding(ftdi_class, &line_coding);
-            }
-
-            ret = RT_EOK;
-            break;
-#endif
-#if defined(PKG_CHERRYUSB_HOST_CP210X) || defined(RT_CHERRYUSB_HOST_CP210X)
-        case USBH_SERIAL_TYPE_CP210X:
-            if (cmd == RT_DEVICE_CTRL_CONFIG) {
-                struct usbh_cp210x *cp210x_class;
-                cp210x_class = (struct usbh_cp210x *)dev->user_data;
-
-                config = (struct serial_configure *)args;
-
-                line_coding.dwDTERate = config->baud_rate;
-                line_coding.bDataBits = config->data_bits;
-                line_coding.bCharFormat = 0; // STOP_BITS_1
-                line_coding.bParityType = config->parity;
-
-                usbh_cp210x_set_line_coding(cp210x_class, &line_coding);
-            }
-
-            ret = RT_EOK;
-            break;
-#endif
-#if defined(PKG_CHERRYUSB_HOST_CH34X) || defined(RT_CHERRYUSB_HOST_CH34X)
-        case USBH_SERIAL_TYPE_CH34X:
-            if (cmd == RT_DEVICE_CTRL_CONFIG) {
-                struct usbh_ch34x *ch34x_class;
-                ch34x_class = (struct usbh_ch34x *)dev->user_data;
-
-                config = (struct serial_configure *)args;
-
-                line_coding.dwDTERate = config->baud_rate;
-                line_coding.bDataBits = config->data_bits;
-                line_coding.bCharFormat = 0; // STOP_BITS_1
-                line_coding.bParityType = config->parity;
-
-                usbh_ch34x_set_line_coding(ch34x_class, &line_coding);
-            }
-
-            ret = RT_EOK;
-            break;
-#endif
-#if defined(PKG_CHERRYUSB_HOST_PL2303) || defined(RT_CHERRYUSB_HOST_PL2303)
-        case USBH_SERIAL_TYPE_PL2303:
-            if (cmd == RT_DEVICE_CTRL_CONFIG) {
-                struct usbh_pl2303 *pl2303_class;
-                pl2303_class = (struct usbh_pl2303 *)dev->user_data;
-
-                config = (struct serial_configure *)args;
-
-                line_coding.dwDTERate = config->baud_rate;
-                line_coding.bDataBits = config->data_bits;
-                line_coding.bCharFormat = 0; // STOP_BITS_1
-                line_coding.bParityType = config->parity;
-
-                usbh_pl2303_set_line_coding(pl2303_class, &line_coding);
-            }
-
-            ret = RT_EOK;
-            break;
-#endif
-        default:
-            break;
-    }
-
-    return ret;
-}
-
-#ifdef RT_USING_DEVICE_OPS
-const static struct rt_device_ops usbh_serial_ops = {
-    NULL,
-    usbh_serial_open,
-    usbh_serial_close,
-    usbh_serial_read,
-    usbh_serial_write,
-    usbh_serial_control
-};
-#endif
-
-#ifdef RT_USING_POSIX_DEVIO
-#include <unistd.h>
-#include <fcntl.h>
-#include <poll.h>
-#include <sys/ioctl.h>
-#include <dfs_file.h>
-
-#ifdef RT_USING_POSIX_TERMIOS
-#include <termios.h>
-#endif
-
-static rt_err_t usbh_serial_fops_rx_ind(rt_device_t dev, rt_size_t size)
-{
-    rt_wqueue_wakeup(&(dev->wait_queue), (void*)POLLIN);
-
-    return RT_EOK;
-}
-
-/* fops for serial */
-static int usbh_serial_fops_open(struct dfs_file *fd)
-{
-    rt_err_t ret = 0;
-    rt_uint16_t flags = 0;
-    rt_device_t device;
-
-    device = (rt_device_t)fd->vnode->data;
-    RT_ASSERT(device != RT_NULL);
-
-    switch (fd->flags & O_ACCMODE)
-    {
-    case O_RDONLY:
-        USB_LOG_DBG("fops open: O_RDONLY!");
-        flags = RT_DEVICE_FLAG_RDONLY;
-        break;
-    case O_WRONLY:
-        USB_LOG_DBG("fops open: O_WRONLY!");
-        flags = RT_DEVICE_FLAG_WRONLY;
-        break;
-    case O_RDWR:
-        USB_LOG_DBG("fops open: O_RDWR!");
-        flags = RT_DEVICE_FLAG_RDWR;
-        break;
-    default:
-        USB_LOG_ERR("fops open: unknown mode - %d!", fd->flags & O_ACCMODE);
-        break;
-    }
-
-    if ((fd->flags & O_ACCMODE) != O_WRONLY)
-        rt_device_set_rx_indicate(device, usbh_serial_fops_rx_ind);
-    ret = rt_device_open(device, flags);
-    if (ret == RT_EOK) return 0;
-
-    return ret;
-}
-
-static int usbh_serial_fops_close(struct dfs_file *fd)
-{
-    rt_device_t device;
-
-    device = (rt_device_t)fd->vnode->data;
-
-    rt_device_set_rx_indicate(device, RT_NULL);
-    rt_device_close(device);
-
-    return 0;
-}
-
-static int usbh_serial_fops_ioctl(struct dfs_file *fd, int cmd, void *args)
-{
-    rt_device_t device;
-    int flags = (int)(rt_base_t)args;
-    int mask  = O_NONBLOCK | O_APPEND;
-
-    device = (rt_device_t)fd->vnode->data;
-    switch (cmd)
-    {
-    case FIONREAD:
-        break;
-    case FIONWRITE:
-        break;
-    case F_SETFL:
-        flags &= mask;
-        fd->flags &= ~mask;
-        fd->flags |= flags;
-        break;
-    }
-
-    return rt_device_control(device, cmd, args);
-}
-
-static int usbh_serial_fops_read(struct dfs_file *fd, void *buf, size_t count)
-{
-    int size = 0;
-    rt_device_t device;
-
-    device = (rt_device_t)fd->vnode->data;
-
-    do
-    {
-        size = rt_device_read(device, -1,  buf, count);
-        if (size <= 0)
-        {
-            if (fd->flags & O_NONBLOCK)
-            {
-                size = -EAGAIN;
-                break;
-            }
-
-            rt_wqueue_wait(&(device->wait_queue), 0, RT_WAITING_FOREVER);
-        }
-    }while (size <= 0);
-
-    return size;
-}
-
-static int usbh_serial_fops_write(struct dfs_file *fd, const void *buf, size_t count)
-{
-    rt_device_t device;
-
-    device = (rt_device_t)fd->vnode->data;
-    return rt_device_write(device, -1, buf, count);
-}
-
-static int usbh_serial_fops_poll(struct dfs_file *fd, struct rt_pollreq *req)
-{
-    int mask = 0;
-    int flags = 0;
-    rt_device_t device;
-    struct usbh_serial *serial;
-
-    device = (rt_device_t)fd->vnode->data;
-    RT_ASSERT(device != RT_NULL);
-
-    serial = (struct usbh_serial *)device;
-
-    /* only support POLLIN */
-    flags = fd->flags & O_ACCMODE;
-    if (flags == O_RDONLY || flags == O_RDWR)
-    {
-        rt_base_t level;
-
-        rt_poll_add(&(device->wait_queue), req);
-
-        level = rt_hw_interrupt_disable();
-
-        if (rt_ringbuffer_data_len(&serial->rx_rb))
-            mask |= POLLIN;
-        rt_hw_interrupt_enable(level);
-    }
-    // mask|=POLLOUT;
-   return mask;
-}
-
-const static struct dfs_file_ops usbh_serial_fops =
-{
-    usbh_serial_fops_open,
-    usbh_serial_fops_close,
-    usbh_serial_fops_ioctl,
-    usbh_serial_fops_read,
-    usbh_serial_fops_write,
-    RT_NULL, /* flush */
-    RT_NULL, /* lseek */
-    RT_NULL, /* getdents */
-    usbh_serial_fops_poll,
-};
-#endif /* RT_USING_POSIX_DEVIO */
-
-rt_err_t usbh_serial_register(struct usbh_serial *serial,
-                              void *data)
-{
-    rt_err_t ret;
-    struct rt_device *device;
-    RT_ASSERT(serial != RT_NULL);
-
-    device = &(serial->parent);
-
-    device->type = RT_Device_Class_Char;
-    device->rx_indicate = RT_NULL;
-    device->tx_complete = RT_NULL;
-
-#ifdef RT_USING_DEVICE_OPS
-    device->ops = &usbh_serial_ops;
-#else
-    device->init = NULL;
-    device->open = usbh_serial_open;
-    device->close = usbh_serial_close;
-    device->read = usbh_serial_read;
-    device->write = usbh_serial_write;
-    device->control = usbh_serial_control;
-#endif
-    device->user_data = data;
-
-    /* register a character device */
-    ret = rt_device_register(device, serial->name, RT_DEVICE_FLAG_RDWR | RT_DEVICE_FLAG_INT_RX | RT_DEVICE_FLAG_REMOVABLE);
-
-#ifdef RT_USING_POSIX_DEVIO
-    /* set fops */
-    device->fops = &usbh_serial_fops;
-#endif
-    rt_ringbuffer_init(&serial->rx_rb, serial->rx_rb_buffer, sizeof(serial->rx_rb_buffer));
-
-    return ret;
-}
-
-void usbh_serial_unregister(struct usbh_serial *serial)
-{
-    RT_ASSERT(serial != NULL);
-
-    rt_device_unregister(&serial->parent);
-
-    if (serial->type == USBH_SERIAL_TYPE_CDC_ACM) {
-        usbh_serial_cdc_acm_free(serial);
-    } else {
-        usbh_serial_free(serial);
-    }
-}
-
-#if defined(PKG_CHERRYUSB_HOST_CDC_ACM) || defined(RT_CHERRYUSB_HOST_CDC_ACM)
-void usbh_cdc_acm_callback(void *arg, int nbytes)
-{
-    struct usbh_cdc_acm *cdc_acm_class = (struct usbh_cdc_acm *)arg;
-    struct usbh_serial *serial;
-    int ret;
-    struct usbh_urb *urb = &cdc_acm_class->bulkin_urb;
-
-    if (nbytes > 0) {
-        serial = (struct usbh_serial *)cdc_acm_class->user_data;
-        rt_ringbuffer_put(&serial->rx_rb, g_usbh_serial_cdc_acm_rx_buf[serial->minor], nbytes);
-
-        if (serial->parent.rx_indicate) {
-            serial->parent.rx_indicate(&serial->parent, nbytes);
-        }
-
-        usbh_bulk_urb_fill(urb, cdc_acm_class->hport, cdc_acm_class->bulkin, g_usbh_serial_cdc_acm_rx_buf[serial->minor], sizeof(g_usbh_serial_cdc_acm_rx_buf[serial->minor]), 0, usbh_cdc_acm_callback, cdc_acm_class);
-        ret = usbh_submit_urb(urb);
-        if (ret < 0) {
-            USB_LOG_ERR("usbh_submit_urb failed: %d\n", ret);
-        }
-    }
-}
-
-void usbh_cdc_acm_run(struct usbh_cdc_acm *cdc_acm_class)
-{
-    struct usbh_serial *serial;
-    int ret;
-    struct usbh_urb *urb = &cdc_acm_class->bulkin_urb;
-
-    serial = usbh_serial_cdc_acm_alloc(USBH_SERIAL_TYPE_CDC_ACM);
-    cdc_acm_class->user_data = serial;
-
-    usbh_serial_register(serial, cdc_acm_class);
-
-    struct cdc_line_coding linecoding;
-    linecoding.dwDTERate = 115200;
-    linecoding.bDataBits = 8;
-    linecoding.bParityType = 0;
-    linecoding.bCharFormat = 0;
-    usbh_cdc_acm_set_line_coding(cdc_acm_class, &linecoding);
-
-    usbh_bulk_urb_fill(urb, cdc_acm_class->hport, cdc_acm_class->bulkin, g_usbh_serial_cdc_acm_rx_buf[serial->minor], sizeof(g_usbh_serial_cdc_acm_rx_buf[serial->minor]), 0, usbh_cdc_acm_callback, cdc_acm_class);
-    ret = usbh_submit_urb(urb);
-    if (ret < 0) {
-        USB_LOG_ERR("usbh_submit_urb failed: %d\n", ret);
-        usbh_serial_unregister(serial);
-        return;
-    }
-}
-
-void usbh_cdc_acm_stop(struct usbh_cdc_acm *cdc_acm_class)
-{
-    struct usbh_serial *serial;
-
-    serial = (struct usbh_serial *)cdc_acm_class->user_data;
-    usbh_serial_unregister(serial);
-}
-#endif
-
-#if defined(PKG_CHERRYUSB_HOST_FTDI) || defined(RT_CHERRYUSB_HOST_FTDI)
-void usbh_ftdi_callback(void *arg, int nbytes)
-{
-    struct usbh_ftdi *ftdi_class = (struct usbh_ftdi *)arg;
-    struct usbh_serial *serial;
-    int ret;
-    struct usbh_urb *urb = &ftdi_class->bulkin_urb;
-
-    if (nbytes >= 2) {
-        serial = (struct usbh_serial *)ftdi_class->user_data;
-
-        nbytes -= 2; // Skip the first two bytes (header)
-        rt_ringbuffer_put(&serial->rx_rb, &g_usbh_serial_vendor_rx_buf[serial->minor][2], nbytes);
-
-        if (serial->parent.rx_indicate && nbytes) {
-            serial->parent.rx_indicate(&serial->parent, nbytes);
-        }
-
-        usbh_bulk_urb_fill(urb, ftdi_class->hport, ftdi_class->bulkin, g_usbh_serial_vendor_rx_buf[serial->minor], sizeof(g_usbh_serial_vendor_rx_buf[serial->minor]), 0, usbh_ftdi_callback, ftdi_class);
-        ret = usbh_submit_urb(urb);
-        if (ret < 0) {
-            USB_LOG_ERR("usbh_submit_urb failed: %d\n", ret);
-        }
-    }
-}
-
-void usbh_ftdi_run(struct usbh_ftdi *ftdi_class)
-{
-    struct usbh_serial *serial;
-    int ret;
-    struct usbh_urb *urb = &ftdi_class->bulkin_urb;
-
-    serial = usbh_serial_alloc(USBH_SERIAL_TYPE_FTDI);
-    ftdi_class->user_data = serial;
-
-    usbh_serial_register(serial, ftdi_class);
-
-    struct cdc_line_coding linecoding;
-    linecoding.dwDTERate = 115200;
-    linecoding.bDataBits = 8;
-    linecoding.bParityType = 0;
-    linecoding.bCharFormat = 0;
-    usbh_ftdi_set_line_coding(ftdi_class, &linecoding);
-
-    usbh_bulk_urb_fill(urb, ftdi_class->hport, ftdi_class->bulkin, g_usbh_serial_vendor_rx_buf[serial->minor], sizeof(g_usbh_serial_vendor_rx_buf[serial->minor]), 0, usbh_ftdi_callback, ftdi_class);
-    ret = usbh_submit_urb(urb);
-    if (ret < 0) {
-        USB_LOG_ERR("usbh_submit_urb failed: %d\n", ret);
-        usbh_serial_unregister(serial);
-        return;
-    }
-}
-
-void usbh_ftdi_stop(struct usbh_ftdi *ftdi_class)
-{
-    struct usbh_serial *serial;
-
-    serial = (struct usbh_serial *)ftdi_class->user_data;
-    usbh_serial_unregister(serial);
-}
-#endif
-
-#if defined(PKG_CHERRYUSB_HOST_CH34X) || defined(RT_CHERRYUSB_HOST_CH34X)
-void usbh_ch34x_callback(void *arg, int nbytes)
-{
-    struct usbh_ch34x *ch34x_class = (struct usbh_ch34x *)arg;
-    struct usbh_serial *serial;
-    int ret;
-    struct usbh_urb *urb = &ch34x_class->bulkin_urb;
-
-    if (nbytes > 0) {
-        serial = (struct usbh_serial *)ch34x_class->user_data;
-        rt_ringbuffer_put(&serial->rx_rb, g_usbh_serial_vendor_rx_buf[serial->minor], nbytes);
-
-        if (serial->parent.rx_indicate) {
-            serial->parent.rx_indicate(&serial->parent, nbytes);
-        }
-
-        usbh_bulk_urb_fill(urb, ch34x_class->hport, ch34x_class->bulkin, g_usbh_serial_vendor_rx_buf[serial->minor], sizeof(g_usbh_serial_vendor_rx_buf[serial->minor]), 0, usbh_ch34x_callback, ch34x_class);
-        ret = usbh_submit_urb(urb);
-        if (ret < 0) {
-            USB_LOG_ERR("usbh_submit_urb failed: %d\n", ret);
-        }
-    }
-}
-
-void usbh_ch34x_run(struct usbh_ch34x *ch34x_class)
-{
-    struct usbh_serial *serial;
-    int ret;
-    struct usbh_urb *urb = &ch34x_class->bulkin_urb;
-
-    serial = usbh_serial_alloc(USBH_SERIAL_TYPE_CH34X);
-    ch34x_class->user_data = serial;
-
-    usbh_serial_register(serial, ch34x_class);
-
-    struct cdc_line_coding linecoding;
-    linecoding.dwDTERate = 115200;
-    linecoding.bDataBits = 8;
-    linecoding.bParityType = 0;
-    linecoding.bCharFormat = 0;
-    usbh_ch34x_set_line_coding(ch34x_class, &linecoding);
-
-    usbh_bulk_urb_fill(urb, ch34x_class->hport, ch34x_class->bulkin, g_usbh_serial_vendor_rx_buf[serial->minor], sizeof(g_usbh_serial_vendor_rx_buf[serial->minor]), 0, usbh_ch34x_callback, ch34x_class);
-    ret = usbh_submit_urb(urb);
-    if (ret < 0) {
-        USB_LOG_ERR("usbh_submit_urb failed: %d\n", ret);
-        usbh_serial_unregister(serial);
-        return;
-    }
-}
-
-void usbh_ch34x_stop(struct usbh_ch34x *ch34x_class)
-{
-    struct usbh_serial *serial;
-
-    serial = (struct usbh_serial *)ch34x_class->user_data;
-    usbh_serial_unregister(serial);
-}
-#endif
-
-#if defined(PKG_CHERRYUSB_HOST_CP210X) || defined(RT_CHERRYUSB_HOST_CP210X)
-void usbh_cp210x_callback(void *arg, int nbytes)
-{
-    struct usbh_cp210x *cp210x_class = (struct usbh_cp210x *)arg;
-    struct usbh_serial *serial;
-    int ret;
-    struct usbh_urb *urb = &cp210x_class->bulkin_urb;
-
-    if (nbytes > 0) {
-        serial = (struct usbh_serial *)cp210x_class->user_data;
-        rt_ringbuffer_put(&serial->rx_rb, g_usbh_serial_vendor_rx_buf[serial->minor], nbytes);
-
-        if (serial->parent.rx_indicate) {
-            serial->parent.rx_indicate(&serial->parent, nbytes);
-        }
-
-        usbh_bulk_urb_fill(urb, cp210x_class->hport, cp210x_class->bulkin, g_usbh_serial_vendor_rx_buf[serial->minor], sizeof(g_usbh_serial_vendor_rx_buf[serial->minor]), 0, usbh_cp210x_callback, cp210x_class);
-        ret = usbh_submit_urb(urb);
-        if (ret < 0) {
-            USB_LOG_ERR("usbh_submit_urb failed: %d\n", ret);
-        }
-    }
-}
-
-void usbh_cp210x_run(struct usbh_cp210x *cp210x_class)
-{
-    struct usbh_serial *serial;
-    int ret;
-    struct usbh_urb *urb = &cp210x_class->bulkin_urb;
-
-    serial = usbh_serial_alloc(USBH_SERIAL_TYPE_CP210X);
-    cp210x_class->user_data = serial;
-
-    usbh_serial_register(serial, cp210x_class);
-
-    struct cdc_line_coding linecoding;
-    linecoding.dwDTERate = 115200;
-    linecoding.bDataBits = 8;
-    linecoding.bParityType = 0;
-    linecoding.bCharFormat = 0;
-    usbh_cp210x_set_line_coding(cp210x_class, &linecoding);
-
-    usbh_bulk_urb_fill(urb, cp210x_class->hport, cp210x_class->bulkin, g_usbh_serial_vendor_rx_buf[serial->minor], sizeof(g_usbh_serial_vendor_rx_buf[serial->minor]), 0, usbh_cp210x_callback, cp210x_class);
-    ret = usbh_submit_urb(urb);
-    if (ret < 0) {
-        USB_LOG_ERR("usbh_submit_urb failed: %d\n", ret);
-        usbh_serial_unregister(serial);
-        return;
-    }
-}
-
-void usbh_cp210x_stop(struct usbh_cp210x *cp210x_class)
-{
-    struct usbh_serial *serial;
-
-    serial = (struct usbh_serial *)cp210x_class->user_data;
-    usbh_serial_unregister(serial);
-}
-#endif
-
-#if defined(PKG_CHERRYUSB_HOST_PL2303) || defined(RT_CHERRYUSB_HOST_PL2303)
-void usbh_pl2303_callback(void *arg, int nbytes)
-{
-    struct usbh_pl2303 *pl2303_class = (struct usbh_pl2303 *)arg;
-    struct usbh_serial *serial;
-    int ret;
-    struct usbh_urb *urb = &pl2303_class->bulkin_urb;
-
-    if (nbytes > 0) {
-        serial = (struct usbh_serial *)pl2303_class->user_data;
-        rt_ringbuffer_put(&serial->rx_rb, g_usbh_serial_vendor_rx_buf[serial->minor], nbytes);
-
-        if (serial->parent.rx_indicate) {
-            serial->parent.rx_indicate(&serial->parent, nbytes);
-        }
-
-        usbh_bulk_urb_fill(urb, pl2303_class->hport, pl2303_class->bulkin, g_usbh_serial_vendor_rx_buf[serial->minor], sizeof(g_usbh_serial_vendor_rx_buf[serial->minor]), 0, usbh_pl2303_callback, pl2303_class);
-        ret = usbh_submit_urb(urb);
-        if (ret < 0) {
-            USB_LOG_ERR("usbh_submit_urb failed: %d\n", ret);
-        }
-    }
-}
-
-void usbh_pl2303_run(struct usbh_pl2303 *pl2303_class)
-{
-    struct usbh_serial *serial;
-    int ret;
-    struct usbh_urb *urb = &pl2303_class->bulkin_urb;
-
-    serial = usbh_serial_alloc(USBH_SERIAL_TYPE_PL2303);
-    pl2303_class->user_data = serial;
-
-    usbh_serial_register(serial, pl2303_class);
-
-    struct cdc_line_coding linecoding;
-    linecoding.dwDTERate = 115200;
-    linecoding.bDataBits = 8;
-    linecoding.bParityType = 0;
-    linecoding.bCharFormat = 0;
-    usbh_pl2303_set_line_coding(pl2303_class, &linecoding);
-
-    usbh_bulk_urb_fill(urb, pl2303_class->hport, pl2303_class->bulkin, g_usbh_serial_vendor_rx_buf[serial->minor], sizeof(g_usbh_serial_vendor_rx_buf[serial->minor]), 0, usbh_pl2303_callback, pl2303_class);
-    ret = usbh_submit_urb(urb);
-    if (ret < 0) {
-        USB_LOG_ERR("usbh_submit_urb failed: %d\n", ret);
-        usbh_serial_unregister(serial);
-        return;
-    }
-}
-
-void usbh_pl2303_stop(struct usbh_pl2303 *pl2303_class)
-{
-    struct usbh_serial *serial;
-
-    serial = (struct usbh_serial *)pl2303_class->user_data;
-    usbh_serial_unregister(serial);
-}
-#endif