added all assert check to osal_queue_send and osal_semaphore_post

4 files changed, 28 insertions, 23 deletions

diff --git a/tinyusb/class/msc_host.c b/tinyusb/class/msc_host.c
index e3eaf7993..9dc86e939 100644
--- a/tinyusb/class/msc_host.c
+++ b/tinyusb/class/msc_host.c
@@ -408,7 +408,7 @@ void msch_isr(pipe_handle_t pipe_hdl, tusb_event_t event, uint32_t xferred_bytes
       tusbh_msc_isr(pipe_hdl.dev_addr, event, xferred_bytes);

     }else

     { // still initializing under open subtask

-      osal_semaphore_post(msch_sem_hdl);

+      ASSERT( TUSB_ERROR_NONE == osal_semaphore_post(msch_sem_hdl), VOID_RETURN );

     }

   }

 }

diff --git a/tinyusb/device/usbd.c b/tinyusb/device/usbd.c
index 6200113b6..61a9ab636 100644
--- a/tinyusb/device/usbd.c
+++ b/tinyusb/device/usbd.c
@@ -431,7 +431,7 @@ void usbd_xfer_isr(endpoint_handle_t edpt_hdl, tusb_event_t event, uint32_t xfer
 {

   if (edpt_hdl.class_code == 0 ) // Control Transfer

   {

-    osal_semaphore_post( usbd_control_xfer_sem_hdl );

+    ASSERT( TUSB_ERROR_NONE == osal_semaphore_post( usbd_control_xfer_sem_hdl ), VOID_RETURN);

   }else

   {

     usbd_task_event_t task_event =

diff --git a/tinyusb/host/usbh.c b/tinyusb/host/usbh.c
index b36fa7cd1..5504e9602 100644
--- a/tinyusb/host/usbh.c
+++ b/tinyusb/host/usbh.c
@@ -253,7 +253,7 @@ void usbh_xfer_isr(pipe_handle_t pipe_hdl, uint8_t class_code, tusb_event_t even
   {

     usbh_devices[ pipe_hdl.dev_addr ].control.pipe_status   = event;

 //    usbh_devices[ pipe_hdl.dev_addr ].control.xferred_bytes = xferred_bytes; not yet neccessary

-    osal_semaphore_post( usbh_devices[ pipe_hdl.dev_addr ].control.sem_hdl );

+    ASSERT( TUSB_ERROR_NONE == osal_semaphore_post( usbh_devices[ pipe_hdl.dev_addr ].control.sem_hdl ), VOID_RETURN);

   }else if (usbh_class_drivers[class_index].isr)

   {

     usbh_class_drivers[class_index].isr(pipe_hdl, event, xferred_bytes);

@@ -265,22 +265,26 @@ void usbh_xfer_isr(pipe_handle_t pipe_hdl, uint8_t class_code, tusb_event_t even
 

 void usbh_hub_port_plugged_isr(uint8_t hub_addr, uint8_t hub_port)

 {

-  osal_queue_send(enum_queue_hdl,

-                  &(usbh_enumerate_t){

-                    .core_id  = usbh_devices[hub_addr].core_id,

-                    .hub_addr = hub_addr,

-                    .hub_port = hub_port}

-                  );

+  usbh_enumerate_t enum_entry =

+  {

+      .core_id  = usbh_devices[hub_addr].core_id,

+      .hub_addr = hub_addr,

+      .hub_port = hub_port

+  };

+

+  ASSERT( TUSB_ERROR_NONE == osal_queue_send(enum_queue_hdl, &enum_entry), VOID_RETURN );

 }

 

 void usbh_hcd_rhport_plugged_isr(uint8_t hostid)

 {

-  osal_queue_send(enum_queue_hdl,

-                  &(usbh_enumerate_t){

-                    .core_id  = hostid,

-                    .hub_addr = 0,

-                    .hub_port = 0}

-                  );

+  usbh_enumerate_t enum_entry =

+  {

+      .core_id  = hostid,

+      .hub_addr = 0,

+      .hub_port = 0

+  };

+

+  ASSERT( TUSB_ERROR_NONE == osal_queue_send(enum_queue_hdl, &enum_entry), VOID_RETURN );

 }

 

 // a device unplugged on hostid, hub_addr, hub_port

@@ -325,13 +329,14 @@ static void usbh_device_unplugged(uint8_t hostid, uint8_t hub_addr, uint8_t hub_
 

 void usbh_hcd_rhport_unplugged_isr(uint8_t hostid)

 {

-  osal_queue_send(enum_queue_hdl,

-                  &(usbh_enumerate_t)

-                  {

-                    .core_id = hostid,

-                    .hub_addr = 0,

-                    .hub_port = 0

-                  } );

+  usbh_enumerate_t enum_entry =

+  {

+      .core_id = hostid,

+      .hub_addr = 0,

+      .hub_port = 0

+  };

+

+  ASSERT( TUSB_ERROR_NONE == osal_queue_send(enum_queue_hdl, &enum_entry), VOID_RETURN );

 }

 

 //--------------------------------------------------------------------+

diff --git a/tinyusb/osal/osal_cmsis_rtx.h b/tinyusb/osal/osal_cmsis_rtx.h
index 57f015d82..62a1ec4ff 100644
--- a/tinyusb/osal/osal_cmsis_rtx.h
+++ b/tinyusb/osal/osal_cmsis_rtx.h
@@ -182,7 +182,7 @@ static inline void osal_queue_receive (osal_queue_handle_t const queue_hdl, void
   }
 }
 
-static inline tusb_error_t osal_queue_send(osal_queue_handle_t const queue_hdl, void const * data) ATTR_ALWAYS_INLINE;
+static inline tusb_error_t osal_queue_send(osal_queue_handle_t const queue_hdl, void const * data) ATTR_WARN_UNUSED_RESULT ATTR_ALWAYS_INLINE;
 static inline tusb_error_t osal_queue_send(osal_queue_handle_t const queue_hdl, void const * data)
 {
   void *p_buf = osMailAlloc(queue_hdl->pool, 0); // instantly return in case of sending within ISR (mostly used)