mirror/tinyusb
3
0
Fork 0
mirror of https://github.com/hathach/tinyusb.git synced 2026-03-31 20:03:28 +00:00
Code Issues Packages Projects Releases Wiki Activity

osal/mynewt: fix queue receive tiemout

Browse Source 
Signed-off-by: HiFiPhile <admin@hifiphile.com>
This commit is contained in:
HiFiPhile
2026-03-27 15:44:24 +01:00
parent 04701bf918
commit 653e6300a3
1 changed files with 23 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
src/osal/osal_mynewt.h
View File

@ -123,6 +123,24 @@ TU_ATTR_ALWAYS_INLINE static inline bool osal_mutex_unlock(osal_mutex_t mutex_hd
return os_mutex_release(mutex_hdl) == OS_OK;
}
TU_ATTR_ALWAYS_INLINE static inline os_time_t _osal_ms2tick(uint32_t msec) {
if (msec == OSAL_TIMEOUT_WAIT_FOREVER) {
return OS_TIMEOUT_NEVER;
}
if (msec == 0) {
return 0;
}
os_time_t ticks = os_time_ms_to_ticks32(msec);
// If 1 tick > 1 ms, still wait at least 1 tick for non-zero timeout.
if (ticks == 0) {
ticks = 1;
}
return ticks;
}
//--------------------------------------------------------------------+
// QUEUE API
//--------------------------------------------------------------------+
@ -161,10 +179,11 @@ TU_ATTR_ALWAYS_INLINE static inline bool osal_queue_delete(osal_queue_t qhdl) {
}
TU_ATTR_ALWAYS_INLINE static inline bool osal_queue_receive(osal_queue_t qhdl, void* data, uint32_t msec) {
(void) msec; // os_eventq_get() does not take timeout, always behave as msec = WAIT_FOREVER
struct os_event* ev;
ev = os_eventq_get(&qhdl->evq);
struct os_eventq* evq = &qhdl->evq;
struct os_event* ev = os_eventq_poll(&evq, 1, _osal_ms2tick(msec));
if (!ev) {
return false;
}
memcpy(data, ev->ev_arg, qhdl->item_sz); // copy message
os_memblock_put(&qhdl->mpool, ev->ev_arg); // put back mem block