shared/tinyusb: Add USBD_CDC class to access usb serial port.

Signed-off-by: Andrew Leech <[email protected]>

Author: pi-anl

extmod/modmachine.c

@@ -32,6 +32,10 @@
 #include "extmod/modmachine.h"
 #include "shared/runtime/pyexec.h"
 
+#if MICROPY_HW_USB_CDC
+#include "shared/tinyusb/mp_usbd_cdc.h"
+#endif
+
 #if MICROPY_PY_MACHINE_DHT_READINTO
 #include "drivers/dht/dht.h"
 #endif

extmod/os_dupterm.c

@@ -53,6 +53,7 @@ void mp_os_deactivate(size_t dupterm_idx, const char *msg, mp_obj_t exc) {
     if (nlr_push(&nlr) == 0) {
         mp_stream_close(term);
         const mp_stream_p_t *stream_p = mp_get_stream_raise(term, MP_STREAM_OP_IOCTL);
+        int errcode = 0;
         stream_p->ioctl(term, MP_STREAM_REPL_ATTACHED, 0, &errcode);
         nlr_pop();
     } else {

shared/tinyusb/mp_usbd.h

@@ -45,6 +45,10 @@ static inline void mp_usbd_init_tud(void) {
     tusb_init();
     tud_cdc_configure_fifo_t cfg = { .rx_persistent = 0, .tx_persistent = 1 };
     tud_cdc_configure_fifo(&cfg);
+
+    #if MICROPY_HW_USB_CDC
+    machine_usbd_cdc_init0();
+    #endif
 }
 
 // Run the TinyUSB device task

shared/tinyusb/mp_usbd_cdc.c

@@ -75,7 +75,7 @@ mp_uint_t mp_usbd_cdc_rx_strn(const char *buf, mp_uint_t len) {
 }
 
 void tud_cdc_rx_cb(uint8_t itf) {
-    #if 0
+    #if !MICROPY_PY_OS_DUPTERM
     // consume pending USB data immediately to free usb buffer and keep the endpoint from stalling.
     // in case the ringbuffer is full, mark the CDC interface that need attention later on for polling
     cdc_itf_pending &= ~(1 << itf);
@@ -230,18 +230,19 @@ const machine_usbd_cdc_obj_t machine_usbd_cdc_obj = {{&machine_usbd_cdc_type}};/
 
 static bool machine_usbd_cdc_irq_scheduled;// [MICROPY_HW_USB_CDC_NUM];
 
-static void machine_usbd_cdc_init0(void) {
+void machine_usbd_cdc_init0(void) {
     // for (size_t i = 0; i < MICROPY_HW_USB_CDC_NUM; ++i) {
     MP_STATE_PORT(machine_usbd_cdc_irq) = mp_const_none;
     machine_usbd_cdc_irq_scheduled = false;
     // }
 
+    #if MICROPY_PY_OS_DUPTERM
     // #if MICROPY_HW_USB_CDC_REPL
     // Activate USB_CDC(0) on dupterm slot 1 for the REPL
     // todo auto detect appropriate slot
     MP_STATE_VM(dupterm_objs[1]) = MP_OBJ_FROM_PTR(&machine_usbd_cdc_obj);
     usb_vcp_attach_to_repl(&machine_usbd_cdc_obj, true);
-    // #endif
+    #endif
 
 }
 
@@ -349,7 +350,7 @@ static MP_DEFINE_CONST_FUN_OBJ_1(machine_usbd_cdc_isconnected_obj, machine_usbd_
 /// Return `True` if any characters waiting, else `False`.
 static mp_obj_t machine_usbd_cdc_any(mp_obj_t self_in) {
     UNUSED(self_in);
-    if (ringbuf_peek(&stdin_ringbuf) != -1) {
+    if (tud_cdc_available()) {
         return mp_const_true;
     } else {
         return mp_const_false;
@@ -488,8 +489,9 @@ static const mp_rom_map_elem_t machine_usbd_cdc_locals_dict_table[] = {
 static MP_DEFINE_CONST_DICT(machine_usbd_cdc_locals_dict, machine_usbd_cdc_locals_dict_table);
 
 static mp_uint_t machine_usbd_cdc_read(mp_obj_t self_in, void *buf, mp_uint_t size, int *errcode) {
+    UNUSED(self_in);
     machine_usbd_cdc_obj_t *self = MP_OBJ_TO_PTR(self_in);
-    int ret = usbd_cdc_rx(self, (byte *)buf, size, 0);
+    int ret = mp_usbd_cdc_rx_strn((byte *)buf, size);
     if (ret == 0) {
         // return EAGAIN error to indicate non-blocking
         *errcode = MP_EAGAIN;
@@ -499,7 +501,7 @@ static mp_uint_t machine_usbd_cdc_read(mp_obj_t self_in, void *buf, mp_uint_t si
 }
 
 static mp_uint_t machine_usbd_cdc_write(mp_obj_t self_in, const void *buf, mp_uint_t size, int *errcode) {
-    machine_usbd_cdc_obj_t *self = MP_OBJ_TO_PTR(self_in);
+    UNUSED(self_in);
     int ret = mp_usbd_cdc_tx_strn((const char *)buf, size);
     if (ret == 0) {
         // return EAGAIN error to indicate non-blocking
@@ -514,13 +516,7 @@ static mp_uint_t machine_usbd_cdc_ioctl(mp_obj_t self_in, mp_uint_t request, uin
     machine_usbd_cdc_obj_t *self = MP_OBJ_TO_PTR(self_in);
     if (request == MP_STREAM_POLL) {
         uintptr_t flags = arg;
-        ret = 0;
-        if ((flags & MP_STREAM_POLL_RD) && usbd_cdc_rx_num(self) > 0) {
-            ret |= MP_STREAM_POLL_RD;
-        }
-        if ((flags & MP_STREAM_POLL_WR) && usbd_cdc_tx_half_empty(self)) {
-            ret |= MP_STREAM_POLL_WR;
-        }
+        ret = mp_usbd_cdc_poll_interfaces(flags);
     } else if (request == MP_STREAM_CLOSE) {
         ret = 0;
     } else if (request == MP_STREAM_REPL_ATTACHED) {

shared/tinyusb/mp_usbd_cdc.h

@@ -37,6 +37,7 @@
 #define MICROPY_HW_USB_CDC_DTR_RTS_BOOTLOADER (0)
 #endif
 
+void machine_usbd_cdc_init0(void);
 // extern const mp_obj_type_t pyb_usb_vcp_type;
 extern const mp_obj_type_t machine_usbd_cdc_type;
 // extern void machine_usbd_cdc_attach_to_repl(const machine_usbd_cdc_obj_t *self, bool attached);