diff options
Diffstat (limited to 'bsp')
8 files changed, 8 insertions, 8 deletions
diff --git a/bsp/allwinner/libraries/sunxi-hal/hal/source/sdmmc/osal/os/RT-Thread/os_queue.c b/bsp/allwinner/libraries/sunxi-hal/hal/source/sdmmc/osal/os/RT-Thread/os_queue.c index a90eeaae65..c0e773f13d 100644 --- a/bsp/allwinner/libraries/sunxi-hal/hal/source/sdmmc/osal/os/RT-Thread/os_queue.c +++ b/bsp/allwinner/libraries/sunxi-hal/hal/source/sdmmc/osal/os/RT-Thread/os_queue.c @@ -150,7 +150,7 @@ OS_Status OS_QueueReceive(OS_Queue_t *queue, void *item, OS_Time_t waitMS) OS_HANDLE_ASSERT(OS_QueueIsValid(queue), queue->handle); ret = rt_mq_recv(queue->handle, item, queue->itemSize, OS_CalcWaitTicks(waitMS)); - if (ret != RT_EOK) { + if (ret < 0) { OS_DBG("%s() fail @ %d, %"OS_TIME_F" ms\n", __func__, __LINE__, (unsigned int)waitMS); return OS_FAIL; } diff --git a/bsp/allwinner/libraries/sunxi-hal/osal/src/hal_queue.c b/bsp/allwinner/libraries/sunxi-hal/osal/src/hal_queue.c index d44c784469..091aa32c49 100644 --- a/bsp/allwinner/libraries/sunxi-hal/osal/src/hal_queue.c +++ b/bsp/allwinner/libraries/sunxi-hal/osal/src/hal_queue.c @@ -182,7 +182,7 @@ int hal_queue_recv(hal_queue_t queue, void *buffer, int timeout) } ret = rt_mq_recv(queue, buffer, queue->msg_size, timeout); - if (ret != RT_EOK) + if (ret < 0) { return -2; } diff --git a/bsp/fujitsu/mb9x/mb9bf500r/application.c b/bsp/fujitsu/mb9x/mb9bf500r/application.c index 1cbd0c2d83..b61f6e05f0 100644 --- a/bsp/fujitsu/mb9x/mb9bf500r/application.c +++ b/bsp/fujitsu/mb9x/mb9bf500r/application.c @@ -74,7 +74,7 @@ void rt_init_thread_entry(void *parameter) while(1) { - if (rt_mq_recv(&mq, &msg, sizeof(msg), RT_WAITING_FOREVER) == RT_EOK) + if (rt_mq_recv(&mq, &msg, sizeof(msg), RT_WAITING_FOREVER) >= 0) { switch(msg.type) { diff --git a/bsp/imxrt/libraries/MIMXRT1050/MIMXRT1052/drivers/fsl_os_abstraction_rtthread.c b/bsp/imxrt/libraries/MIMXRT1050/MIMXRT1052/drivers/fsl_os_abstraction_rtthread.c index 524744c251..6b8fc6ca16 100644 --- a/bsp/imxrt/libraries/MIMXRT1050/MIMXRT1052/drivers/fsl_os_abstraction_rtthread.c +++ b/bsp/imxrt/libraries/MIMXRT1050/MIMXRT1052/drivers/fsl_os_abstraction_rtthread.c @@ -788,7 +788,7 @@ osa_status_t OSA_MsgQGet(osa_msgq_handle_t msgqHandle, osa_msg_handle_t pMessage { timeoutTicks = rt_tick_from_millisecond(millisec); } - if (RT_EOK != rt_mq_recv(handler, pMessage, handler->msg_size, timeoutTicks)) + if (rt_mq_recv(handler, pMessage, handler->msg_size, timeoutTicks) < 0) { osaStatus = KOSA_StatusTimeout; /* not able to send it to the queue? */ } diff --git a/bsp/imxrt/libraries/MIMXRT1060/MIMXRT1060/drivers/fsl_os_abstraction_rtthread.c b/bsp/imxrt/libraries/MIMXRT1060/MIMXRT1060/drivers/fsl_os_abstraction_rtthread.c index 524744c251..6b8fc6ca16 100644 --- a/bsp/imxrt/libraries/MIMXRT1060/MIMXRT1060/drivers/fsl_os_abstraction_rtthread.c +++ b/bsp/imxrt/libraries/MIMXRT1060/MIMXRT1060/drivers/fsl_os_abstraction_rtthread.c @@ -788,7 +788,7 @@ osa_status_t OSA_MsgQGet(osa_msgq_handle_t msgqHandle, osa_msg_handle_t pMessage { timeoutTicks = rt_tick_from_millisecond(millisec); } - if (RT_EOK != rt_mq_recv(handler, pMessage, handler->msg_size, timeoutTicks)) + if (rt_mq_recv(handler, pMessage, handler->msg_size, timeoutTicks) < 0) { osaStatus = KOSA_StatusTimeout; /* not able to send it to the queue? */ } diff --git a/bsp/imxrt/libraries/MIMXRT1061/MIMXRT1061/drivers/fsl_os_abstraction_rtthread.c b/bsp/imxrt/libraries/MIMXRT1061/MIMXRT1061/drivers/fsl_os_abstraction_rtthread.c index 524744c251..6b8fc6ca16 100644 --- a/bsp/imxrt/libraries/MIMXRT1061/MIMXRT1061/drivers/fsl_os_abstraction_rtthread.c +++ b/bsp/imxrt/libraries/MIMXRT1061/MIMXRT1061/drivers/fsl_os_abstraction_rtthread.c @@ -788,7 +788,7 @@ osa_status_t OSA_MsgQGet(osa_msgq_handle_t msgqHandle, osa_msg_handle_t pMessage { timeoutTicks = rt_tick_from_millisecond(millisec); } - if (RT_EOK != rt_mq_recv(handler, pMessage, handler->msg_size, timeoutTicks)) + if (rt_mq_recv(handler, pMessage, handler->msg_size, timeoutTicks) < 0) { osaStatus = KOSA_StatusTimeout; /* not able to send it to the queue? */ } diff --git a/bsp/imxrt/libraries/MIMXRT1170/MIMXRT1176/drivers/fsl_os_abstraction_rtthread.c b/bsp/imxrt/libraries/MIMXRT1170/MIMXRT1176/drivers/fsl_os_abstraction_rtthread.c index 524744c251..6b8fc6ca16 100644 --- a/bsp/imxrt/libraries/MIMXRT1170/MIMXRT1176/drivers/fsl_os_abstraction_rtthread.c +++ b/bsp/imxrt/libraries/MIMXRT1170/MIMXRT1176/drivers/fsl_os_abstraction_rtthread.c @@ -788,7 +788,7 @@ osa_status_t OSA_MsgQGet(osa_msgq_handle_t msgqHandle, osa_msg_handle_t pMessage { timeoutTicks = rt_tick_from_millisecond(millisec); } - if (RT_EOK != rt_mq_recv(handler, pMessage, handler->msg_size, timeoutTicks)) + if (rt_mq_recv(handler, pMessage, handler->msg_size, timeoutTicks) < 0) { osaStatus = KOSA_StatusTimeout; /* not able to send it to the queue? */ } diff --git a/bsp/stm32/stm32mp157a-st-ev1/board/ports/dma_sample.c b/bsp/stm32/stm32mp157a-st-ev1/board/ports/dma_sample.c index 30b0c99496..49cf2b2757 100644 --- a/bsp/stm32/stm32mp157a-st-ev1/board/ports/dma_sample.c +++ b/bsp/stm32/stm32mp157a-st-ev1/board/ports/dma_sample.c @@ -50,7 +50,7 @@ static void serial_thread_entry(void *parameter) { rt_memset(&msg, 0, sizeof(msg)); result = rt_mq_recv(&rx_mq, &msg, sizeof(msg), RT_WAITING_FOREVER); - if (result == RT_EOK) + if (result >= 0) { rx_length = rt_device_read(msg.dev, 0, rx_buffer, msg.size); rx_buffer[rx_length] = '\0'; |