diff options
| author | Kai <[email protected]> | 2024-02-16 15:16:17 +0800 |
|---|---|---|
| committer | GitHub <[email protected]> | 2024-02-16 15:16:17 +0800 |
| commit | 27c125416a60986c4bce670097efbd88744fab9b (patch) | |
| tree | b8405c9ae5fca76b2394a08f5cbfc73b46c6e9e9 /src/osal | |
| parent | b60d0ff1d4f1db0e3caeb26895e73e749206023a (diff) | |
use rt-thread 5+ mq recv api
Diffstat (limited to 'src/osal')
| -rw-r--r-- | src/osal/osal_rtthread.h | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/src/osal/osal_rtthread.h b/src/osal/osal_rtthread.h index 18eb9c693..d03b53bee 100644 --- a/src/osal/osal_rtthread.h +++ b/src/osal/osal_rtthread.h @@ -2,6 +2,7 @@ * The MIT License (MIT) * * Copyright (c) 2020 tfx2001 ([email protected]) + * Copyright (c) 2020 yekai ([email protected]) * * Permission is hereby granted, free of charge, to any person obtaining a copy * of this software and associated documentation files (the "Software"), to deal @@ -111,9 +112,12 @@ TU_ATTR_ALWAYS_INLINE static inline osal_queue_t osal_queue_create(osal_queue_de } TU_ATTR_ALWAYS_INLINE static inline bool osal_queue_receive(osal_queue_t qhdl, void *data, uint32_t msec) { - rt_tick_t tick = rt_tick_from_millisecond((rt_int32_t) msec); +#if RT_VERSION_MAJOR >= 5 + return rt_mq_recv(qhdl, data, qhdl->msg_size, tick) > 0; +#else return rt_mq_recv(qhdl, data, qhdl->msg_size, tick) == RT_EOK; +#endif /* RT_VERSION_MAJOR >= 5 */ } TU_ATTR_ALWAYS_INLINE static inline bool osal_queue_send(osal_queue_t qhdl, void const *data, bool in_isr) { |