@@ -49,7 +49,7 @@ typedef rt_sem_t osal_semaphore_t;
49
49
50
50
TU_ATTR_ALWAYS_INLINE static inline osal_semaphore_t
51
51
osal_semaphore_create (osal_semaphore_def_t * semdef ) {
52
- rt_sem_init (semdef , "tusb" , 0 , RT_IPC_FLAG_FIFO );
52
+ rt_sem_init (semdef , "tusb" , 0 , RT_IPC_FLAG_PRIO );
53
53
return semdef ;
54
54
}
55
55
@@ -59,7 +59,7 @@ TU_ATTR_ALWAYS_INLINE static inline bool osal_semaphore_post(osal_semaphore_t se
59
59
}
60
60
61
61
TU_ATTR_ALWAYS_INLINE static inline bool osal_semaphore_wait (osal_semaphore_t sem_hdl , uint32_t msec ) {
62
- return rt_sem_take (sem_hdl , rt_tick_from_millisecond (msec )) == RT_EOK ;
62
+ return rt_sem_take (sem_hdl , rt_tick_from_millisecond (( rt_int32_t ) msec )) == RT_EOK ;
63
63
}
64
64
65
65
TU_ATTR_ALWAYS_INLINE static inline void osal_semaphore_reset (osal_semaphore_t const sem_hdl ) {
@@ -73,12 +73,12 @@ typedef struct rt_mutex osal_mutex_def_t;
73
73
typedef rt_mutex_t osal_mutex_t ;
74
74
75
75
TU_ATTR_ALWAYS_INLINE static inline osal_mutex_t osal_mutex_create (osal_mutex_def_t * mdef ) {
76
- rt_mutex_init (mdef , "tusb" , RT_IPC_FLAG_FIFO );
76
+ rt_mutex_init (mdef , "tusb" , RT_IPC_FLAG_PRIO );
77
77
return mdef ;
78
78
}
79
79
80
80
TU_ATTR_ALWAYS_INLINE static inline bool osal_mutex_lock (osal_mutex_t mutex_hdl , uint32_t msec ) {
81
- return rt_mutex_take (mutex_hdl , rt_tick_from_millisecond (msec )) == RT_EOK ;
81
+ return rt_mutex_take (mutex_hdl , rt_tick_from_millisecond (( rt_int32_t ) msec )) == RT_EOK ;
82
82
}
83
83
84
84
TU_ATTR_ALWAYS_INLINE static inline bool osal_mutex_unlock (osal_mutex_t mutex_hdl ) {
@@ -106,13 +106,13 @@ typedef rt_mq_t osal_queue_t;
106
106
107
107
TU_ATTR_ALWAYS_INLINE static inline osal_queue_t osal_queue_create (osal_queue_def_t * qdef ) {
108
108
rt_mq_init (& (qdef -> sq ), "tusb" , qdef -> buf , qdef -> item_sz ,
109
- qdef -> item_sz * qdef -> depth , RT_IPC_FLAG_FIFO );
109
+ qdef -> item_sz * qdef -> depth , RT_IPC_FLAG_PRIO );
110
110
return & (qdef -> sq );
111
111
}
112
112
113
113
TU_ATTR_ALWAYS_INLINE static inline bool osal_queue_receive (osal_queue_t qhdl , void * data , uint32_t msec ) {
114
114
115
- rt_tick_t tick = rt_tick_from_millisecond ((rt_int32_t ) msec )) ;
115
+ rt_tick_t tick = rt_tick_from_millisecond ((rt_int32_t ) msec );
116
116
return rt_mq_recv (qhdl , data , qhdl -> msg_size , tick ) == RT_EOK ;
117
117
}
118
118
0 commit comments